See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/38/display/redirect>
Changes:
------------------------------------------
[...truncated 68.66 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PTRANSFORM":
"ref_AppliedPTransform_SaveToBQ-BigQueryBatchFileLoads-ImpulseMonitorDestinationLoadJobs-Map-decode-_108"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"urn": "beam:metric:pardo_execution_time:finish_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PTRANSFORM": "fn/read/ref_PCollection_PCollection_76:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"urn": "beam:metric:pardo_execution_time:finish_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PTRANSFORM":
"ref_AppliedPTransform_SaveToBQ-BigQueryBatchFileLoads-ImpulseMonitorDestinationLoadJobs-Map-decode-_108"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"urn": "beam:metric:pardo_execution_time:process_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PTRANSFORM": "fn/read/ref_PCollection_PCollection_76:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"urn": "beam:metric:pardo_execution_time:finish_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PTRANSFORM": "fn/write/ref_PCollection_PCollection_78:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"urn": "beam:metric:pardo_execution_time:start_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PTRANSFORM": "fn/write/ref_PCollection_PCollection_78:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PTRANSFORM": "fn/read/ref_PCollection_PCollection_76:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PTRANSFORM":
"ref_AppliedPTransform_SaveToBQ-BigQueryBatchFileLoads-ImpulseMonitorDestinationLoadJobs-FlatMap-lamb_106"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PTRANSFORM":
"ref_AppliedPTransform_SaveToBQ-BigQueryBatchFileLoads-ImpulseMonitorDestinationLoadJobs-Map-decode-_108"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PTRANSFORM": "fn/write/ref_PCollection_PCollection_78:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"urn": "beam:metric:pardo_execution_time:start_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PTRANSFORM": "fn/read/ref_PCollection_PCollection_76:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"urn": "beam:metric:pardo_execution_time:start_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PTRANSFORM":
"ref_AppliedPTransform_SaveToBQ-BigQueryBatchFileLoads-ImpulseMonitorDestinationLoadJobs-Map-decode-_108"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"urn": "beam:metric:pardo_execution_time:start_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PTRANSFORM":
"ref_AppliedPTransform_SaveToBQ-BigQueryBatchFileLoads-ImpulseMonitorDestinationLoadJobs-FlatMap-lamb_106"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"urn": "beam:metric:sampled_byte_size:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"type": "beam:metrics:distribution_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"payload": "AQ4ODg==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PCOLLECTION": "ref_PCollection_PCollection_77"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"urn": "beam:metric:sampled_byte_size:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"type": "beam:metrics:distribution_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"payload": "AQ4ODg==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PCOLLECTION": "ref_PCollection_PCollection_78"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' },
{'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"urn": "beam:metric:sampled_byte_size:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"type": "beam:metrics:distribution_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"payload": "AQ0NDQ==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
"PCOLLECTION": "ref_PCollection_PCollection_76"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'}'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 15,
2022 12:08:52 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Stopping Akka RPC service.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 15,
2022 12:08:53 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Stopping Akka RPC service.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 15,
2022 12:08:53 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$7'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Stopped Akka RPC service.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 15,
2022 12:08:53 PM org.apache.flink.runtime.blob.AbstractBlobCache close'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Shutting down BLOB cache'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 15,
2022 12:08:53 PM org.apache.flink.runtime.blob.AbstractBlobCache close'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Shutting down BLOB cache'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 15,
2022 12:08:53 PM org.apache.flink.runtime.blob.BlobServer close'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Stopped BLOB server at 0.0.0.0:45539'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 15,
2022 12:08:53 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService
lambda$stopService$7'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Stopped Akka RPC service.'
PASSED [ 73%]
apache_beam/examples/cookbook/group_with_coder_test.py::GroupWithCoderTest::test_basics_with_type_check
-------------------------------- live log call ---------------------------------
INFO root:pipeline.py:188 Missing pipeline option (runner). Executing
pipeline using the default runner: DirectRunner.
WARNING root:environments.py:374 Make sure that locally built Python SDK
docker image has Python 3.7 interpreter.
INFO root:environments.py:380 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.38.0.dev
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function annotate_downstream_side_inputs at
0x7fe332ecac20> ====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function fix_side_input_pcoll_coders at 0x7fe332ecad40>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function pack_combiners at 0x7fe332ec2290>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function lift_combiners at 0x7fe332ec2320>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function expand_sdf at 0x7fe332ec24d0>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function expand_gbk at 0x7fe332ec2560>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function sink_flattens at 0x7fe332ec2680>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function greedily_fuse at 0x7fe332ec2710>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function read_to_impulse at 0x7fe332ec27a0>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function impulse_to_input at 0x7fe332ec2830>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function sort_stages at 0x7fe332ec2a70>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function setup_timer_mapping at 0x7fe332ec29e0>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function populate_data_channel_coders at 0x7fe332ec2b00>
====================
INFO apache_beam.runners.worker.statecache:statecache.py:172 Creating state
cache with size 100
INFO
apache_beam.runners.portability.fn_api_runner.worker_handlers:worker_handlers.py:894
Created Worker handler
<apache_beam.runners.portability.fn_api_runner.worker_handlers.EmbeddedWorkerHandler
object at 0x7fe3176826d0> for environment
ref_Environment_default_environment_1 (beam:env:embedded_python:v1, b'')
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
(((((ref_AppliedPTransform_WriteToText-Write-WriteImpl-DoOnce-Impulse_18)+(ref_AppliedPTransform_WriteToText-Write-WriteImpl-DoOnce-FlatMap-lambda-at-core-py-3229-_19))+(ref_AppliedPTransform_WriteToText-Write-WriteImpl-DoOnce-Map-decode-_21))+(ref_AppliedPTransform_WriteToText-Write-WriteImpl-InitializeWrite_22))+(ref_PCollection_PCollection_10/Write))+(ref_PCollection_PCollection_11/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((ref_AppliedPTransform_ReadFromText-Read-Impulse_4)+(ref_AppliedPTransform_ReadFromText-Read-Map-lambda-at-iobase-py-898-_5))+(ReadFromText/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/PairWithRestriction))+(ReadFromText/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/SplitAndSizeRestriction))+(ref_PCollection_PCollection_2_split/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((ref_PCollection_PCollection_2_split/Read)+(ReadFromText/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/Process))+(ref_AppliedPTransform_Map-get_players-_8))+(CombinePerKey(sum)/Precombine))+(CombinePerKey(sum)/Group/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
(((((((CombinePerKey(sum)/Group/Read)+(CombinePerKey(sum)/Merge))+(CombinePerKey(sum)/ExtractOutputs))+(ref_AppliedPTransform_Map-lambda-at-group_with_coder-py-115-_13))+(ref_AppliedPTransform_WriteToText-Write-WriteImpl-WindowInto-WindowIntoFn-_23))+(ref_AppliedPTransform_WriteToText-Write-WriteImpl-WriteBundles_24))+(ref_AppliedPTransform_WriteToText-Write-WriteImpl-Pair_25))+(WriteToText/Write/WriteImpl/GroupByKey/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((WriteToText/Write/WriteImpl/GroupByKey/Read)+(ref_AppliedPTransform_WriteToText-Write-WriteImpl-Extract_27))+(ref_PCollection_PCollection_16/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((ref_PCollection_PCollection_10/Read)+(ref_AppliedPTransform_WriteToText-Write-WriteImpl-PreFinalize_28))+(ref_PCollection_PCollection_17/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
(ref_PCollection_PCollection_10/Read)+(ref_AppliedPTransform_WriteToText-Write-WriteImpl-FinalizeWrite_29)
INFO apache_beam.io.filebasedsink:filebasedsink.py:303 Starting
finalize_write threads with num_shards: 1 (skipped: 0), batches: 1,
num_threads: 1
INFO apache_beam.io.filebasedsink:filebasedsink.py:348 Renamed 1 shards in
0.10 seconds.
INFO root:group_with_coder_test.py:73 result: [('x:joe', 60), ('x:fred',
9), ('x:mary', 8), ('x:ann', 15)]
PASSED [ 78%]
apache_beam/examples/cookbook/group_with_coder_test.py::GroupWithCoderTest::test_basics_without_type_check
-------------------------------- live log call ---------------------------------
INFO root:pipeline.py:188 Missing pipeline option (runner). Executing
pipeline using the default runner: DirectRunner.
WARNING root:environments.py:374 Make sure that locally built Python SDK
docker image has Python 3.7 interpreter.
INFO root:environments.py:380 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.38.0.dev
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function annotate_downstream_side_inputs at
0x7fe332ecac20> ====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function fix_side_input_pcoll_coders at 0x7fe332ecad40>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function pack_combiners at 0x7fe332ec2290>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function lift_combiners at 0x7fe332ec2320>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function expand_sdf at 0x7fe332ec24d0>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function expand_gbk at 0x7fe332ec2560>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function sink_flattens at 0x7fe332ec2680>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function greedily_fuse at 0x7fe332ec2710>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function read_to_impulse at 0x7fe332ec27a0>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function impulse_to_input at 0x7fe332ec2830>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function sort_stages at 0x7fe332ec2a70>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function setup_timer_mapping at 0x7fe332ec29e0>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function populate_data_channel_coders at 0x7fe332ec2b00>
====================
INFO apache_beam.runners.worker.statecache:statecache.py:172 Creating state
cache with size 100
INFO
apache_beam.runners.portability.fn_api_runner.worker_handlers:worker_handlers.py:894
Created Worker handler
<apache_beam.runners.portability.fn_api_runner.worker_handlers.EmbeddedWorkerHandler
object at 0x7fe32c402d50> for environment
ref_Environment_default_environment_1 (beam:env:embedded_python:v1, b'')
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
(((((ref_AppliedPTransform_WriteToText-Write-WriteImpl-DoOnce-Impulse_18)+(ref_AppliedPTransform_WriteToText-Write-WriteImpl-DoOnce-FlatMap-lambda-at-core-py-3229-_19))+(ref_AppliedPTransform_WriteToText-Write-WriteImpl-DoOnce-Map-decode-_21))+(ref_AppliedPTransform_WriteToText-Write-WriteImpl-InitializeWrite_22))+(ref_PCollection_PCollection_10/Write))+(ref_PCollection_PCollection_11/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((ref_AppliedPTransform_ReadFromText-Read-Impulse_4)+(ref_AppliedPTransform_ReadFromText-Read-Map-lambda-at-iobase-py-898-_5))+(ReadFromText/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/PairWithRestriction))+(ReadFromText/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/SplitAndSizeRestriction))+(ref_PCollection_PCollection_2_split/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((ref_PCollection_PCollection_2_split/Read)+(ReadFromText/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/Process))+(ref_AppliedPTransform_Map-get_players-_8))+(CombinePerKey(sum)/Precombine))+(CombinePerKey(sum)/Group/Write)
WARNING apache_beam.coders.coder_impl:coder_impl.py:448 Using fallback
deterministic coder for type '<class
'apache_beam.examples.cookbook.group_with_coder.Player'>' in
'CombinePerKey(sum)/GroupByKey'.
PASSED [ 82%]
apache_beam/examples/cookbook/mergecontacts_test.py::MergeContactsTest::test_mergecontacts
-------------------------------- live log call ---------------------------------
INFO root:pipeline.py:188 Missing pipeline option (runner). Executing
pipeline using the default runner: DirectRunner.
WARNING root:environments.py:374 Make sure that locally built Python SDK
docker image has Python 3.7 interpreter.
INFO root:environments.py:380 Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.38.0.dev
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function annotate_downstream_side_inputs at
0x7fe332ecac20> ====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function fix_side_input_pcoll_coders at 0x7fe332ecad40>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function pack_combiners at 0x7fe332ec2290>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function lift_combiners at 0x7fe332ec2320>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function expand_sdf at 0x7fe332ec24d0>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function expand_gbk at 0x7fe332ec2560>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function sink_flattens at 0x7fe332ec2680>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function greedily_fuse at 0x7fe332ec2710>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function read_to_impulse at 0x7fe332ec27a0>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function impulse_to_input at 0x7fe332ec2830>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function sort_stages at 0x7fe332ec2a70>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function setup_timer_mapping at 0x7fe332ec29e0>
====================
INFO
apache_beam.runners.portability.fn_api_runner.translations:translations.py:678
==================== <function populate_data_channel_coders at 0x7fe332ec2b00>
====================
INFO apache_beam.runners.worker.statecache:statecache.py:172 Creating state
cache with size 100
INFO
apache_beam.runners.portability.fn_api_runner.worker_handlers:worker_handlers.py:894
Created Worker handler
<apache_beam.runners.portability.fn_api_runner.worker_handlers.EmbeddedWorkerHandler
object at 0x7fe3173adf90> for environment
ref_Environment_default_environment_1 (beam:env:embedded_python:v1, b'')
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
(((((ref_AppliedPTransform_WriteTsv-Write-WriteImpl-DoOnce-Impulse_88)+(ref_AppliedPTransform_WriteTsv-Write-WriteImpl-DoOnce-FlatMap-lambda-at-core-py-3229-_89))+(ref_AppliedPTransform_WriteTsv-Write-WriteImpl-DoOnce-Map-decode-_91))+(ref_AppliedPTransform_WriteTsv-Write-WriteImpl-InitializeWrite_92))+(ref_PCollection_PCollection_56/Write))+(ref_PCollection_PCollection_57/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((ref_AppliedPTransform_Read-email-Read-Impulse_4)+(ref_AppliedPTransform_Read-email-Read-Map-lambda-at-iobase-py-898-_5))+(Read:
email/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/PairWithRestriction))+(Read:
email/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/SplitAndSizeRestriction))+(ref_PCollection_PCollection_2_split/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running (((((((ref_PCollection_PCollection_2_split/Read)+(Read:
email/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/Process))+(ref_AppliedPTransform_Backslash-email_8))+(ref_AppliedPTransform_EscapeQuotes-email_9))+(ref_AppliedPTransform_Split-email_10))+(ref_AppliedPTransform_group_by_name-CoGroupByKeyImpl-Tag-0-_31))+(group_by_name/CoGroupByKeyImpl/Flatten/Transcode/0))+(group_by_name/CoGroupByKeyImpl/Flatten/Write/0)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((ref_AppliedPTransform_Read-phone-Read-Impulse_13)+(ref_AppliedPTransform_Read-phone-Read-Map-lambda-at-iobase-py-898-_14))+(Read:
phone/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/PairWithRestriction))+(Read:
phone/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/SplitAndSizeRestriction))+(ref_PCollection_PCollection_8_split/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running (((((((ref_PCollection_PCollection_8_split/Read)+(Read:
phone/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/Process))+(ref_AppliedPTransform_Backslash-phone_17))+(ref_AppliedPTransform_EscapeQuotes-phone_18))+(ref_AppliedPTransform_Split-phone_19))+(ref_AppliedPTransform_group_by_name-CoGroupByKeyImpl-Tag-1-_32))+(group_by_name/CoGroupByKeyImpl/Flatten/Transcode/1))+(group_by_name/CoGroupByKeyImpl/Flatten/Write/1)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((ref_AppliedPTransform_Read-snailmail-Read-Impulse_22)+(ref_AppliedPTransform_Read-snailmail-Read-Map-lambda-at-iobase-py-898-_23))+(Read:
snailmail/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/PairWithRestriction))+(Read:
snailmail/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/SplitAndSizeRestriction))+(ref_PCollection_PCollection_14_split/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running (((((((ref_PCollection_PCollection_14_split/Read)+(Read:
snailmail/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/Process))+(ref_AppliedPTransform_Backslash-snailmail_26))+(ref_AppliedPTransform_EscapeQuotes-snailmail_27))+(ref_AppliedPTransform_Split-snailmail_28))+(ref_AppliedPTransform_group_by_name-CoGroupByKeyImpl-Tag-2-_33))+(group_by_name/CoGroupByKeyImpl/Flatten/Transcode/2))+(group_by_name/CoGroupByKeyImpl/Flatten/Write/2)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
(group_by_name/CoGroupByKeyImpl/Flatten/Read)+(group_by_name/CoGroupByKeyImpl/GroupByKey/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
(((((((((((((((((((group_by_name/CoGroupByKeyImpl/GroupByKey/Read)+(ref_AppliedPTransform_group_by_name-CoGroupByKeyImpl-MapTuple-collect_values-_36))+(ref_AppliedPTransform_group_by_name-RestoreTags_37))+(ref_AppliedPTransform_Map-format_as_tsv-_38))+(ref_AppliedPTransform_Filter-without_email-_39))+(ref_AppliedPTransform_Filter-without_phones-_40))+(ref_AppliedPTransform_Filter-without_address-_41))+(ref_AppliedPTransform_WriteTsv-Write-WriteImpl-WindowInto-WindowIntoFn-_93))+(ref_AppliedPTransform_Luddites-CombineGlobally-CountCombineFn-KeyWithVoid_44))+(ref_AppliedPTransform_Writers-CombineGlobally-CountCombineFn-KeyWithVoid_58))+(ref_AppliedPTransform_Nomads-CombineGlobally-CountCombineFn-KeyWithVoid_72))+(Luddites/CombineGlobally(CountCombineFn)/CombinePerKey/Precombine))+(Luddites/CombineGlobally(CountCombineFn)/CombinePerKey/Group/Write))+(Writers/CombineGlobally(CountCombineFn)/CombinePerKey/Precombine))+(Writers/CombineGlobally(CountCombineFn)/CombinePerKey/Group/Write))+(Nomads/CombineGlobally(CountCombineFn)/CombinePerKey/Precombine))+(Nomads/CombineGlobally(CountCombineFn)/CombinePerKey/Group/Write))+(ref_AppliedPTransform_WriteTsv-Write-WriteImpl-WriteBundles_94))+(ref_AppliedPTransform_WriteTsv-Write-WriteImpl-Pair_95))+(WriteTsv/Write/WriteImpl/GroupByKey/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((WriteTsv/Write/WriteImpl/GroupByKey/Read)+(ref_AppliedPTransform_WriteTsv-Write-WriteImpl-Extract_97))+(ref_PCollection_PCollection_62/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((ref_PCollection_PCollection_56/Read)+(ref_AppliedPTransform_WriteTsv-Write-WriteImpl-PreFinalize_98))+(ref_PCollection_PCollection_63/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
(ref_PCollection_PCollection_56/Read)+(ref_AppliedPTransform_WriteTsv-Write-WriteImpl-FinalizeWrite_99)
INFO apache_beam.io.filebasedsink:filebasedsink.py:303 Starting
finalize_write threads with num_shards: 1 (skipped: 0), batches: 1,
num_threads: 1
INFO apache_beam.io.filebasedsink:filebasedsink.py:348 Renamed 1 shards in
0.10 seconds.
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((Luddites/CombineGlobally(CountCombineFn)/CombinePerKey/Group/Read)+(Luddites/CombineGlobally(CountCombineFn)/CombinePerKey/Merge))+(Luddites/CombineGlobally(CountCombineFn)/CombinePerKey/ExtractOutputs))+(ref_AppliedPTransform_Luddites-CombineGlobally-CountCombineFn-UnKey_49))+(ref_PCollection_PCollection_33/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((((((ref_AppliedPTransform_Luddites-CombineGlobally-CountCombineFn-DoOnce-Impulse_51)+(ref_AppliedPTransform_Luddites-CombineGlobally-CountCombineFn-DoOnce-FlatMap-lambda-at-core-py-3229-_52))+(ref_AppliedPTransform_Luddites-CombineGlobally-CountCombineFn-DoOnce-Map-decode-_54))+(ref_AppliedPTransform_Luddites-CombineGlobally-CountCombineFn-InjectDefault_55))+(ref_AppliedPTransform_assert-luddites-WindowInto-WindowIntoFn-_106))+(ref_AppliedPTransform_assert-luddites-ToVoidKey_107))+(ref_AppliedPTransform_assert-luddites-Group-CoGroupByKeyImpl-Tag-1-_111))+(assert:luddites/Group/CoGroupByKeyImpl/Flatten/Transcode/1))+(assert:luddites/Group/CoGroupByKeyImpl/Flatten/Write/1)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
(((((ref_AppliedPTransform_assert-luddites-Create-Impulse_102)+(ref_AppliedPTransform_assert-luddites-Create-FlatMap-lambda-at-core-py-3229-_103))+(ref_AppliedPTransform_assert-luddites-Create-Map-decode-_105))+(ref_AppliedPTransform_assert-luddites-Group-CoGroupByKeyImpl-Tag-0-_110))+(assert:luddites/Group/CoGroupByKeyImpl/Flatten/Transcode/0))+(assert:luddites/Group/CoGroupByKeyImpl/Flatten/Write/0)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
(assert:luddites/Group/CoGroupByKeyImpl/Flatten/Read)+(assert:luddites/Group/CoGroupByKeyImpl/GroupByKey/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((assert:luddites/Group/CoGroupByKeyImpl/GroupByKey/Read)+(ref_AppliedPTransform_assert-luddites-Group-CoGroupByKeyImpl-MapTuple-collect_values-_114))+(ref_AppliedPTransform_assert-luddites-Group-RestoreTags_115))+(ref_AppliedPTransform_assert-luddites-Unkey_116))+(ref_AppliedPTransform_assert-luddites-Match_117)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((Nomads/CombineGlobally(CountCombineFn)/CombinePerKey/Group/Read)+(Nomads/CombineGlobally(CountCombineFn)/CombinePerKey/Merge))+(Nomads/CombineGlobally(CountCombineFn)/CombinePerKey/ExtractOutputs))+(ref_AppliedPTransform_Nomads-CombineGlobally-CountCombineFn-UnKey_77))+(ref_PCollection_PCollection_49/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((Writers/CombineGlobally(CountCombineFn)/CombinePerKey/Group/Read)+(Writers/CombineGlobally(CountCombineFn)/CombinePerKey/Merge))+(Writers/CombineGlobally(CountCombineFn)/CombinePerKey/ExtractOutputs))+(ref_AppliedPTransform_Writers-CombineGlobally-CountCombineFn-UnKey_63))+(ref_PCollection_PCollection_41/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
(((((ref_AppliedPTransform_assert-writers-Create-Impulse_120)+(ref_AppliedPTransform_assert-writers-Create-FlatMap-lambda-at-core-py-3229-_121))+(ref_AppliedPTransform_assert-writers-Create-Map-decode-_123))+(ref_AppliedPTransform_assert-writers-Group-CoGroupByKeyImpl-Tag-0-_128))+(assert:writers/Group/CoGroupByKeyImpl/Flatten/Transcode/0))+(assert:writers/Group/CoGroupByKeyImpl/Flatten/Write/0)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((((((ref_AppliedPTransform_Writers-CombineGlobally-CountCombineFn-DoOnce-Impulse_65)+(ref_AppliedPTransform_Writers-CombineGlobally-CountCombineFn-DoOnce-FlatMap-lambda-at-core-py-3229-_66))+(ref_AppliedPTransform_Writers-CombineGlobally-CountCombineFn-DoOnce-Map-decode-_68))+(ref_AppliedPTransform_Writers-CombineGlobally-CountCombineFn-InjectDefault_69))+(ref_AppliedPTransform_assert-writers-WindowInto-WindowIntoFn-_124))+(ref_AppliedPTransform_assert-writers-ToVoidKey_125))+(ref_AppliedPTransform_assert-writers-Group-CoGroupByKeyImpl-Tag-1-_129))+(assert:writers/Group/CoGroupByKeyImpl/Flatten/Transcode/1))+(assert:writers/Group/CoGroupByKeyImpl/Flatten/Write/1)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
(assert:writers/Group/CoGroupByKeyImpl/Flatten/Read)+(assert:writers/Group/CoGroupByKeyImpl/GroupByKey/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((((((ref_AppliedPTransform_Nomads-CombineGlobally-CountCombineFn-DoOnce-Impulse_79)+(ref_AppliedPTransform_Nomads-CombineGlobally-CountCombineFn-DoOnce-FlatMap-lambda-at-core-py-3229-_80))+(ref_AppliedPTransform_Nomads-CombineGlobally-CountCombineFn-DoOnce-Map-decode-_82))+(ref_AppliedPTransform_Nomads-CombineGlobally-CountCombineFn-InjectDefault_83))+(ref_AppliedPTransform_assert-nomads-WindowInto-WindowIntoFn-_142))+(ref_AppliedPTransform_assert-nomads-ToVoidKey_143))+(ref_AppliedPTransform_assert-nomads-Group-CoGroupByKeyImpl-Tag-1-_147))+(assert:nomads/Group/CoGroupByKeyImpl/Flatten/Transcode/1))+(assert:nomads/Group/CoGroupByKeyImpl/Flatten/Write/1)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((assert:writers/Group/CoGroupByKeyImpl/GroupByKey/Read)+(ref_AppliedPTransform_assert-writers-Group-CoGroupByKeyImpl-MapTuple-collect_values-_132))+(ref_AppliedPTransform_assert-writers-Group-RestoreTags_133))+(ref_AppliedPTransform_assert-writers-Unkey_134))+(ref_AppliedPTransform_assert-writers-Match_135)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
(((((ref_AppliedPTransform_assert-nomads-Create-Impulse_138)+(ref_AppliedPTransform_assert-nomads-Create-FlatMap-lambda-at-core-py-3229-_139))+(ref_AppliedPTransform_assert-nomads-Create-Map-decode-_141))+(ref_AppliedPTransform_assert-nomads-Group-CoGroupByKeyImpl-Tag-0-_146))+(assert:nomads/Group/CoGroupByKeyImpl/Flatten/Transcode/0))+(assert:nomads/Group/CoGroupByKeyImpl/Flatten/Write/0)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
(assert:nomads/Group/CoGroupByKeyImpl/Flatten/Read)+(assert:nomads/Group/CoGroupByKeyImpl/GroupByKey/Write)
INFO
apache_beam.runners.portability.fn_api_runner.fn_runner:fn_runner.py:621
Running
((((assert:nomads/Group/CoGroupByKeyImpl/GroupByKey/Read)+(ref_AppliedPTransform_assert-nomads-Group-CoGroupByKeyImpl-MapTuple-collect_values-_150))+(ref_AppliedPTransform_assert-nomads-Group-RestoreTags_151))+(ref_AppliedPTransform_assert-nomads-Unkey_152))+(ref_AppliedPTransform_assert-nomads-Match_153)
PASSED [ 86%]
apache_beam/examples/cookbook/multiple_output_pardo_test.py::MultipleOutputParDo::test_multiple_output_pardo
-------------------------------- live log call ---------------------------------
INFO root:pipeline.py:188 Missing pipeline option (runner). Executing
pipeline using the default runner: DirectRunner.
> Task :sdks:python:test-suites:portable:py39:flinkExamples
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 15,
2022 12:07:37 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 15,
2022 12:07:37 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 0f65d944743742752536d8ad8048a4ae.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 15,
2022 12:07:37 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[6]Write/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
SchemaModJobNamePrefix, LoadJobNamePrefix, GenerateFilePrefix,
CopyJobNamePrefix}) (16/16)#0 (31681007119782bbc29ad7a6acf05fb4) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 15,
2022 12:07:37 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (16/16)#0 (3594ab66d8d83e8d59b521081b1832c1) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 15,
2022 12:07:37 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
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]
