See
<https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Flink/5820/display/redirect?page=changes>
Changes:
[Pablo Estrada] Simplify README for new users
[laraschmidt] Fix final allowskew error to properly handle a large allowedSkew
[noreply] [BEAM-13946] Add get_dummies(), a non-deferred column operation on
------------------------------------------
[...truncated 5.51 MB...]
INFO: Received task CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
passert.Sum(emit2_2)/CoGBK) -> Map (Key Extractor) (1/1)#0
(01472f9ec62e53c8ed6b9354e7bc0c9f), deploy into slot with allocation id
fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: MapPartition (MapPartition at [4]{beam.createFn, regression.emit2Fn,
passert.Sum(emit2_2), passert.Sum(emit2_1)}) (1/1)
(ba232f6030b64d45e8c73dd56362262e) switched from DEPLOYING to INITIALIZING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: passert.Sum(emit2_2)/CoGBK) -> Map
(Key Extractor) (1/1)#0 (01472f9ec62e53c8ed6b9354e7bc0c9f) switched from
CREATED to DEPLOYING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: MapPartition (MapPartition at [4]{beam.createFn, regression.emit2Fn,
passert.Sum(emit2_2), passert.Sum(emit2_1)}) (1/1)
(ba232f6030b64d45e8c73dd56362262e) switched from INITIALIZING to RUNNING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Loading JAR files for task CHAIN FlatMap (FlatMap at ExtractOutput[1]) ->
Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
passert.Sum(emit2_2)/CoGBK) -> Map (Key Extractor) (1/1)#0
(01472f9ec62e53c8ed6b9354e7bc0c9f) [DEPLOYING].
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: passert.Sum(emit2_2)/CoGBK) -> Map
(Key Extractor) (1/1)#0 (01472f9ec62e53c8ed6b9354e7bc0c9f) switched from
DEPLOYING to INITIALIZING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: passert.Sum(emit2_2)/CoGBK) -> Map
(Key Extractor) (1/1)#0 (01472f9ec62e53c8ed6b9354e7bc0c9f) switched from
INITIALIZING to RUNNING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: passert.Sum(emit2_2)/CoGBK) -> Map
(Key Extractor) (1/1) (01472f9ec62e53c8ed6b9354e7bc0c9f) switched from
DEPLOYING to INITIALIZING.
Feb 18, 2022 12:26:18 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN FlatMap (FlatMap at ExtractOutput[1]) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: passert.Sum(emit2_2)/CoGBK) -> Map
(Key Extractor) (1/1) (01472f9ec62e53c8ed6b9354e7bc0c9f) switched from
INITIALIZING to RUNNING.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task GroupReduce (GroupReduce at passert.Sum(emit2_2)/CoGBK)
(1/1)#0 (86b23d6ff710de7befe3042ca689fcc7), deploy into slot with allocation id
fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: GroupReduce (GroupReduce at passert.Sum(emit2_2)/CoGBK) (1/1)#0
(86b23d6ff710de7befe3042ca689fcc7) switched from CREATED to DEPLOYING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Loading JAR files for task GroupReduce (GroupReduce at
passert.Sum(emit2_2)/CoGBK) (1/1)#0 (86b23d6ff710de7befe3042ca689fcc7)
[DEPLOYING].
Feb 18, 2022 12:26:18 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: GroupReduce (GroupReduce at passert.Sum(emit2_2)/CoGBK) (1/1)#0
(86b23d6ff710de7befe3042ca689fcc7) switched from DEPLOYING to INITIALIZING.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: GroupReduce (GroupReduce at passert.Sum(emit2_2)/CoGBK) (1/1)#0
(86b23d6ff710de7befe3042ca689fcc7) switched from INITIALIZING to RUNNING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: GroupReduce (GroupReduce at passert.Sum(emit2_2)/CoGBK) (1/1)
(86b23d6ff710de7befe3042ca689fcc7) switched from DEPLOYING to INITIALIZING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: GroupReduce (GroupReduce at passert.Sum(emit2_2)/CoGBK) (1/1)
(86b23d6ff710de7befe3042ca689fcc7) switched from INITIALIZING to RUNNING.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils getItems
WARNING: Unable to retrieve the requested metadata.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task MapPartition (MapPartition at
[1]passert.Sum(emit2_2)/passert.sumFn) (1/1)#0
(872394ed8ec350df9f8bc982eeec5696), deploy into slot with allocation id
fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils getItems
WARNING: Unable to retrieve the requested metadata.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: MapPartition (MapPartition at [1]passert.Sum(emit2_2)/passert.sumFn)
(1/1)#0 (872394ed8ec350df9f8bc982eeec5696) switched from CREATED to DEPLOYING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Loading JAR files for task MapPartition (MapPartition at
[1]passert.Sum(emit2_2)/passert.sumFn) (1/1)#0
(872394ed8ec350df9f8bc982eeec5696) [DEPLOYING].
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: MapPartition (MapPartition at [1]passert.Sum(emit2_2)/passert.sumFn)
(1/1)#0 (872394ed8ec350df9f8bc982eeec5696) switched from DEPLOYING to
INITIALIZING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: MapPartition (MapPartition at [1]passert.Sum(emit2_2)/passert.sumFn)
(1/1)#0 (872394ed8ec350df9f8bc982eeec5696) switched from INITIALIZING to
RUNNING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: MapPartition (MapPartition at [1]passert.Sum(emit2_2)/passert.sumFn)
(1/1) (872394ed8ec350df9f8bc982eeec5696) switched from DEPLOYING to
INITIALIZING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink (DiscardingOutput) (1/1)#0
(decd8e06e0ffcc7bd4e8bc363d299ea0), deploy into slot with allocation id
fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: MapPartition (MapPartition at [1]passert.Sum(emit2_2)/passert.sumFn)
(1/1) (872394ed8ec350df9f8bc982eeec5696) switched from INITIALIZING to RUNNING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (DiscardingOutput) (1/1)#0 (decd8e06e0ffcc7bd4e8bc363d299ea0)
switched from CREATED to DEPLOYING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Loading JAR files for task DataSink (DiscardingOutput) (1/1)#0
(decd8e06e0ffcc7bd4e8bc363d299ea0) [DEPLOYING].
Feb 18, 2022 12:26:18 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM
software.amazon.awssdk.regions.internal.util.EC2MetadataUtils getItems
WARNING: Unable to retrieve the requested metadata.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (DiscardingOutput) (1/1)#0 (decd8e06e0ffcc7bd4e8bc363d299ea0)
switched from DEPLOYING to INITIALIZING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (DiscardingOutput) (1/1)#0 (decd8e06e0ffcc7bd4e8bc363d299ea0)
switched from INITIALIZING to RUNNING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (DiscardingOutput) (1/1) (decd8e06e0ffcc7bd4e8bc363d299ea0)
switched from DEPLOYING to INITIALIZING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
passert.Sum(emit2_1)/CoGBK) -> Map (Key Extractor) (1/1)#0
(fbbd5f5e9b4c03ef714d2c660029d954), deploy into slot with allocation id
fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (DiscardingOutput) (1/1) (decd8e06e0ffcc7bd4e8bc363d299ea0)
switched from INITIALIZING to RUNNING.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: passert.Sum(emit2_1)/CoGBK) -> Map
(Key Extractor) (1/1)#0 (fbbd5f5e9b4c03ef714d2c660029d954) switched from
CREATED to DEPLOYING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Loading JAR files for task CHAIN FlatMap (FlatMap at ExtractOutput[0]) ->
Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine:
passert.Sum(emit2_1)/CoGBK) -> Map (Key Extractor) (1/1)#0
(fbbd5f5e9b4c03ef714d2c660029d954) [DEPLOYING].
Feb 18, 2022 12:26:18 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: passert.Sum(emit2_1)/CoGBK) -> Map
(Key Extractor) (1/1)#0 (fbbd5f5e9b4c03ef714d2c660029d954) switched from
DEPLOYING to INITIALIZING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: passert.Sum(emit2_1)/CoGBK) -> Map
(Key Extractor) (1/1)#0 (fbbd5f5e9b4c03ef714d2c660029d954) switched from
INITIALIZING to RUNNING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: passert.Sum(emit2_1)/CoGBK) -> Map
(Key Extractor) (1/1) (fbbd5f5e9b4c03ef714d2c660029d954) switched from
DEPLOYING to INITIALIZING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task GroupReduce (GroupReduce at passert.Sum(emit2_1)/CoGBK)
(1/1)#0 (f341ab7459a1ab4764f02d3a566fe574), deploy into slot with allocation id
fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: CHAIN FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) ->
GroupCombine (GroupCombine at GroupCombine: passert.Sum(emit2_1)/CoGBK) -> Map
(Key Extractor) (1/1) (fbbd5f5e9b4c03ef714d2c660029d954) switched from
INITIALIZING to RUNNING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: GroupReduce (GroupReduce at passert.Sum(emit2_1)/CoGBK) (1/1)#0
(f341ab7459a1ab4764f02d3a566fe574) switched from CREATED to DEPLOYING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Loading JAR files for task GroupReduce (GroupReduce at
passert.Sum(emit2_1)/CoGBK) (1/1)#0 (f341ab7459a1ab4764f02d3a566fe574)
[DEPLOYING].
Feb 18, 2022 12:26:18 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: GroupReduce (GroupReduce at passert.Sum(emit2_1)/CoGBK) (1/1)#0
(f341ab7459a1ab4764f02d3a566fe574) switched from DEPLOYING to INITIALIZING.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSource (Impulse) (1/1)#0 (f3b4ffc67f3f9ba05ec543030a4f3e3c) switched
from RUNNING to FINISHED.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: GroupReduce (GroupReduce at passert.Sum(emit2_1)/CoGBK) (1/1)
(f341ab7459a1ab4764f02d3a566fe574) switched from DEPLOYING to INITIALIZING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: GroupReduce (GroupReduce at passert.Sum(emit2_1)/CoGBK) (1/1)#0
(f341ab7459a1ab4764f02d3a566fe574) switched from INITIALIZING to RUNNING.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: GroupReduce (GroupReduce at passert.Sum(emit2_1)/CoGBK) (1/1)
(f341ab7459a1ab4764f02d3a566fe574) switched from INITIALIZING to RUNNING.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for DataSource (Impulse) (1/1)#0
(f3b4ffc67f3f9ba05ec543030a4f3e3c).
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task MapPartition (MapPartition at
[1]passert.Sum(emit2_1)/passert.sumFn) (1/1)#0
(fa4a3c0261bd1994610258db9b2989c0), deploy into slot with allocation id
fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: MapPartition (MapPartition at [1]passert.Sum(emit2_1)/passert.sumFn)
(1/1)#0 (fa4a3c0261bd1994610258db9b2989c0) switched from CREATED to DEPLOYING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Loading JAR files for task MapPartition (MapPartition at
[1]passert.Sum(emit2_1)/passert.sumFn) (1/1)#0
(fa4a3c0261bd1994610258db9b2989c0) [DEPLOYING].
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: MapPartition (MapPartition at [1]passert.Sum(emit2_1)/passert.sumFn)
(1/1)#0 (fa4a3c0261bd1994610258db9b2989c0) switched from DEPLOYING to
INITIALIZING.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: MapPartition (MapPartition at [1]passert.Sum(emit2_1)/passert.sumFn)
(1/1)#0 (fa4a3c0261bd1994610258db9b2989c0) switched from INITIALIZING to
RUNNING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: MapPartition (MapPartition at [1]passert.Sum(emit2_1)/passert.sumFn)
(1/1) (fa4a3c0261bd1994610258db9b2989c0) switched from DEPLOYING to
INITIALIZING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task DataSink (DiscardingOutput) (1/1)#0
(9b7d8fa6d2bbefb94b8d50c7c04629f4), deploy into slot with allocation id
fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: MapPartition (MapPartition at [1]passert.Sum(emit2_1)/passert.sumFn)
(1/1) (fa4a3c0261bd1994610258db9b2989c0) switched from INITIALIZING to RUNNING.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot fc1734eb459b1e61ccf2ae45da84ecdb.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task DataSource (Impulse) (1/1)#0
f3b4ffc67f3f9ba05ec543030a4f3e3c.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (DiscardingOutput) (1/1)#0 (9b7d8fa6d2bbefb94b8d50c7c04629f4)
switched from CREATED to DEPLOYING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Loading JAR files for task DataSink (DiscardingOutput) (1/1)#0
(9b7d8fa6d2bbefb94b8d50c7c04629f4) [DEPLOYING].
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (DiscardingOutput) (1/1)#0 (9b7d8fa6d2bbefb94b8d50c7c04629f4)
switched from DEPLOYING to INITIALIZING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: DataSink (DiscardingOutput) (1/1)#0 (9b7d8fa6d2bbefb94b8d50c7c04629f4)
switched from INITIALIZING to RUNNING.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSource (Impulse) (1/1) (f3b4ffc67f3f9ba05ec543030a4f3e3c) switched
from RUNNING to FINISHED.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (DiscardingOutput) (1/1) (9b7d8fa6d2bbefb94b8d50c7c04629f4)
switched from DEPLOYING to INITIALIZING.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: DataSink (DiscardingOutput) (1/1) (9b7d8fa6d2bbefb94b8d50c7c04629f4)
switched from INITIALIZING to RUNNING.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:18 AM
org.apache.beam.runners.fnexecution.environment.DockerCommand runImage
WARNING: Unable to pull docker image apache/beam_go_sdk:dev, cause: Received
exit code 1 for command 'docker pull apache/beam_go_sdk:dev'. stderr: Error
response from daemon: manifest for apache/beam_go_sdk:dev not found
Feb 18, 2022 12:26:19 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:19 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:19 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
Feb 18, 2022 12:26:19 AM
org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder
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.
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-1' is disconnected.
at
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:216)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:286)
at com.sun.proxy.$Proxy126.isAlive(Unknown Source)
at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1213)
at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1205)
at hudson.Launcher$ProcStarter.join(Launcher.java:522)
at hudson.plugins.gradle.Gradle.perform(Gradle.java:317)
at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
at
hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:806)
at hudson.model.Build$BuildExecution.build(Build.java:198)
at hudson.model.Build$BuildExecution.doRun(Build.java:163)
at
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:514)
at hudson.model.Run.execute(Run.java:1888)
at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:43)
at hudson.model.ResourceController.execute(ResourceController.java:99)
at hudson.model.Executor.run(Executor.java:432)
Caused by: java.io.IOException: Pipe closed after 0 cycles
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:126)
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:105)
at
hudson.remoting.FlightRecorderInputStream.read(FlightRecorderInputStream.java:93)
at
hudson.remoting.ChunkedInputStream.readHeader(ChunkedInputStream.java:74)
at
hudson.remoting.ChunkedInputStream.readUntilBreak(ChunkedInputStream.java:104)
at
hudson.remoting.ChunkedCommandTransport.readBlock(ChunkedCommandTransport.java:39)
at
hudson.remoting.AbstractSynchronousByteArrayCommandTransport.read(AbstractSynchronousByteArrayCommandTransport.java:34)
at
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:61)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-1 is offline; cannot locate jdk_1.8_latest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
