[BEAM-11490] Spark test failure: org.apache.beam.sdk.transforms.ReifyTimestampsTest.inValuesSucceeds

• Type: Sub-task
• Status: Resolved
• Priority: P1
• Resolution: Fixed
• Fix Version/s: Missing
• Component/s: runner-spark, test-failures
• Labels: flake portability-spark
• Assignee: Unassigned
• Reporter: Tyson Hamilton
• Created: 17/Dec/20 18:28
• Updated: 13/Jan/22 21:49
• Resolved: 26/Apr/21 22:05

Description

From: https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Spark_Streaming/468/testReport/org.apache.beam.sdk.transforms/ReifyTimestampsTest/inValuesSucceeds/

 

Others:

https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Spark_Streaming/467/testReport/org.apache.beam.sdk.transforms/ReifyTimestampsTest/inValuesSucceeds/

https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Spark_Streaming/465/testReport/org.apache.beam.sdk.transforms/ReifyTimestampsTest/inValuesSucceeds/

 

Failedorg.apache.beam.sdk.transforms.ReifyTimestampsTest.inValuesSucceedsFailing for the past 2 builds (Since #467 )Took 36 sec.Error Messagejava.lang.AssertionError: Expected 1 successful assertions, but found 0.
Expected: is <1L>
     but: was <0L>Stacktracejava.lang.AssertionError: Expected 1 successful assertions, but found 0.
Expected: is <1L>
     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.ReifyTimestampsTest.inValuesSucceeds(ReifyTimestampsTest.java:60)
	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.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.GeneratedMethodAccessor155.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.GeneratedMethodAccessor154.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 OutputShutting SDK harness down.
Shutting SDK harness down.
Shutting SDK harness down.
Standard Error20/12/17 12:32:38 INFO org.apache.beam.runners.jobsubmission.JobServerDriver: ArtifactStagingService started on localhost:44947
20/12/17 12:32:38 INFO org.apache.beam.runners.jobsubmission.JobServerDriver: Java ExpansionService started on localhost:43961
20/12/17 12:32:38 INFO org.apache.beam.runners.jobsubmission.JobServerDriver: JobService started on localhost:36055
20/12/17 12:32:40 INFO org.apache.beam.runners.portability.PortableRunner: Using job server endpoint: localhost:36055
20/12/17 12:32:40 INFO org.apache.beam.runners.portability.PortableRunner: PrepareJobResponse: preparation_id: "reifytimestampstest0extractfromvalueswhenvaluetimestampedlatersucceeds-jenkins-1217123240-9d824154_9af7aaef-569a-4ebb-892a-99093c1aa08c"
artifact_staging_endpoint {
  url: "localhost:44947"
}
staging_session_token: "reifytimestampstest0extractfromvalueswhenvaluetimestampedlatersucceeds-jenkins-1217123240-9d824154_9af7aaef-569a-4ebb-892a-99093c1aa08c"

20/12/17 12:32:40 INFO org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Staging artifacts for reifytimestampstest0extractfromvalueswhenvaluetimestampedlatersucceeds-jenkins-1217123240-9d824154_9af7aaef-569a-4ebb-892a-99093c1aa08c.
20/12/17 12:32:40 INFO org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Resolving artifacts for reifytimestampstest0extractfromvalueswhenvaluetimestampedlatersucceeds-jenkins-1217123240-9d824154_9af7aaef-569a-4ebb-892a-99093c1aa08c.EMBEDDED.
20/12/17 12:32:40 INFO org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Getting 313 artifacts for reifytimestampstest0extractfromvalueswhenvaluetimestampedlatersucceeds-jenkins-1217123240-9d824154_9af7aaef-569a-4ebb-892a-99093c1aa08c.null.
20/12/17 12:32:41 INFO org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Artifacts fully staged for reifytimestampstest0extractfromvalueswhenvaluetimestampedlatersucceeds-jenkins-1217123240-9d824154_9af7aaef-569a-4ebb-892a-99093c1aa08c.
20/12/17 12:32:41 INFO org.apache.beam.runners.spark.SparkJobInvoker: Invoking job reifytimestampstest0extractfromvalueswhenvaluetimestampedlatersucceeds-jenkins-1217123240-9d824154_9e99e808-2703-4eb3-9e6e-920ec22562d6
20/12/17 12:32:41 INFO org.apache.beam.runners.jobsubmission.JobInvocation: Starting job invocation reifytimestampstest0extractfromvalueswhenvaluetimestampedlatersucceeds-jenkins-1217123240-9d824154_9e99e808-2703-4eb3-9e6e-920ec22562d6
20/12/17 12:32:41 INFO org.apache.beam.runners.portability.PortableRunner: RunJobResponse: job_id: "reifytimestampstest0extractfromvalueswhenvaluetimestampedlatersucceeds-jenkins-1217123240-9d824154_9e99e808-2703-4eb3-9e6e-920ec22562d6"

20/12/17 12:32:41 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 12:32:41 INFO org.apache.beam.runners.spark.translation.SparkContextFactory: Creating a brand new Spark Context.
20/12/17 12:32:41 INFO org.apache.beam.runners.spark.SparkPipelineRunner: Running job reifytimestampstest0extractfromvalueswhenvaluetimestampedlatersucceeds-jenkins-1217123240-9d824154_9e99e808-2703-4eb3-9e6e-920ec22562d6 on Spark master local[4]
20/12/17 12:32:41 INFO org.apache.beam.runners.spark.SparkPipelineRunner: Running job reifytimestampstest0extractfromvalueswhenvaluetimestampedlatersucceeds-jenkins-1217123240-9d824154_9e99e808-2703-4eb3-9e6e-920ec22562d6 on Spark master local[4]
20/12/17 12:32:41 INFO org.apache.beam.runners.spark.SparkPipelineRunner: Job reifytimestampstest0extractfromvalueswhenvaluetimestampedlatersucceeds-jenkins-1217123240-9d824154_9e99e808-2703-4eb3-9e6e-920ec22562d6: Pipeline translated successfully. Computing outputs
20/12/17 12:32:41 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:32:41 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:32:41 INFO org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory: Closing environment urn: "EMBEDDED"
capabilities: "beam:coder:bytes:v1"
capabilities: "beam:coder:bool:v1"
capabilities: "beam:coder:varint:v1"
capabilities: "beam:coder:string_utf8:v1"
capabilities: "beam:coder:iterable:v1"
capabilities: "beam:coder:timer:v1"
capabilities: "beam:coder:kv:v1"
capabilities: "beam:coder:length_prefix:v1"
capabilities: "beam:coder:global_window:v1"
capabilities: "beam:coder:interval_window:v1"
capabilities: "beam:coder:windowed_value:v1"
capabilities: "beam:coder:double:v1"
capabilities: "beam:coder:row:v1"
capabilities: "beam:coder:param_windowed_value:v1"
capabilities: "beam:coder:state_backed_iterable:v1"
capabilities: "beam:coder:sharded_key:v1"
capabilities: "beam:protocol:multi_core_bundle_processing:v1"
capabilities: "beam:protocol:progress_reporting:v1"
capabilities: "beam:version:sdk_base:apache/beam_java8_sdk:2.28.0.dev"
capabilities: "beam:transform:sdf_truncate_sized_restrictions:v1"
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\244\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/1-EMBEDDED-icedtea-sound-Iwne2hzRY_LcFqVV9QV5vKlMjP51hQ-1eOLJzzvtpbI.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n=icedtea-sound-Iwne2hzRY_LcFqVV9QV5vKlMjP51hQ-1eOLJzzvtpbI.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\236\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/2-EMBEDDED-jaccess-GSuLz3csmJu-X9AUZiHTbJqpaMTUV566wbey67oiHdQ.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n7jaccess-GSuLz3csmJu-X9AUZiHTbJqpaMTUV566wbey67oiHdQ.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\241\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/3-EMBEDDED-localedata-TEwJCunHd18wxAwBm3LvJNJx12solPe-xMDYaFol2sA.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n:localedata-TEwJCunHd18wxAwBm3LvJNJx12solPe-xMDYaFol2sA.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\236\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/4-EMBEDDED-nashorn-SdgMcTpgWcQtx3JL51KmsDXzNAZxettGu89S8K56auc.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n7nashorn-SdgMcTpgWcQtx3JL51KmsDXzNAZxettGu89S8K56auc.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\237\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/5-EMBEDDED-cldrdata-OUiyQiNqFFtu58zOPukvi1Butg3ZPuK250n_3RmVExU.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n8cldrdata-OUiyQiNqFFtu58zOPukvi1Butg3ZPuK250n_3RmVExU.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\234\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/6-EMBEDDED-dnsns-R-BZtd9v6E5wbD8eGFy7fqsxltVReeEAFsXCJxHGNrw.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n5dnsns-R-BZtd9v6E5wbD8eGFy7fqsxltVReeEAFsXCJxHGNrw.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\244\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/7-EMBEDDED-gradle-worker-qf5IiwZXu67peCt-moRUDeA9ftsB4QLMU30y-NdWzC8.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n=gradle-worker-qf5IiwZXu67peCt-moRUDeA9ftsB4QLMU30y-NdWzC8.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\277\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/8-EMBEDDED-beam-runners-spark-2.28.0-SNAPSHOT-tests-VIUwWCUBH9VYrRfgJ3JgkXOH_rL8lwAXCrO3No5eqhs.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nXbeam-runners-spark-2.28.0-SNAPSHOT-tests-VIUwWCUBH9VYrRfgJ3JgkXOH_rL8lwAXCrO3No5eqhs.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\271\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/9-EMBEDDED-beam-runners-spark-2.28.0-SNAPSHOT-roDcluFjvJNigr8KNT1mYws9zKKLnT9KBmLXJGHrakA.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nRbeam-runners-spark-2.28.0-SNAPSHOT-roDcluFjvJNigr8KNT1mYws9zKKLnT9KBmLXJGHrakA.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/10-EMBEDDED-beam-runners-portability-java-2.28.0-SNAPSHOT-tests-k6rmbO4nQYSnVfGyVKueSIwhszdOeM0Ln-vO"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\ncbeam-runners-portability-java-2.28.0-SNAPSHOT-tests-k6rmbO4nQYSnVfGyVKueSIwhszdOeM0Ln-vOOb1MPmI.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/11-EMBEDDED-beam-runners-portability-java-2.28.0-SNAPSHOT-rnaz2uH7bTuALGVp2OiUkziXEVGgWgkfy2FYrt0Gd4"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n]beam-runners-portability-java-2.28.0-SNAPSHOT-rnaz2uH7bTuALGVp2OiUkziXEVGgWgkfy2FYrt0Gd4w.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/12-EMBEDDED-beam-sdks-java-harness-2.28.0-SNAPSHOT-unshaded-R6H9cNeLp6V6pbHhkBIQlNPuxNmrlXlGMMe2UazY"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n_beam-sdks-java-harness-2.28.0-SNAPSHOT-unshaded-R6H9cNeLp6V6pbHhkBIQlNPuxNmrlXlGMMe2UazY1NI.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\276\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/13-EMBEDDED-beam-sdks-java-harness-2.28.0-SNAPSHOT-YycEpLR4Ct0SHtOQ0Wfm5a93GKDwKbcxf9MubjOAJBo.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nVbeam-sdks-java-harness-2.28.0-SNAPSHOT-YycEpLR4Ct0SHtOQ0Wfm5a93GKDwKbcxf9MubjOAJBo.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/14-EMBEDDED-beam-runners-core-java-2.28.0-SNAPSHOT-tests-RDLdZGC6JzZSXd5C3QOfmvw0_5AsazsorSCUoRhjukg"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n\\beam-runners-core-java-2.28.0-SNAPSHOT-tests-RDLdZGC6JzZSXd5C3QOfmvw0_5AsazsorSCUoRhjukg.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\276\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/15-EMBEDDED-beam-runners-core-java-2.28.0-SNAPSHOT-EoJ25ciIZMjsAsXPS5rF9lMtKKNpvgoVfoiRRL_Y070.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nVbeam-runners-core-java-2.28.0-SNAPSHOT-EoJ25ciIZMjsAsXPS5rF9lMtKKNpvgoVfoiRRL_Y070.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/16-EMBEDDED-beam-runners-java-job-service-2.28.0-SNAPSHOT-uX1c_5frzX2Xl8Dxwhv74l1LtK_tJN0lnW47YmuX_m"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n]beam-runners-java-job-service-2.28.0-SNAPSHOT-uX1c_5frzX2Xl8Dxwhv74l1LtK_tJN0lnW47YmuX_mg.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\277\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/17-EMBEDDED-beam-sdks-java-io-kafka-2.28.0-SNAPSHOT--3tpjyY5fnm6MnYASABrYhNPATm_9NQWNJ5O0OzNd9g.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nWbeam-sdks-java-io-kafka-2.28.0-SNAPSHOT--3tpjyY5fnm6MnYASABrYhNPATm_9NQWNJ5O0OzNd9g.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/18-EMBEDDED-beam-sdks-java-expansion-service-2.28.0-SNAPSHOT-Pq7-h5rVFSiymvpGKRHg_tR7ri-Pw5Fpm-Oku_A"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n`beam-sdks-java-expansion-service-2.28.0-SNAPSHOT-Pq7-h5rVFSiymvpGKRHg_tR7ri-Pw5Fpm-Oku_AFSf0.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/19-EMBEDDED-beam-runners-java-fn-execution-2.28.0-SNAPSHOT-F7yo2w8-i6VnpVD9viLcI04VkkboYBM2c7mSZqfHp"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n^beam-runners-java-fn-execution-2.28.0-SNAPSHOT-F7yo2w8-i6VnpVD9viLcI04VkkboYBM2c7mSZqfHpLc.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/20-EMBEDDED-beam-runners-core-construction-java-2.28.0-SNAPSHOT-CIMmn5THHKVYsTOdd9ZB67FVO6Ru7B_q48Of"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\ncbeam-runners-core-construction-java-2.28.0-SNAPSHOT-CIMmn5THHKVYsTOdd9ZB67FVO6Ru7B_q48Of6usYPc4.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/21-EMBEDDED-beam-runners-core-construction-java-2.28.0-SNAPSHOT-tests-O6I6jZM0kJWyiJHL-qHgPRFSUwXEEj"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nibeam-runners-core-construction-java-2.28.0-SNAPSHOT-tests-O6I6jZM0kJWyiJHL-qHgPRFSUwXEEj-oJVNOB4027p4.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/22-EMBEDDED-beam-sdks-java-extensions-google-cloud-platform-core-2.28.0-SNAPSHOT-RGTlUSZ9ATn9KQPtZ4Q"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\ntbeam-sdks-java-extensions-google-cloud-platform-core-2.28.0-SNAPSHOT-RGTlUSZ9ATn9KQPtZ4QuP0pbls8RBTH-gdR-EFJhkYM.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/23-EMBEDDED-beam-sdks-java-fn-execution-2.28.0-SNAPSHOT-Pmfe35mZE8zLMJpjz-sptwayCpdMEM8Z04gJSvwMALs."
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n[beam-sdks-java-fn-execution-2.28.0-SNAPSHOT-Pmfe35mZE8zLMJpjz-sptwayCpdMEM8Z04gJSvwMALs.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/24-EMBEDDED-beam-vendor-sdks-java-extensions-protobuf-2.28.0-SNAPSHOT-9iRMFbkAPmuqqeP3_AwCLH9MnrDvLu"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nibeam-vendor-sdks-java-extensions-protobuf-2.28.0-SNAPSHOT-9iRMFbkAPmuqqeP3_AwCLH9MnrDvLuA4tMcMNJYhaGY.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/25-EMBEDDED-beam-sdks-java-core-2.28.0-SNAPSHOT-tests-FB4KyxowVLZuqUVDK6zQ0kXL6qK9mF6mrJARQCHcw10.ja"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nYbeam-sdks-java-core-2.28.0-SNAPSHOT-tests-FB4KyxowVLZuqUVDK6zQ0kXL6qK9mF6mrJARQCHcw10.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\273\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/26-EMBEDDED-beam-sdks-java-core-2.28.0-SNAPSHOT-3RYbsIHqBp1_8vPS5X4rg60DB0-s1AdM9Vb9om-LnZ0.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nSbeam-sdks-java-core-2.28.0-SNAPSHOT-3RYbsIHqBp1_8vPS5X4rg60DB0-s1AdM9Vb9om-LnZ0.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/27-EMBEDDED-beam-sdks-java-core-2.28.0-SNAPSHOT-unshaded-qQLAPDN_dNXivpP1lEgPQSQ0fdCiOpmWYz3VI0_LNKU"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n\\beam-sdks-java-core-2.28.0-SNAPSHOT-unshaded-qQLAPDN_dNXivpP1lEgPQSQ0fdCiOpmWYz3VI0_LNKU.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\256\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/28-EMBEDDED-guava-testlib-25.1-jre-Gs-YhZbSzRrSwEz1JPl5w-hUaJjNF3C9wAfy8mjXtmQ.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nFguava-testlib-25.1-jre-Gs-YhZbSzRrSwEz1JPl5w-hUaJjNF3C9wAfy8mjXtmQ.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\254\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/29-EMBEDDED-spark-sql_2.11-2.4.7-CsTKJqhM5x-U_FGx7jDozW9Fht4c_cDu74ZBnyGX6fw.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nDspark-sql_2.11-2.4.7-CsTKJqhM5x-U_FGx7jDozW9Fht4c_cDu74ZBnyGX6fw.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\262\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/30-EMBEDDED-spark-streaming_2.11-2.4.7-ue_7LAg7Qr813xkNgtQfU9eAIy07ReCHArqpz9Cv0Ew.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nJspark-streaming_2.11-2.4.7-ue_7LAg7Qr813xkNgtQfU9eAIy07ReCHArqpz9Cv0Ew.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\261\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/31-EMBEDDED-spark-catalyst_2.11-2.4.7-HPCOgFf3FaqeYmff418i_Br9I2v89E_YDyEEJizcIU0.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nIspark-catalyst_2.11-2.4.7-HPCOgFf3FaqeYmff418i_Br9I2v89E_YDyEEJizcIU0.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\255\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/32-EMBEDDED-spark-core_2.11-2.4.7-kfYudFrbOp2tu2iliTUL91CGXawNYRvw3hHz-VnbUFI.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nEspark-core_2.11-2.4.7-kfYudFrbOp2tu2iliTUL91CGXawNYRvw3hHz-VnbUFI.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\254\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/33-EMBEDDED-hadoop-client-2.10.1-bZMdxnHBprJoceVSpimHjHyDAlR_8INTS5Ku1LylsAI.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nDhadoop-client-2.10.1-bZMdxnHBprJoceVSpimHjHyDAlR_8INTS5Ku1LylsAI.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\272\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/34-EMBEDDED-hadoop-mapreduce-client-app-2.10.1-NH4nvQw_Czc4M4WzRq2tj6-1cFEdzq5PBdwN4QG4RBE.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nRhadoop-mapreduce-client-app-2.10.1-NH4nvQw_Czc4M4WzRq2tj6-1cFEdzq5PBdwN4QG4RBE.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/35-EMBEDDED-hadoop-mapreduce-client-jobclient-2.10.1-nfZ_Ocdnp24qWUZ6RM9JQ3wro8n2JRrCanuecVq7Ubg.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nXhadoop-mapreduce-client-jobclient-2.10.1-nfZ_Ocdnp24qWUZ6RM9JQ3wro8n2JRrCanuecVq7Ubg.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\276\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/36-EMBEDDED-hadoop-mapreduce-client-shuffle-2.10.1-UTrRBwBQKG40z_CG64RfISUBsktoZ6cl7KEunywMYfQ.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nVhadoop-mapreduce-client-shuffle-2.10.1-UTrRBwBQKG40z_CG64RfISUBsktoZ6cl7KEunywMYfQ.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\275\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/37-EMBEDDED-hadoop-yarn-server-nodemanager-2.10.1-tgNbEbkCuTUhAYpNN5XJZnAX1iNurbPv99ysUI6cCaU.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nUhadoop-yarn-server-nodemanager-2.10.1-tgNbEbkCuTUhAYpNN5XJZnAX1iNurbPv99ysUI6cCaU.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\270\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/38-EMBEDDED-hadoop-yarn-server-common-2.10.1-pvfLtr8jdHR_M2SpzglErT2BgBRsUdZgeYTk4Kr02IA.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nPhadoop-yarn-server-common-2.10.1-pvfLtr8jdHR_M2SpzglErT2BgBRsUdZgeYTk4Kr02IA.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\263\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/39-EMBEDDED-hadoop-yarn-registry-2.10.1-B1aKWUmtsxIHdlXs15tzO7JVNJbsc72bexiSx6Ta3Ks.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nKhadoop-yarn-registry-2.10.1-B1aKWUmtsxIHdlXs15tzO7JVNJbsc72bexiSx6Ta3Ks.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\254\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/40-EMBEDDED-hadoop-common-2.10.1-ZEwFDVser7F01cLblHm86RovcSyTEEIq5OnleOw1qPI.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nDhadoop-common-2.10.1-ZEwFDVser7F01cLblHm86RovcSyTEEIq5OnleOw1qPI.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/41-EMBEDDED-google-api-services-cloudresourcemanager-v1-rev20200720-1.30.10-PQqVlsOIu2M59XLbEl59CW6w"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nogoogle-api-services-cloudresourcemanager-v1-rev20200720-1.30.10-PQqVlsOIu2M59XLbEl59CW6wNmY5OYy_R71khhZQ8-Y.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\243\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/42-EMBEDDED-gcsio-2.1.6-DDvpa0BcZtKnPC239b3P0szeJfKpgCbE1tZeDi1fMio.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n;gcsio-2.1.6-DDvpa0BcZtKnPC239b3P0szeJfKpgCbE1tZeDi1fMio.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\242\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/43-EMBEDDED-util-2.1.6-284LeJDNfVgny-ddI5wcKbvJN8Ug2xC2tZwCOF_F_pk.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n:util-2.1.6-284LeJDNfVgny-ddI5wcKbvJN8Ug2xC2tZwCOF_F_pk.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/44-EMBEDDED-google-api-services-storage-v1-rev20200611-1.30.10-INrcnpWLWvkN-Mf-ig-ab-lYg9NBuztZDHchm"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nbgoogle-api-services-storage-v1-rev20200611-1.30.10-INrcnpWLWvkN-Mf-ig-ab-lYg9NBuztZDHchmNhVCVc.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\267\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/45-EMBEDDED-google-api-client-java6-1.30.10-m2I4oHqNXjz0pJ-TP3zK5_cofaMLXRJwTHexGAhXg04.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nOgoogle-api-client-java6-1.30.10-m2I4oHqNXjz0pJ-TP3zK5_cofaMLXRJwTHexGAhXg04.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\272\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/46-EMBEDDED-google-api-client-jackson2-1.30.10-VpK9R1T0BTfZBKYo0BYUAFSlh5Bc_I_Q_fdy5_Z9rTc.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nRgoogle-api-client-jackson2-1.30.10-VpK9R1T0BTfZBKYo0BYUAFSlh5Bc_I_Q_fdy5_Z9rTc.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/47-EMBEDDED-google-api-services-iamcredentials-v1-rev20201022-1.30.10-KY-5cxRydZDW8rX96DEAbTnLjTcfn_"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nigoogle-api-services-iamcredentials-v1-rev20201022-1.30.10-KY-5cxRydZDW8rX96DEAbTnLjTcfn_SMGgOAUiNbN38.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\261\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/48-EMBEDDED-google-api-client-1.30.10-7bDzALb3Oeai2wPM6a7-ITpWzwAmZClXyRvl43ox-lE.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nIgoogle-api-client-1.30.10-7bDzALb3Oeai2wPM6a7-ITpWzwAmZClXyRvl43ox-lE.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\252\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/49-EMBEDDED-hadoop-auth-2.10.1-bQBa26Dmk_izZNA8mb830PpLP5U7UqZ21o0J5W1Zr1Y.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nBhadoop-auth-2.10.1-bQBa26Dmk_izZNA8mb830PpLP5U7UqZ21o0J5W1Zr1Y.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\256\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/50-EMBEDDED-curator-recipes-2.13.0-Ir4FwaPmxe3iLnc3KwjcYxo7k7ZKy39oJTfqZabdugY.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nFcurator-recipes-2.13.0-Ir4FwaPmxe3iLnc3KwjcYxo7k7ZKy39oJTfqZabdugY.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\260\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/51-EMBEDDED-curator-framework-2.13.0-2whOXg_tBUioEo8So-ehXIdclZXnUxbJV41k53N1xKk.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nHcurator-framework-2.13.0-2whOXg_tBUioEo8So-ehXIdclZXnUxbJV41k53N1xKk.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\255\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/52-EMBEDDED-curator-client-2.13.0-YqsiAbW5r2OyFaTmgp2-fVU6CAXPsLGmZfm0nagnDFE.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nEcurator-client-2.13.0-YqsiAbW5r2OyFaTmgp2-fVU6CAXPsLGmZfm0nagnDFE.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\250\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/53-EMBEDDED-grpc-alts-1.32.2--ZC6OnLbAv2d_q5SI7JiYWDRIvoZhuBdpNxqpfNveQA.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n@grpc-alts-1.32.2--ZC6OnLbAv2d_q5SI7JiYWDRIvoZhuBdpNxqpfNveQA.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\276\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/54-EMBEDDED-google-auth-library-oauth2-http-0.21.1-Hv_9dSHbDzcIUoTvrY32SZvHv_0XE-98dTdpK601brc.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nVgoogle-auth-library-oauth2-http-0.21.1-Hv_9dSHbDzcIUoTvrY32SZvHv_0XE-98dTdpK601brc.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\272\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/55-EMBEDDED-google-http-client-jackson2-1.36.0-ZBMVy9W29KBp3MjVnmj8_6RywV8JbhGAhe58prLtV0k.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nRgoogle-http-client-jackson2-1.36.0-ZBMVy9W29KBp3MjVnmj8_6RywV8JbhGAhe58prLtV0k.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\270\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/56-EMBEDDED-google-oauth-client-java6-1.31.0-nGYS21dwrwkEoUPYFWsIkA4BWwYgS-D7Dsqi_bA4tdU.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nPgoogle-oauth-client-java6-1.31.0-nGYS21dwrwkEoUPYFWsIkA4BWwYgS-D7Dsqi_bA4tdU.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\262\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/57-EMBEDDED-google-oauth-client-1.31.0-9fiaR9DCEOJ3VPxypLVvfxhohPwMB0pyoLY-Gc52QtA.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nJgoogle-oauth-client-1.31.0-9fiaR9DCEOJ3VPxypLVvfxhohPwMB0pyoLY-Gc52QtA.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\261\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/58-EMBEDDED-google-http-client-1.36.0-FsJUVitseNIt0cjra4WIpHzf3Qfw6ECLJ9kZQss8Jys.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nIgoogle-http-client-1.36.0-FsJUVitseNIt0cjra4WIpHzf3Qfw6ECLJ9kZQss8Jys.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\254\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/59-EMBEDDED-guava-retrying-2.0.0-X2BJpwxsL7VqXzo-E1DOHoU7XGzKugH7-caDXXKslIQ.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nDguava-retrying-2.0.0-X2BJpwxsL7VqXzo-E1DOHoU7XGzKugH7-caDXXKslIQ.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\250\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/60-EMBEDDED-grpc-auth-1.32.2-tXVw3UA6m9k1LDfn19L7hdIL7IdVNGEkn3Nkk5j64u8.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\[e-mail]"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\252\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/61-EMBEDDED-grpc-grpclb-1.32.2-Uhock4UYgrJH4slC6y9BpfjRJ-yrExibTernv194QBY.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nBgrpc-grpclb-1.32.2-Uhock4UYgrJH4slC6y9BpfjRJ-yrExibTernv194QBY.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\254\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/62-EMBEDDED-grpc-protobuf-1.32.2-w0rDphOeaIP11jbfUK-tfnfen4bTXw350rGvZ3nTdbc.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nDgrpc-protobuf-1.32.2-w0rDphOeaIP11jbfUK-tfnfen4bTXw350rGvZ3nTdbc.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\250\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/63-EMBEDDED-grpc-stub-1.32.2-Cb7aepW8MirhWxyDPJZguHRJkvdgmL_KiJ6fUoEdrc4.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n@grpc-stub-1.32.2-Cb7aepW8MirhWxyDPJZguHRJkvdgmL_KiJ6fUoEdrc4.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\261\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/64-EMBEDDED-protobuf-java-util-3.12.0-FLc01aNq-LufosYgt1sfpMcB58bzXVypTyeuN7Qpc6Y.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nIprotobuf-java-util-3.12.0-FLc01aNq-LufosYgt1sfpMcB58bzXVypTyeuN7Qpc6Y.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\275\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/65-EMBEDDED-hadoop-mapreduce-client-common-2.10.1-arqPLaCkcmvoxvSF4MeqbFyX3yOz_ogFRpeSjWNrQLw.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nUhadoop-mapreduce-client-common-2.10.1-arqPLaCkcmvoxvSF4MeqbFyX3yOz_ogFRpeSjWNrQLw.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\273\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/66-EMBEDDED-hadoop-mapreduce-client-core-2.10.1-ckjKJlrNpYV3610ySwWNAeslfACzE4un8_GEhljgMIg.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nShadoop-mapreduce-client-core-2.10.1-ckjKJlrNpYV3610ySwWNAeslfACzE4un8_GEhljgMIg.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\261\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/67-EMBEDDED-hadoop-yarn-client-2.10.1-XckP92wdceTuH5qxJJ-TW-vPQhD9o8LYZId9vesU7dg.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nIhadoop-yarn-client-2.10.1-XckP92wdceTuH5qxJJ-TW-vPQhD9o8LYZId9vesU7dg.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\261\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/68-EMBEDDED-hadoop-yarn-common-2.10.1-X_vtNq_EbKagW40r3DHgYBR9cgjKnejLGT0YlGVTXeU.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nIhadoop-yarn-common-2.10.1-X_vtNq_EbKagW40r3DHgYBR9cgjKnejLGT0YlGVTXeU.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\256\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/69-EMBEDDED-hadoop-yarn-api-2.10.1-z4MB8y0eZBVIZREunMoTNQtYUZ9Lk7v_qcSa-Uc5fUQ.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nFhadoop-yarn-api-2.10.1-z4MB8y0eZBVIZREunMoTNQtYUZ9Lk7v_qcSa-Uc5fUQ.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\273\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/70-EMBEDDED-opencensus-contrib-http-util-0.24.0-cVUnO7se09R36jPPGde7wLKF_zlfQ7Ka5XZyLPJHAA8.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nSopencensus-contrib-http-util-0.24.0-cVUnO7se09R36jPPGde7wLKF_zlfQ7Ka5XZyLPJHAA8.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\260\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/71-EMBEDDED-grpc-netty-shaded-1.32.2-jwcS3rpu2MJjPpzcnKpvCaKTLneldMIE3K22fEL83vU.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nHgrpc-netty-shaded-1.32.2-jwcS3rpu2MJjPpzcnKpvCaKTLneldMIE3K22fEL83vU.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\250\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/72-EMBEDDED-grpc-core-1.32.2-TKg9cKsQsqYM0qBsD6yBJicAALKToEJNmzzyB5TF7S0.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\[e-mail]"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\261\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/73-EMBEDDED-grpc-protobuf-lite-1.32.2-iJSr-113av7NbF-7whm6vXxOin7zuKEoPRuUP3w-6Vo.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nIgrpc-protobuf-lite-1.32.2-iJSr-113av7NbF-7whm6vXxOin7zuKEoPRuUP3w-6Vo.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\247\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/74-EMBEDDED-grpc-api-1.32.2-dZhDwk9nNuGJqc3If690Sv0UsrGWr3wZ7XBufzXKHhA.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n?grpc-api-1.32.2-dZhDwk9nNuGJqc3If690Sv0UsrGWr3wZ7XBufzXKHhA.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\246\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/75-EMBEDDED-guava-25.1-jre-bbDDokTDl0KcLjYuooN8NiLVtou5UQXTfCHDblvHCr8.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n>guava-25.1-jre-bbDDokTDl0KcLjYuooN8NiLVtou5UQXTfCHDblvHCr8.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\252\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/76-EMBEDDED-checker-qual-3.7.0-viA5cyFZ0T8_AIZ_IiI5kheKOyi4oUNyTrpCBqj9__M.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nBchecker-qual-3.7.0-viA5cyFZ0T8_AIZ_IiI5kheKOyi4oUNyTrpCBqj9__M.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\273\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/77-EMBEDDED-beam-model-pipeline-2.28.0-SNAPSHOT-io0m1nJQX84pY6rWKJIl2ko0iycNZu73WNDFFdYhreI.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nSbeam-model-pipeline-2.28.0-SNAPSHOT-io0m1nJQX84pY6rWKJIl2ko0iycNZu73WNDFFdYhreI.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\270\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/78-EMBEDDED-spark-network-shuffle_2.11-2.4.7-q8zZnKnuQtP5dF950fgS5pGTgPjGG9NbIoZsSlOg2Is.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nPspark-network-shuffle_2.11-2.4.7-q8zZnKnuQtP5dF950fgS5pGTgPjGG9NbIoZsSlOg2Is.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\267\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/79-EMBEDDED-spark-network-common_2.11-2.4.7--mcuLmo5zKARffljTpPwpfb_JU8wjZRBaDm00IFDH9c.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nOspark-network-common_2.11-2.4.7--mcuLmo5zKARffljTpPwpfb_JU8wjZRBaDm00IFDH9c.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\250\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/80-EMBEDDED-kafka_2.11-2.4.1-Xp58c5Vk-c0ZuvnuQg3ZneaYWzYJbU962x41gIIFYqk.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n@kafka_2.11-2.4.1-Xp58c5Vk-c0ZuvnuQg3ZneaYWzYJbU962x41gIIFYqk.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\270\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/81-EMBEDDED-jackson-module-scala_2.11-2.10.2-LoQ4jcp7jUzdwJxbYPG-BB5CzLJHC2o5E6Qu1k6Xofk.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nPjackson-module-scala_2.11-2.10.2-LoQ4jcp7jUzdwJxbYPG-BB5CzLJHC2o5E6Qu1k6Xofk.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\265\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/82-EMBEDDED-jackson-dataformat-csv-2.10.2-PxAn3VeIPEjd7sxsSL9DfUuIPfYrMi2YqEuWdadZsrk.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nMjackson-dataformat-csv-2.10.2-PxAn3VeIPEjd7sxsSL9DfUuIPfYrMi2YqEuWdadZsrk.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\264\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/83-EMBEDDED-jackson-datatype-jdk8-2.10.0-Yp1PtiBE8JSpXQ9vGjaROLcEfbJqKKb0cwVFGfY56Y0.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nLjackson-datatype-jdk8-2.10.0-Yp1PtiBE8JSpXQ9vGjaROLcEfbJqKKb0cwVFGfY56Y0.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\260\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/84-EMBEDDED-spark-kvstore_2.11-2.4.7-qm_-ZheHxSCaa1aGpOG5ytvwF5tU5L35vsFEXRlSzSA.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nHspark-kvstore_2.11-2.4.7-qm_-ZheHxSCaa1aGpOG5ytvwF5tU5L35vsFEXRlSzSA.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\252\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/85-EMBEDDED-metrics-json-3.1.5-LH5--mzfjUHyMusv6R-BHyJnXDb5p6cRxmYZu6-zvpY.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nBmetrics-json-3.1.5-LH5--mzfjUHyMusv6R-BHyJnXDb5p6cRxmYZu6-zvpY.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\263\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/86-EMBEDDED-kafka-avro-serializer-5.3.2-7FAoV2nngjZLbCXD3IPBOus_R_2KrM_zffAaNlVOls4.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nKkafka-avro-serializer-5.3.2-7FAoV2nngjZLbCXD3IPBOus_R_2KrM_zffAaNlVOls4.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\272\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/87-EMBEDDED-kafka-schema-registry-client-5.3.2-0mGQmXEF1E2hwRsR-O-mddgC_DwcNIU4Ba9SQcw2hKY.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nRkafka-schema-registry-client-5.3.2-0mGQmXEF1E2hwRsR-O-mddgC_DwcNIU4Ba9SQcw2hKY.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\267\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/88-EMBEDDED-jackson-module-paranamer-2.10.2-3hFzshNH-MLNBEFx_bTuninzeRzzHJo3QYfysy_lSO8.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nOjackson-module-paranamer-2.10.2-3hFzshNH-MLNBEFx_bTuninzeRzzHJo3QYfysy_lSO8.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\257\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/89-EMBEDDED-jackson-databind-2.10.2-QsJWRONfrfve0bfzWo0ecKhnN_GQ5DqixWzqS5bL2og.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nGjackson-databind-2.10.2-QsJWRONfrfve0bfzWo0ecKhnN_GQ5DqixWzqS5bL2og.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\262\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/90-EMBEDDED-jackson-annotations-2.10.2-jDy6ib8-A7NaDm-JLC6xftj93i4hTDpMGHA9Y3lrrkY.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nJjackson-annotations-2.10.2-jDy6ib8-A7NaDm-JLC6xftj93i4hTDpMGHA9Y3lrrkY.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\261\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/91-EMBEDDED-avro-mapred-1.8.2-hadoop2-Z7_oR87EiQ634VCEHpnPNiczrqGMA68EhrhLc2USZQg.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nIavro-mapred-1.8.2-hadoop2-Z7_oR87EiQ634VCEHpnPNiczrqGMA68EhrhLc2USZQg.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\246\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/92-EMBEDDED-avro-ipc-1.8.2-zveK2wkIRz47WJuVvlba1pI_LOUtSE0y8t0wbCJ51fE.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n>avro-ipc-1.8.2-zveK2wkIRz47WJuVvlba1pI_LOUtSE0y8t0wbCJ51fE.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\242\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/93-EMBEDDED-avro-1.8.2-91SggwzmelqfpnpU7BXRA-8V4chQ17Jvr3tkfu3cgtM.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n:avro-1.8.2-91SggwzmelqfpnpU7BXRA-8V4chQ17Jvr3tkfu3cgtM.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\250\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/94-EMBEDDED-avro-1.8.2-tests-HEy7CtrEiTEM7hQq7DJ5WARe8R9al5zBS5hzetDeO2U.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\[e-mail]"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\253\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/95-EMBEDDED-kafka-clients-2.4.1-or4Vrm01S3aXE64MuzGE8iWqFvyYIFseskr9n8KjYNk.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nCkafka-clients-2.4.1-or4Vrm01S3aXE64MuzGE8iWqFvyYIFseskr9n8KjYNk.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\300\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/96-EMBEDDED-beam-model-job-management-2.28.0-SNAPSHOT-WVx32zW-P-h_7-88x9BhCprKzKQffHmHgpSAHJ6YqmE.ja"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nYbeam-model-job-management-2.28.0-SNAPSHOT-WVx32zW-P-h_7-88x9BhCprKzKQffHmHgpSAHJ6YqmE.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\277\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/97-EMBEDDED-beam-model-fn-execution-2.28.0-SNAPSHOT-LNzbHzl9XC9ZtCOdV4qyG5-kdMvqxG2WN2NUzsJsRvk.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nWbeam-model-fn-execution-2.28.0-SNAPSHOT-LNzbHzl9XC9ZtCOdV4qyG5-kdMvqxG2WN2NUzsJsRvk.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\263\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/98-EMBEDDED-beam-vendor-grpc-1_26_0-0.3-SEmsD4-h8ovjlLQ5knmFJ-2g4YIiwqMzwlbcJ9EeRdA.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nKbeam-vendor-grpc-1_26_0-0.3-SEmsD4-h8ovjlLQ5knmFJ-2g4YIiwqMzwlbcJ9EeRdA.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\261\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/99-EMBEDDED-junit-quickcheck-core-0.8-mw7TO8vQe8FVrOYKKjeKuzDesi4PHMvcbrlzBNhwz1I.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nIjunit-quickcheck-core-0.8-mw7TO8vQe8FVrOYKKjeKuzDesi4PHMvcbrlzBNhwz1I.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\250\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/100-EMBEDDED-zookeeper-3.5.7-QstW_ae85xl4c7mz8ymQk52TVE3F47Cvd-3GXNSq31M.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\n?zookeeper-3.5.7-QstW_ae85xl4c7mz8ymQk52TVE3F47Cvd-3GXNSq31M.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\253\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/101-EMBEDDED-metrics-core-2.2.0-a3oUpvNMEPhoP3teLznfDwe1jH3_DkaOu8cTkFxGl5w.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nBmetrics-core-2.2.0-a3oUpvNMEPhoP3teLznfDwe1jH3_DkaOu8cTkFxGl5w.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\261\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/102-EMBEDDED-scala-logging_2.11-3.9.2-WWLxi2nNer1thu6fYo934tUB8MyS--8HDE8enz6po-A.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nHscala-logging_2.11-3.9.2-WWLxi2nNer1thu6fYo934tUB8MyS--8HDE8enz6po-A.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\254\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/103-EMBEDDED-jul-to-slf4j-1.7.16-pn2Y0nv8vBIODvv0fPB_q4XLMraydNQyV6KfoUu2WdA.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nCjul-to-slf4j-1.7.16-pn2Y0nv8vBIODvv0fPB_q4XLMraydNQyV6KfoUu2WdA.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\256\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/104-EMBEDDED-jcl-over-slf4j-1.7.16-dk2GmOAMCN-9j2Qm7ZVhnL9UczJ6Kn07a-prHZh8ZUc.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nEjcl-over-slf4j-1.7.16-dk2GmOAMCN-9j2Qm7ZVhnL9UczJ6Kn07a-prHZh8ZUc.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\255\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/105-EMBEDDED-slf4j-log4j12-1.7.30-TUHgHEDK-KbHSt0rBzBV2KTOHDDlgVQXexPxLXirvns.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nDslf4j-log4j12-1.7.30-TUHgHEDK-KbHSt0rBzBV2KTOHDDlgVQXexPxLXirvns.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\252\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/106-EMBEDDED-metrics-jvm-3.1.5-nj7KQm9c9hh1BUBqlNOw44DjIxV0CSU_VZxnnm2wFwQ.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nAmetrics-jvm-3.1.5-nj7KQm9c9hh1BUBqlNOw44DjIxV0CSU_VZxnnm2wFwQ.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\257\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/107-EMBEDDED-metrics-graphite-3.1.5-r3QBviVvLpGj15mVf-isCkRAem3wmAkqD54U_rXImcU.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nFmetrics-graphite-3.1.5-r3QBviVvLpGj15mVf-isCkRAem3wmAkqD54U_rXImcU.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\253\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/108-EMBEDDED-metrics-core-3.1.5-edkD1K6FDJ3ujTk55b2NQXKpH9pAsxt-QKXYw-H-RTQ.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nBmetrics-core-3.1.5-edkD1K6FDJ3ujTk55b2NQXKpH9pAsxt-QKXYw-H-RTQ.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\256\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/109-EMBEDDED-orc-core-1.5.5-nohive-HtbSj_SIACGgDi_pQQSD8M9o5XMeU9E9ySkPd_klh7Q.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\nEorc-core-1.5.5-nohive-HtbSj_SIACGgDi_pQQSD8M9o5XMeU9E9ySkPd_klh7Q.jar"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\254\001/tmp/beam-artifact-staging/d51ed496425528397a80ae2b861e462b4faf942819a72249bdd4ea3cc83f3f95/110-EMBEDDED-arrow-vector-0.10.0-fiZPKPO5wDUSkaJBXk
...[truncated 425786 chars]...
nWYCMbTMc3vr_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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/303-EMBEDDED-javax.json-1.0.4-Dh3sQKHt6WWUElHtqWiu7gUsxPUDeLwxbMSOgVm9vrQ.jar"
  role_urn: "beam:artifact:role:staging_to:v1"
  role_payload: "\[e-mail]"
}
dependencies {
  type_urn: "beam:artifact:type:file:v1"
  type_payload: "\n\243\001/tmp/beam-artifact-staging/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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/a4a90b248c86be67c71616e41b10237392c2e87e4552d2bdd11613566e758c44/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 12:33:58 INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService: 1 Beam Fn Logging clients still connected during shutdown.
20/12/17 12:33:58 WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer: Hanged up for unknown endpoint.
20/12/17 12:33:58 ERROR org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer: Failed to handle for url: "InProcessServer_304"

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 12:33:58 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder: No new watermarks could be computed upon completion of batch: 1608208417500
20/12/17 12:33:58 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder$WatermarkAdvancingStreamingListener: Batch with timestamp: 1608208417500 has completed, watermarks have been updated.
20/12/17 12:33:59 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder: No new watermarks could be computed upon completion of batch: 1608208418000
20/12/17 12:33:59 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder$WatermarkAdvancingStreamingListener: Batch with timestamp: 1608208418000 has completed, watermarks have been updated.
20/12/17 12:33:59 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder: No new watermarks could be computed upon completion of batch: 1608208418500
20/12/17 12:33:59 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder$WatermarkAdvancingStreamingListener: Batch with timestamp: 1608208418500 has completed, watermarks have been updated.
Dec 17, 2020 12:33:59 PM org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference cleanQueue
SEVERE: *~*~*~ Channel ManagedChannelImpl{logId=2088, target=directaddress:///InProcessServer_304} 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 12:33:59 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder: No new watermarks could be computed upon completion of batch: 1608208419000
20/12/17 12:33:59 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder$WatermarkAdvancingStreamingListener: Batch with timestamp: 1608208419000 has completed, watermarks have been updated.
20/12/17 12:34:00 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder: No new watermarks could be computed upon completion of batch: 1608208419500
20/12/17 12:34:00 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder$WatermarkAdvancingStreamingListener: Batch with timestamp: 1608208419500 has completed, watermarks have been updated.
20/12/17 12:34:00 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder: No new watermarks could be computed upon completion of batch: 1608208420000
20/12/17 12:34:00 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder$WatermarkAdvancingStreamingListener: Batch with timestamp: 1608208420000 has completed, watermarks have been updated.
20/12/17 12:34:00 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder: No new watermarks could be computed upon completion of batch: 1608208420500
20/12/17 12:34:00 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder$WatermarkAdvancingStreamingListener: Batch with timestamp: 1608208420500 has completed, watermarks have been updated.
20/12/17 12:34:00 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder: No new watermarks could be computed upon completion of batch: 1608208421000
20/12/17 12:34:00 INFO org.apache.beam.runners.spark.util.GlobalWatermarkHolder$WatermarkAdvancingStreamingListener: Batch with timestamp: 1608208421000 has completed, watermarks have been updated.
20/12/17 12:34:01 INFO org.apache.beam.runners.spark.SparkPipelineRunner: Job reifytimestampstest0extractfromvaluessucceeds-jenkins-1217123322-3ef050a8_8259aac7-7163-4d07-8acf-c836cd2a9265 finished.
20/12/17 12:34:01 WARN org.apache.spark.streaming.StreamingContext: StreamingContext has already been stopped
20/12/17 12:34:02 INFO org.apache.beam.runners.jobsubmission.InMemoryJobService: Getting job metrics for reifytimestampstest0extractfromvaluessucceeds-jenkins-1217123322-3ef050a8_8259aac7-7163-4d07-8acf-c836cd2a9265
20/12/17 12:34:02 INFO org.apache.beam.runners.jobsubmission.InMemoryJobService: Finished getting job metrics for reifytimestampstest0extractfromvaluessucceeds-jenkins-1217123322-3ef050a8_8259aac7-7163-4d07-8acf-c836cd2a9265
20/12/17 12:34:02 INFO org.apache.beam.runners.jobsubmission.JobServerDriver: JobServer stopped on localhost:41677
20/12/17 12:34:02 INFO org.apache.beam.runners.jobsubmission.JobServerDriver: ArtifactStagingServer stopped on localhost:44109
20/12/17 12:34:02 INFO org.apache.beam.runners.jobsubmission.JobServerDriver: Expansion stopped on localhost:43697
20/12/17 12:34:02 INFO org.apache.beam.runners.jobsubmission.JobServerDriver: ArtifactStagingService started on localhost:46229
20/12/17 12:34:02 INFO org.apache.beam.runners.jobsubmission.JobServerDriver: Java ExpansionService started on localhost:40321
20/12/17 12:34:02 INFO org.apache.beam.runners.jobsubmission.JobServerDriver: JobService started on localhost:44029
20/12/17 12:34:04 INFO org.apache.beam.runners.portability.PortableRunner: Using job server endpoint: localhost:44029
Dec 17, 2020 12:34:04 PM org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference cleanQueue
SEVERE: *~*~*~ Channel ManagedChannelImpl{logId=2080, target=directaddress:///InProcessServer_300} 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 12:34:05 PM org.apache.beam.vendor.grpc.v1p26p0.io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference cleanQueue
SEVERE: *~*~*~ Channel ManagedChannelImpl{logId=2084, target=directaddress:///InProcessServer_305} 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 12:34:05 INFO org.apache.beam.runners.portability.PortableRunner: PrepareJobResponse: preparation_id: "reifytimestampstest0invaluessucceeds-jenkins-1217123404-54c80868_f17c2e82-bf37-4cee-ba9a-068e585aa87e"
artifact_staging_endpoint {
  url: "localhost:46229"
}
staging_session_token: "reifytimestampstest0invaluessucceeds-jenkins-1217123404-54c80868_f17c2e82-bf37-4cee-ba9a-068e585aa87e"

20/12/17 12:34:05 INFO org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Staging artifacts for reifytimestampstest0invaluessucceeds-jenkins-1217123404-54c80868_f17c2e82-bf37-4cee-ba9a-068e585aa87e.
20/12/17 12:34:05 INFO org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Resolving artifacts for reifytimestampstest0invaluessucceeds-jenkins-1217123404-54c80868_f17c2e82-bf37-4cee-ba9a-068e585aa87e.EMBEDDED.
20/12/17 12:34:05 INFO org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Getting 313 artifacts for reifytimestampstest0invaluessucceeds-jenkins-1217123404-54c80868_f17c2e82-bf37-4cee-ba9a-068e585aa87e.null.
20/12/17 12:34:05 INFO org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: Artifacts fully staged for reifytimestampstest0invaluessucceeds-jenkins-1217123404-54c80868_f17c2e82-bf37-4cee-ba9a-068e585aa87e.
20/12/17 12:34:05 INFO org.apache.beam.runners.spark.SparkJobInvoker: Invoking job reifytimestampstest0invaluessucceeds-jenkins-1217123404-54c80868_f01a425f-efaf-4882-8cfa-bc9af7726086
20/12/17 12:34:05 INFO org.apache.beam.runners.jobsubmission.JobInvocation: Starting job invocation reifytimestampstest0invaluessucceeds-jenkins-1217123404-54c80868_f01a425f-efaf-4882-8cfa-bc9af7726086
20/12/17 12:34:05 INFO org.apache.beam.runners.portability.PortableRunner: RunJobResponse: job_id: "reifytimestampstest0invaluessucceeds-jenkins-1217123404-54c80868_f01a425f-efaf-4882-8cfa-bc9af7726086"

20/12/17 12:34:05 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 12:34:05 INFO org.apache.beam.runners.spark.translation.SparkContextFactory: Creating a brand new Spark Context.
20/12/17 12:34:05 INFO org.apache.beam.runners.spark.SparkPipelineRunner: Running job reifytimestampstest0invaluessucceeds-jenkins-1217123404-54c80868_f01a425f-efaf-4882-8cfa-bc9af7726086 on Spark master local[4]
20/12/17 12:34:05 INFO org.apache.beam.runners.spark.SparkPipelineRunner: Running job reifytimestampstest0invaluessucceeds-jenkins-1217123404-54c80868_f01a425f-efaf-4882-8cfa-bc9af7726086 on Spark master local[4]
20/12/17 12:34:05 INFO org.apache.beam.runners.spark.SparkPipelineRunner: Job reifytimestampstest0invaluessucceeds-jenkins-1217123404-54c80868_f01a425f-efaf-4882-8cfa-bc9af7726086: Pipeline translated successfully. Computing outputs
20/12/17 12:34:05 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:05 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:06 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:06 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:06 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:06 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:07 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:07 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:07 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:07 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:08 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:08 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:08 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:08 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:09 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:09 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:09 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:09 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:10 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:10 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:10 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:10 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:11 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:11 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:11 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:11 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:12 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:12 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:12 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:12 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:13 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:13 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:13 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:13 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:14 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:14 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:14 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:14 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:15 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:15 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:15 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:15 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:16 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:16 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:16 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:16 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:17 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:17 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:17 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:17 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:18 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:18 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:18 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:18 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:19 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:19 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:19 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:19 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:20 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:20 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:20 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:20 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:21 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:21 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:21 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:21 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:22 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:22 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:22 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:22 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:23 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:23 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:23 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:23 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:24 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:24 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:24 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:24 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:25 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:25 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:25 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:25 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:26 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:26 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:26 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:26 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:27 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:27 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:27 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:27 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:28 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:28 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:28 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:28 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:29 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:29 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:29 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:29 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:30 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:30 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:30 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:30 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:31 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:31 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:31 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:31 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:32 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:32 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:32 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:32 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:33 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:33 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:33 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:33 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:34 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:34 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:34 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:34 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:35 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:35 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:35 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:35 WARN org.apache.spark.streaming.dstream.QueueInputDStream: queueStream doesn't support checkpointing
20/12/17 12:34:35 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 12:34:37 ERROR org.apache.spark.util.Utils: Aborting task
java.io.IOException: Failed to connect to localhost/127.0.0.1:40515
	at org.apache.spark.network.client.TransportClientFactory.createClient(TransportClientFactory.java:245)
	at org.apache.spark.network.client.TransportClientFactory.createClient(TransportClientFactory.java:187)
	at org.apache.spark.rpc.netty.NettyRpcEnv.org$apache$spark$rpc$netty$NettyRpcEnv$$downloadClient(NettyRpcEnv.scala:368)
	at org.apache.spark.rpc.netty.NettyRpcEnv$$anonfun$openChannel$1.apply$mcV$sp(NettyRpcEnv.scala:336)
	at org.apache.spark.rpc.netty.NettyRpcEnv$$anonfun$openChannel$1.apply(NettyRpcEnv.scala:335)
	at org.apache.spark.rpc.netty.NettyRpcEnv$$anonfun$openChannel$1.apply(NettyRpcEnv.scala:335)
	at org.apache.spark.util.Utils$.tryWithSafeFinallyAndFailureCallbacks(Utils.scala:1394)
	at org.apache.spark.rpc.netty.NettyRpcEnv.openChannel(NettyRpcEnv.scala:339)
	at org.apache.spark.util.Utils$.doFetchFile(Utils.scala:693)
	at org.apache.spark.util.Utils$.fetchFile(Utils.scala:509)
	at org.apache.spark.executor.Executor$$anonfun$org$apache$spark$executor$Executor$$updateDependencies$5.apply(Executor.scala:816)
	at org.apache.spark.executor.Executor$$anonfun$org$apache$spark$executor$Executor$$updateDependencies$5.apply(Executor.scala:808)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:733)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:130)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:130)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:236)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:40)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:130)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:732)
	at org.apache.spark.executor.Executor.org$apache$spark$executor$Executor$$updateDependencies(Executor.scala:808)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:375)
	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)
Caused by: java.lang.IllegalStateException: executor not accepting a task
	at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
	at io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
	at io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
	at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
	at io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
	at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:577)
	at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:551)
	at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:490)
	at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:615)
	at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:604)
	at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
	at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
	at io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:984)
	at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:504)
	at io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:417)
	at io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:474)
	at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
	at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	... 1 more
20/12/17 12:34:37 WARN org.apache.spark.util.Utils: Suppressing exception in catch: null
java.lang.NullPointerException
	at org.apache.spark.util.Utils$.tryWithSafeFinallyAndFailureCallbacks(Utils.scala:1402)
	at org.apache.spark.rpc.netty.NettyRpcEnv.openChannel(NettyRpcEnv.scala:339)
	at org.apache.spark.util.Utils$.doFetchFile(Utils.scala:693)
	at org.apache.spark.util.Utils$.fetchFile(Utils.scala:509)
	at org.apache.spark.executor.Executor$$anonfun$org$apache$spark$executor$Executor$$updateDependencies$5.apply(Executor.scala:816)
	at org.apache.spark.executor.Executor$$anonfun$org$apache$spark$executor$Executor$$updateDependencies$5.apply(Executor.scala:808)
	at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:733)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:130)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:130)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:236)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:40)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:130)
	at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:732)
	at org.apache.spark.executor.Executor.org$apache$spark$executor$Executor$$updateDependencies(Executor.scala:808)
	at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:375)
	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 12:34:37 ERROR org.apache.spark.executor.Executor: Exception in task 0.0 in stage 0.0 (TID 0): Failed to connect to localhost/127.0.0.1:40515
20/12/17 12:34:37 INFO org.apache.beam.runners.spark.SparkPipelineRunner: Job reifytimestampstest0invaluessucceeds-jenkins-1217123404-54c80868_f01a425f-efaf-4882-8cfa-bc9af7726086 finished.
20/12/17 12:34:37 WARN org.apache.spark.streaming.StreamingContext: StreamingContext has already been stopped
20/12/17 12:34:37 ERROR org.apache.spark.executor.Executor: Exception in task 3.0 in stage 0.0 (TID 3): Cannot retrieve files with 'spark' scheme without an active SparkEnv.
20/12/17 12:34:37 ERROR org.apache.spark.executor.Executor: Exception in task 2.0 in stage 0.0 (TID 2): null
20/12/17 12:34:37 ERROR org.apache.spark.executor.Executor: Exception in task 1.0 in stage 0.0 (TID 1): null
20/12/17 12:34:38 INFO org.apache.beam.runners.jobsubmission.InMemoryJobService: Getting job metrics for reifytimestampstest0invaluessucceeds-jenkins-1217123404-54c80868_f01a425f-efaf-4882-8cfa-bc9af7726086
20/12/17 12:34:38 INFO org.apache.beam.runners.jobsubmission.InMemoryJobService: Finished getting job metrics for reifytimestampstest0invaluessucceeds-jenkins-1217123404-54c80868_f01a425f-efaf-4882-8cfa-bc9af7726086
20/12/17 12:34:38 INFO org.apache.beam.runners.jobsubmission.JobServerDriver: JobServer stopped on localhost:44029
20/12/17 12:34:38 INFO org.apache.beam.runners.jobsubmission.JobServerDriver: ArtifactStagingServer stopped on localhost:46229
20/12/17 12:34:38 INFO org.apache.beam.runners.jobsubmission.JobServerDriver: Expansion stopped on localhost:40321