Alex Amato created BEAM-12540:
---------------------------------
Summary: beam_PostRelease_NightlySnapshot - Task
:runners:direct-java:runMobileGamingJavaDirect FAILED
Key: BEAM-12540
URL: https://issues.apache.org/jira/browse/BEAM-12540
Project: Beam
Issue Type: Test
Components: test-failures
Reporter: Alex Amato
04:11:00 >04:11:00 >Task :runners:direct-java:runMobileGamingJavaDirect
04:11:00 bq rm -f -t
beam_postrelease_mobile_gaming.leaderboard_DirectRunner_team04:11:00 bq query
SELECT table_id FROM beam_postrelease_mobile_gaming.__TABLES_SUMMARY__04:11:00
04:11:00 Waiting on bqjob_r60cba783e1715a5e_0000017a42dd4a75_1 ... (0s) Current
status: RUNNING04:11:00
04:11:00 Waiting on
bqjob_r60cba783e1715a5e_0000017a42dd4a75_1 ... (0s) Current status: DONE
04:11:00 +-----------------------------------+04:11:00 | table_id
|04:11:00 +-----------------------------------+04:11:00 |
hourly_team_score_python_dataflow |04:11:00 | hourly_team_score_python_direct
|04:11:00 | leaderboard_DataflowRunner_team |04:11:00 |
leaderboard_DataflowRunner_user |04:11:00
+-----------------------------------+04:11:00 mvn compile exec:java
-Dexec.mainClass=org.apache.beam.examples.complete.game.injector.Injector
-Dexec.args="apache-beam-testing java_mobile_gaming_topic none"04:11:00 Using
maven /home/jenkins/tools/maven/apache-maven-3.5.404:11:00 mvn compile
exec:java -q -Dmaven.wagon.http.retryHandler.class=default
-Dmaven.wagon.http.retryHandler.count=5 -Dmaven.wagon.http.pool=false
-Dmaven.wagon.httpconnectionManager.ttlSeconds=120
-Dhttp.keepAlive=false
-Dexec.mainClass=org.apache.beam.examples.complete.game.LeaderBoard
-Dexec.args="--tempLocation=gs://temp-storage-for-release-validation-tests/nightly-snapshot-validation/tmp
--runner=DirectRunner --project=apache-beam-testing
--dataset=beam_postrelease_mobile_gaming
--topic=projects/apache-beam-testing/topics/java_mobile_gaming_topic
--leaderBoardTableName=leaderboard_DirectRunner --teamWindowDuration=5
--jobName=leaderboard-validation-1624619439411-78 "
-Pdirect-runner04:11:00 Using maven
/home/jenkins/tools/maven/apache-maven-3.5.404:11:00 bq query SELECT table_id
FROM beam_postrelease_mobile_gaming.__TABLES_SUMMARY__04:11:00 [INFO] Scanning
for projects...04:11:00 [INFO] 04:11:00 [INFO] --------------------<
org.example:word-count-beam >---------------------04:11:00 [INFO] Building
word-count-beam 0.104:11:00 [INFO] --------------------------------[ jar
]---------------------------------04:11:00 04:11:00 Waiting on
bqjob_r31f5ca34693bc4a1_0000017a42dd577e_1 ... (0s) Current status:
RUNNING04:11:00
04:11:00 Waiting on
bqjob_r31f5ca34693bc4a1_0000017a42dd577e_1 ... (0s) Current status: DONE
04:11:00 +-----------------------------------+04:11:00 | table_id
|04:11:00 +-----------------------------------+04:11:00 |
hourly_team_score_python_dataflow |04:11:00 | hourly_team_score_python_direct
|04:11:00 | leaderboard_DataflowRunner_team |04:11:00 |
leaderboard_DataflowRunner_user |04:11:00
+-----------------------------------+04:11:00 [INFO] Downloading from
test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-portability-java/2.32.0-SNAPSHOT/maven-metadata.xml
04:11:00 [INFO] Downloading from apache.snapshots:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-portability-java/2.32.0-SNAPSHOT/maven-metadata.xml
04:11:00 Waiting for pipeline to produce more results...04:11:00 [INFO]
Downloaded from apache.snapshots:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-portability-java/2.32.0-SNAPSHOT/maven-metadata.xml
(1.7 kB at 1.4 kB/s)04:11:00 [INFO] Downloaded from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-portability-java/2.32.0-SNAPSHOT/maven-metadata.xml
(1.7 kB at 1.4 kB/s)04:11:00 [INFO] Downloading from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-portability-java/2.32.0-SNAPSHOT/beam-runners-portability-java-2.32.0-20210625.070206-19.pom
04:11:00 [INFO] Downloaded from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-portability-java/2.32.0-SNAPSHOT/beam-runners-portability-java-2.32.0-20210625.070206-19.pom
(16 kB at 45 kB/s)04:11:00 [INFO] Downloading from apache.snapshots:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-java-job-service/2.32.0-SNAPSHOT/maven-metadata.xml
04:11:00 [INFO] Downloading from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-java-job-service/2.32.0-SNAPSHOT/maven-metadata.xml
04:11:00 [INFO] Downloaded from apache.snapshots:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-java-job-service/2.32.0-SNAPSHOT/maven-metadata.xml
(1.7 kB at 6.9 kB/s)04:11:00 [INFO] Downloaded from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-java-job-service/2.32.0-SNAPSHOT/maven-metadata.xml
(1.7 kB at 6.9 kB/s)04:11:00 [INFO] Downloading from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-java-job-service/2.32.0-SNAPSHOT/beam-runners-java-job-service-2.32.0-20210625.070206-19.pom
04:11:00 [INFO] Downloaded from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-java-job-service/2.32.0-SNAPSHOT/beam-runners-java-job-service-2.32.0-20210625.070206-19.pom
(17 kB at 51 kB/s)04:11:00 [INFO] Downloading from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/commons/commons-compress/1.20/commons-compress-1.20.pom
04:11:00 [INFO] Downloading from central:
https://repo.maven.apache.org/maven2/org/apache/commons/commons-compress/1.20/commons-compress-1.20.pom
04:11:00 [INFO] Downloaded from central:
https://repo.maven.apache.org/maven2/org/apache/commons/commons-compress/1.20/commons-compress-1.20.pom
(18 kB at 165 kB/s)04:11:00 [INFO] Downloading from test.release:
https://repository.apache.org/content/repositories/snapshots/args4j/args4j/2.33/args4j-2.33.pom
04:11:00 [INFO] Downloading from central:
https://repo.maven.apache.org/maven2/args4j/args4j/2.33/args4j-2.33.pom
04:11:00 [INFO] Downloaded from central:
https://repo.maven.apache.org/maven2/args4j/args4j/2.33/args4j-2.33.pom
(1.3 kB at 48 kB/s)04:11:00 [INFO] Downloading from test.release:
https://repository.apache.org/content/repositories/snapshots/args4j/args4j-site/2.33/args4j-site-2.33.pom
04:11:00 [INFO] Downloading from central:
https://repo.maven.apache.org/maven2/args4j/args4j-site/2.33/args4j-site-2.33.pom
04:11:00 [INFO] Downloaded from central:
https://repo.maven.apache.org/maven2/args4j/args4j-site/2.33/args4j-site-2.33.pom
(4.4 kB at 164 kB/s)04:11:00 [INFO] Downloading from test.release:
https://repository.apache.org/content/repositories/snapshots/org/kohsuke/pom/14/pom-14.pom
04:11:00 [INFO] Downloading from central:
https://repo.maven.apache.org/maven2/org/kohsuke/pom/14/pom-14.pom
04:11:00 [INFO] Downloaded from central:
https://repo.maven.apache.org/maven2/org/kohsuke/pom/14/pom-14.pom
(5.5 kB at 203 kB/s)04:11:00 [INFO] Downloading from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-sdks-java-harness/2.32.0-SNAPSHOT/maven-metadata.xml
04:11:00 [INFO] Downloading from apache.snapshots:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-sdks-java-harness/2.32.0-SNAPSHOT/maven-metadata.xml
04:11:00 [INFO] Downloaded from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-sdks-java-harness/2.32.0-SNAPSHOT/maven-metadata.xml
(1.7 kB at 3.5 kB/s)04:11:00 [INFO] Downloaded from apache.snapshots:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-sdks-java-harness/2.32.0-SNAPSHOT/maven-metadata.xml
(1.7 kB at 3.5 kB/s)04:11:00 [INFO] Downloading from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-sdks-java-harness/2.32.0-SNAPSHOT/beam-sdks-java-harness-2.32.0-20210625.070206-19.pom
04:11:00 [INFO] Downloaded from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-sdks-java-harness/2.32.0-SNAPSHOT/beam-sdks-java-harness-2.32.0-20210625.070206-19.pom
(4.1 kB at 17 kB/s)04:11:00 [INFO] Downloading from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-portability-java/2.32.0-SNAPSHOT/beam-runners-portability-java-2.32.0-20210625.070206-19.jar
04:11:00 [INFO] Downloading from test.release:
https://repository.apache.org/content/repositories/snapshots/args4j/args4j/2.33/args4j-2.33.jar
04:11:00 [INFO] Downloading from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-java-job-service/2.32.0-SNAPSHOT/beam-runners-java-job-service-2.32.0-20210625.070206-19.jar
04:11:00 [INFO] Downloading from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-sdks-java-harness/2.32.0-SNAPSHOT/beam-sdks-java-harness-2.32.0-20210625.070206-19.jar
04:11:00 [INFO] Downloaded from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-portability-java/2.32.0-SNAPSHOT/beam-runners-portability-java-2.32.0-20210625.070206-19.jar
(47 kB at 102 kB/s)04:11:00 [INFO] Downloaded from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-runners-java-job-service/2.32.0-SNAPSHOT/beam-runners-java-job-service-2.32.0-20210625.070206-19.jar
(59 kB at 84 kB/s)04:11:00 Jun 25, 2021 11:10:48 AM
org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSource
createRandomSubscription04:11:00 WARNING: Created subscription
projects/apache-beam-testing/subscriptions/java_mobile_gaming_topic_beam_8645954854694430782
to topic projects/apache-beam-testing/topics/java_mobile_gaming_topic. Note
this subscription WILL NOT be deleted when the pipeline terminates04:11:00
[INFO] Downloaded from test.release:
https://repository.apache.org/content/repositories/snapshots/org/apache/beam/beam-sdks-java-harness/2.32.0-SNAPSHOT/beam-sdks-java-harness-2.32.0-20210625.070206-19.jar
(67 MB at 17 MB/s)04:11:00 [INFO] Downloading from central:
https://repo.maven.apache.org/maven2/args4j/args4j/2.33/args4j-2.33.jar
04:11:00 [INFO] Downloaded from central:
https://repo.maven.apache.org/maven2/args4j/args4j/2.33/args4j-2.33.jar
(155 kB at 2.6 MB/s)04:11:00 [INFO] 04:11:00 [INFO] ---
maven-resources-plugin:2.6:resources (default-resources) @ word-count-beam
---04:11:00 [WARNING] Using platform encoding (UTF-8 actually) to copy filtered
resources, i.e. build is platform dependent!04:11:00 [INFO] skip non existing
resourceDirectory
/tmp/groovy-generated-514136545224591336-tmpdir/word-count-beam/src/main/resources04:11:00
[INFO] 04:11:00 [INFO] --- maven-compiler-plugin:3.7.0:compile
(default-compile) @ word-count-beam ---04:11:00 [INFO] Nothing to compile - all
classes are up to date04:11:00 [INFO] 04:11:00 [INFO] ---
exec-maven-plugin:1.6.0:java (default-cli) @ word-count-beam ---04:11:00
fullTopicName
projects/apache-beam-testing/topics/java_mobile_gaming_topic04:11:00 Injecting
to topic: projects/apache-beam-testing/topics/java_mobile_gaming_topic04:11:00
Starting Injector04:11:00 [+(AmethystKangaroo, num members: 17, starting at:
1624619451835, expires in: 26, robot: null)]04:11:00 [+(ArmyGreenCockatoo, num
members: 16, starting at: 1624619451836, expires in: 21, robot:
Robot-15)]04:11:00 [+(AzureDingo, num members: 18, starting at: 1624619451836,
expires in: 24, robot: null)]04:11:00 [+(FuchsiaQuokka, num members: 9,
starting at: 1624619451836, expires in: 33, robot: null)]04:11:00
[+(AppleGreenCassowary, num members: 5, starting at: 1624619451836, expires in:
21, robot: null)]04:11:00 [+(AntiqueBrassCaneToad, num members: 7, starting at:
1624619451836, expires in: 35, robot: null)]04:11:00 [+(AmethystEchidna, num
members: 14, starting at: 1624619451836, expires in: 32, robot:
Robot-12)]04:11:00 [+(AmethystBilby, num members: 12, starting at:
1624619451837, expires in: 36, robot: null)]04:11:00 [+(AndroidGreenPlatypus,
num members: 14, starting at: 1624619451837, expires in: 24, robot:
Robot-13)]04:11:00 [+(AmaranthWombat, num members: 5, starting at:
1624619451837, expires in: 39, robot: null)]04:11:00 [+(ApricotKoala, num
members: 13, starting at: 1624619451837, expires in: 30, robot: null)]04:11:00
[+(AuburnKangaroo, num members: 12, starting at: 1624619451837, expires in: 28,
robot: null)]04:11:00 [+(AliceBlueBandicoot, num members: 19, starting at:
1624619451837, expires in: 39, robot: Robot-15)]04:11:00 [+(BisqueKookaburra,
num members: 13, starting at: 1624619451837, expires in: 37, robot:
null)]04:11:00 [+(RubyEchidna, num members: 17, starting at: 1624619451838,
expires in: 23, robot: Robot-9)]04:11:00 DELAY(330982, 1)04:11:00
\{timestamp_ms=1624619120000}04:11:00 late data for:
user4_AmaranthWombat,AmaranthWombat,1,1624619120000,2021-06-25
04:10:51.84004:11:34 Jun 25, 2021 11:11:34 AM
io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference
cleanQueue04:11:34 SEVERE: *~*~*~ Channel ManagedChannelImpl\{logId=3,
target=bigquerystorage.googleapis.com:443} was not shutdown properly!!!
~*~*~*04:11:34 Make sure to call shutdown()/shutdownNow() and wait until
awaitTermination() returns true.04:11:34 java.lang.RuntimeException:
ManagedChannel allocation site04:11:34 at
io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference.<init>(ManagedChannelOrphanWrapper.java:93)04:11:34
at
io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:53)04:11:34
at
io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:44)04:11:34
at
io.grpc.internal.ManagedChannelImplBuilder.build(ManagedChannelImplBuilder.java:615)04:11:34
at
io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:261)04:11:34
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createSingleChannel(InstantiatingGrpcChannelProvider.java:327)04:11:34
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.access$1700(InstantiatingGrpcChannelProvider.java:74)04:11:34
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider$1.createSingleChannel(InstantiatingGrpcChannelProvider.java:220)04:11:34
at com.google.api.gax.grpc.ChannelPool.create(ChannelPool.java:72)04:11:34 at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createChannel(InstantiatingGrpcChannelProvider.java:227)04:11:34
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.getTransportChannel(InstantiatingGrpcChannelProvider.java:210)04:11:34
at com.google.api.gax.rpc.ClientContext.create(ClientContext.java:169)04:11:34
at
com.google.cloud.bigquery.storage.v1beta2.stub.GrpcBigQueryWriteStub.create(GrpcBigQueryWriteStub.java:138)04:11:34
at
com.google.cloud.bigquery.storage.v1beta2.stub.BigQueryWriteStubSettings.createStub(BigQueryWriteStubSettings.java:145)04:11:34
at
com.google.cloud.bigquery.storage.v1beta2.BigQueryWriteClient.<init>(BigQueryWriteClient.java:128)04:11:34
at
com.google.cloud.bigquery.storage.v1beta2.BigQueryWriteClient.create(BigQueryWriteClient.java:109)04:11:34
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl.newBigQueryWriteClient(BigQueryServicesImpl.java:1260)04:11:34
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl.access$800(BigQueryServicesImpl.java:137)04:11:34
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl.<init>(BigQueryServicesImpl.java:508)04:11:34
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl.<init>(BigQueryServicesImpl.java:453)04:11:34
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl.getDatasetService(BigQueryServicesImpl.java:170)04:11:34
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO$Write.validate(BigQueryIO.java:2459)04:11:34
at
org.apache.beam.sdk.Pipeline$ValidateVisitor.enterCompositeTransform(Pipeline.java:662)04:11:34
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:581)04:11:34
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:585)04:11:34
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:585)04:11:34
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.access$500(TransformHierarchy.java:240)04:11:34
at
org.apache.beam.sdk.runners.TransformHierarchy.visit(TransformHierarchy.java:214)04:11:34
at
org.apache.beam.sdk.Pipeline.traverseTopologically(Pipeline.java:469)04:11:34
at org.apache.beam.sdk.Pipeline.validate(Pipeline.java:598)04:11:34 at
org.apache.beam.sdk.Pipeline.run(Pipeline.java:322)04:11:34 at
org.apache.beam.sdk.Pipeline.run(Pipeline.java:309)04:11:34 at
org.apache.beam.examples.complete.game.LeaderBoard.main(LeaderBoard.java:240)04:11:34
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)04:11:34 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)04:11:34
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)04:11:34
at java.lang.reflect.Method.invoke(Method.java:498)04:11:34 at
org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:282)04:11:34 at
java.lang.Thread.run(Thread.java:748)04:11:34 04:11:34 Jun 25, 2021 11:11:34 AM
io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference
cleanQueue04:11:34 SEVERE: *~*~*~ Channel ManagedChannelImpl\{logId=1,
target=bigquerystorage.googleapis.com:443} was not shutdown properly!!!
~*~*~*04:11:34 Make sure to call shutdown()/shutdownNow() and wait until
awaitTermination() returns true.04:11:34 java.lang.RuntimeException:
ManagedChannel allocation site04:11:34 at
io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference.<init>(ManagedChannelOrphanWrapper.java:93)04:11:34
at
io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:53)04:11:34
at
io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:44)04:11:34
at
io.grpc.internal.ManagedChannelImplBuilder.build(ManagedChannelImplBuilder.java:615)04:11:34
at
io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:261)04:11:34
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createSingleChannel(InstantiatingGrpcChannelProvider.java:327)04:11:34
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.access$1700(InstantiatingGrpcChannelProvider.java:74)04:11:34
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider$1.createSingleChannel(InstantiatingGrpcChannelProvider.java:220)04:11:34
at com.google.api.gax.grpc.ChannelPool.create(ChannelPool.java:72)04:11:34 at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createChannel(InstantiatingGrpcChannelProvider.java:227)04:11:34
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.getTransportChannel(InstantiatingGrpcChannelProvider.java:210)04:11:34
at com.google.api.gax.rpc.ClientContext.create(ClientContext.java:169)04:11:34
at
com.google.cloud.bigquery.storage.v1beta2.stub.GrpcBigQueryWriteStub.create(GrpcBigQueryWriteStub.java:138)04:11:34
at
com.google.cloud.bigquery.storage.v1beta2.stub.BigQueryWriteStubSettings.createStub(BigQueryWriteStubSettings.java:145)04:11:34
at
com.google.cloud.bigquery.storage.v1beta2.BigQueryWriteClient.<init>(BigQueryWriteClient.java:128)04:11:34
at
com.google.cloud.bigquery.storage.v1beta2.BigQueryWriteClient.create(BigQueryWriteClient.java:109)04:11:34
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl.newBigQueryWriteClient(BigQueryServicesImpl.java:1260)04:11:34
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl.access$800(BigQueryServicesImpl.java:137)04:11:34
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl.<init>(BigQueryServicesImpl.java:508)04:11:34
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl.<init>(BigQueryServicesImpl.java:453)04:11:34
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl.getDatasetService(BigQueryServicesImpl.java:170)04:11:34
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO$Write.validate(BigQueryIO.java:2459)04:11:34
at
org.apache.beam.sdk.Pipeline$ValidateVisitor.enterCompositeTransform(Pipeline.java:662)04:11:34
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:581)04:11:34
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:585)04:11:34
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:585)04:11:34
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.access$500(TransformHierarchy.java:240)04:11:34
at
org.apache.beam.sdk.runners.TransformHierarchy.visit(TransformHierarchy.java:214)04:11:34
at
org.apache.beam.sdk.Pipeline.traverseTopologically(Pipeline.java:469)04:11:34
at org.apache.beam.sdk.Pipeline.validate(Pipeline.java:598)04:11:34 at
org.apache.beam.sdk.Pipeline.run(Pipeline.java:322)04:11:34 at
org.apache.beam.sdk.Pipeline.run(Pipeline.java:309)04:11:34 at
org.apache.beam.examples.complete.game.LeaderBoard.main(LeaderBoard.java:240)04:11:34
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)04:11:34 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)04:11:34
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)04:11:34
at java.lang.reflect.Method.invoke(Method.java:498)04:11:34 at
org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:282)04:11:34 at
java.lang.Thread.run(Thread.java:748)04:11:34 04:11:34 Jun 25, 2021 11:11:34 AM
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl
createTable04:11:34 INFO: Trying to create BigQuery table:
apache-beam-testing:beam_postrelease_mobile_gaming.leaderboard_DirectRunner_team04:11:42
bq query SELECT table_id FROM
beam_postrelease_mobile_gaming.__TABLES_SUMMARY__04:11:44 04:11:45 Waiting on
bqjob_r5990917d1c6bc8ab_0000017a42de4ee7_1 ... (0s) Current status:
RUNNING04:11:45
04:11:46 Waiting on
bqjob_r5990917d1c6bc8ab_0000017a42de4ee7_1 ... (0s) Current status: DONE
04:11:46 +-----------------------------------+04:11:46 | table_id
|04:11:46 +-----------------------------------+04:11:46 |
hourly_team_score_python_dataflow |04:11:46 | hourly_team_score_python_direct
|04:11:46 | leaderboard_DataflowRunner_team |04:11:46 |
leaderboard_DataflowRunner_user |04:11:46 | leaderboard_DirectRunner_team
|04:11:46 +-----------------------------------+04:11:46 Waiting for pipeline to
produce more results...04:12:46 bq query SELECT table_id FROM
beam_postrelease_mobile_gaming.__TABLES_SUMMARY__04:12:48 04:12:49 Waiting on
bqjob_r413d61696d302c08_0000017a42df466b_1 ... (0s) Current status:
RUNNING04:12:49
04:12:49 Waiting on
bqjob_r413d61696d302c08_0000017a42df466b_1 ... (0s) Current status: DONE
04:12:49 +-----------------------------------+04:12:49 | table_id
|04:12:49 +-----------------------------------+04:12:49 |
hourly_team_score_python_dataflow |04:12:49 | hourly_team_score_python_direct
|04:12:49 | leaderboard_DataflowRunner_team |04:12:49 |
leaderboard_DataflowRunner_user |04:12:49 | leaderboard_DirectRunner_team
|04:12:49 +-----------------------------------+04:12:49 Waiting for pipeline to
produce more results...04:13:49 bq query SELECT table_id FROM
beam_postrelease_mobile_gaming.__TABLES_SUMMARY__04:13:51 04:13:53 Waiting on
bqjob_r67a5a9a2cb99c279_0000017a42e03ef0_1 ... (0s) Current status:
RUNNING04:13:53
04:13:53 Waiting on
bqjob_r67a5a9a2cb99c279_0000017a42e03ef0_1 ... (0s) Current status: DONE
04:13:53 +-----------------------------------+04:13:53 | table_id
|04:13:53 +-----------------------------------+04:13:53 |
hourly_team_score_python_dataflow |04:13:53 | hourly_team_score_python_direct
|04:13:53 | leaderboard_DataflowRunner_team |04:13:53 |
leaderboard_DataflowRunner_user |04:13:53 | leaderboard_DirectRunner_team
|04:13:53 +-----------------------------------+04:13:53 Waiting for pipeline to
produce more results...04:14:33
...........................................................................................................................................................................................................................................................................................................................................................................................................................................................Introducing
a parse error.04:14:49 [ERROR] Failed to execute goal
org.codehaus.mojo:exec-maven-plugin:1.6.0:java (default-cli) on project
word-count-beam: An exception occured while executing the Java class.
java.io.IOException: Premature EOF -> [Help 1]04:14:49 [ERROR] 04:14:49 [ERROR]
To see the full stack trace of the errors, re-run Maven with the -e
switch.04:14:49 [ERROR] Re-run Maven using the -X switch to enable full debug
logging.04:14:49 [ERROR] 04:14:49 [ERROR] For more information about the errors
and possible solutions, please read the following articles:04:14:49 [ERROR]
[Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoExecutionException
04:14:50 Jun 25, 2021 11:10:48 AM
org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSource
createRandomSubscription04:14:50 WARNING: Created subscription
projects/apache-beam-testing/subscriptions/java_mobile_gaming_topic_beam_8645954854694430782
to topic projects/apache-beam-testing/topics/java_mobile_gaming_topic. Note
this subscription WILL NOT be deleted when the pipeline terminates04:14:50 Jun
25, 2021 11:11:34 AM
io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference
cleanQueue04:14:50 SEVERE: *~*~*~ Channel ManagedChannelImpl\{logId=3,
target=bigquerystorage.googleapis.com:443} was not shutdown properly!!!
~*~*~*04:14:50 Make sure to call shutdown()/shutdownNow() and wait until
awaitTermination() returns true.04:14:50 java.lang.RuntimeException:
ManagedChannel allocation site04:14:50 at
io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference.<init>(ManagedChannelOrphanWrapper.java:93)04:14:50
at
io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:53)04:14:50
at
io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:44)04:14:50
at
io.grpc.internal.ManagedChannelImplBuilder.build(ManagedChannelImplBuilder.java:615)04:14:50
at
io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:261)04:14:50
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createSingleChannel(InstantiatingGrpcChannelProvider.java:327)04:14:50
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.access$1700(InstantiatingGrpcChannelProvider.java:74)04:14:50
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider$1.createSingleChannel(InstantiatingGrpcChannelProvider.java:220)04:14:50
at com.google.api.gax.grpc.ChannelPool.create(ChannelPool.java:72)04:14:50 at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createChannel(InstantiatingGrpcChannelProvider.java:227)04:14:50
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.getTransportChannel(InstantiatingGrpcChannelProvider.java:210)04:14:50
at com.google.api.gax.rpc.ClientContext.create(ClientContext.java:169)04:14:50
at
com.google.cloud.bigquery.storage.v1beta2.stub.GrpcBigQueryWriteStub.create(GrpcBigQueryWriteStub.java:138)04:14:50
at
com.google.cloud.bigquery.storage.v1beta2.stub.BigQueryWriteStubSettings.createStub(BigQueryWriteStubSettings.java:145)04:14:50
at
com.google.cloud.bigquery.storage.v1beta2.BigQueryWriteClient.<init>(BigQueryWriteClient.java:128)04:14:50
at
com.google.cloud.bigquery.storage.v1beta2.BigQueryWriteClient.create(BigQueryWriteClient.java:109)04:14:50
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl.newBigQueryWriteClient(BigQueryServicesImpl.java:1260)04:14:50
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl.access$800(BigQueryServicesImpl.java:137)04:14:50
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl.<init>(BigQueryServicesImpl.java:508)04:14:50
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl.<init>(BigQueryServicesImpl.java:453)04:14:50
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl.getDatasetService(BigQueryServicesImpl.java:170)04:14:50
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO$Write.validate(BigQueryIO.java:2459)04:14:50
at
org.apache.beam.sdk.Pipeline$ValidateVisitor.enterCompositeTransform(Pipeline.java:662)04:14:50
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:581)04:14:50
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:585)04:14:50
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:585)04:14:50
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.access$500(TransformHierarchy.java:240)04:14:50
at
org.apache.beam.sdk.runners.TransformHierarchy.visit(TransformHierarchy.java:214)04:14:50
at
org.apache.beam.sdk.Pipeline.traverseTopologically(Pipeline.java:469)04:14:50
at org.apache.beam.sdk.Pipeline.validate(Pipeline.java:598)04:14:50 at
org.apache.beam.sdk.Pipeline.run(Pipeline.java:322)04:14:50 at
org.apache.beam.sdk.Pipeline.run(Pipeline.java:309)04:14:50 at
org.apache.beam.examples.complete.game.LeaderBoard.main(LeaderBoard.java:240)04:14:50
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)04:14:50 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)04:14:50
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)04:14:50
at java.lang.reflect.Method.invoke(Method.java:498)04:14:50 at
org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:282)04:14:50 at
java.lang.Thread.run(Thread.java:748)04:14:50 04:14:50 Jun 25, 2021 11:11:34 AM
io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference
cleanQueue04:14:50 SEVERE: *~*~*~ Channel ManagedChannelImpl\{logId=1,
target=bigquerystorage.googleapis.com:443} was not shutdown properly!!!
~*~*~*04:14:50 Make sure to call shutdown()/shutdownNow() and wait until
awaitTermination() returns true.04:14:50 java.lang.RuntimeException:
ManagedChannel allocation site04:14:50 at
io.grpc.internal.ManagedChannelOrphanWrapper$ManagedChannelReference.<init>(ManagedChannelOrphanWrapper.java:93)04:14:50
at
io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:53)04:14:50
at
io.grpc.internal.ManagedChannelOrphanWrapper.<init>(ManagedChannelOrphanWrapper.java:44)04:14:50
at
io.grpc.internal.ManagedChannelImplBuilder.build(ManagedChannelImplBuilder.java:615)04:14:50
at
io.grpc.internal.AbstractManagedChannelImplBuilder.build(AbstractManagedChannelImplBuilder.java:261)04:14:50
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createSingleChannel(InstantiatingGrpcChannelProvider.java:327)04:14:50
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.access$1700(InstantiatingGrpcChannelProvider.java:74)04:14:50
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider$1.createSingleChannel(InstantiatingGrpcChannelProvider.java:220)04:14:50
at com.google.api.gax.grpc.ChannelPool.create(ChannelPool.java:72)04:14:50 at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.createChannel(InstantiatingGrpcChannelProvider.java:227)04:14:50
at
com.google.api.gax.grpc.InstantiatingGrpcChannelProvider.getTransportChannel(InstantiatingGrpcChannelProvider.java:210)04:14:50
at com.google.api.gax.rpc.ClientContext.create(ClientContext.java:169)04:14:50
at
com.google.cloud.bigquery.storage.v1beta2.stub.GrpcBigQueryWriteStub.create(GrpcBigQueryWriteStub.java:138)04:14:50
at
com.google.cloud.bigquery.storage.v1beta2.stub.BigQueryWriteStubSettings.createStub(BigQueryWriteStubSettings.java:145)04:14:50
at
com.google.cloud.bigquery.storage.v1beta2.BigQueryWriteClient.<init>(BigQueryWriteClient.java:128)04:14:50
at
com.google.cloud.bigquery.storage.v1beta2.BigQueryWriteClient.create(BigQueryWriteClient.java:109)04:14:50
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl.newBigQueryWriteClient(BigQueryServicesImpl.java:1260)04:14:50
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl.access$800(BigQueryServicesImpl.java:137)04:14:50
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl.<init>(BigQueryServicesImpl.java:508)04:14:50
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl.<init>(BigQueryServicesImpl.java:453)04:14:50
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl.getDatasetService(BigQueryServicesImpl.java:170)04:14:50
at
org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO$Write.validate(BigQueryIO.java:2459)04:14:50
at
org.apache.beam.sdk.Pipeline$ValidateVisitor.enterCompositeTransform(Pipeline.java:662)04:14:50
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:581)04:14:50
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:585)04:14:50
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:585)04:14:50
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.access$500(TransformHierarchy.java:240)04:14:50
at
org.apache.beam.sdk.runners.TransformHierarchy.visit(TransformHierarchy.java:214)04:14:50
at
org.apache.beam.sdk.Pipeline.traverseTopologically(Pipeline.java:469)04:14:50
at org.apache.beam.sdk.Pipeline.validate(Pipeline.java:598)04:14:50 at
org.apache.beam.sdk.Pipeline.run(Pipeline.java:322)04:14:50 at
org.apache.beam.sdk.Pipeline.run(Pipeline.java:309)04:14:50 at
org.apache.beam.examples.complete.game.LeaderBoard.main(LeaderBoard.java:240)04:14:50
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)04:14:50 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)04:14:50
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)04:14:50
at java.lang.reflect.Method.invoke(Method.java:498)04:14:50 at
org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:282)04:14:50 at
java.lang.Thread.run(Thread.java:748)04:14:50 04:14:50 Jun 25, 2021 11:11:34 AM
org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl
createTable04:14:50 INFO: Trying to create BigQuery table:
apache-beam-testing:beam_postrelease_mobile_gaming.leaderboard_DirectRunner_team04:14:50
[ERROR] Failed to execute goal org.codehaus.mojo:exec-maven-plugin:1.6.0:java
(default-cli) on project word-count-beam: An exception occured while executing
the Java class. java.io.IOException: Premature EOF -> [Help 1]04:14:50 [ERROR]
04:14:50 [ERROR] To see the full stack trace of the errors, re-run Maven with
the -e switch.04:14:50 [ERROR] Re-run Maven using the -X switch to enable full
debug logging.04:14:50 [ERROR] 04:14:50 [ERROR] For more information about the
errors and possible solutions, please read the following articles:04:14:50
[ERROR] [Help 1]
http://cwiki.apache.org/confluence/display/MAVEN/MojoExecutionException
04:14:50 [ERROR] Failed command04:14:50 04:14:50 >Task
:runners:direct-java:runMobileGamingJavaDirect
FAILED
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
