You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Valentyn Tymofieiev (Jira)" <ji...@apache.org> on 2021/12/21 01:46:00 UTC
[jira] [Updated] (BEAM-13500) NPE in Flink Portable ValidatesRunner streaming suite
[ https://issues.apache.org/jira/browse/BEAM-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Valentyn Tymofieiev updated BEAM-13500:
---------------------------------------
Summary: NPE in Flink Portable ValidatesRunner streaming suite (was: NPE in Flink ValidatesRunner streaming suite)
> NPE in Flink Portable 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
> Priority: P2
>
> 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)