[
https://issues.apache.org/jira/browse/BEAM-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kenneth Knowles updated BEAM-13500:
-----------------------------------
Priority: P1 (was: P2)
> 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: P1
>
> 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)
