Valentyn Tymofieiev created BEAM-13500:
------------------------------------------
Summary: NPE in Flink ValidatesRunner streaming suite
Key: BEAM-13500
URL: https://issues.apache.org/jira/browse/BEAM-13500
Project: Beam
Issue Type: Bug
Components: runner-flink
Reporter: Valentyn Tymofieiev
org.apache.beam.sdk.transforms.CombineTest$CombineWithContextTests.testSimpleCombineWithContextEmpty
failed for me with an NPE. Suspecting a flake.
{noformat}
Error Message
java.lang.RuntimeException: The Runner experienced the following error during
execution:
java.lang.NullPointerException
Stacktrace
java.lang.RuntimeException: The Runner experienced the following error during
execution:
java.lang.NullPointerException
at
org.apache.beam.runners.portability.JobServicePipelineResult.propagateErrors(JobServicePipelineResult.java:176)
at
org.apache.beam.runners.portability.JobServicePipelineResult.waitUntilFinish(JobServicePipelineResult.java:117)
at
org.apache.beam.runners.portability.testing.TestPortableRunner.run(TestPortableRunner.java:83)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:323)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:399)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:335)
at
org.apache.beam.sdk.transforms.CombineTest$SharedTestBase.runTestSimpleCombineWithContext(CombineTest.java:168)
at
org.apache.beam.sdk.transforms.CombineTest$CombineWithContextTests.testSimpleCombineWithContextEmpty(CombineTest.java:1005)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:323)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:110)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:38)
at
org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:62)
at
org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
at sun.reflect.GeneratedMethodAccessor109.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
at
org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:119)
at sun.reflect.GeneratedMethodAccessor108.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:182)
at
org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:164)
at
org.gradle.internal.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:414)
at
org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:64)
at
org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:48)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at
org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:56)
at java.lang.Thread.run(Thread.java:748)
Standard Output
Shutting SDK harness down.
Shutting SDK harness down.
Standard Error
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Received task [9]{Stateful ParDo, PAssert$106, PAssert$105} ->
(ToKeyedWorkItem, ToKeyedWorkItem) (2/2)#0 (0e77dd08419bcd58679f46ccc0f6cc80),
deploy into slot with allocation id 2b4c72ef6734eb8711c9a56c071d8aac.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
[3]PAssert$106/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2)#0 be61759a0b7a68a797ff906ee914c4d7.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Shutting down the network environment and its components.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: ToKeyedWorkItem (1/2) (0f03c77b7e5f2481c3ada3627d68d26a) switched from
SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: getProcessBundleDescriptor request with id 96-8
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@6e3602a6
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$105/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$105/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/2)#0
(d9f6279ba3b02124c456d3d36967bb44) switched from DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Finished to build heap keyed state-backend.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Initializing heap keyed state backend with stream factory.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Activate slot 89280a8dc29f606aebb3b6d5aa98e929.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [9]{Stateful ParDo, PAssert$106, PAssert$105} -> (ToKeyedWorkItem,
ToKeyedWorkItem) (1/2)#0 (63e9d9c766e871c9af14ab5fbcf8af09) switched from
CREATED to DEPLOYING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@37da2d98
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: FileChannelManager removed spill file directory
/tmp/flink-netty-shuffle-fba8da1a-a5ea-4df8-bbda-e9ac15a21741
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [5]PAssert$105/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)#0
(9f72e938a7e1c8bd27f548fed404daf4) switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]PAssert$106/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2) (be61759a0b7a68a797ff906ee914c4d7)
switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@794606f0
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Shutting down the kvState service and its components.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$105/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$105/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)#0
(fd6761c8bb3c18aedbd6f90360545427) switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Freeing task resources for
PAssert$105/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$105/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)#0
(fd6761c8bb3c18aedbd6f90360545427).
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [3]{Create.TimestampedValues, Window.Into()} (2/2)#0
(e20bacb462a875d89b174eef9da9aabf) switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Stop job leader service.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [9]{Stateful ParDo, PAssert$106, PAssert$105} -> (ToKeyedWorkItem,
ToKeyedWorkItem) (2/2) (0e77dd08419bcd58679f46ccc0f6cc80) switched from RUNNING
to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Finished to build heap keyed state-backend.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$106/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$106/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/2)#0
(2e727a87bb84ce23908309b2690e5010) switched from DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Received task
[3]PAssert$105/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2)#0 (9cf804bd1dfa0eb0ffc917069fcc41c3),
deploy into slot with allocation id 2b4c72ef6734eb8711c9a56c071d8aac.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Initializing heap keyed state backend with stream factory.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$105/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$105/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/2)
(d9f6279ba3b02124c456d3d36967bb44) switched from DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Activate slot 89280a8dc29f606aebb3b6d5aa98e929.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [5]PAssert$105/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)
(9f72e938a7e1c8bd27f548fed404daf4) switched from DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: removed file cache directory
/tmp/flink-dist-cache-e2a21c18-b1e9-4629-848b-94b594c07c60
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
[3]PAssert$106/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2)#0 b768925c44903de5e62fbeec997d710f.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [5]PAssert$105/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)
(9f72e938a7e1c8bd27f548fed404daf4) switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
[3]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2)#0 e12733cd85d1258134b6e5c78f53d5d3.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$106/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$106/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)#0
(dbacb21ddbab3ab9b082bd2acd2c9211) switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Source: Impulse (1/1) (d965225b5a01b55cb61cc3a6d8e365b1) switched from
RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [5]PAssert$105/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)
(6e474ed0962fb75a544b242c1d4f50c4) switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_380.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]PAssert$105/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2) (9cf804bd1dfa0eb0ffc917069fcc41c3)
switched from SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$106/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$106/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/2)
(2e727a87bb84ce23908309b2690e5010) switched from DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]PAssert$106/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2)#0 (be61759a0b7a68a797ff906ee914c4d7)
switched from DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [3]{Create.TimestampedValues, Window.Into()} (1/2)#0
(0bd897307a3f5bd317e94eb853d5c34f) switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task [3]{Create.TimestampedValues, Window.Into()} (2/2)#0
e20bacb462a875d89b174eef9da9aabf.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]PAssert$106/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2) (be61759a0b7a68a797ff906ee914c4d7)
switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]PAssert$106/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2)#0 (be61759a0b7a68a797ff906ee914c4d7)
switched from CREATED to DEPLOYING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Deploying
[3]PAssert$105/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2) (attempt #0) with attempt id
9cf804bd1dfa0eb0ffc917069fcc41c3 to 7fdb4ac4-2e5c-4bd5-806e-fe0f37d8aff1 @
localhost (dataPort=-1) with allocation id 2b4c72ef6734eb8711c9a56c071d8aac
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [3]{Create.TimestampedValues, Window.Into()} (2/2)
(e20bacb462a875d89b174eef9da9aabf) switched from DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Removing cache directory /tmp/flink-web-ui
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$105/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$105/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/2)#0
(eb2515d4af5596083c2328dc2d7e39f5) switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
WARNING: The operator name [6]PAssert$106/GroupGlobally/{GatherAllOutputs,
RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents,
NeverTrigger} exceeded the 80 characters length limit and was truncated.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: getProcessBundleDescriptor request with id 96-10
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$106/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$106/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/2)#0
(2e727a87bb84ce23908309b2690e5010) switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: ToKeyedWorkItem (2/2) (170cb230245b2a3a603ad602abf14c73) switched from
RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Freeing task resources for
PAssert$106/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$106/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/2)#0
(2e727a87bb84ce23908309b2690e5010).
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Finished to build heap keyed state-backend.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Activate slot 89280a8dc29f606aebb3b6d5aa98e929.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]PAssert$105/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2)#0 (9cf804bd1dfa0eb0ffc917069fcc41c3)
switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Initializing heap keyed state backend with stream factory.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Freeing task resources for
[3]PAssert$105/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2)#0 (9cf804bd1dfa0eb0ffc917069fcc41c3).
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Deploying ToKeyedWorkItem (1/2) (attempt #0) with attempt id
0f03c77b7e5f2481c3ada3627d68d26a to 7fdb4ac4-2e5c-4bd5-806e-fe0f37d8aff1 @
localhost (dataPort=-1) with allocation id 89280a8dc29f606aebb3b6d5aa98e929
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Shut down complete.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Loading JAR files for task
[3]PAssert$106/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2)#0 (be61759a0b7a68a797ff906ee914c4d7)
[DEPLOYING].
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [3]{Create.TimestampedValues, Window.Into()} (1/2)
(0bd897307a3f5bd317e94eb853d5c34f) switched from DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Freeing task resources for [3]{Create.TimestampedValues, Window.Into()}
(1/2)#0 (0bd897307a3f5bd317e94eb853d5c34f).
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task PAssert$106/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$106/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/2)#0
2e727a87bb84ce23908309b2690e5010.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [5]PAssert$105/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)#0
(6e474ed0962fb75a544b242c1d4f50c4) switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Received task [5]PAssert$106/GroupGlobally/{Create.Values,
WindowIntoDummy, RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger}
(2/2)#0 (ec25331872eae87482a359cd34f5c3e3), deploy into slot with allocation id
2b4c72ef6734eb8711c9a56c071d8aac.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$105/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$105/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/2)
(eb2515d4af5596083c2328dc2d7e39f5) switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$106/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$106/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)#0
(dbacb21ddbab3ab9b082bd2acd2c9211) switched from CREATED to DEPLOYING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Shut down cluster because application is in CANCELED, diagnostics
DispatcherResourceManagerComponent has been closed..
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]PAssert$105/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2)#0 (fa4e4c59ad872aecb1b0147ba65ba42d)
switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task [5]PAssert$106/GroupGlobally/{Create.Values,
WindowIntoDummy, RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger}
(1/2)#0 df5b2e6a9d368b5500133973e95a9f5b.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Freeing task resources for
[3]PAssert$105/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2)#0 (fa4e4c59ad872aecb1b0147ba65ba42d).
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: getProcessBundleDescriptor request with id 96-6
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Closing components.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task [3]{Create.TimestampedValues, Window.Into()} (1/2)#0
0bd897307a3f5bd317e94eb853d5c34f.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [5]PAssert$105/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)
(6e474ed0962fb75a544b242c1d4f50c4) switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Loading JAR files for task [9]{Stateful ParDo, PAssert$106, PAssert$105}
-> (ToKeyedWorkItem, ToKeyedWorkItem) (2/2)#0
(0e77dd08419bcd58679f46ccc0f6cc80) [DEPLOYING].
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Received task PAssert$106/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$106/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)#0
(6e28f9befd37ab598a0fff81a55f1b68), deploy into slot with allocation id
89280a8dc29f606aebb3b6d5aa98e929.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2) (09c6014275b5ab79b1010bd01ae68f8c)
switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [5]PAssert$105/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)
(9f72e938a7e1c8bd27f548fed404daf4) switched from SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [5]PAssert$105/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)
(6e474ed0962fb75a544b242c1d4f50c4) switched from SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Activate slot 2b4c72ef6734eb8711c9a56c071d8aac.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task [9]{Stateful ParDo, PAssert$106, PAssert$105} ->
(ToKeyedWorkItem, ToKeyedWorkItem) (1/2)#0 63e9d9c766e871c9af14ab5fbcf8af09.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Stopping SessionDispatcherLeaderProcess.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Loading JAR files for task
PAssert$106/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$106/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)#0
(dbacb21ddbab3ab9b082bd2acd2c9211) [DEPLOYING].
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Downloading
3b73e095fa2b3680ecaa6a04b3daae80/p-df5cc43480e8a51f89e337810d3318361f18d56c-bbc3445724ced8b8ca89c3bdfc3c7732
from localhost/127.0.0.1:33019
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2) (e12733cd85d1258134b6e5c78f53d5d3)
switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@77e3d245
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@7867a148
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Closing the slot manager.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Stopping dispatcher akka://flink/user/rpc/dispatcher_382.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Deploying [5]PAssert$105/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (2/2) (attempt
#0) with attempt id 6e474ed0962fb75a544b242c1d4f50c4 to
7fdb4ac4-2e5c-4bd5-806e-fe0f37d8aff1 @ localhost (dataPort=-1) with allocation
id 2b4c72ef6734eb8711c9a56c071d8aac
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Suspending the slot manager.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Stopping all currently running jobs of dispatcher
akka://flink/user/rpc/dispatcher_382.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [9]{Stateful ParDo, PAssert$106, PAssert$105} -> (ToKeyedWorkItem,
ToKeyedWorkItem) (1/2) (63e9d9c766e871c9af14ab5fbcf8af09) switched from
DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Activate slot 89280a8dc29f606aebb3b6d5aa98e929.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]PAssert$105/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2)#0 (9cf804bd1dfa0eb0ffc917069fcc41c3)
switched from CREATED to DEPLOYING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Deploying [5]PAssert$105/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (1/2) (attempt
#0) with attempt id 9f72e938a7e1c8bd27f548fed404daf4 to
7fdb4ac4-2e5c-4bd5-806e-fe0f37d8aff1 @ localhost (dataPort=-1) with allocation
id 89280a8dc29f606aebb3b6d5aa98e929
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@695e2626
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]PAssert$106/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2)#0 (b768925c44903de5e62fbeec997d710f)
switched from DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Loading JAR files for task
[3]PAssert$105/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2)#0 (9cf804bd1dfa0eb0ffc917069fcc41c3)
[DEPLOYING].
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [3]{Create.TimestampedValues, Window.Into()} (1/2)
(0bd897307a3f5bd317e94eb853d5c34f) switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [5]PAssert$106/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)#0
(ec25331872eae87482a359cd34f5c3e3) switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]PAssert$106/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2) (b768925c44903de5e62fbeec997d710f)
switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Loading JAR files for task [9]{Stateful ParDo, PAssert$106, PAssert$105}
-> (ToKeyedWorkItem, ToKeyedWorkItem) (1/2)#0
(63e9d9c766e871c9af14ab5fbcf8af09) [DEPLOYING].
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: ArtifactStagingService started on localhost:35835
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: getProcessBundleDescriptor request with id 96-21
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: ToKeyedWorkItem (1/2) (a7a491716dc2d32e76c00a1d0ea9b76e) switched from
SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task
[3]PAssert$105/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2)#0 fa4e4c59ad872aecb1b0147ba65ba42d.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$105/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$105/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/2)#0
(d9f6279ba3b02124c456d3d36967bb44) switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [9]{Stateful ParDo, PAssert$106, PAssert$105} -> (ToKeyedWorkItem,
ToKeyedWorkItem) (1/2)#0 (63e9d9c766e871c9af14ab5fbcf8af09) switched from
RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Freeing task resources for [9]{Stateful ParDo, PAssert$106, PAssert$105}
-> (ToKeyedWorkItem, ToKeyedWorkItem) (1/2)#0
(63e9d9c766e871c9af14ab5fbcf8af09).
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task [5]PAssert$106/GroupGlobally/{Create.Values,
WindowIntoDummy, RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger}
(2/2)#0 ec25331872eae87482a359cd34f5c3e3.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Downloading
3b73e095fa2b3680ecaa6a04b3daae80/p-b588b454123560459f21475955d4ae22751d3606-e3499cf27f5bbf860d22ca033151136e
from localhost/127.0.0.1:33019
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$106/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$106/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)#0
(6e28f9befd37ab598a0fff81a55f1b68) switched from CREATED to DEPLOYING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: getProcessBundleDescriptor request with id 96-12
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Stopped dispatcher akka://flink/user/rpc/dispatcher_382.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$105/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$105/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/2)
(d9f6279ba3b02124c456d3d36967bb44) switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [9]{Stateful ParDo, PAssert$106, PAssert$105} -> (ToKeyedWorkItem,
ToKeyedWorkItem) (2/2) (0e77dd08419bcd58679f46ccc0f6cc80) switched from
DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Deploying ToKeyedWorkItem (1/2) (attempt #0) with attempt id
a7a491716dc2d32e76c00a1d0ea9b76e to 7fdb4ac4-2e5c-4bd5-806e-fe0f37d8aff1 @
localhost (dataPort=-1) with allocation id 89280a8dc29f606aebb3b6d5aa98e929
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Activate slot 89280a8dc29f606aebb3b6d5aa98e929.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [5]PAssert$106/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)#0
(ec25331872eae87482a359cd34f5c3e3) switched from CREATED to DEPLOYING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Fn Harness started
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [3]{Create.TimestampedValues, Window.Into()} (2/2)
(e20bacb462a875d89b174eef9da9aabf) switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Loading JAR files for task [5]PAssert$106/GroupGlobally/{Create.Values,
WindowIntoDummy, RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger}
(2/2)#0 (ec25331872eae87482a359cd34f5c3e3) [DEPLOYING].
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Loading JAR files for task
PAssert$106/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$106/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)#0
(6e28f9befd37ab598a0fff81a55f1b68) [DEPLOYING].
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [5]PAssert$106/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)
(df5b2e6a9d368b5500133973e95a9f5b) switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Activate slot 2b4c72ef6734eb8711c9a56c071d8aac.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Getting job metrics for
pardotest0statetests0testvaluestatefixedwindows-jenkins-1219043109-5b3756c7_fa2e69c7-75e2-42b1-8c5a-37c6eadab88f
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Received task PAssert$105/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$105/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)#0
(0c7b7c969e8a22307a6e243157052348), deploy into slot with allocation id
2b4c72ef6734eb8711c9a56c071d8aac.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task PAssert$106/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$106/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)#0
dbacb21ddbab3ab9b082bd2acd2c9211.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [5]PAssert$106/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)
(ec25331872eae87482a359cd34f5c3e3) switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$105/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$105/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)#0
(fd6761c8bb3c18aedbd6f90360545427) switched from DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: getProcessBundleDescriptor request with id 96-18
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: getProcessBundleDescriptor request with id 96-22
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [5]PAssert$106/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)#0
(ec25331872eae87482a359cd34f5c3e3) switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Downloading
3b73e095fa2b3680ecaa6a04b3daae80/p-ec368617417743bf878d29aafe81bdc37f895359-851ed012166e35dfc47b979788fb89dc
from localhost/127.0.0.1:33019
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Freeing task resources for [5]PAssert$106/GroupGlobally/{Create.Values,
WindowIntoDummy, RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger}
(2/2)#0 (ec25331872eae87482a359cd34f5c3e3).
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Shutting down BLOB cache
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Received task [5]PAssert$106/GroupGlobally/{Create.Values,
WindowIntoDummy, RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger}
(1/2)#0 (df5b2e6a9d368b5500133973e95a9f5b), deploy into slot with allocation id
89280a8dc29f606aebb3b6d5aa98e929.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task ToKeyedWorkItem (2/2)#0 43b17cb8ffbd37706e2c932623659a56.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Beam Fn Control client connected with id 96-1
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task PAssert$105/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$105/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)#0
0c7b7c969e8a22307a6e243157052348.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
WARNING: The operator name
[3]PAssert$106/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} exceeded the 80 characters length limit and
was truncated.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
WARNING: The operator name [6]PAssert$106/GroupGlobally/{GatherAllOutputs,
RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents,
NeverTrigger} exceeded the 80 characters length limit and was truncated.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [9]{Stateful ParDo, PAssert$106, PAssert$105} -> (ToKeyedWorkItem,
ToKeyedWorkItem) (2/2)#0 (0e77dd08419bcd58679f46ccc0f6cc80) switched from
INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$106/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$106/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/2)
(2e727a87bb84ce23908309b2690e5010) switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$106/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$106/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)
(6e28f9befd37ab598a0fff81a55f1b68) switched from DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]PAssert$106/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2) (be61759a0b7a68a797ff906ee914c4d7)
switched from SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2) (09c6014275b5ab79b1010bd01ae68f8c)
switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@2beaf203
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task PAssert$106/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$106/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)#0
6e28f9befd37ab598a0fff81a55f1b68.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Finished getting job metrics for
pardotest0statetests0testvaluestatefixedwindows-jenkins-1219043109-5b3756c7_fa2e69c7-75e2-42b1-8c5a-37c6eadab88f
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Beam Fn Logging client connected.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$106/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$106/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)
(dbacb21ddbab3ab9b082bd2acd2c9211) switched from DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [9]{Stateful ParDo, PAssert$106, PAssert$105} -> (ToKeyedWorkItem,
ToKeyedWorkItem) (1/2)#0 (63e9d9c766e871c9af14ab5fbcf8af09) switched from
DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$105/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$105/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/2)
(d9f6279ba3b02124c456d3d36967bb44) switched from SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [9]{Stateful ParDo, PAssert$106, PAssert$105} -> (ToKeyedWorkItem,
ToKeyedWorkItem) (1/2) (63e9d9c766e871c9af14ab5fbcf8af09) switched from RUNNING
to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]Create.TimestampedValues/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2)#0 (09c6014275b5ab79b1010bd01ae68f8c)
switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
WARNING: The operator name [5]PAssert$105/GroupGlobally/{Create.Values,
WindowIntoDummy, RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger}
exceeded the 80 characters length limit and was truncated.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Finished to build heap keyed state-backend.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@b64bbec
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: getProcessBundleDescriptor request with id 96-15
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: ToKeyedWorkItem (1/2)#0 (0f03c77b7e5f2481c3ada3627d68d26a) switched from
RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [9]{Stateful ParDo, PAssert$106, PAssert$105} -> (ToKeyedWorkItem,
ToKeyedWorkItem) (2/2) (0e77dd08419bcd58679f46ccc0f6cc80) switched from
INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Freeing task resources for ToKeyedWorkItem (1/2)#0
(0f03c77b7e5f2481c3ada3627d68d26a).
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: ToKeyedWorkItem (2/2)#0 (43b17cb8ffbd37706e2c932623659a56) switched from
DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Job 3b73e095fa2b3680ecaa6a04b3daae80 reached terminal state FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Finished to build heap keyed state-backend.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Shutting down Flink Mini Cluster
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [5]PAssert$105/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)#0
(9f72e938a7e1c8bd27f548fed404daf4) switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Initializing heap keyed state backend with stream factory.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Freeing task resources for [5]PAssert$105/GroupGlobally/{Create.Values,
WindowIntoDummy, RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger}
(1/2)#0 (9f72e938a7e1c8bd27f548fed404daf4).
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task PAssert$105/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$105/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)#0
fd6761c8bb3c18aedbd6f90360545427.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task [5]PAssert$105/GroupGlobally/{Create.Values,
WindowIntoDummy, RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger}
(1/2)#0 9f72e938a7e1c8bd27f548fed404daf4.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO:
[3]PAssert$105/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2) (fa4e4c59ad872aecb1b0147ba65ba42d)
switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Shutting down rest endpoint.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Initializing heap keyed state backend with stream factory.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$105/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$105/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)
(fd6761c8bb3c18aedbd6f90360545427) switched from DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Stopping TaskExecutor akka://flink/user/rpc/taskmanager_380.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Stopped BLOB server at 0.0.0.0:33019
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$106/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$106/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/2)
(dbacb21ddbab3ab9b082bd2acd2c9211) switched from INITIALIZING to RUNNING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Close ResourceManager connection b400ec55a28c8b4aa36ac94eabc05e2e.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: ToKeyedWorkItem (1/2)#0 (a7a491716dc2d32e76c00a1d0ea9b76e) switched from
RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: PAssert$105/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$105/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/2)#0
(eb2515d4af5596083c2328dc2d7e39f5) switched from RUNNING to FINISHED.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: [5]PAssert$106/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (1/2)#0
(df5b2e6a9d368b5500133973e95a9f5b) switched from CREATED to DEPLOYING.
Dec 19, 2021 4:31:15 AM
org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO: Stopping the JobMaster for job
pardotest0statetests0testvaluestatefixedwindows-jenkins-1
...[truncated 734142 chars]...
file' is not set.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.webmonitor.WebMonitorUtils$LogFileLocation find
WARNING: JobManager log files are unavailable in the web dashboard. Log file
location not found in environment variable 'log.file' or configuration key
'web.log.path'.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.rest.RestServerEndpoint start
INFO: Rest endpoint listening at localhost:45465
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
updateLeader
INFO: Proposing leadership to contender http://localhost:45465
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.webmonitor.WebMonitorEndpoint
grantLeadership
INFO: http://localhost:45465 was granted leadership with
leaderSessionID=d1ccdfd5-ce68-47f2-a99a-8814583eb7e6
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
confirmLeader
INFO: Received confirmation of leadership for leader http://localhost:45465 ,
session=d1ccdfd5-ce68-47f2-a99a-8814583eb7e6
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
startServer
INFO: Starting RPC endpoint for
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at
akka://flink/user/rpc/resourcemanager_389 .
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
updateLeader
INFO: Proposing leadership to contender LeaderContender: DefaultDispatcherRunner
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.resourcemanager.ResourceManager onStart
INFO: Starting the resource manager.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.dispatcher.runner.AbstractDispatcherLeaderProcess
startInternal
INFO: Start SessionDispatcherLeaderProcess.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
updateLeader
INFO: Proposing leadership to contender LeaderContender:
StandaloneResourceManager
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.minicluster.MiniCluster start
INFO: Flink Mini Cluster started successfully
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess
recoverJobs
INFO: Recover all persisted job graphs.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.resourcemanager.ResourceManager tryAcceptLeadership
INFO: ResourceManager akka://flink/user/rpc/resourcemanager_389 was granted
leadership with fencing token a8c0c30f74467b1737225b2fb0884cd9
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess
recoverJobs
INFO: Successfully recovered 0 persisted job graphs.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
startServer
INFO: Starting RPC endpoint for
org.apache.flink.runtime.dispatcher.StandaloneDispatcher at
akka://flink/user/rpc/dispatcher_390 .
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
confirmLeader
INFO: Received confirmation of leadership for leader
akka://flink/user/rpc/resourcemanager_389 ,
session=37225b2f-b088-4cd9-a8c0-c30f74467b17
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
confirmLeader
INFO: Received confirmation of leadership for leader
akka://flink/user/rpc/dispatcher_390 ,
session=7125045e-cc04-4dac-a4f0-cb658390360a
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
connectToResourceManager
INFO: Connecting to ResourceManager
akka://flink/user/rpc/resourcemanager_389(a8c0c30f74467b1737225b2fb0884cd9).
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.registration.RetryingRegistration
lambda$startRegistration$0
INFO: Resolved ResourceManager address, beginning registration
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.dispatcher.Dispatcher submitJob
INFO: Received JobGraph submission d51a5fe9deb3a336b4e9c0eb2965fc16
(combinetest0combinewithcontexttests0testsimplecombinewithcontextempty-jenkins-1219043121-623a3f36).
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.resourcemanager.ResourceManager
registerTaskExecutorInternal
INFO: Registering TaskManager with ResourceID
75b7cce6-4a61-4739-b5ba-b2a6b0d91274 (akka://flink/user/rpc/taskmanager_388) at
ResourceManager
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.dispatcher.Dispatcher
internalSubmitJob
INFO: Submitting job d51a5fe9deb3a336b4e9c0eb2965fc16
(combinetest0combinewithcontexttests0testsimplecombinewithcontextempty-jenkins-1219043121-623a3f36).
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection
onRegistrationSuccess
INFO: Successful registration at resource manager
akka://flink/user/rpc/resourcemanager_389 under registration id
203ead1dba2673d1dce79d1edc1c7bb3.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
updateLeader
INFO: Proposing leadership to contender LeaderContender:
JobMasterServiceLeadershipRunner
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.rpc.akka.AkkaRpcService
startServer
INFO: Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at
akka://flink/user/rpc/jobmanager_391 .
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.jobmaster.JobMaster <init>
INFO: Initializing job
combinetest0combinewithcontexttests0testsimplecombinewithcontextempty-jenkins-1219043121-623a3f36
(d51a5fe9deb3a336b4e9c0eb2965fc16).
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.scheduler.DefaultSchedulerFactory createInstance
INFO: Using restart back off time strategy NoRestartBackoffTimeStrategy for
combinetest0combinewithcontexttests0testsimplecombinewithcontextempty-jenkins-1219043121-623a3f36
(d51a5fe9deb3a336b4e9c0eb2965fc16).
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder buildGraph
INFO: Running initialization on master for job
combinetest0combinewithcontexttests0testsimplecombinewithcontextempty-jenkins-1219043121-623a3f36
(d51a5fe9deb3a336b4e9c0eb2965fc16).
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder buildGraph
INFO: Successfully ran initialization on master in 0 ms.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.scheduler.adapter.DefaultExecutionTopology
computePipelinedRegions
INFO: Built 1 pipelined regions in 0 ms
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.StateBackendLoader
loadFromApplicationOrConfigOrDefaultInternal
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@369e68b8
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.CheckpointStorageLoader
createJobManagerCheckpointStorage
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.checkpoint.CheckpointCoordinator
restoreLatestCheckpointedStateInternal
INFO: No checkpoint found during restore.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.scheduler.DefaultScheduler
<init>
INFO: Using failover strategy
org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy@ab35cbd
for
combinetest0combinewithcontexttests0testsimplecombinewithcontextempty-jenkins-1219043121-623a3f36
(d51a5fe9deb3a336b4e9c0eb2965fc16).
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
confirmLeader
INFO: Received confirmation of leadership for leader
akka://flink/user/rpc/jobmanager_391 ,
session=5ec73383-d123-4f6a-9208-332a1e359057
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.jobmaster.JobMaster
startJobExecution
INFO: Starting execution of job
combinetest0combinewithcontexttests0testsimplecombinewithcontextempty-jenkins-1219043121-623a3f36
(d51a5fe9deb3a336b4e9c0eb2965fc16) under job master id
9208332a1e3590575ec73383d1234f6a.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.scheduler.DefaultScheduler
startSchedulingInternal
INFO: Starting scheduling with scheduling strategy
[org.apache.flink.runtime.scheduler.strategy.PipelinedRegionSchedulingStrategy]
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph transitionState
INFO: Job
combinetest0combinewithcontexttests0testsimplecombinewithcontextempty-jenkins-1219043121-623a3f36
(d51a5fe9deb3a336b4e9c0eb2965fc16) switched from state CREATED to RUNNING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Impulse (1/1) (386fc561b1b9e04212ae27f312466df5) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Impulse (1/1) (cb7930cf4360f4a7acd71699cc691ad0) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Impulse (1/1) (6f149336b1f9efebfa142e2222b26743) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Impulse (1/1) (1697504865e75134f039b47ce7eb6b00) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Impulse (1/1) (18931ff4dea83080593d007a02c88023) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2) (deaa2a30b1ca292073c98524edcaf4cb)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2) (2aa29af976eaf7665d90af6d4793c1eb)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
[1]Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/ProcessSizedElementsAndRestrictions0
-> ([3]{Values, Combine.globally(TestCombineFnWithContext), Sum} ->
(ToKeyedWorkItem, ToKeyedWorkItem), ToKeyedWorkItem) (1/2)
(3d50f297d449bd9d1a077a0712aa5b62) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
[1]Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/ProcessSizedElementsAndRestrictions0
-> ([3]{Values, Combine.globally(TestCombineFnWithContext), Sum} ->
(ToKeyedWorkItem, ToKeyedWorkItem), ToKeyedWorkItem) (2/2)
(c7a0962582f32439c60edb91c857ed48) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Sum/Combine.perKey(SumInts)/GroupByKey -> [10]{Sum, PAssert$110,
View.AsSingleton} -> Map -> ToKeyedWorkItem (1/2)
(4c766450aa92c94f313272fb8b689a8a) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Sum/Combine.perKey(SumInts)/GroupByKey -> [10]{Sum, PAssert$110,
View.AsSingleton} -> Map -> ToKeyedWorkItem (2/2)
(63a1525ec6a7b34669fb1622caa990b8) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
Sum-ProduceDefault-ParMultiDo-Anonymous--org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1261#fb104b049a64e8f4
-> Map (1/2) (4ec95572b880bacf728926bec914051d) switched from CREATED to
SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
Sum-ProduceDefault-ParMultiDo-Anonymous--org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1261#fb104b049a64e8f4
-> Map (2/2) (398d1c0e464120121784d17e68026f10) switched from CREATED to
SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey
(1/2) (c2035bd80e7cbf29f3b09b7067ce9389) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
Combine.globally(TestCombineFnWithContext)/Combine.perKey(TestCombineFnWithContext)/GroupByKey
(2/2) (7edcb79f9cfe97d1d84ce1a5220c35f6) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Combine.perKey(TestCombineFnWithContext)/GroupByKey (1/2)
(e0af81a177439c5ed4412f129f7d824f) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Combine.perKey(TestCombineFnWithContext)/GroupByKey (2/2)
(44c6de06815efbefc3ea8cbd481b8467) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [3]Sum/CreateVoid/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2) (5d6309b1559c5be3efbc3012465e4085)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [3]Sum/CreateVoid/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2) (3df0c9371587b48baad22b91e5954133)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
[1]Sum/CreateVoid/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/ProcessSizedElementsAndRestrictions0
(1/2) (ad9a442cd149c520e26c05b69edaae55) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
[1]Sum/CreateVoid/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/ProcessSizedElementsAndRestrictions0
(2/2) (aff3d0a90dc352f70e3f5a126e38417c) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [8]{Sum, PAssert$110, View.AsSingleton} (1/2)
(0eab7301d1c0a7f33df0e8b33b36ab7c) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [8]{Sum, PAssert$110, View.AsSingleton} (2/2)
(b04a15da4a42043a0c04b7ce42853f3b) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: ToKeyedWorkItem (1/2) (8b81be5ecc6cf72ae07c2b9a3af0f5cb) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: ToKeyedWorkItem (2/2) (6c7440cd3c85d38e1f63387c73bf1fbb) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
View.AsSingleton/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey
->
[2]View.AsSingleton/Combine.GloballyAsSingletonView/CombineValues/{Combine.perKey(Singleton),
Values} -> (Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (1/2)
(ae1239359b8fb30cfffc136506f157aa) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
View.AsSingleton/Combine.GloballyAsSingletonView/CombineValues/Combine.perKey(Singleton)/GroupByKey
->
[2]View.AsSingleton/Combine.GloballyAsSingletonView/CombineValues/{Combine.perKey(Singleton),
Values} -> (Map -> ToKeyedWorkItem, Map -> ToKeyedWorkItem) (2/2)
(a56a4c855424bce2da4b0476e43d8a1c) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
Combine-perKey-TestCombineFnWithContext--Combine-GroupedValues-ParDo-Anonymous--ParMultiDo-Anonymous-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1261#ea3d24bb2541d5e9
-> Map (1/2) (33bcf5c069ffa3d1a0ba3fee7ade2690) switched from CREATED to
SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
Combine-perKey-TestCombineFnWithContext--Combine-GroupedValues-ParDo-Anonymous--ParMultiDo-Anonymous-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1261#ea3d24bb2541d5e9
-> Map (2/2) (b6a9638bb9ca8f5804a7e93cfe0bcdd1) switched from CREATED to
SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [6]{Combine.perKey(TestCombineFnWithContext), PAssert$111} (1/2)
(100c29f63f56e425dd2ea4771b33118c) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [6]{Combine.perKey(TestCombineFnWithContext), PAssert$111} (2/2)
(7970cc6fd2a49fc8e19b59efbf0e1922) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
Combine-globally-TestCombineFnWithContext--Combine-perKey-TestCombineFnWithContext--Combine-GroupedV-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1261#ea3d24bb2541d5e9
-> Map (1/2) (45836417df573ba99b09102390f33fbf) switched from CREATED to
SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
Combine-globally-TestCombineFnWithContext--Combine-perKey-TestCombineFnWithContext--Combine-GroupedV-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1261#ea3d24bb2541d5e9
-> Map (2/2) (14ffe64061a14b3cb4c5ffd5c726ffab) switched from CREATED to
SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [7]{Combine.globally(TestCombineFnWithContext), PAssert$112} (1/2)
(a070cf2a7e8f497207b3467c2510bee0) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [7]{Combine.globally(TestCombineFnWithContext), PAssert$112} (2/2)
(54e735129f2d49720402dada6a1750db) switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
[3]PAssert$112/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2) (2bf28772458a7e887ccda7ec5ee341b6)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
[3]PAssert$112/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2) (6ebe7e814b58cf5d7c35f20784123e76)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [4]PAssert$112/GroupGlobally/{Create.Values, Flatten.PCollections,
Window.Into(), WithKeys} (1/2) (4da1fefbbb15e8683b686a443a482ea2) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [4]PAssert$112/GroupGlobally/{Create.Values, Flatten.PCollections,
Window.Into(), WithKeys} (2/2) (38d1f627918e81a4d2109413f53fd314) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: ToKeyedWorkItem (1/2) (d0977215f563cb83c2fb6136a345fe12) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: ToKeyedWorkItem (2/2) (b3987a279046372271ed27d435a7b8a0) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: PAssert$112/GroupGlobally/GroupByKey -> [5]PAssert$112/{GroupGlobally,
GetPane, RunChecks, VerifyAssertions} (1/2) (ccb76bd3e1180dbd675e56df064ce90f)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: PAssert$112/GroupGlobally/GroupByKey -> [5]PAssert$112/{GroupGlobally,
GetPane, RunChecks, VerifyAssertions} (2/2) (7004dfa77a5d8b6454248cc1683e4ed9)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
[3]PAssert$111/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2) (437c5a8d048770ef2f43f437cd6ee7b0)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
[3]PAssert$111/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2) (cd044f4e9300412ed57f0b7ab10e11d4)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [4]PAssert$111/GroupGlobally/{Create.Values, Flatten.PCollections,
Window.Into(), WithKeys} (1/2) (7fae345be4b39d65f2f939a09428ffa4) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [4]PAssert$111/GroupGlobally/{Create.Values, Flatten.PCollections,
Window.Into(), WithKeys} (2/2) (3ebbb1cab84a74f605a2d64257b75078) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: ToKeyedWorkItem (1/2) (c1ba2b9f98cdfc60296b875db497e2ad) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: ToKeyedWorkItem (2/2) (d2562c4ccc0e9f6877a2197d6cc03300) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: PAssert$111/GroupGlobally/GroupByKey -> [5]PAssert$111/{GroupGlobally,
GetPane, RunChecks, VerifyAssertions} (1/2) (869c737c284b6294cfb736179231dd1f)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: PAssert$111/GroupGlobally/GroupByKey -> [5]PAssert$111/{GroupGlobally,
GetPane, RunChecks, VerifyAssertions} (2/2) (e976ad0b0d6967e0430a9c373d6f117d)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
[3]PAssert$110/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2) (c38e145806d28aac5dc0bf5aaf601465)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
[3]PAssert$110/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2) (b89e87bd610d46f38e18f09cdf291a52)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [4]PAssert$110/GroupGlobally/{Create.Values, Flatten.PCollections,
Window.Into(), WithKeys} (1/2) (c4e8d05e608f5fc2c89a76162c91157d) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [4]PAssert$110/GroupGlobally/{Create.Values, Flatten.PCollections,
Window.Into(), WithKeys} (2/2) (6c1b2220996ff8e6abf13480808f48b6) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: ToKeyedWorkItem (1/2) (faf317fcf0b517e729b8cf1ec89eb377) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: ToKeyedWorkItem (2/2) (f74cb0780b43c03593ff61d9fbd3ab35) switched from
CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: PAssert$110/GroupGlobally/GroupByKey -> [5]PAssert$110/{GroupGlobally,
GetPane, RunChecks, VerifyAssertions} (1/2) (e3860e69cb391ea1c03739acdba135f9)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: PAssert$110/GroupGlobally/GroupByKey -> [5]PAssert$110/{GroupGlobally,
GetPane, RunChecks, VerifyAssertions} (2/2) (7a5802061de6780e39e12f425b00fa2f)
switched from CREATED to SCHEDULED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.jobmaster.JobMaster
connectToResourceManager
INFO: Connecting to ResourceManager
akka://flink/user/rpc/resourcemanager_389(a8c0c30f74467b1737225b2fb0884cd9)
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.registration.RetryingRegistration
lambda$startRegistration$0
INFO: Resolved ResourceManager address, beginning registration
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.resourcemanager.ResourceManager registerJobManager
INFO: Registering job manager
9208332a1e3590575ec73383d1234f6a@akka://flink/user/rpc/jobmanager_391 for job
d51a5fe9deb3a336b4e9c0eb2965fc16.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.resourcemanager.ResourceManager
registerJobMasterInternal
INFO: Registered job manager
9208332a1e3590575ec73383d1234f6a@akka://flink/user/rpc/jobmanager_391 for job
d51a5fe9deb3a336b4e9c0eb2965fc16.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.jobmaster.JobMaster
establishResourceManagerConnection
INFO: JobManager successfully registered at ResourceManager, leader id:
a8c0c30f74467b1737225b2fb0884cd9.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements
INFO: Received resource requirements from job d51a5fe9deb3a336b4e9c0eb2965fc16:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=2}]
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
requestSlot
INFO: Receive slot request fe22c83f8a53f47be0d059c22603b779 for job
d51a5fe9deb3a336b4e9c0eb2965fc16 from resource manager with leader id
a8c0c30f74467b1737225b2fb0884cd9.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
allocateSlot
INFO: Allocated slot for fe22c83f8a53f47be0d059c22603b779.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService addJob
INFO: Add job d51a5fe9deb3a336b4e9c0eb2965fc16 for job leader monitoring.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
requestSlot
INFO: Receive slot request 4a9d2573a69ba931e37f7317b7138dd8 for job
d51a5fe9deb3a336b4e9c0eb2965fc16 from resource manager with leader id
a8c0c30f74467b1737225b2fb0884cd9.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService$JobManagerLeaderListener
openRpcConnectionTo
INFO: Try to register at job manager akka://flink/user/rpc/jobmanager_391 with
leader id 5ec73383-d123-4f6a-9208-332a1e359057.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
allocateSlot
INFO: Allocated slot for 4a9d2573a69ba931e37f7317b7138dd8.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.registration.RetryingRegistration
lambda$startRegistration$0
INFO: Resolved JobManager address, beginning registration
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService$JobManagerLeaderListener$JobManagerRegisteredRpcConnection
lambda$onRegistrationSuccess$0
INFO: Successful registration at job manager
akka://flink/user/rpc/jobmanager_391 for job d51a5fe9deb3a336b4e9c0eb2965fc16.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
establishJobManagerConnection
INFO: Establish JobManager connection for job d51a5fe9deb3a336b4e9c0eb2965fc16.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
internalOfferSlotsToJobManager
INFO: Offer reserved slots to the leader of job
d51a5fe9deb3a336b4e9c0eb2965fc16.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Impulse (1/1) (386fc561b1b9e04212ae27f312466df5) switched from
SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying Source: Impulse (1/1) (attempt #0) with attempt id
386fc561b1b9e04212ae27f312466df5 to 75b7cce6-4a61-4739-b5ba-b2a6b0d91274 @
localhost (dataPort=-1) with allocation id fe22c83f8a53f47be0d059c22603b779
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot fe22c83f8a53f47be0d059c22603b779.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Impulse (1/1) (cb7930cf4360f4a7acd71699cc691ad0) switched from
SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying Source: Impulse (1/1) (attempt #0) with attempt id
cb7930cf4360f4a7acd71699cc691ad0 to 75b7cce6-4a61-4739-b5ba-b2a6b0d91274 @
localhost (dataPort=-1) with allocation id fe22c83f8a53f47be0d059c22603b779
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Impulse (1/1) (6f149336b1f9efebfa142e2222b26743) switched from
SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying Source: Impulse (1/1) (attempt #0) with attempt id
6f149336b1f9efebfa142e2222b26743 to 75b7cce6-4a61-4739-b5ba-b2a6b0d91274 @
localhost (dataPort=-1) with allocation id fe22c83f8a53f47be0d059c22603b779
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task Source: Impulse (1/1)#0 (386fc561b1b9e04212ae27f312466df5),
deploy into slot with allocation id fe22c83f8a53f47be0d059c22603b779.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (386fc561b1b9e04212ae27f312466df5) switched from
CREATED to DEPLOYING.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot fe22c83f8a53f47be0d059c22603b779.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Impulse (1/1) (1697504865e75134f039b47ce7eb6b00) switched from
SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Loading JAR files for task Source: Impulse (1/1)#0
(386fc561b1b9e04212ae27f312466df5) [DEPLOYING].
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying Source: Impulse (1/1) (attempt #0) with attempt id
1697504865e75134f039b47ce7eb6b00 to 75b7cce6-4a61-4739-b5ba-b2a6b0d91274 @
localhost (dataPort=-1) with allocation id fe22c83f8a53f47be0d059c22603b779
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task Source: Impulse (1/1)#0 (cb7930cf4360f4a7acd71699cc691ad0),
deploy into slot with allocation id fe22c83f8a53f47be0d059c22603b779.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (cb7930cf4360f4a7acd71699cc691ad0) switched from
CREATED to DEPLOYING.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot fe22c83f8a53f47be0d059c22603b779.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Loading JAR files for task Source: Impulse (1/1)#0
(cb7930cf4360f4a7acd71699cc691ad0) [DEPLOYING].
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Source: Impulse (1/1) (18931ff4dea83080593d007a02c88023) switched from
SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.StateBackendLoader
loadFromApplicationOrConfigOrDefaultInternal
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@75a0c21b
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying Source: Impulse (1/1) (attempt #0) with attempt id
18931ff4dea83080593d007a02c88023 to 75b7cce6-4a61-4739-b5ba-b2a6b0d91274 @
localhost (dataPort=-1) with allocation id fe22c83f8a53f47be0d059c22603b779
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.CheckpointStorageLoader
createJobManagerCheckpointStorage
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task Source: Impulse (1/1)#0 (6f149336b1f9efebfa142e2222b26743),
deploy into slot with allocation id fe22c83f8a53f47be0d059c22603b779.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.StateBackendLoader
loadFromApplicationOrConfigOrDefaultInternal
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@14ae971b
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.CheckpointStorageLoader
createJobManagerCheckpointStorage
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (cb7930cf4360f4a7acd71699cc691ad0) switched from
DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (6f149336b1f9efebfa142e2222b26743) switched from
CREATED to DEPLOYING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Loading JAR files for task Source: Impulse (1/1)#0
(6f149336b1f9efebfa142e2222b26743) [DEPLOYING].
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot fe22c83f8a53f47be0d059c22603b779.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2) (deaa2a30b1ca292073c98524edcaf4cb)
switched from SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (386fc561b1b9e04212ae27f312466df5) switched from
DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying [3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2) (attempt #0) with attempt id
deaa2a30b1ca292073c98524edcaf4cb to 75b7cce6-4a61-4739-b5ba-b2a6b0d91274 @
localhost (dataPort=-1) with allocation id fe22c83f8a53f47be0d059c22603b779
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.StateBackendLoader
loadFromApplicationOrConfigOrDefaultInternal
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@2669f396
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task Source: Impulse (1/1)#0 (1697504865e75134f039b47ce7eb6b00),
deploy into slot with allocation id fe22c83f8a53f47be0d059c22603b779.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.CheckpointStorageLoader
createJobManagerCheckpointStorage
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (6f149336b1f9efebfa142e2222b26743) switched from
DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot fe22c83f8a53f47be0d059c22603b779.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (1697504865e75134f039b47ce7eb6b00) switched from
CREATED to DEPLOYING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Loading JAR files for task Source: Impulse (1/1)#0
(1697504865e75134f039b47ce7eb6b00) [DEPLOYING].
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: [3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2) (2aa29af976eaf7665d90af6d4793c1eb)
switched from SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying [3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2) (attempt #0) with attempt id
2aa29af976eaf7665d90af6d4793c1eb to 75b7cce6-4a61-4739-b5ba-b2a6b0d91274 @
localhost (dataPort=-1) with allocation id 4a9d2573a69ba931e37f7317b7138dd8
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task Source: Impulse (1/1)#0 (18931ff4dea83080593d007a02c88023),
deploy into slot with allocation id fe22c83f8a53f47be0d059c22603b779.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
[1]Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/ProcessSizedElementsAndRestrictions0
-> ([3]{Values, Combine.globally(TestCombineFnWithContext), Sum} ->
(ToKeyedWorkItem, ToKeyedWorkItem), ToKeyedWorkItem) (1/2)
(3d50f297d449bd9d1a077a0712aa5b62) switched from SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying
[1]Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/ProcessSizedElementsAndRestrictions0
-> ([3]{Values, Combine.globally(TestCombineFnWithContext), Sum} ->
(ToKeyedWorkItem, ToKeyedWorkItem), ToKeyedWorkItem) (1/2) (attempt #0) with
attempt id 3d50f297d449bd9d1a077a0712aa5b62 to
75b7cce6-4a61-4739-b5ba-b2a6b0d91274 @ localhost (dataPort=-1) with allocation
id fe22c83f8a53f47be0d059c22603b779
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot fe22c83f8a53f47be0d059c22603b779.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (18931ff4dea83080593d007a02c88023) switched from
CREATED to DEPLOYING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Loading JAR files for task Source: Impulse (1/1)#0
(18931ff4dea83080593d007a02c88023) [DEPLOYING].
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.StateBackendLoader
loadFromApplicationOrConfigOrDefaultInternal
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@236f0791
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.CheckpointStorageLoader
createJobManagerCheckpointStorage
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (1697504865e75134f039b47ce7eb6b00) switched from
DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.StateBackendLoader
loadFromApplicationOrConfigOrDefaultInternal
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@2f4d3456
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task
[3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2)#0 (deaa2a30b1ca292073c98524edcaf4cb),
deploy into slot with allocation id fe22c83f8a53f47be0d059c22603b779.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.CheckpointStorageLoader
createJobManagerCheckpointStorage
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (18931ff4dea83080593d007a02c88023) switched from
DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: [3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2)#0 (deaa2a30b1ca292073c98524edcaf4cb)
switched from CREATED to DEPLOYING.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot 4a9d2573a69ba931e37f7317b7138dd8.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Loading JAR files for task
[3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2)#0 (deaa2a30b1ca292073c98524edcaf4cb)
[DEPLOYING].
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
submitTask
INFO: Received task
[3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2)#0 (2aa29af976eaf7665d90af6d4793c1eb),
deploy into slot with allocation id 4a9d2573a69ba931e37f7317b7138dd8.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: [3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2)#0 (2aa29af976eaf7665d90af6d4793c1eb)
switched from CREATED to DEPLOYING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Loading JAR files for task
[3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2)#0 (2aa29af976eaf7665d90af6d4793c1eb)
[DEPLOYING].
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (cb7930cf4360f4a7acd71699cc691ad0) switched from
INITIALIZING to RUNNING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (1697504865e75134f039b47ce7eb6b00) switched from
INITIALIZING to RUNNING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (386fc561b1b9e04212ae27f312466df5) switched from
INITIALIZING to RUNNING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (6f149336b1f9efebfa142e2222b26743) switched from
INITIALIZING to RUNNING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (386fc561b1b9e04212ae27f312466df5) switched from
RUNNING to FINISHED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Impulse (1/1)#0
(386fc561b1b9e04212ae27f312466df5).
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (1697504865e75134f039b47ce7eb6b00) switched from
RUNNING to FINISHED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (18931ff4dea83080593d007a02c88023) switched from
INITIALIZING to RUNNING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Impulse (1/1)#0
(1697504865e75134f039b47ce7eb6b00).
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (6f149336b1f9efebfa142e2222b26743) switched from
RUNNING to FINISHED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Impulse (1/1)#0
(6f149336b1f9efebfa142e2222b26743).
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (cb7930cf4360f4a7acd71699cc691ad0) switched from
RUNNING to FINISHED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Impulse (1/1)#0 386fc561b1b9e04212ae27f312466df5.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Impulse (1/1)#0
(cb7930cf4360f4a7acd71699cc691ad0).
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Impulse (1/1)#0 1697504865e75134f039b47ce7eb6b00.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Impulse (1/1)#0 6f149336b1f9efebfa142e2222b26743.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Impulse (1/1)#0 cb7930cf4360f4a7acd71699cc691ad0.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.StateBackendLoader
loadFromApplicationOrConfigOrDefaultInternal
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@1c9e3b7a
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.CheckpointStorageLoader
createJobManagerCheckpointStorage
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: [3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/2)#0 (deaa2a30b1ca292073c98524edcaf4cb)
switched from DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.StateBackendLoader
loadFromApplicationOrConfigOrDefaultInternal
INFO: No state backend has been configured, using default (HashMap)
org.apache.flink.runtime.state.hashmap.HashMapStateBackend@38c11615
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.state.CheckpointStorageLoader
createJobManagerCheckpointStorage
INFO: Checkpoint storage is set to 'jobmanager'
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: Source: Impulse (1/1)#0 (18931ff4dea83080593d007a02c88023) switched from
RUNNING to FINISHED.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task
transitionState
INFO: [3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/2)#0 (2aa29af976eaf7665d90af6d4793c1eb)
switched from DEPLOYING to INITIALIZING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO: Freeing task resources for Source: Impulse (1/1)#0
(18931ff4dea83080593d007a02c88023).
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState
INFO: Un-registering task and sending final execution state FINISHED to
JobManager for task Source: Impulse (1/1)#0 18931ff4dea83080593d007a02c88023.
Dec 19, 2021 4:31:22 AM
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO: Activate slot fe22c83f8a53f47be0d059c22603b779.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO:
[1]Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/ProcessSizedElementsAndRestrictions0
-> ([3]{Values, Combine.globally(TestCombineFnWithContext), Sum} ->
(ToKeyedWorkItem, ToKeyedWorkItem), ToKeyedWorkItem) (2/2)
(c7a0962582f32439c60edb91c857ed48) switched from SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying
[1]Create.Values/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/ProcessSizedElementsAndRestrictions0
-> ([3]{Values, Combine.globally(TestCombineFnWithContext), Sum} ->
(ToKeyedWorkItem, ToKeyedWorkItem), ToKeyedWorkItem) (2/2) (attempt #0) with
attempt id c7a0962582f32439c60edb91c857ed48 to
75b7cce6-4a61-4739-b5ba-b2a6b0d91274 @ localhost (dataPort=-1) with allocation
id 4a9d2573a69ba931e37f7317b7138dd8
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.blob.BlobClient
downloadFromBlobServer
INFO: Downloading
d51a5fe9deb3a336b4e9c0eb2965fc16/p-2dd541fe53d2e68e0819d603d81315c11ca72612-edae20db78bc113e328784627b348a86
from localhost/127.0.0.1:43629
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Sum/Combine.perKey(SumInts)/GroupByKey -> [10]{Sum, PAssert$110,
View.AsSingleton} -> Map -> ToKeyedWorkItem (1/2)
(4c766450aa92c94f313272fb8b689a8a) switched from SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying Sum/Combine.perKey(SumInts)/GroupByKey -> [10]{Sum,
PAssert$110, View.AsSingleton} -> Map -> ToKeyedWorkItem (1/2) (attempt #0)
with attempt id 4c766450aa92c94f313272fb8b689a8a to
75b7cce6-4a61-4739-b5ba-b2a6b0d91274 @ localhost (dataPort=-1) with allocation
id fe22c83f8a53f47be0d059c22603b779
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
WARNING: The operator name
[3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} exceeded the 80 characters length limit and
was truncated.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
WARNING: The operator name
[3]Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} exceeded the 80 characters length limit and
was truncated.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO: Sum/Combine.perKey(SumInts)/GroupByKey -> [10]{Sum, PAssert$110,
View.AsSingleton} -> Map -> ToKeyedWorkItem (2/2)
(63a1525ec6a7b34669fb1622caa990b8) switched from SCHEDULED to DEPLOYING.
Dec 19, 2021 4:31:22 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO: Deploying Sum/Combine.perKey(SumInts)/GroupByKey -> [10]{Sum,
PAssert$110, View.AsSingleton} -> Map -> ToKeyedWorkItem (2/2) (attempt #0)
with attempt id 63a1525ec6a7b34669fb1622caa990b8 to
75b7cce6-4a61-4739-b5ba-b2a6b0d91274 @ localhost (dataPort=-1) with allocation
id 4a9d2573a69ba931e37f7317b7138dd8
{noformat}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
