[
https://issues.apache.org/jira/browse/BEAM-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475660#comment-17475660
]
Kenneth Knowles commented on BEAM-13500:
----------------------------------------
This particular problem is not occurring in recent runs, though there are other
flakes and weird failures of causes (like the TestPortableRunner not being
registered?!). Leaving open for further triage, but perhaps this is fixed or a
flake?
> 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, test-failures
> 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)
