Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

NPE in Flink Portable ValidatesRunner streaming suite #21463

Closed
damccorm opened this issue Jun 4, 2022 · 1 comment
Closed

NPE in Flink Portable ValidatesRunner streaming suite #21463

damccorm opened this issue Jun 4, 2022 · 1 comment
Labels
bug done & done Issue has been reviewed after it was closed for verification, followups, etc. failing test flake flink java P1 runners
Milestone
2.44.0 Release

Comments

@damccorm
Copy link
Contributor

damccorm commented Jun 4, 2022 •
edited by kennknowles

org.apache.beam.sdk.transforms.CombineTest$CombineWithContextTests.testSimpleCombineWithContextEmpty failed for me with an NPE. Suspecting a flake.


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

issue truncated because of its length - to see full context, see original Jira

Imported from Jira BEAM-13500. Original Jira may contain additional context.
Reported by: tvalentyn.
@damccorm damccorm added the java label Oct 5, 2022
@kennknowles
Copy link
Member

This was already not flaking at the time of migration to GitHub Issues and has not flaked in all the Jenkins history that we have.

@github-actions github-actions bot added this to the 2.44.0 Release milestone Oct 21, 2022
@apilloud apilloud added the done & done Issue has been reviewed after it was closed for verification, followups, etc. label Oct 25, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
bug done & done Issue has been reviewed after it was closed for verification, followups, etc. failing test flake flink java P1 runners
Projects
None yet
Milestone
2.44.0 Release
Development

No branches or pull requests
3 participants
@kennknowles @apilloud @damccorm