See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/996/display/redirect>
Changes:
------------------------------------------
[...truncated 18.79 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(11/16) (4b21f0b59bc137dc57c1429d2c786b21) switched from DEPLOYING to
INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-48
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-25
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-4
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(12/16)#0 (dfbaaaf7bf3841588b2ce593ebeeba46) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(12/16)#0 (dfbaaaf7bf3841588b2ce593ebeeba46) [DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(12/16)#0 (dfbaaaf7bf3841588b2ce593ebeeba46) switched from DEPLOYING to
INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(12/16)#0 (dfbaaaf7bf3841588b2ce593ebeeba46) switched from INITIALIZING to
RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-55
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-5
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-11
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot 0bbfbfd50a3ba5ec36100d73afb96e06.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(11/16) (4b21f0b59bc137dc57c1429d2c786b21) switched from INITIALIZING to
RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(12/16) (dfbaaaf7bf3841588b2ce593ebeeba46) switched from DEPLOYING to
INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(12/16) (dfbaaaf7bf3841588b2ce593ebeeba46) switched from INITIALIZING to
RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-39
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-20
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-61
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-57
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(13/16)#0 (e7f5fa99d4b9a78ce2072d3a7a49fdbc), deploy into slot with allocation
id 0bbfbfd50a3ba5ec36100d73afb96e06.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-49
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-52
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.beam.runners.fnexecution.data.GrpcDataService data
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Beam Fn Data client connected.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot 218a9b5be00003ff59f0639d14d5d332.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-31
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(13/16)#0 (e7f5fa99d4b9a78ce2072d3a7a49fdbc) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(13/16)#0 (e7f5fa99d4b9a78ce2072d3a7a49fdbc) [DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(13/16)#0 (e7f5fa99d4b9a78ce2072d3a7a49fdbc) switched from DEPLOYING to
INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(13/16)#0 (e7f5fa99d4b9a78ce2072d3a7a49fdbc) switched from INITIALIZING to
RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(13/16) (e7f5fa99d4b9a78ce2072d3a7a49fdbc) switched from DEPLOYING to
INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(13/16) (e7f5fa99d4b9a78ce2072d3a7a49fdbc) switched from INITIALIZING to
RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(14/16)#0 (9dc0fc757c36e942efb2e383b02e87a9), deploy into slot with allocation
id 218a9b5be00003ff59f0639d14d5d332.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot 88f2f143ab2907260d93b1ae971a3bda.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(14/16)#0 (9dc0fc757c36e942efb2e383b02e87a9) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(14/16)#0 (9dc0fc757c36e942efb2e383b02e87a9) [DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(14/16)#0 (9dc0fc757c36e942efb2e383b02e87a9) switched from DEPLOYING to
INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(14/16)#0 (9dc0fc757c36e942efb2e383b02e87a9) switched from INITIALIZING to
RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(14/16) (9dc0fc757c36e942efb2e383b02e87a9) switched from DEPLOYING to
INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(14/16) (9dc0fc757c36e942efb2e383b02e87a9) switched from INITIALIZING to
RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(15/16)#0 (9e21a3e5895aad0f53bbf9277f7816b4), deploy into slot with allocation
id 88f2f143ab2907260d93b1ae971a3bda.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot 00f135f68d1cc985f7116d5bad0aff76.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(15/16)#0 (9e21a3e5895aad0f53bbf9277f7816b4) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(15/16)#0 (9e21a3e5895aad0f53bbf9277f7816b4) [DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(15/16)#0 (9e21a3e5895aad0f53bbf9277f7816b4) switched from DEPLOYING to
INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(15/16) (9e21a3e5895aad0f53bbf9277f7816b4) switched from DEPLOYING to
INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(15/16)#0 (9e21a3e5895aad0f53bbf9277f7816b4) switched from INITIALIZING to
RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(15/16) (9e21a3e5895aad0f53bbf9277f7816b4) switched from INITIALIZING to
RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(16/16)#0 (6ada36d2e340270f9a3d8b3992eb94d7), deploy into slot with allocation
id 00f135f68d1cc985f7116d5bad0aff76.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(16/16)#0 (6ada36d2e340270f9a3d8b3992eb94d7) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(16/16)#0 (6ada36d2e340270f9a3d8b3992eb94d7) [DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(16/16)#0 (6ada36d2e340270f9a3d8b3992eb94d7) switched from DEPLOYING to
INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(16/16)#0 (6ada36d2e340270f9a3d8b3992eb94d7) switched from INITIALIZING to
RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(16/16) (6ada36d2e340270f9a3d8b3992eb94d7) switched from DEPLOYING to
INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
(16/16) (6ada36d2e340270f9a3d8b3992eb94d7) switched from INITIALIZING to
RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING:
The operator name GroupReduce (GroupReduce at ToPCollection(df) -
gs://temp-storage-for-end-to-end-tests/temp-it/flight_delays_it-13b8c80c-7fd8-4ea8-8688-39301b97e393/output.csv/[ComputedExpression[apply_DataFrame_139964817449936]]:139964817537872/CoGroupByKey/CoGroupByKeyImpl/GroupByKey)
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot 03be6c714b62a3a374517bf5a4270960.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-34
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-63
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-58
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-15
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-42
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-38
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-60
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-41
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-53
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
getProcessBundleDescriptor request with id 1-35
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task MapPartition (MapPartition at [8]{ToPCollection(df) - gs:,
WriteToPandas(df) - gs:}) (1/16)#0 (ddfa05eb954ea5d432f01f1837456f79), deploy
into slot with allocation id 03be6c714b62a3a374517bf5a4270960.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [8]{ToPCollection(df) - gs:, WriteToPandas(df) -
gs:}) (1/16)#0 (ddfa05eb954ea5d432f01f1837456f79) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task MapPartition (MapPartition at [8]{ToPCollection(df)
- gs:, WriteToPandas(df) - gs:}) (1/16)#0 (ddfa05eb954ea5d432f01f1837456f79)
[DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot c98421da86992e2d4009d6aab4299ed2.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task MapPartition (MapPartition at [8]{ToPCollection(df) - gs:,
WriteToPandas(df) - gs:}) (2/16)#0 (d28ae5330d0c7a9b6885388a974cdcbb), deploy
into slot with allocation id c98421da86992e2d4009d6aab4299ed2.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot 13b3b1e78065921b8c580a446985c1d8.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [8]{ToPCollection(df) - gs:, WriteToPandas(df) -
gs:}) (2/16)#0 (d28ae5330d0c7a9b6885388a974cdcbb) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task MapPartition (MapPartition at [8]{ToPCollection(df)
- gs:, WriteToPandas(df) - gs:}) (2/16)#0 (d28ae5330d0c7a9b6885388a974cdcbb)
[DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task MapPartition (MapPartition at [8]{ToPCollection(df) - gs:,
WriteToPandas(df) - gs:}) (3/16)#0 (ca7f28bc8e3bb0c054a3ae25d645a212), deploy
into slot with allocation id 13b3b1e78065921b8c580a446985c1d8.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot 739453a51c895ae869edcb00ec5ee345.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [8]{ToPCollection(df) - gs:, WriteToPandas(df) -
gs:}) (3/16)#0 (ca7f28bc8e3bb0c054a3ae25d645a212) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task MapPartition (MapPartition at [8]{ToPCollection(df)
- gs:, WriteToPandas(df) - gs:}) (3/16)#0 (ca7f28bc8e3bb0c054a3ae25d645a212)
[DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task MapPartition (MapPartition at [8]{ToPCollection(df) - gs:,
WriteToPandas(df) - gs:}) (4/16)#0 (d1fc29b904c64873b42a5ff0f79f3015), deploy
into slot with allocation id 739453a51c895ae869edcb00ec5ee345.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [8]{ToPCollection(df) - gs:, WriteToPandas(df) -
gs:}) (4/16)#0 (d1fc29b904c64873b42a5ff0f79f3015) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot 9e39ec2735c7a82d63c6bf41df0b745a.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task MapPartition (MapPartition at [8]{ToPCollection(df)
- gs:, WriteToPandas(df) - gs:}) (4/16)#0 (d1fc29b904c64873b42a5ff0f79f3015)
[DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task MapPartition (MapPartition at [8]{ToPCollection(df) - gs:,
WriteToPandas(df) - gs:}) (5/16)#0 (f75997b16226e8ac6195344a91592797), deploy
into slot with allocation id 9e39ec2735c7a82d63c6bf41df0b745a.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot 73f07f5a77d94c5c47022a9f86d72c5a.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [8]{ToPCollection(df) - gs:, WriteToPandas(df) -
gs:}) (5/16)#0 (f75997b16226e8ac6195344a91592797) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task MapPartition (MapPartition at [8]{ToPCollection(df)
- gs:, WriteToPandas(df) - gs:}) (5/16)#0 (f75997b16226e8ac6195344a91592797)
[DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task MapPartition (MapPartition at [8]{ToPCollection(df) - gs:,
WriteToPandas(df) - gs:}) (6/16)#0 (95ee1a0fad563c5b62ba7f0c1d829bf8), deploy
into slot with allocation id 73f07f5a77d94c5c47022a9f86d72c5a.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot ae335d64401e02e364c25b392fa6c801.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [8]{ToPCollection(df) - gs:, WriteToPandas(df) -
gs:}) (6/16)#0 (95ee1a0fad563c5b62ba7f0c1d829bf8) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task MapPartition (MapPartition at [8]{ToPCollection(df)
- gs:, WriteToPandas(df) - gs:}) (6/16)#0 (95ee1a0fad563c5b62ba7f0c1d829bf8)
[DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task MapPartition (MapPartition at [8]{ToPCollection(df) - gs:,
WriteToPandas(df) - gs:}) (7/16)#0 (5c4605e358146ee491d536e90fbaa6b8), deploy
into slot with allocation id ae335d64401e02e364c25b392fa6c801.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot dca9dfc29249d7df4760e0054faaab00.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [8]{ToPCollection(df) - gs:, WriteToPandas(df) -
gs:}) (7/16)#0 (5c4605e358146ee491d536e90fbaa6b8) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task MapPartition (MapPartition at [8]{ToPCollection(df)
- gs:, WriteToPandas(df) - gs:}) (7/16)#0 (5c4605e358146ee491d536e90fbaa6b8)
[DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task MapPartition (MapPartition at [8]{ToPCollection(df) - gs:,
WriteToPandas(df) - gs:}) (8/16)#0 (5ce92be37de97bca4a329d1c22ee204c), deploy
into slot with allocation id dca9dfc29249d7df4760e0054faaab00.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot e66e0f911fcd68389c9cb41519d9c2aa.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [8]{ToPCollection(df) - gs:, WriteToPandas(df) -
gs:}) (8/16)#0 (5ce92be37de97bca4a329d1c22ee204c) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task MapPartition (MapPartition at [8]{ToPCollection(df)
- gs:, WriteToPandas(df) - gs:}) (8/16)#0 (5ce92be37de97bca4a329d1c22ee204c)
[DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task MapPartition (MapPartition at [8]{ToPCollection(df) - gs:,
WriteToPandas(df) - gs:}) (9/16)#0 (d7a102b28fae45a95d203b443af79234), deploy
into slot with allocation id e66e0f911fcd68389c9cb41519d9c2aa.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot 3b848ca1f845e298b019da383819e782.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [8]{ToPCollection(df) - gs:, WriteToPandas(df) -
gs:}) (9/16)#0 (d7a102b28fae45a95d203b443af79234) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task MapPartition (MapPartition at [8]{ToPCollection(df)
- gs:, WriteToPandas(df) - gs:}) (9/16)#0 (d7a102b28fae45a95d203b443af79234)
[DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task MapPartition (MapPartition at [8]{ToPCollection(df) - gs:,
WriteToPandas(df) - gs:}) (10/16)#0 (8080b164f51ba86946215b88a283b64d), deploy
into slot with allocation id 3b848ca1f845e298b019da383819e782.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot 3b674b4f087ffe6be0089a5c23838e9d.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [8]{ToPCollection(df) - gs:, WriteToPandas(df) -
gs:}) (10/16)#0 (8080b164f51ba86946215b88a283b64d) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task MapPartition (MapPartition at [8]{ToPCollection(df)
- gs:, WriteToPandas(df) - gs:}) (10/16)#0 (8080b164f51ba86946215b88a283b64d)
[DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task MapPartition (MapPartition at [8]{ToPCollection(df) - gs:,
WriteToPandas(df) - gs:}) (11/16)#0 (5e04be422bfbfab0dc415f02e0ee1763), deploy
into slot with allocation id 3b674b4f087ffe6be0089a5c23838e9d.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot bb89315be4c9a073b282d01eba851e36.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [8]{ToPCollection(df) - gs:, WriteToPandas(df) -
gs:}) (11/16)#0 (5e04be422bfbfab0dc415f02e0ee1763) switched from CREATED to
DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Loading JAR files for task MapPartition (MapPartition at [8]{ToPCollection(df)
- gs:, WriteToPandas(df) - gs:}) (11/16)#0 (5e04be422bfbfab0dc415f02e0ee1763)
[DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received task MapPartition (MapPartition at [8]{ToPCollection(df) - gs:,
WriteToPandas(df) - gs:}) (12/16)#0 (70b865ca656eb298fbca965c32eea70a), deploy
into slot with allocation id bb89315be4c9a073b282d01eba851e36.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Activate slot 0bbfbfd50a3ba5ec36100d73afb96e06.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:47:19 AM org.apache.flink.runtime.taskmanager.Task transitionState
> Task :sdks:python:test-suites:portable:py39:flinkExamples
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:46:57 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at [2]read
table/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3481>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)#0
(68fcb12b224809f2b1d777080882daad).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:46:57 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSource (Impulse) (10/16)#0 ece0400489ac0a5f2de5b31b15f9a3a1.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:46:57 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSource (Impulse) (5/16)#0 b792030d21bb57bb1e2a6c4c8601dd7c.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:46:57 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSource (Impulse) (8/16)#0 1e961675201576f3c59502b32ef3b51f.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 15,
2022 9:46:57 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
java.lang.OutOfMemoryError: GC overhead limit exceeded
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]
