See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/825/display/redirect?page=changes>
Changes:
[noreply] [Tour Of Beam][backend] get unit content (#22967)
[noreply] Allows to use databaseio with postgres driver (#22941)
[noreply] Bump cloud.google.com/go/storage from 1.25.0 to 1.26.0 in /sdks
(#22954)
[noreply] [BEAM-22859] Allow the specification of extra packages for external
------------------------------------------
[...truncated 113.93 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Loading JAR files for task CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(13/16)#0 (85502da346d3e8e4b1b2e1b44aa1adb1) [DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(13/16)#0 (85502da346d3e8e4b1b2e1b44aa1adb1) switched from DEPLOYING to FAILED
with failure cause: java.io.IOException: Insufficient number of network
buffers: required 17, but only 6 available. The total number of network buffers
is currently set to 2048 of 32768 bytes each. You can increase this number by
setting the configuration keys 'taskmanager.memory.network.fraction',
'taskmanager.memory.network.min', and 'taskmanager.memory.network.max'.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.io.network.buffer.NetworkBufferPool.internalCreateBufferPool(NetworkBufferPool.java:483)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.io.network.buffer.NetworkBufferPool.createBufferPool(NetworkBufferPool.java:461)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.io.network.partition.ResultPartitionFactory.lambda$createBufferPoolFactory$0(ResultPartitionFactory.java:279)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.io.network.partition.ResultPartition.setup(ResultPartition.java:160)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.io.network.partition.BufferWritingResultPartition.setup(BufferWritingResultPartition.java:97)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.taskmanager.Task.setupPartitionsAndGates(Task.java:959)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:652)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(13/16)#0 (85502da346d3e8e4b1b2e1b44aa1adb1).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
13, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
13, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
13, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
13, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
13, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
13, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
13]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Received task CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(14/16)#0 (a6cb9c1cb2e99fae01308c5b01da2ce7), deploy into slot with allocation
id c46ee216f49af98f6be83c6f8b1070ec.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Activate slot 5ae81e1443ade7bd093f96e4d9aedb74.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(14/16)#0 (a6cb9c1cb2e99fae01308c5b01da2ce7) switched from CREATED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Loading JAR files for task CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(14/16)#0 (a6cb9c1cb2e99fae01308c5b01da2ce7) [DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(14/16)#0 (a6cb9c1cb2e99fae01308c5b01da2ce7) switched from DEPLOYING to FAILED
with failure cause: java.io.IOException: Insufficient number of network
buffers: required 17, but only 6 available. The total number of network buffers
is currently set to 2048 of 32768 bytes each. You can increase this number by
setting the configuration keys 'taskmanager.memory.network.fraction',
'taskmanager.memory.network.min', and 'taskmanager.memory.network.max'.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.io.network.buffer.NetworkBufferPool.internalCreateBufferPool(NetworkBufferPool.java:483)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.io.network.buffer.NetworkBufferPool.createBufferPool(NetworkBufferPool.java:461)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.io.network.partition.ResultPartitionFactory.lambda$createBufferPoolFactory$0(ResultPartitionFactory.java:279)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.io.network.partition.ResultPartition.setup(ResultPartition.java:160)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.io.network.partition.BufferWritingResultPartition.setup(BufferWritingResultPartition.java:97)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.taskmanager.Task.setupPartitionsAndGates(Task.java:959)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:652)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(14/16)#0 (a6cb9c1cb2e99fae01308c5b01da2ce7).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocal'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemote'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBytesInRemotePerSecond'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocal'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInLocalPerSecond'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14, Shuffle, Netty, Input]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
getProcessBundleDescriptor request with id 2-120
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
f507c158-ecb9-4838-93e6-e9cb06d759b3, BeamApp-jenkins-0902155205-284a18bc,
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor),
14]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Received task CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(15/16)#0 (1a817392dfe99b95c900f4826ecf29a1), deploy into slot with allocation
id 5ae81e1443ade7bd093f96e4d9aedb74.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Sep 02,
2022 3:52:38 PM org.apache.flink.runtime.taskmanager.Task transitionState
=============================== warnings summary ===============================
../../build/gradleenv/2022703441/lib/python3.7/site-packages/hdfs/config.py:15
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/hdfs/config.py>:15:
DeprecationWarning: the imp module is deprecated in favour of importlib; see
the module's documentation for alternative uses
from imp import load_source
../../build/gradleenv/2022703441/lib/python3.7/site-packages/google/api_core/grpc_helpers.py:42
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/google/api_core/grpc_helpers.py>:42:
DeprecationWarning: Support for grpcio-gcp is deprecated. This feature will be
removed from `google-api-core` after January 1, 2024. If you need
to
continue to use this feature, please pin to a specific version of
`google-api-core`.
DeprecationWarning,
apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_output_checksum_on_small_input
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/tests/utils.py>:63:
PendingDeprecationWarning: Client.dataset is deprecated and will be removed in
a future version. Use a string like 'my_project.my_dataset' or a
cloud.google.bigquery.DatasetReference object, instead.
dataset_ref = client.dataset(unique_dataset_name, project=project)
apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_output_checksum_on_small_input
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2285:
BeamDeprecationWarning: options is deprecated since First stable release.
References to <pipeline>.options will not be supported
is_streaming_pipeline = p.options.view_as(StandardOptions).streaming
apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_output_checksum_on_small_input
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2291:
BeamDeprecationWarning: options is deprecated since First stable release.
References to <pipeline>.options will not be supported
experiments = p.options.view_as(DebugOptions).experiments or []
apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_output_checksum_on_small_input
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py>:1129:
BeamDeprecationWarning: options is deprecated since First stable release.
References to <pipeline>.options will not be supported
temp_location = p.options.view_as(GoogleCloudOptions).temp_location
apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_output_checksum_on_small_input
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py>:1131:
BeamDeprecationWarning: options is deprecated since First stable release.
References to <pipeline>.options will not be supported
p.options.view_as(GoogleCloudOptions).job_name or 'AUTOMATIC_JOB_NAME')
apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it
apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2774:
BeamDeprecationWarning: options is deprecated since First stable release.
References to <pipeline>.options will not be supported
temp_location = pcoll.pipeline.options.view_as(
apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it
apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2776:
BeamDeprecationWarning: options is deprecated since First stable release.
References to <pipeline>.options will not be supported
job_name = pcoll.pipeline.options.view_as(GoogleCloudOptions).job_name
apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it
apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2807:
BeamDeprecationWarning: options is deprecated since First stable release.
References to <pipeline>.options will not be supported
| _PassThroughThenCleanup(files_to_remove_pcoll))
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2281:
BeamDeprecationWarning: options is deprecated since First stable release.
References to <pipeline>.options will not be supported
self.table_reference.projectId = pcoll.pipeline.options.view_as(
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it
apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/tests/utils.py>:100:
PendingDeprecationWarning: Client.dataset is deprecated and will be removed in
a future version. Use a string like 'my_project.my_dataset' or a
cloud.google.bigquery.DatasetReference object, instead.
table_ref = client.dataset(dataset_id).table(table_id)
apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/examples/dataframe/flight_delays.py>:47:
FutureWarning: Dropping of nuisance columns in DataFrame reductions (with
'numeric_only=None') is deprecated; in a future version this will raise
TypeError. Select only valid columns before calling the reduction.
return airline_df[at_top_airports].mean()
apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
apache_beam/examples/dataframe/wordcount_test.py::WordCountTest::test_basics
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/dataframe/io.py>:664:
FutureWarning: WriteToFiles is experimental.
sink=lambda _: _WriteToPandasFileSink(
apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays
apache_beam/examples/dataframe/wordcount_test.py::WordCountTest::test_basics
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/fileio.py>:590:
BeamDeprecationWarning: options is deprecated since First stable release.
References to <pipeline>.options will not be supported
p.options.view_as(GoogleCloudOptions).temp_location or
-- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html
- generated xml file:
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/pytest_postCommitExamples-flink-py37.xml>
-
=========================== short test summary info ============================
FAILED
apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it
= 1 failed, 21 passed, 3 skipped, 6635 deselected, 40 warnings in 1013.77s
(0:16:53) =
> Task :sdks:python:test-suites:portable:py37:flinkExamples FAILED
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* Where:
Script
'<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
line: 240
* What went wrong:
Execution failed for task
':sdks:python:test-suites:portable:py39:flinkExamples'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* Where:
Script
'<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
line: 240
* What went wrong:
Execution failed for task
':sdks:python:test-suites:portable:py37:flinkExamples'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
==============================================================================
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 8.0.
You can use '--warning-mode all' to show the individual deprecation warnings
and determine if they come from your own scripts or plugins.
See
https://docs.gradle.org/7.4/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 20m 48s
133 actionable tasks: 87 executed, 44 from cache, 2 up-to-date
Publishing build scan...
https://gradle.com/s/6pw7vulr7n23u
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
