Tyson Hamilton created BEAM-11487:
-------------------------------------
Summary: Spark test failure:
org.apache.beam.sdk.transforms.WithTimestampsTest.withTimestampsShouldApplyTimestamps
Key: BEAM-11487
URL: https://issues.apache.org/jira/browse/BEAM-11487
Project: Beam
Issue Type: Sub-task
Components: runner-spark, test-failures
Reporter: Tyson Hamilton
h1.
From:
[https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Spark_Streaming/467/testReport/org.apache.beam.sdk.transforms/WithTimestampsTest/withTimestampsShouldApplyTimestamps/]
Another:
[https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Spark_Streaming/464/testReport/org.apache.beam.sdk.transforms/WithTimestampsTest/withTimestampsShouldApplyTimestamps/]
{code:java}
Regression
org.apache.beam.sdk.transforms.WithTimestampsTest.withTimestampsShouldApplyTimestamps
Failing for the past 1 build (Since #467 ) Took 36 sec. Error Message
java.lang.AssertionError: Expected 2 successful assertions, but found 0.
Expected: is <2L> but: was <0L>
Stacktrace
java.lang.AssertionError: Expected 2 successful assertions, but found 0.
Expected: is <2L> but: was <0L> at
org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:18) at
org.apache.beam.sdk.testing.TestPipeline.verifyPAssertsSucceeded(TestPipeline.java:516)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:354) at
org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:334) at
org.apache.beam.sdk.transforms.WithTimestampsTest.withTimestampsShouldApplyTimestamps(WithTimestampsTest.java:81)
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:322)
at
org.junit.rules.ExpectedException$ExpectedExceptionStatement.evaluate(ExpectedException.java:266)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:305) at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:365) 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:330) at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:78) at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:328) at
org.junit.runners.ParentRunner.access$100(ParentRunner.java:65) at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:292) at
org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:305) at
org.junit.runners.ParentRunner.run(ParentRunner.java:412) 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.GeneratedMethodAccessor3.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.GeneratedMethodAccessor2.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
20/12/17 06:07:27 INFO org.apache.beam.runners.jobsubmission.JobServerDriver:
ArtifactStagingService started on localhost:38619 20/12/17 06:07:27 INFO
org.apache.beam.runners.jobsubmission.JobServerDriver: Java ExpansionService
started on localhost:39481 20/12/17 06:07:27 INFO
org.apache.beam.runners.jobsubmission.JobServerDriver: JobService started on
localhost:39529 20/12/17 06:07:30 INFO
org.apache.beam.runners.portability.PortableRunner: Using job server endpoint:
localhost:39529 20/12/17 06:07:30 INFO
org.apache.beam.runners.portability.PortableRunner: PrepareJobResponse:
preparation_id:
"withtimestampstest0withtimestampsshouldapplytimestamps-jenkins-1217060730-a19b4d6d_69c2d439-86b2-47ed-b6e1-89fc1278c802"
artifact_staging_endpoint { url: "localhost:38619" } staging_session_token:
"withtimestampstest0withtimestampsshouldapplytimestamps-jenkins-1217060730-a19b4d6d_69c2d439-86b2-47ed-b6e1-89fc1278c802"
20/12/17 06:07:30 INFO
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Staging
artifacts for
withtimestampstest0withtimestampsshouldapplytimestamps-jenkins-1217060730-a19b4d6d_69c2d439-86b2-47ed-b6e1-89fc1278c802.
20/12/17 06:07:30 INFO
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Resolving
artifacts for
withtimestampstest0withtimestampsshouldapplytimestamps-jenkins-1217060730-a19b4d6d_69c2d439-86b2-47ed-b6e1-89fc1278c802.EMBEDDED.
20/12/17 06:07:30 INFO
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Getting
313 artifacts for
withtimestampstest0withtimestampsshouldapplytimestamps-jenkins-1217060730-a19b4d6d_69c2d439-86b2-47ed-b6e1-89fc1278c802.null.
20/12/17 06:07:31 INFO
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Artifacts
fully staged for
withtimestampstest0withtimestampsshouldapplytimestamps-jenkins-1217060730-a19b4d6d_69c2d439-86b2-47ed-b6e1-89fc1278c802.
20/12/17 06:07:31 INFO org.apache.beam.runners.spark.SparkJobInvoker: Invoking
job
withtimestampstest0withtimestampsshouldapplytimestamps-jenkins-1217060730-a19b4d6d_af4e1874-7648-49ef-90d5-654955b07da2
20/12/17 06:07:31 INFO org.apache.beam.runners.jobsubmission.JobInvocation:
Starting job invocation
withtimestampstest0withtimestampsshouldapplytimestamps-jenkins-1217060730-a19b4d6d_af4e1874-7648-49ef-90d5-654955b07da2
20/12/17 06:07:31 INFO org.apache.beam.runners.portability.PortableRunner:
RunJobResponse: job_id:
"withtimestampstest0withtimestampsshouldapplytimestamps-jenkins-1217060730-a19b4d6d_af4e1874-7648-49ef-90d5-654955b07da2"
20/12/17 06:07:31 INFO org.apache.beam.runners.spark.SparkPipelineRunner: Will
stage 313 files. (Enable logging at DEBUG level to see which files will be
staged.) 20/12/17 06:07:31 INFO
org.apache.beam.runners.spark.translation.SparkContextFactory: Creating a brand
new Spark Context. 20/12/17 06:07:31 INFO
org.apache.beam.runners.spark.SparkPipelineRunner: Running job
withtimestampstest0withtimestampsshouldapplytimestamps-jenkins-1217060730-a19b4d6d_af4e1874-7648-49ef-90d5-654955b07da2
on Spark master local[4] 20/12/17 06:07:31 INFO
org.apache.beam.runners.spark.SparkPipelineRunner: Running job
withtimestampstest0withtimestampsshouldapplytimestamps-jenkins-1217060730-a19b4d6d_af4e1874-7648-49ef-90d5-654955b07da2
on Spark master local[4] 20/12/17 06:07:31 INFO
org.apache.beam.runners.spark.SparkPipelineRunner: Job
withtimestampstest0withtimestampsshouldapplytimestamps-jenkins-1217060730-a19b4d6d_af4e1874-7648-49ef-90d5-654955b07da2:
Pipeline translated successfully. Computing outputs 20/12/17 06:07:31 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:31 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:31 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:32 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:32 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:32 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:32 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:32 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:32 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:33 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:33 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:33 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:33 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:33 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:33 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:34 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:34 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:34 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:34 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:34 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:34 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:35 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:35 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:35 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:35 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:35 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:35 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:36 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:36 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:36 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:36 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:36 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:36 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:37 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:37 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:37 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:37 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:37 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:37 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:38 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:38 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:38 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:38 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:38 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:38 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:39 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:39 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:39 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:39 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:39 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:39 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:40 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:40 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:40 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:40 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:40 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:40 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:41 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:41 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:41 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:41 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:41 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:41 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:42 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:42 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:42 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:42 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:42 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:42 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:43 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:43 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:43 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:43 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:43 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:43 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:44 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:44 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:44 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:44 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:44 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:44 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:45 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:45 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:45 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:45 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:45 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:45 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:46 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:46 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:46 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:46 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:46 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:46 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:47 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:47 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:47 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:47 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:47 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:47 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:48 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:48 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:48 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:48 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:48 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:48 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:49 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:49 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:49 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:49 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:49 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:49 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:50 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:50 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:50 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:50 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:50 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:50 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:51 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:51 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:51 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:51 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:51 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:51 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:52 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:52 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:52 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:52 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:52 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:52 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:53 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:53 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:53 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:53 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:53 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:53 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:54 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:54 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:54 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:54 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:54 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:54 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:55 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:55 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:55 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:55 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:55 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:55 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:56 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:56 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:56 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:56 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:56 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:56 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:57 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:57 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:57 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:57 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:57 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:57 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:58 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:58 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:58 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:58 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:58 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:58 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:59 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:59 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:59 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:59 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:59 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:07:59 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:00 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:00 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:00 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:00 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:00 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:00 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:01 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:01 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:01 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:01 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:01 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:01 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:01 WARN
org.apache.spark.streaming.util.BatchedWriteAheadLog: BatchedWriteAheadLog
Writer queue interrupted. Exception in thread "streaming-job-executor-0"
java.lang.Error: java.lang.InterruptedException at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1155)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748) Caused by:
java.lang.InterruptedException at
java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:998)
at
java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304)
at scala.concurrent.impl.Promise$DefaultPromise.tryAwait(Promise.scala:206) at
scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:222) at
scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:157) at
org.apache.spark.util.ThreadUtils$.awaitReady(ThreadUtils.scala:243) at
org.apache.spark.scheduler.DAGScheduler.runJob(DAGScheduler.scala:750) at
org.apache.spark.SparkContext.runJob(SparkContext.scala:2061) at
org.apache.spark.SparkContext.runJob(SparkContext.scala:2082) at
org.apache.spark.SparkContext.runJob(SparkContext.scala:2101) at
org.apache.spark.SparkContext.runJob(SparkContext.scala:2126) at
org.apache.spark.rdd.RDD$$anonfun$foreach$1.apply(RDD.scala:972) at
org.apache.spark.rdd.RDD$$anonfun$foreach$1.apply(RDD.scala:970) at
org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at
org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:112)
at org.apache.spark.rdd.RDD.withScope(RDD.scala:385) at
org.apache.spark.rdd.RDD.foreach(RDD.scala:970) at
org.apache.spark.api.java.JavaRDDLike$class.foreach(JavaRDDLike.scala:351) at
org.apache.spark.api.java.AbstractJavaRDDLike.foreach(JavaRDDLike.scala:45) at
org.apache.beam.runners.spark.translation.streaming.UnboundedDataset.lambda$action$e3b46054$1(UnboundedDataset.java:79)
at
org.apache.spark.streaming.api.java.JavaDStreamLike$$anonfun$foreachRDD$1.apply(JavaDStreamLike.scala:272)
at
org.apache.spark.streaming.api.java.JavaDStreamLike$$anonfun$foreachRDD$1.apply(JavaDStreamLike.scala:272)
at
org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628)
at
org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628)
at
org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ForEachDStream.scala:51)
at
org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51)
at
org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51)
at
org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:416)
at
org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:50)
at
org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50)
at
org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50)
at scala.util.Try$.apply(Try.scala:192) at
org.apache.spark.streaming.scheduler.Job.run(Job.scala:39) at
org.apache.spark.streaming.scheduler.JobScheduler$JobHandler$$anonfun$run$1.apply$mcV$sp(JobScheduler.scala:257)
at
org.apache.spark.streaming.scheduler.JobScheduler$JobHandler$$anonfun$run$1.apply(JobScheduler.scala:257)
at
org.apache.spark.streaming.scheduler.JobScheduler$JobHandler$$anonfun$run$1.apply(JobScheduler.scala:257)
at scala.util.DynamicVariable.withValue(DynamicVariable.scala:58) at
org.apache.spark.streaming.scheduler.JobScheduler$JobHandler.run(JobScheduler.scala:256)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
... 2 more 20/12/17 06:08:03 INFO
org.apache.beam.runners.spark.SparkPipelineRunner: Job
withtimestampstest0withtimestampsshouldapplytimestamps-jenkins-1217060730-a19b4d6d_af4e1874-7648-49ef-90d5-654955b07da2
finished. 20/12/17 06:08:03 WARN org.apache.spark.streaming.StreamingContext:
StreamingContext has already been stopped 20/12/17 06:08:04 ERROR
org.apache.spark.executor.Executor: Exception in task 0.0 in stage 0.0 (TID 0):
/tmp/spark-b66f9a5e-bbde-47a3-9b65-5aa30eb2fdb0/userFiles-a0136afd-c7f6-4d29-a2e4-958b0a094b83/fetchFileTemp5925458518729920238.tmp
20/12/17 06:08:04 ERROR org.apache.spark.executor.Executor: Exception in task
3.0 in stage 0.0 (TID 3): null 20/12/17 06:08:04 ERROR
org.apache.spark.executor.Executor: Exception in task 1.0 in stage 0.0 (TID 1):
null 20/12/17 06:08:04 ERROR org.apache.spark.executor.Executor: Exception in
task 2.0 in stage 0.0 (TID 2): null 20/12/17 06:08:04 INFO
org.apache.beam.runners.jobsubmission.InMemoryJobService: Getting job metrics
for
withtimestampstest0withtimestampsshouldapplytimestamps-jenkins-1217060730-a19b4d6d_af4e1874-7648-49ef-90d5-654955b07da2
20/12/17 06:08:04 INFO
org.apache.beam.runners.jobsubmission.InMemoryJobService: Finished getting job
metrics for
withtimestampstest0withtimestampsshouldapplytimestamps-jenkins-1217060730-a19b4d6d_af4e1874-7648-49ef-90d5-654955b07da2
20/12/17 06:08:04 INFO org.apache.beam.runners.jobsubmission.JobServerDriver:
JobServer stopped on localhost:39529 20/12/17 06:08:04 INFO
org.apache.beam.runners.jobsubmission.JobServerDriver: ArtifactStagingServer
stopped on localhost:38619 20/12/17 06:08:04 INFO
org.apache.beam.runners.jobsubmission.JobServerDriver: Expansion stopped on
localhost:39481 20/12/17 06:08:04 INFO
org.apache.beam.runners.jobsubmission.JobServerDriver: ArtifactStagingService
started on localhost:37027 20/12/17 06:08:04 INFO
org.apache.beam.runners.jobsubmission.JobServerDriver: Java ExpansionService
started on localhost:39899 20/12/17 06:08:04 INFO
org.apache.beam.runners.jobsubmission.JobServerDriver: JobService started on
localhost:33497 20/12/17 06:08:07 INFO
org.apache.beam.runners.portability.PortableRunner: Using job server endpoint:
localhost:33497 20/12/17 06:08:07 INFO
org.apache.beam.runners.portability.PortableRunner: PrepareJobResponse:
preparation_id:
"withtimestampstest0withtimestampsbackwardsintimeandwithallowedtimestampskewshouldsucceed-jenkins-1217060807-4417703d_c45da23a-016c-416e-871a-05f718138a33"
artifact_staging_endpoint { url: "localhost:37027" } staging_session_token:
"withtimestampstest0withtimestampsbackwardsintimeandwithallowedtimestampskewshouldsucceed-jenkins-1217060807-4417703d_c45da23a-016c-416e-871a-05f718138a33"
20/12/17 06:08:07 INFO
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Staging
artifacts for
withtimestampstest0withtimestampsbackwardsintimeandwithallowedtimestampskewshouldsucceed-jenkins-1217060807-4417703d_c45da23a-016c-416e-871a-05f718138a33.
20/12/17 06:08:07 INFO
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Resolving
artifacts for
withtimestampstest0withtimestampsbackwardsintimeandwithallowedtimestampskewshouldsucceed-jenkins-1217060807-4417703d_c45da23a-016c-416e-871a-05f718138a33.EMBEDDED.
20/12/17 06:08:07 INFO
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Getting
313 artifacts for
withtimestampstest0withtimestampsbackwardsintimeandwithallowedtimestampskewshouldsucceed-jenkins-1217060807-4417703d_c45da23a-016c-416e-871a-05f718138a33.null.
20/12/17 06:08:08 INFO
org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Artifacts
fully staged for
withtimestampstest0withtimestampsbackwardsintimeandwithallowedtimestampskewshouldsucceed-jenkins-1217060807-4417703d_c45da23a-016c-416e-871a-05f718138a33.
20/12/17 06:08:08 INFO org.apache.beam.runners.spark.SparkJobInvoker: Invoking
job
withtimestampstest0withtimestampsbackwardsintimeandwithallowedtimestampskewshouldsucceed-jenkins-1217060807-4417703d_901df391-6e1d-43bc-b9af-8af4c70b38bc
20/12/17 06:08:08 INFO org.apache.beam.runners.jobsubmission.JobInvocation:
Starting job invocation
withtimestampstest0withtimestampsbackwardsintimeandwithallowedtimestampskewshouldsucceed-jenkins-1217060807-4417703d_901df391-6e1d-43bc-b9af-8af4c70b38bc
20/12/17 06:08:08 INFO org.apache.beam.runners.portability.PortableRunner:
RunJobResponse: job_id:
"withtimestampstest0withtimestampsbackwardsintimeandwithallowedtimestampskewshouldsucceed-jenkins-1217060807-4417703d_901df391-6e1d-43bc-b9af-8af4c70b38bc"
20/12/17 06:08:08 INFO org.apache.beam.runners.spark.SparkPipelineRunner: Will
stage 313 files. (Enable logging at DEBUG level to see which files will be
staged.) 20/12/17 06:08:08 INFO
org.apache.beam.runners.spark.translation.SparkContextFactory: Creating a brand
new Spark Context. 20/12/17 06:08:08 INFO
org.apache.beam.runners.spark.SparkPipelineRunner: Running job
withtimestampstest0withtimestampsbackwardsintimeandwithallowedtimestampskewshouldsucceed-jenkins-1217060807-4417703d_901df391-6e1d-43bc-b9af-8af4c70b38bc
on Spark master local[4] 20/12/17 06:08:08 INFO
org.apache.beam.runners.spark.SparkPipelineRunner: Running job
withtimestampstest0withtimestampsbackwardsintimeandwithallowedtimestampskewshouldsucceed-jenkins-1217060807-4417703d_901df391-6e1d-43bc-b9af-8af4c70b38bc
on Spark master local[4] 20/12/17 06:08:08 INFO
org.apache.beam.runners.spark.SparkPipelineRunner: Job
withtimestampstest0withtimestampsbackwardsintimeandwithallowedtimestampskewshouldsucceed-jenkins-1217060807-4417703d_901df391-6e1d-43bc-b9af-8af4c70b38bc:
Pipeline translated successfully. Computing outputs 20/12/17 06:08:08 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:08 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:08 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:08 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:08 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:08 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:09 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:09 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:09 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:09 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:09 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:09 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:10 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:10 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:10 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:10 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:10 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:10 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:11 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:11 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:11 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:11 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:11 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:11 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:12 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:12 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:12 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:12 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:12 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:12 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:13 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:13 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:13 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:13 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:13 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:13 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:14 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:14 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:14 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:14 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:14 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:14 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:18 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:18 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:18 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:18 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:18 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:18 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:19 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:19 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:19 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:19 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:19 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:19 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:20 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:20 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:20 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:20 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:20 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:20 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:21 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:21 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:21 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:21 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:21 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:21 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:22 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:22 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:22 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:22 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:22 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:22 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:23 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:23 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:23 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:23 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:23 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:23 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:23 INFO
org.apache.beam.fn.harness.FnHarness: Fn Harness started 20/12/17 06:08:23 INFO
org.apache.beam.runners.fnexecution.logging.GrpcLoggingService: Beam Fn Logging
client connected. 20/12/17 06:08:24 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:24 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:24 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:24 WARN
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: No
worker_id header provided in control request 20/12/17 06:08:24 INFO
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: Beam
Fn Control client connected with id 20/12/17 06:08:24 INFO
org.apache.beam.fn.harness.FnHarness: Entering instruction processing loop
20/12/17 06:08:24 INFO
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService:
getProcessBundleDescriptor request with id 9-2 20/12/17 06:08:24 INFO
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService:
getProcessBundleDescriptor request with id 9-3 20/12/17 06:08:24 INFO
org.apache.beam.runners.fnexecution.data.GrpcDataService: Beam Fn Data client
connected. 20/12/17 06:08:24 INFO
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService:
getProcessBundleDescriptor request with id 9-5 20/12/17 06:08:24 INFO
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService:
getProcessBundleDescriptor request with id 9-4 20/12/17 06:08:24 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:24 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:24 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:24 INFO
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService:
getProcessBundleDescriptor request with id 9-6 20/12/17 06:08:24 INFO
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService:
getProcessBundleDescriptor request with id 9-7 20/12/17 06:08:25 INFO
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService:
getProcessBundleDescriptor request with id 9-8 20/12/17 06:08:25 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:25 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:25 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:25 INFO
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService:
getProcessBundleDescriptor request with id 9-9 20/12/17 06:08:25 INFO
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService:
getProcessBundleDescriptor request with id 9-10 20/12/17 06:08:25 INFO
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService:
getProcessBundleDescriptor request with id 9-11 20/12/17 06:08:25 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:25 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:25 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:08:25 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn'
...[truncated 351304 chars]... dencies { type_urn: "beam:artifact:type:file:v1"
type_payload:
"\n\266\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/235-EMBEDDED-htrace-core4-4.1.0-incubating-XUW3kEhXw-StNrO8xXvi0sXzCMabX2pYvYaqfUiiXvY.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nMhtrace-core4-4.1.0-incubating-XUW3kEhXw-StNrO8xXvi0sXzCMabX2pYvYaqfUiiXvY.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\254\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/236-EMBEDDED-woodstox-core-5.0.3-ocBLZPv-IK6fLGCjvxYz_tZoiuMZNba9SkV6G7sugtQ.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nCwoodstox-core-5.0.3-ocBLZPv-IK6fLGCjvxYz_tZoiuMZNba9SkV6G7sugtQ.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\250\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/237-EMBEDDED-stax2-api-4.2.1-Z4Vn5ItRpCxlxpnyZlOa09Z21LGlsK19iezoudV3JXk.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n?stax2-api-4.2.1-Z4Vn5ItRpCxlxpnyZlOa09Z21LGlsK19iezoudV3JXk.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\245\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/238-EMBEDDED-hamcrest-2.1-upOy46ViMiukMvChtTrdzFXLGIJTMZoCDtd_gk5pIFA.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n<hamcrest-2.1-upOy46ViMiukMvChtTrdzFXLGIJTMZoCDtd_gk5pIFA.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\257\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/239-EMBEDDED-reflectasm-1.07-shaded-CKcOrbSydO2u_BGUwfdXBiGlGwqaoDaqFdzbe5J-fHY.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nFreflectasm-1.07-shaded-CKcOrbSydO2u_BGUwfdXBiGlGwqaoDaqFdzbe5J-fHY.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\243\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/240-EMBEDDED-minlog-1.2-pnjLGqj10D2QHJksdXQYQdmKm8PVXa0C6E1lMVxOYPI.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n:minlog-1.2-pnjLGqj10D2QHJksdXQYQdmKm8PVXa0C6E1lMVxOYPI.jar" } dependencies
{ type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\257\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/241-EMBEDDED-j2objc-annotations-1.3-Ia8wySJnvWEiwOC00gzMtmQaN-r5VsZUDsRx1YTmSns.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nFj2objc-annotations-1.3-Ia8wySJnvWEiwOC00gzMtmQaN-r5VsZUDsRx1YTmSns.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\250\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/242-EMBEDDED-javaruntype-1.3-hGIPTL4YOPBHEuOnoizGWeK7lC6c27i1TX8uRrF9Q-g.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n?javaruntype-1.3-hGIPTL4YOPBHEuOnoizGWeK7lC6c27i1TX8uRrF9Q-g.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\244\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/243-EMBEDDED-ognl-3.1.12-dLY_oM2x1HGOaAfy7RAFrC8VpRORDWgDmvmlWRlhlek.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n;ognl-3.1.12-dLY_oM2x1HGOaAfy7RAFrC8VpRORDWgDmvmlWRlhlek.jar" } dependencies
{ type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\260\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/244-EMBEDDED-generics-resolver-2.0.1-LT7P9gZLIjSTlVVcCZQJSTcacMt8Dg_e23EVZrE_KTE.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nGgenerics-resolver-2.0.1-LT7P9gZLIjSTlVVcCZQJSTcacMt8Dg_e23EVZrE_KTE.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\265\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/245-EMBEDDED-auto-value-annotations-1.7.2-hzmNqWKhIQOhlXuyOcVW-OjWbKESv4q5msQEyAojhas.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nLauto-value-annotations-1.7.2-hzmNqWKhIQOhlXuyOcVW-OjWbKESv4q5msQEyAojhas.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\256\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/246-EMBEDDED-opencensus-api-0.24.0-9WGxzCZzhEKI5Zbd9btlloaKhHL9LLiZOVP8XANLI1I.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nEopencensus-api-0.24.0-9WGxzCZzhEKI5Zbd9btlloaKhHL9LLiZOVP8XANLI1I.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\254\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/247-EMBEDDED-grpc-context-1.32.2-0H-oAV0WIUvlA0wvEXe_uKBRhqwRIR-eLAJr7PQ6844.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nCgrpc-context-1.32.2-0H-oAV0WIUvlA0wvEXe_uKBRhqwRIR-eLAJr7PQ6844.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\260\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/248-EMBEDDED-google-extensions-0.5.1-iwhiythblUnzVf44PGxjgW0vGVKWNOAzrgbQEHqxELk.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nGgoogle-extensions-0.5.1-iwhiythblUnzVf44PGxjgW0vGVKWNOAzrgbQEHqxELk.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\265\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/249-EMBEDDED-flogger-system-backend-0.5.1-aF3jO1PrMTBJu-7n9LeoDdCejnVOlrBIo-2rLOuzZEI.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nLflogger-system-backend-0.5.1-aF3jO1PrMTBJu-7n9LeoDdCejnVOlrBIo-2rLOuzZEI.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\255\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/250-EMBEDDED-zookeeper-jute-3.5.7-AjJ2xg8IPcfJGZqfwkbEb-l3XELhhcJ_RTiH4zyDtwU.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nDzookeeper-jute-3.5.7-AjJ2xg8IPcfJGZqfwkbEb-l3XELhhcJ_RTiH4zyDtwU.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\263\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/251-EMBEDDED-audience-annotations-0.5.0-yCYx8Gx11Gv2Uk2V8NbC467xs-tKe1hMopZiTvDUdL4.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nJaudience-annotations-0.5.0-yCYx8Gx11Gv2Uk2V8NbC467xs-tKe1hMopZiTvDUdL4.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\263\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/252-EMBEDDED-netty-handler-4.1.51.Final-RGGXDwT01euREq2UJVzhmHOUzmTebDyHaQvwhlyTYlg.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nJnetty-handler-4.1.51.Final-RGGXDwT01euREq2UJVzhmHOUzmTebDyHaQvwhlyTYlg.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\300\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/253-EMBEDDED-netty-transport-native-epoll-4.1.51.Final-jhp8_fw4knNnkBZ4PgG68gbezxSQmhnAGpocbjesu9M.j"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nYnetty-transport-native-epoll-4.1.51.Final-jhp8_fw4knNnkBZ4PgG68gbezxSQmhnAGpocbjesu9M.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\262\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/254-EMBEDDED-hadoop-hdfs-client-2.10.1-PY6m6joD2T6vr-wkECaRkhrDk3J5PT6sa_ybU6-bjkQ.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nIhadoop-hdfs-client-2.10.1-PY6m6joD2T6vr-wkECaRkhrDk3J5PT6sa_ybU6-bjkQ.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\245\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/255-EMBEDDED-shims-0.7.45-jqsADNtdJKUQB6hTc082FGkyfte63kS6gYD9Pk-w_V0.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n<shims-0.7.45-jqsADNtdJKUQB6hTc082FGkyfte63kS6gYD9Pk-w_V0.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\256\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/256-EMBEDDED-javax.ws.rs-api-2.0.1-OGB9Ym8iiNj7wbH4piw2nmOAbZoxOsfLxfnWyU9LRm0.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nEjavax.ws.rs-api-2.0.1-OGB9Ym8iiNj7wbH4piw2nmOAbZoxOsfLxfnWyU9LRm0.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\256\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/257-EMBEDDED-hk2-locator-2.4.0-b34-6kfr9-1W73UQVXEM-tNoQLzDY4PPOHxKljtBRHwGb48.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nEhk2-locator-2.4.0-b34-6kfr9-1W73UQVXEM-tNoQLzDY4PPOHxKljtBRHwGb48.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\252\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/258-EMBEDDED-hk2-api-2.4.0-b34-brBxquoycBWsPaGNUGbDZMGjmXj0tvlGRBWGdcpbnO0.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nAhk2-api-2.4.0-b34-brBxquoycBWsPaGNUGbDZMGjmXj0tvlGRBWGdcpbnO0.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\257\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/259-EMBEDDED-javax.inject-2.4.0-b34-_b-AoBuFQEW9QAS3xrH9wtqB20db-9CO1XTu_8-aexo.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nFjavax.inject-2.4.0-b34-_b-AoBuFQEW9QAS3xrH9wtqB20db-9CO1XTu_8-aexo.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\261\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/260-EMBEDDED-javax.annotation-api-1.2-WQmzlso6K-ENDuoyx073jYFuG06tId4deN4fiQ0DPgQ.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nHjavax.annotation-api-1.2-WQmzlso6K-ENDuoyx073jYFuG06tId4deN4fiQ0DPgQ.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\254\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/261-EMBEDDED-jersey-guava-2.22.2-D9zHXQJa_0Ay07i-kJtaCCkTsn2VOtgt1d8q0prqY2s.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nCjersey-guava-2.22.2-D9zHXQJa_0Ay07i-kJtaCCkTsn2VOtgt1d8q0prqY2s.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\264\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/262-EMBEDDED-osgi-resource-locator-1.0.1-d1ADvld-iAb1G25EK-EDPYO-LLIgciezSb4L8W5sCEM.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nKosgi-resource-locator-1.0.1-d1ADvld-iAb1G25EK-EDPYO-LLIgciezSb4L8W5sCEM.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\263\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/263-EMBEDDED-validation-api-1.1.0.Final-8517pyU-NfWsSAgewbwoxd-bMqxLfbIIU-Wo52v3sO0.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nJvalidation-api-1.1.0.Final-8517pyU-NfWsSAgewbwoxd-bMqxLfbIIU-Wo52v3sO0.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\246\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/264-EMBEDDED-janino-3.0.16-9h24Y75jpbOBXYwclGRugdEWiJXv3lrNNIPCQiG5xlU.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n=janino-3.0.16-9h24Y75jpbOBXYwclGRugdEWiJXv3lrNNIPCQiG5xlU.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\260\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/265-EMBEDDED-commons-compiler-3.0.16-C4BjaTC2IZexotsEriG57Vz6yXFctE7dbcb2dfQXlwg.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nGcommons-compiler-3.0.16-C4BjaTC2IZexotsEriG57Vz6yXFctE7dbcb2dfQXlwg.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\243\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/266-EMBEDDED-antlr4-4.7-eGclcCizNzrwEd7nts6bWHqP1cegsl9osv9MuQvoqgc.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n:antlr4-4.7-eGclcCizNzrwEd7nts6bWHqP1cegsl9osv9MuQvoqgc.jar" } dependencies
{ type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\253\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/267-EMBEDDED-antlr4-runtime-4.7-KmGUP4A7vR0OAt_9GbkqQY-DNAyZQ0aAnjtR4iMapsA.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nBantlr4-runtime-4.7-KmGUP4A7vR0OAt_9GbkqQY-DNAyZQ0aAnjtR4iMapsA.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\253\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/268-EMBEDDED-aircompressor-0.10-pUcavdyZqVk5q_wEBc3bIhPE-6Vh3pT4iNbmJVZugmw.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nBaircompressor-0.10-pUcavdyZqVk5q_wEBc3bIhPE-6Vh3pT4iNbmJVZugmw.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\257\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/269-EMBEDDED-parquet-jackson-1.10.1-m8RDI886Nr-xqxl_W48rE6OiYTuqBIm7JSszVTVipSg.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nFparquet-jackson-1.10.1-m8RDI886Nr-xqxl_W48rE6OiYTuqBIm7JSszVTVipSg.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\254\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/270-EMBEDDED-arrow-format-0.10.0-ITh71gEtmLvHCD80n5Vp3EeYzXLFt8mqcTCSu84ZOes.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nCarrow-format-0.10.0-ITh71gEtmLvHCD80n5Vp3EeYzXLFt8mqcTCSu84ZOes.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\243\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/271-EMBEDDED-hppc-0.7.2-ez3WZh6D4xPXC0qoLFGAuzlTXlNqNDX6dB__lydDO2o.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n:hppc-0.7.2-ez3WZh6D4xPXC0qoLFGAuzlTXlNqNDX6dB__lydDO2o.jar" } dependencies
{ type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\263\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/272-EMBEDDED-flatbuffers-1.2.0-3f79e055-dD-XMWCWum6FKJFOorBi9qAvyR7HPJilpGJA1tZ-aJg.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nJflatbuffers-1.2.0-3f79e055-dD-XMWCWum6FKJFOorBi9qAvyR7HPJilpGJA1tZ-aJg.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\270\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/273-EMBEDDED-animal-sniffer-annotations-1.18-R_BYUrSO6brv74D6PYzqYO-kdTwAExId1_5e7y5ccp0.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nOanimal-sniffer-annotations-1.18-R_BYUrSO6brv74D6PYzqYO-kdTwAExId1_5e7y5ccp0.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\250\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/274-EMBEDDED-httpcore-4.4.13-4G6J1AlDJF_Po57FN82_zjdirs3o-cWXeA0rAMK0NCQ.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n?httpcore-4.4.13-4G6J1AlDJF_Po57FN82_zjdirs3o-cWXeA0rAMK0NCQ.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\245\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/275-EMBEDDED-jettison-1.1-N3lAKIsGQ8SHgBN_b2hXiTfh6lyitzgwqCDFCnt-2AE.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n<jettison-1.1-N3lAKIsGQ8SHgBN_b2hXiTfh6lyitzgwqCDFCnt-2AE.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\250\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/276-EMBEDDED-jaxb-impl-2.3.3-5ReNDHlIJH91oTxom_NvTV1JEKEh9xKqOyCulDdwadg.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n?jaxb-impl-2.3.3-5ReNDHlIJH91oTxom_NvTV1JEKEh9xKqOyCulDdwadg.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\240\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/277-EMBEDDED-asm-3.1-Mz_1NpBDl1t-AxuLJyBpN0QYVHOOA4wfR_mNByogQ3o.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n7asm-3.1-Mz_1NpBDl1t-AxuLJyBpN0QYVHOOA4wfR_mNByogQ3o.jar" } dependencies {
type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\254\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/278-EMBEDDED-java-xmlbuilder-0.4-aB5TxP_Vn6EgaIA7JZ46g9Q_B6R8ES50ihh97heesx8.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nCjava-xmlbuilder-0.4-aB5TxP_Vn6EgaIA7JZ46g9Q_B6R8ES50ihh97heesx8.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\254\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/279-EMBEDDED-nimbus-jose-jwt-7.9-tPWEU-GAqYHrdEoZtNVq-xLxDD3TXnUxzFjubL9b8oY.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nCnimbus-jose-jwt-7.9-tPWEU-GAqYHrdEoZtNVq-xLxDD3TXnUxzFjubL9b8oY.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\247\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/280-EMBEDDED-json-smart-2.3-kD9IyKpMP2QmRAuNMt6J-h3COxFpq94l5OHQaKpncIs.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n>json-smart-2.3-kD9IyKpMP2QmRAuNMt6J-h3COxFpq94l5OHQaKpncIs.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\254\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/281-EMBEDDED-accessors-smart-1.2-DHwmXWL8AHEk3DK5EzbpxCcmUdYpvF-hpOTjvHWOsuQ.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nCaccessors-smart-1.2-DHwmXWL8AHEk3DK5EzbpxCcmUdYpvF-hpOTjvHWOsuQ.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\242\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/282-EMBEDDED-asm-5.0.4-iWYY7YrmJwJSGni8e-QrfEkaCOaSChX4mj7N7DHpoiA.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n9asm-5.0.4-iWYY7YrmJwJSGni8e-QrfEkaCOaSChX4mj7N7DHpoiA.jar" } dependencies {
type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\242\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/283-EMBEDDED-ST4-4.0.8-WMqrxAyfdLC1mT_YaOD2SlDAdZCU5qJRqq-tmO38ejs.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n9ST4-4.0.8-WMqrxAyfdLC1mT_YaOD2SlDAdZCU5qJRqq-tmO38ejs.jar" } dependencies {
type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\254\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/284-EMBEDDED-antlr-runtime-3.5.2-zj_I7LEPOemjzdy7LONQ0nLZzT0LHhjm_nPDuTichzQ.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nCantlr-runtime-3.5.2-zj_I7LEPOemjzdy7LONQ0nLZzT0LHhjm_nPDuTichzQ.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\254\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/285-EMBEDDED-javassist-3.20.0-GA-12kQYvt3nCOBZAyPcqy6LCOHOwHCQ4ZtQcFdxMiEjqI.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nCjavassist-3.20.0-GA-12kQYvt3nCOBZAyPcqy6LCOHOwHCQ4ZtQcFdxMiEjqI.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\246\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/286-EMBEDDED-flogger-0.5.1-tezRSD4EEZcBJ4b3SZaKYgY8GWTT7Pv5a6kqlXl7uPU.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n=flogger-0.5.1-tezRSD4EEZcBJ4b3SZaKYgY8GWTT7Pv5a6kqlXl7uPU.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\262\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/287-EMBEDDED-checker-compat-qual-2.5.3-12ua_qYcfAgpCAI_DLwUJ_q5q9LfkVyLij56UJvMvG0.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nIchecker-compat-qual-2.5.3-12ua_qYcfAgpCAI_DLwUJ_q5q9LfkVyLij56UJvMvG0.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\261\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/288-EMBEDDED-netty-codec-4.1.51.Final-_3QaqjX3BIpr58cAqkhRv2Q5F2SOpbfAy62i84SMK-4.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nHnetty-codec-4.1.51.Final-_3QaqjX3BIpr58cAqkhRv2Q5F2SOpbfAy62i84SMK-4.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\300\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/289-EMBEDDED-netty-transport-native-unix-common-4.1.51.Final-FHWV_0ViQv0bMtHmzXgKZluNjgOk4b9W2ot3Kzh"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n_netty-transport-native-unix-common-4.1.51.Final-FHWV_0ViQv0bMtHmzXgKZluNjgOk4b9W2ot3Kzhjxtk.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\265\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/290-EMBEDDED-netty-transport-4.1.51.Final-5b4lnzWiRr9QStk-qPXfMYcrWr6_t1E4DquV1dyEDUQ.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nLnetty-transport-4.1.51.Final-5b4lnzWiRr9QStk-qPXfMYcrWr6_t1E4DquV1dyEDUQ.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\264\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/291-EMBEDDED-netty-resolver-4.1.51.Final-yKd3ZeSB-_WQbFlutEHeSQlrNUvK4DVrdASsXpY5k1A.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nKnetty-resolver-4.1.51.Final-yKd3ZeSB-_WQbFlutEHeSQlrNUvK4DVrdASsXpY5k1A.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\262\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/292-EMBEDDED-netty-buffer-4.1.51.Final-w8O3EOG1qN89YM1GAuCnQ0gdXmCeSqhS-iYp5OQS0kU.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nInetty-buffer-4.1.51.Final-w8O3EOG1qN89YM1GAuCnQ0gdXmCeSqhS-iYp5OQS0kU.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\262\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/293-EMBEDDED-netty-common-4.1.51.Final-EQ4GUV9DkTorusI-GqeLf1muCdRmsAr1_POZpPmvG2s.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nInetty-common-4.1.51.Final-EQ4GUV9DkTorusI-GqeLf1muCdRmsAr1_POZpPmvG2s.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\245\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/294-EMBEDDED-minlog-1.3.0-97OZ06VHik8-DZi9HJ9HdmEZxmQUvDOqD2zeAGbyTMI.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n<minlog-1.3.0-97OZ06VHik8-DZi9HJ9HdmEZxmQUvDOqD2zeAGbyTMI.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\245\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/295-EMBEDDED-okhttp-2.7.5-iKyf0btR-CvMZkzB65wiXJDcQ4nWYCMbTMc3vr_n0Ko.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n<okhttp-2.7.5-iKyf0btR-CvMZkzB65wiXJDcQ4nWYCMbTMc3vr_n0Ko.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\254\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/296-EMBEDDED-hk2-utils-2.4.0-b34-cCEbH5GIGb9q-_adPRnUrm4qddbib2w5up8g645WEtc.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nChk2-utils-2.4.0-b34-cCEbH5GIGb9q-_adPRnUrm4qddbib2w5up8g645WEtc.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\271\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/297-EMBEDDED-aopalliance-repackaged-2.4.0-b34-XTywzs5yLHuoq5h7kxBTzbywyxKtXIyKdpHrb35gpks.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nPaopalliance-repackaged-2.4.0-b34-XTywzs5yLHuoq5h7kxBTzbywyxKtXIyKdpHrb35gpks.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\261\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/298-EMBEDDED-servlet-api-2.5-20081211-BodWCWmW_gD2BKw7ZnLW9mPcd36kqDBW4kDQRW535HI.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nHservlet-api-2.5-20081211-BodWCWmW_gD2BKw7ZnLW9mPcd36kqDBW4kDQRW535HI.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\263\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/299-EMBEDDED-jakarta.xml.bind-api-2.3.3-wEU59HLppt0MdoXqgtZ3KCJpq457rKLhRQDjgeDGzsU.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nJjakarta.xml.bind-api-2.3.3-wEU59HLppt0MdoXqgtZ3KCJpq457rKLhRQDjgeDGzsU.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\261\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/300-EMBEDDED-jakarta.activation-1.2.2-AhVnc-SunQSNFKVq011kS-6fEFKnkdBy3z3tPGVubho.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nHjakarta.activation-1.2.2-AhVnc-SunQSNFKVq011kS-6fEFKnkdBy3z3tPGVubho.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\257\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/301-EMBEDDED-jcip-annotations-1.0-1-T8z_g4Kq_FiZYsTtsmL2qlleNPHhHmEFfRxqluj8cyM.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nFjcip-annotations-1.0-1-T8z_g4Kq_FiZYsTtsmL2qlleNPHhHmEFfRxqluj8cyM.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\270\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/302-EMBEDDED-org.abego.treelayout.core-1.0.3--l4xOVw5wufUasoPgfcgYJMWB7L6Qb02A46yy2-5MyY.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nOorg.abego.treelayout.core-1.0.3--l4xOVw5wufUasoPgfcgYJMWB7L6Qb02A46yy2-5MyY.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\251\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/303-EMBEDDED-javax.json-1.0.4-Dh3sQKHt6WWUElHtqWiu7gUsxPUDeLwxbMSOgVm9vrQ.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n...@javax.json-1.0.4-dh3sqkht6wwuelhtqwiu7gusxpudelwxbmsogvm9vrq.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\243\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/304-EMBEDDED-icu4j-58.2-lT4eg7K-fD6i-I2obBNhT0fp5x01eMhSHX8Yd1a2OWI.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n:icu4j-58.2-lT4eg7K-fD6i-I2obBNhT0fp5x01eMhSHX8Yd1a2OWI.jar" } dependencies
{ type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\254\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/305-EMBEDDED-annotations-4.1.1.4-unNOHoTAnWFa9qCdMwNLTwRC-Hct7BIO-zdthqVlrhU.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nCannotations-4.1.1.4-unNOHoTAnWFa9qCdMwNLTwRC-Hct7BIO-zdthqVlrhU.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\243\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/306-EMBEDDED-okio-1.6.0-EUvcH0czimi8vJWr8vXNxyvu7JGBLy_Ne1IcGTeHYmY.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n:okio-1.6.0-EUvcH0czimi8vJWr8vXNxyvu7JGBLy_Ne1IcGTeHYmY.jar" } dependencies
{ type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\247\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/307-EMBEDDED-stax-api-1.0-2-6McOvXb5gslYKoLvgs9s4Up9WKSk3KXLe3_JiMgAibc.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n>stax-api-1.0-2-6McOvXb5gslYKoLvgs9s4Up9WKSk3KXLe3_JiMgAibc.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\242\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/308-EMBEDDED-guice-3.0-GlnQQh_9NVzAtwtC3xwumvdEyKLQyS2jefX8ovB_HSI.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n9guice-3.0-GlnQQh_9NVzAtwtC3xwumvdEyKLQyS2jefX8ovB_HSI.jar" } dependencies {
type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\247\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/309-EMBEDDED-javax.inject-1-kcdwRKUMSBY2wy2Rb9ickRinIZU5BFLIEGUID5V95_8.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n>javax.inject-1-kcdwRKUMSBY2wy2Rb9ickRinIZU5BFLIEGUID5V95_8.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\275\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/310-EMBEDDED-geronimo-jcache_1.0_spec-1.0-alpha-1-AHChLlj0kblXGTkTJSmaYpRTDubDziXlC9yYsLcAlmw.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nTgeronimo-jcache_1.0_spec-1.0-alpha-1-AHChLlj0kblXGTkTJSmaYpRTDubDziXlC9yYsLcAlmw.jar"
} dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\256\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/311-EMBEDDED-mssql-jdbc-6.2.1.jre7-nPollFCuNHHS5uLD2K78ziNuPa74s3NNIdyTw6W76AY.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nEmssql-jdbc-6.2.1.jre7-nPollFCuNHHS5uLD2K78ziNuPa74s3NNIdyTw6W76AY.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\250\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/312-EMBEDDED-aopalliance-1.0-Ct3sZw_tzT8RPFyAkdeDKA0j9146y4QbYanNsHk3agg.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\n?aopalliance-1.0-Ct3sZw_tzT8RPFyAkdeDKA0j9146y4QbYanNsHk3agg.jar" }
dependencies { type_urn: "beam:artifact:type:file:v1" type_payload:
"\n\256\001/tmp/beam-artifact-staging/1a545f5d7ef94671181c2cd5d47c479de586b5f9aab6f7680e4b64b6d4488d1d/313-EMBEDDED-cglib-2.2.1-v20090111-QuHfsmvsvxpjPyW0fjn8xCK4XnfkwEaNmkT4hfX6C-I.jar"
role_urn: "beam:artifact:role:staging_to:v1" role_payload:
"\nEcglib-2.2.1-v20090111-QuHfsmvsvxpjPyW0fjn8xCK4XnfkwEaNmkT4hfX6C-I.jar" }
20/12/17 06:09:14 INFO
org.apache.beam.runners.fnexecution.logging.GrpcLoggingService: 1 Beam Fn
Logging clients still connected during shutdown. 20/12/17 06:09:14 WARN
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer: Hanged up for unknown
endpoint. 20/12/17 06:09:14 ERROR
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer: Failed to handle for
url: "InProcessServer_58"
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.StatusRuntimeException: CANCELLED:
Multiplexer hanging up at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.Status.asRuntimeException(Status.java:533)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.ClientCalls$StreamObserverToCallListenerAdapter.onClose(ClientCalls.java:449)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.CensusStatsModule$StatsClientInterceptor$1$1.onClose(CensusStatsModule.java:700)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.CensusTracingModule$TracingClientInterceptor$1$1.onClose(CensusTracingModule.java:399)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:521)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:66)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.close(ClientCallImpl.java:641)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.access$700(ClientCallImpl.java:529)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:703)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:692)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748) 20/12/17 06:09:14 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:14 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:14 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:14 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:14 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:14 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:14 INFO
org.apache.beam.runners.spark.util.GlobalWatermarkHolder: No new watermarks
could be computed upon completion of batch: 1608185354500 20/12/17 06:09:14
INFO
org.apache.beam.runners.spark.util.GlobalWatermarkHolder$WatermarkAdvancingStreamingListener:
Batch with timestamp: 1608185354500 has completed, watermarks have been
updated. Dec 17, 2020 6:09:14 AM
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference
cleanQueue SEVERE: *~*~*~ Channel ManagedChannelImpl{logId=426,
target=directaddress:///InProcessServer_58} was not shutdown properly!!! ~*~*~*
Make sure to call shutdown()/shutdownNow() and wait until awaitTermination()
returns true. java.lang.RuntimeException: ManagedChannel allocation site at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference.<init>(ManagedChannelOrphanWrapper.java:94)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:52)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:43)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:524)
at
org.apache.beam.sdk.fn.channel.ManagedChannelFactory.forDescriptor(ManagedChannelFactory.java:44)
at
org.apache.beam.fn.harness.data.BeamFnDataGrpcClient.lambda$getClientFor$0(BeamFnDataGrpcClient.java:116)
at
java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660)
at
org.apache.beam.fn.harness.data.BeamFnDataGrpcClient.getClientFor(BeamFnDataGrpcClient.java:110)
at
org.apache.beam.fn.harness.data.BeamFnDataGrpcClient.send(BeamFnDataGrpcClient.java:101)
at
org.apache.beam.fn.harness.data.QueueingBeamFnDataClient.send(QueueingBeamFnDataClient.java:141)
at
org.apache.beam.fn.harness.BeamFnDataWriteRunner.registerForOutput(BeamFnDataWriteRunner.java:169)
at
org.apache.beam.fn.harness.data.PTransformFunctionRegistry.lambda$register$0(PTransformFunctionRegistry.java:108)
at
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:301)
at
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:173)
at
org.apache.beam.fn.harness.control.BeamFnControlClient.lambda$processInstructionRequests$0(BeamFnControlClient.java:157)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748) 20/12/17 06:09:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:15 INFO
org.apache.beam.runners.spark.util.GlobalWatermarkHolder: No new watermarks
could be computed upon completion of batch: 1608185355000 20/12/17 06:09:15
INFO
org.apache.beam.runners.spark.util.GlobalWatermarkHolder$WatermarkAdvancingStreamingListener:
Batch with timestamp: 1608185355000 has completed, watermarks have been
updated. 20/12/17 06:09:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:15 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:15 INFO
org.apache.beam.runners.spark.util.GlobalWatermarkHolder: No new watermarks
could be computed upon completion of batch: 1608185355500 20/12/17 06:09:15
INFO
org.apache.beam.runners.spark.util.GlobalWatermarkHolder$WatermarkAdvancingStreamingListener:
Batch with timestamp: 1608185355500 has completed, watermarks have been
updated. 20/12/17 06:09:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:16 INFO
org.apache.beam.runners.spark.util.GlobalWatermarkHolder: No new watermarks
could be computed upon completion of batch: 1608185356000 20/12/17 06:09:16
INFO
org.apache.beam.runners.spark.util.GlobalWatermarkHolder$WatermarkAdvancingStreamingListener:
Batch with timestamp: 1608185356000 has completed, watermarks have been
updated. 20/12/17 06:09:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:16 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:16 INFO
org.apache.beam.runners.spark.util.GlobalWatermarkHolder: No new watermarks
could be computed upon completion of batch: 1608185356500 20/12/17 06:09:16
INFO
org.apache.beam.runners.spark.util.GlobalWatermarkHolder$WatermarkAdvancingStreamingListener:
Batch with timestamp: 1608185356500 has completed, watermarks have been
updated. 20/12/17 06:09:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:17 INFO
org.apache.beam.runners.spark.util.GlobalWatermarkHolder: No new watermarks
could be computed upon completion of batch: 1608185357000 20/12/17 06:09:17
INFO
org.apache.beam.runners.spark.util.GlobalWatermarkHolder$WatermarkAdvancingStreamingListener:
Batch with timestamp: 1608185357000 has completed, watermarks have been
updated. 20/12/17 06:09:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:17 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:17 INFO
org.apache.beam.runners.spark.util.GlobalWatermarkHolder: No new watermarks
could be computed upon completion of batch: 1608185357500 20/12/17 06:09:17
INFO
org.apache.beam.runners.spark.util.GlobalWatermarkHolder$WatermarkAdvancingStreamingListener:
Batch with timestamp: 1608185357500 has completed, watermarks have been
updated. 20/12/17 06:09:18 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:18 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:18 WARN
org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't
support checkpointing 20/12/17 06:09:18 WARN
org.apache.spark.streaming.util.BatchedWriteAheadLog: BatchedWriteAheadLog
Writer queue interrupted. 20/12/17 06:09:18 INFO
org.apache.beam.runners.spark.SparkPipelineRunner: Job
withtimestampstest0withtimestampslambdashouldapplytimestamps-jenkins-1217060845-cadc3ecb_45479b79-bcaf-4928-9c21-a647c51483c9
finished. 20/12/17 06:09:18 WARN org.apache.spark.streaming.StreamingContext:
StreamingContext has already been stopped 20/12/17 06:09:20 INFO
org.apache.beam.runners.jobsubmission.InMemoryJobService: Getting job metrics
for
withtimestampstest0withtimestampslambdashouldapplytimestamps-jenkins-1217060845-cadc3ecb_45479b79-bcaf-4928-9c21-a647c51483c9
20/12/17 06:09:20 INFO
org.apache.beam.runners.jobsubmission.InMemoryJobService: Finished getting job
metrics for
withtimestampstest0withtimestampslambdashouldapplytimestamps-jenkins-1217060845-cadc3ecb_45479b79-bcaf-4928-9c21-a647c51483c9
Dec 17, 2020 6:09:20 AM
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference
cleanQueue SEVERE: *~*~*~ Channel ManagedChannelImpl{logId=418,
target=directaddress:///InProcessServer_54} was not shutdown properly!!! ~*~*~*
Make sure to call shutdown()/shutdownNow() and wait until awaitTermination()
returns true. java.lang.RuntimeException: ManagedChannel allocation site at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference.<init>(ManagedChannelOrphanWrapper.java:94)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:52)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:43)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:524)
at
org.apache.beam.sdk.fn.channel.ManagedChannelFactory.forDescriptor(ManagedChannelFactory.java:44)
at org.apache.beam.fn.harness.FnHarness.main(FnHarness.java:194) at
org.apache.beam.runners.fnexecution.environment.EmbeddedEnvironmentFactory.lambda$createEnvironment$0(EmbeddedEnvironmentFactory.java:100)
at java.util.concurrent.FutureTask.run(FutureTask.java:266) at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748) Dec 17, 2020 6:09:20 AM
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference
cleanQueue SEVERE: *~*~*~ Channel ManagedChannelImpl{logId=422,
target=directaddress:///InProcessServer_59} was not shutdown properly!!! ~*~*~*
Make sure to call shutdown()/shutdownNow() and wait until awaitTermination()
returns true. java.lang.RuntimeException: ManagedChannel allocation site at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference.<init>(ManagedChannelOrphanWrapper.java:94)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:52)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:43)
at
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:524)
at
org.apache.beam.sdk.fn.channel.ManagedChannelFactory.forDescriptor(ManagedChannelFactory.java:44)
at
org.apache.beam.fn.harness.state.BeamFnStateGrpcClientCache$GrpcStateClient.<init>(BeamFnStateGrpcClientCache.java:89)
at
org.apache.beam.fn.harness.state.BeamFnStateGrpcClientCache$GrpcStateClient.<init>(BeamFnStateGrpcClientCache.java:79)
at
org.apache.beam.fn.harness.state.BeamFnStateGrpcClientCache.createBeamFnStateClient(BeamFnStateGrpcClientCache.java:75)
at
java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660)
at
org.apache.beam.fn.harness.state.BeamFnStateGrpcClientCache.forApiServiceDescriptor(BeamFnStateGrpcClientCache.java:71)
at
org.apache.beam.fn.harness.control.ProcessBundleHandler.createBundleProcessor(ProcessBundleHandler.java:456)
at
org.apache.beam.fn.harness.control.ProcessBundleHandler.lambda$processBundle$0(ProcessBundleHandler.java:284)
at
org.apache.beam.fn.harness.control.ProcessBundleHandler$BundleProcessorCache.get(ProcessBundleHandler.java:572)
at
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:279)
at
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:173)
at
org.apache.beam.fn.harness.control.BeamFnControlClient.lambda$processInstructionRequests$0(BeamFnControlClient.java:157)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748) 20/12/17 06:09:20 INFO
org.apache.beam.runners.jobsubmission.JobServerDriver: JobServer stopped on
localhost:33851 20/12/17 06:09:20 INFO
org.apache.beam.runners.jobsubmission.JobServerDriver: ArtifactStagingServer
stopped on localhost:46355 20/12/17 06:09:20 INFO
org.apache.beam.runners.jobsubmission.JobServerDriver: Expansion stopped on
localhost:45215
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
