You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/11/23 06:00:27 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming
#1
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/1/display/redirect>
------------------------------------------
Started by timer
[EnvInject] - Loading node environment variables.
Building remotely on beam7 (beam) in workspace <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/>
Cloning the remote Git repository
Cloning repository https://github.com/apache/beam.git
> git init <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src> # timeout=10
Fetching upstream changes from https://github.com/apache/beam.git
> git --version # timeout=10
> git fetch --tags --progress https://github.com/apache/beam.git +refs/heads/*:refs/remotes/origin/*
> git config remote.origin.url https://github.com/apache/beam.git # timeout=10
> git config --add remote.origin.fetch +refs/heads/*:refs/remotes/origin/* # timeout=10
> git config remote.origin.url https://github.com/apache/beam.git # timeout=10
Fetching upstream changes from https://github.com/apache/beam.git
> git fetch --tags --progress https://github.com/apache/beam.git +refs/heads/*:refs/remotes/origin/* +refs/pull/${ghprbPullId}/*:refs/remotes/origin/pr/${ghprbPullId}/*
> git rev-parse origin/master^{commit} # timeout=10
Checking out Revision 11283720786aa1abd4a3fc11f7e173c4912146fd (origin/master)
> git config core.sparsecheckout # timeout=10
> git checkout -f 11283720786aa1abd4a3fc11f7e173c4912146fd
Commit message: "Merge pull request #7018 from seznam/simunek/disableCacheSparkRunner"
First time build. Skipping changelog.
Cleaning workspace
> git rev-parse --verify HEAD # timeout=10
Resetting working tree
> git reset --hard # timeout=10
> git clean -fdx # timeout=10
No emails were triggered.
[EnvInject] - Executing scripts and injecting environment variables after the SCM step.
[EnvInject] - Injecting as environment variables the properties content
SPARK_LOCAL_IP=127.0.0.1
[EnvInject] - Variables injected successfully.
[Gradle] - Launching build.
[src] $ <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/gradlew> --info --continue --max-workers=12 -Dorg.gradle.jvmargs=-Xms2g -Dorg.gradle.jvmargs=-Xmx4g :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
Initialized native services in: /home/jenkins/.gradle/native
To honour the JVM settings for this build a new JVM will be forked. Please consider using the daemon: https://docs.gradle.org/4.10.2/userguide/gradle_daemon.html.
Starting process 'Gradle build daemon'. Working directory: /home/jenkins/.gradle/daemon/4.10.2 Command: /usr/local/asfpackages/java/jdk1.8.0_191/bin/java -Xmx4g -Dfile.encoding=UTF-8 -Duser.country=US -Duser.language=en -Duser.variant -cp /home/jenkins/.gradle/wrapper/dists/gradle-4.10.2-all/9fahxiiecdb76a5g3aw9oi8rv/gradle-4.10.2/lib/gradle-launcher-4.10.2.jar org.gradle.launcher.daemon.bootstrap.GradleDaemon 4.10.2
Successfully started process 'Gradle build daemon'
An attempt to start the daemon took 0.766 secs.
The client will now receive all logging from the daemon (pid: 28676). The daemon log file: /home/jenkins/.gradle/daemon/4.10.2/daemon-28676.out.log
Closing daemon's stdin at end of input.
The daemon will no longer process any standard input.
Daemon will be stopped at the end of the build stopping after processing
Using 12 worker leases.
Starting Build
Parallel execution is an incubating feature.
> Configure project :buildSrc
Evaluating project ':buildSrc' using build file '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/buildSrc/build.gradle'.>
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/buildSrc/src/test/groovy',> not found
Selected primary task 'build' from project :
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/buildSrc/src/test/groovy',> not found
:buildSrc:compileJava (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
Using local directory build cache for build ':buildSrc' (location = /home/jenkins/.gradle/caches/build-cache-1, removeUnusedEntriesAfter = 7 days).
> Task :buildSrc:compileJava NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/buildSrc/src/main/java',> not found
Skipping task ':buildSrc:compileJava' as it has no source files and no previous output files.
:buildSrc:compileJava (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.069 secs.
:buildSrc:compileGroovy (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:compileGroovy FROM-CACHE
Build cache key for task ':buildSrc:compileGroovy' is 4cb80fd35b95a64f52a05936e5f8041c
Task ':buildSrc:compileGroovy' is not up-to-date because:
No history is available.
Origin for task ':buildSrc:compileGroovy': {executionTime=1976, hostName=apache-beam-jenkins-slave-group-v286, operatingSystem=Linux, buildInvocationId=jmegobkxerh3nmgywtmpeo5xmu, creationTime=1542844817988, type=org.gradle.api.tasks.compile.GroovyCompile_Decorated, userName=jenkins, gradleVersion=4.10.2, rootPath=/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Java_Examples_Dataflow_Cron/src/buildSrc, path=:compileGroovy}
Unpacked output for task ':buildSrc:compileGroovy' from cache.
:buildSrc:compileGroovy (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.104 secs.
:buildSrc:processResources (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:processResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/buildSrc/src/main/resources',> not found
Skipping task ':buildSrc:processResources' as it has no source files and no previous output files.
:buildSrc:processResources (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.003 secs.
:buildSrc:classes (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:classes UP-TO-DATE
Skipping task ':buildSrc:classes' as it has no actions.
:buildSrc:classes (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.0 secs.
:buildSrc:jar (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:jar
Build cache key for task ':buildSrc:jar' is 3d294c22742df76cdd7820564cf2d216
Caching disabled for task ':buildSrc:jar': Caching has not been enabled for the task
Task ':buildSrc:jar' is not up-to-date because:
No history is available.
:buildSrc:jar (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.126 secs.
:buildSrc:assemble (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:assemble
Skipping task ':buildSrc:assemble' as it has no actions.
:buildSrc:assemble (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.0 secs.
:buildSrc:spotlessGroovy (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:spotlessGroovy
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/buildSrc/src/test/groovy',> not found
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/buildSrc/src/test/groovy',> not found
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/buildSrc/src/test/groovy',> not found
Caching disabled for task ':buildSrc:spotlessGroovy': Caching has not been enabled for the task
Task ':buildSrc:spotlessGroovy' is not up-to-date because:
No history is available.
All input files are considered out-of-date for incremental task ':buildSrc:spotlessGroovy'.
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/buildSrc/src/test/groovy',> not found
:buildSrc:spotlessGroovy (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 1.727 secs.
:buildSrc:spotlessGroovyCheck (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:spotlessGroovyCheck
Skipping task ':buildSrc:spotlessGroovyCheck' as it has no actions.
:buildSrc:spotlessGroovyCheck (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.001 secs.
:buildSrc:spotlessGroovyGradle (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:spotlessGroovyGradle
Caching disabled for task ':buildSrc:spotlessGroovyGradle': Caching has not been enabled for the task
Task ':buildSrc:spotlessGroovyGradle' is not up-to-date because:
No history is available.
All input files are considered out-of-date for incremental task ':buildSrc:spotlessGroovyGradle'.
:buildSrc:spotlessGroovyGradle (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.03 secs.
:buildSrc:spotlessGroovyGradleCheck (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:spotlessGroovyGradleCheck
Skipping task ':buildSrc:spotlessGroovyGradleCheck' as it has no actions.
:buildSrc:spotlessGroovyGradleCheck (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.0 secs.
:buildSrc:spotlessCheck (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:spotlessCheck
Skipping task ':buildSrc:spotlessCheck' as it has no actions.
:buildSrc:spotlessCheck (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.0 secs.
:buildSrc:compileTestJava (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:compileTestJava NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/buildSrc/src/test/java',> not found
Skipping task ':buildSrc:compileTestJava' as it has no source files and no previous output files.
:buildSrc:compileTestJava (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.001 secs.
:buildSrc:compileTestGroovy (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:compileTestGroovy NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/buildSrc/src/test/groovy',> not found
Skipping task ':buildSrc:compileTestGroovy' as it has no source files and no previous output files.
:buildSrc:compileTestGroovy (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.001 secs.
:buildSrc:processTestResources (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:processTestResources NO-SOURCE
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/buildSrc/src/test/resources',> not found
Skipping task ':buildSrc:processTestResources' as it has no source files and no previous output files.
:buildSrc:processTestResources (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.002 secs.
:buildSrc:testClasses (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:testClasses UP-TO-DATE
Skipping task ':buildSrc:testClasses' as it has no actions.
:buildSrc:testClasses (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.0 secs.
:buildSrc:test (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:test NO-SOURCE
Skipping task ':buildSrc:test' as it has no source files and no previous output files.
:buildSrc:test (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.003 secs.
:buildSrc:check (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:check
Skipping task ':buildSrc:check' as it has no actions.
:buildSrc:check (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.0 secs.
:buildSrc:build (Thread[Task worker for ':buildSrc' Thread 7,5,main]) started.
> Task :buildSrc:build
Skipping task ':buildSrc:build' as it has no actions.
:buildSrc:build (Thread[Task worker for ':buildSrc' Thread 7,5,main]) completed. Took 0.0 secs.
Invalidating in-memory cache of /home/jenkins/.gradle/caches/4.10.2/fileHashes/fileHashes.bin
Invalidating in-memory cache of /home/jenkins/.gradle/caches/4.10.2/fileHashes/resourceHashesCache.bin
Invalidating in-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin
Settings evaluated using settings file '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/settings.gradle'.>
Using local directory build cache for the root build (location = /home/jenkins/.gradle/caches/build-cache-1, removeUnusedEntriesAfter = 7 days).
Projects loaded. Root project using build file '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/build.gradle'.>
Included projects: [root project 'beam', project ':beam-examples-java', project ':beam-model-fn-execution', project ':beam-model-job-management', project ':beam-model-pipeline', project ':beam-runners-apex', project ':beam-runners-core-construction-java', project ':beam-runners-core-java', project ':beam-runners-direct-java', project ':beam-runners-extensions-java-metrics', project ':beam-runners-flink_2.11', project ':beam-runners-flink_2.11-job-server', project ':beam-runners-flink_2.11-job-server-container', project ':beam-runners-gearpump', project ':beam-runners-google-cloud-dataflow-java', project ':beam-runners-google-cloud-dataflow-java-examples', project ':beam-runners-google-cloud-dataflow-java-examples-streaming', project ':beam-runners-google-cloud-dataflow-java-fn-api-worker', project ':beam-runners-google-cloud-dataflow-java-legacy-worker', project ':beam-runners-google-cloud-dataflow-java-windmill', project ':beam-runners-java-fn-execution', project ':beam-runners-local-java-core', project ':beam-runners-reference-java', project ':beam-runners-reference-job-server', project ':beam-runners-samza', project ':beam-runners-spark', project ':beam-sdks-go', project ':beam-sdks-go-container', project ':beam-sdks-go-examples', project ':beam-sdks-go-test', project ':beam-sdks-java-build-tools', project ':beam-sdks-java-container', project ':beam-sdks-java-core', project ':beam-sdks-java-extensions-euphoria', project ':beam-sdks-java-extensions-google-cloud-platform-core', project ':beam-sdks-java-extensions-join-library', project ':beam-sdks-java-extensions-json-jackson', project ':beam-sdks-java-extensions-kryo', project ':beam-sdks-java-extensions-protobuf', project ':beam-sdks-java-extensions-sketching', project ':beam-sdks-java-extensions-sorter', project ':beam-sdks-java-extensions-sql', project ':beam-sdks-java-extensions-sql-jdbc', project ':beam-sdks-java-extensions-sql-shell', project ':beam-sdks-java-fn-execution', project ':beam-sdks-java-harness', project ':beam-sdks-java-io-amazon-web-services', project ':beam-sdks-java-io-amqp', project ':beam-sdks-java-io-cassandra', project ':beam-sdks-java-io-common', project ':beam-sdks-java-io-elasticsearch', project ':beam-sdks-java-io-elasticsearch-tests-2', project ':beam-sdks-java-io-elasticsearch-tests-5', project ':beam-sdks-java-io-elasticsearch-tests-6', project ':beam-sdks-java-io-elasticsearch-tests-common', project ':beam-sdks-java-io-file-based-io-tests', project ':beam-sdks-java-io-google-cloud-platform', project ':beam-sdks-java-io-hadoop-common', project ':beam-sdks-java-io-hadoop-file-system', project ':beam-sdks-java-io-hadoop-input-format', project ':beam-sdks-java-io-hbase', project ':beam-sdks-java-io-hcatalog', project ':beam-sdks-java-io-jdbc', project ':beam-sdks-java-io-jms', project ':beam-sdks-java-io-kafka', project ':beam-sdks-java-io-kinesis', project ':beam-sdks-java-io-kudu', project ':beam-sdks-java-io-mongodb', project ':beam-sdks-java-io-mqtt', project ':beam-sdks-java-io-parquet', project ':beam-sdks-java-io-rabbitmq', project ':beam-sdks-java-io-redis', project ':beam-sdks-java-io-solr', project ':beam-sdks-java-io-synthetic', project ':beam-sdks-java-io-tika', project ':beam-sdks-java-io-xml', project ':beam-sdks-java-javadoc', project ':beam-sdks-java-load-tests', project ':beam-sdks-java-maven-archetypes-examples', project ':beam-sdks-java-maven-archetypes-starter', project ':beam-sdks-java-nexmark', project ':beam-sdks-java-test-utils', project ':beam-sdks-python', project ':beam-sdks-python-container', project ':beam-sdks-python-container-py3', project ':beam-test-infra-metrics', project ':beam-vendor-grpc-1_13_1', project ':beam-vendor-guava-20_0', project ':beam-vendor-sdks-java-extensions-protobuf', project ':beam-website', project ':release']
Parallel execution with configuration on demand is an incubating feature.
> Configure project :
Evaluating root project 'beam' using build file '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/build.gradle'.>
Invalidating in-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin
Invalidating in-memory cache of /home/jenkins/.gradle/caches/4.10.2/fileHashes/fileHashes.bin
Invalidating in-memory cache of /home/jenkins/.gradle/caches/4.10.2/fileHashes/resourceHashesCache.bin
Offline dependencies root configured at 'offline-repository'
> Configure project :beam-sdks-java-core
Evaluating project ':beam-sdks-java-core' using build file '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/sdks/java/core/build.gradle'.>
Invalidating in-memory cache of /home/jenkins/.gradle/caches/4.10.2/fileHashes/fileHashes.bin
Invalidating in-memory cache of /home/jenkins/.gradle/caches/4.10.2/fileHashes/resourceHashesCache.bin
Offline dependencies root configured at 'offline-repository'
> Configure project :beam-runners-flink_2.11-job-server
Evaluating project ':beam-runners-flink_2.11-job-server' using build file '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build.gradle'.>
Offline dependencies root configured at 'offline-repository'
> Configure project :beam-runners-core-java
Evaluating project ':beam-runners-core-java' using build file '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/core-java/build.gradle'.>
Invalidating in-memory cache of /home/jenkins/.gradle/caches/4.10.2/fileHashes/fileHashes.bin
Invalidating in-memory cache of /home/jenkins/.gradle/caches/4.10.2/fileHashes/resourceHashesCache.bin
Offline dependencies root configured at 'offline-repository'
> Configure project :beam-runners-flink_2.11-job-server
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/src/main/java',> not found
file or directory '<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/src/test/java',> not found
FAILURE: Build failed with an exception.
* What went wrong:
Task 'validatesPortableRunnerStreaming' not found in project ':beam-runners-flink_2.11-job-server'.
* Try:
Run gradlew tasks to get a list of available tasks. Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
BUILD FAILED in 10s
Publishing build scan...
https://gradle.com/s/vdu7f76n4uvua
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming
#3
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/3/display/redirect?page=changes>
Changes:
[katarzyna.kucharczyk] [BEAM-6115] SyntheticSource bundle size parameter sometimes should be
------------------------------------------
[...truncated 228.80 MB...]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (13/16) (22c323be4216c815ee9c8b180d8fa00f).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (13/16) (22c323be4216c815ee9c8b180d8fa00f) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 22c323be4216c815ee9c8b180d8fa00f.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (3/16) (c03e2a090f62ece8475fa6c0cece8bab) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (3/16) (494bfdf721bc04cbbb212e8a0e003e30) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (3/16) (494bfdf721bc04cbbb212e8a0e003e30).
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (3/16) (494bfdf721bc04cbbb212e8a0e003e30) [FINISHED]
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (13/16) (689fd876515f01f5cb042338a2de2e76) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (13/16) (689fd876515f01f5cb042338a2de2e76).
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16) (689fd876515f01f5cb042338a2de2e76) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 494bfdf721bc04cbbb212e8a0e003e30.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (13/16) (22c323be4216c815ee9c8b180d8fa00f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 689fd876515f01f5cb042338a2de2e76.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16) (494bfdf721bc04cbbb212e8a0e003e30) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (13/16) (689fd876515f01f5cb042338a2de2e76) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (bac5de0c0521a46d05e1a4e3b6e38ae1) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (bac5de0c0521a46d05e1a4e3b6e38ae1).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (bac5de0c0521a46d05e1a4e3b6e38ae1) [FINISHED]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (81cef17a0991ae63f962bb39b5ae5c0a) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (81cef17a0991ae63f962bb39b5ae5c0a).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (81cef17a0991ae63f962bb39b5ae5c0a) [FINISHED]
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (14/16) (82d96b117a133d1d5935005bd7d01422) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (14/16) (82d96b117a133d1d5935005bd7d01422).
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16) (82d96b117a133d1d5935005bd7d01422) [FINISHED]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (9/16) (50a15544c1f7cc302f4a3f759fd6aad3) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (9/16) (50a15544c1f7cc302f4a3f759fd6aad3).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (9/16) (50a15544c1f7cc302f4a3f759fd6aad3) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 bac5de0c0521a46d05e1a4e3b6e38ae1.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (7/16) (ba6b5843a6a5bc5695c314a43673a2ee) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (9/16) (93d6b7cfeb59baefd8736e25b779214b) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (9/16) (93d6b7cfeb59baefd8736e25b779214b).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 81cef17a0991ae63f962bb39b5ae5c0a.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16) (93d6b7cfeb59baefd8736e25b779214b) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 82d96b117a133d1d5935005bd7d01422.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 50a15544c1f7cc302f4a3f759fd6aad3.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (5/16) (30734ad643a64c8eb6b9c32f6b065622) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (5/16) (30734ad643a64c8eb6b9c32f6b065622).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (5/16) (30734ad643a64c8eb6b9c32f6b065622) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (bac5de0c0521a46d05e1a4e3b6e38ae1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 93d6b7cfeb59baefd8736e25b779214b.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 30734ad643a64c8eb6b9c32f6b065622.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (f10e5894841819d7c6ed16a63243ab51) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (f10e5894841819d7c6ed16a63243ab51).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (81cef17a0991ae63f962bb39b5ae5c0a) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (f10e5894841819d7c6ed16a63243ab51) [FINISHED]
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (5/16) (4fbcac15760c9f8daca1744d7218630b) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (5/16) (4fbcac15760c9f8daca1744d7218630b).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 f10e5894841819d7c6ed16a63243ab51.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (14/16) (82d96b117a133d1d5935005bd7d01422) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (5/16) (4fbcac15760c9f8daca1744d7218630b) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 4fbcac15760c9f8daca1744d7218630b.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (9/16) (50a15544c1f7cc302f4a3f759fd6aad3) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) (93d6b7cfeb59baefd8736e25b779214b) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (7/16) (ba6b5843a6a5bc5695c314a43673a2ee).
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16) (ba6b5843a6a5bc5695c314a43673a2ee) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem ba6b5843a6a5bc5695c314a43673a2ee.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (5/16) (30734ad643a64c8eb6b9c32f6b065622) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (4/16) (551ef905404842ad384b9319da46d175) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (4/16) (551ef905404842ad384b9319da46d175).
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (4/16) (551ef905404842ad384b9319da46d175) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 551ef905404842ad384b9319da46d175.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (35707d3c4af4b592c424b8b1f1f07c9c) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (35707d3c4af4b592c424b8b1f1f07c9c).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (35707d3c4af4b592c424b8b1f1f07c9c) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 35707d3c4af4b592c424b8b1f1f07c9c.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (f10e5894841819d7c6ed16a63243ab51) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16) (4fbcac15760c9f8daca1744d7218630b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16) (ba6b5843a6a5bc5695c314a43673a2ee) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16) (551ef905404842ad384b9319da46d175) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (35707d3c4af4b592c424b8b1f1f07c9c) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (2/16) (764d353582467cf7b070420cdd4b47e9) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (764d353582467cf7b070420cdd4b47e9).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (764d353582467cf7b070420cdd4b47e9) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 764d353582467cf7b070420cdd4b47e9.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (764d353582467cf7b070420cdd4b47e9) switched from RUNNING to FINISHED.
[grpc-default-executor-103] WARN org.apache.beam.sdk.metrics.MetricsEnvironment - Reporting metrics are not supported in the current execution environment.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (d282ce7f6f642763374029a0a0041033) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (d282ce7f6f642763374029a0a0041033).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (d282ce7f6f642763374029a0a0041033) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 d282ce7f6f642763374029a0a0041033.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (132941113521b118703020fc18c1a02f) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (132941113521b118703020fc18c1a02f).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (132941113521b118703020fc18c1a02f) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 132941113521b118703020fc18c1a02f.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (d282ce7f6f642763374029a0a0041033) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (132941113521b118703020fc18c1a02f) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (d21c2e7a2c081655af31a1bd1de0c211) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (d21c2e7a2c081655af31a1bd1de0c211).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (d21c2e7a2c081655af31a1bd1de0c211) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 d21c2e7a2c081655af31a1bd1de0c211.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (c923090f1d8d5076e6c3ea6df80e935d) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (c923090f1d8d5076e6c3ea6df80e935d).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (c923090f1d8d5076e6c3ea6df80e935d) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 c923090f1d8d5076e6c3ea6df80e935d.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (d21c2e7a2c081655af31a1bd1de0c211) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (c923090f1d8d5076e6c3ea6df80e935d) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (2d587a1f02fb240e3700c9b168787bab) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (2d587a1f02fb240e3700c9b168787bab).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (2d587a1f02fb240e3700c9b168787bab) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 2d587a1f02fb240e3700c9b168787bab.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (2d587a1f02fb240e3700c9b168787bab) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (5eebecbd565d4a1e4cbe5e1d0327f081) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (5eebecbd565d4a1e4cbe5e1d0327f081).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (5eebecbd565d4a1e4cbe5e1d0327f081) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 5eebecbd565d4a1e4cbe5e1d0327f081.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (0782331ebefc209457b04a440286626d) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (0782331ebefc209457b04a440286626d).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (12a6b204bdaf9a0231457a7673772af5) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (12a6b204bdaf9a0231457a7673772af5).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (0782331ebefc209457b04a440286626d) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (12a6b204bdaf9a0231457a7673772af5) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (f350e16ca31de7e867e4592f1160a313) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (f350e16ca31de7e867e4592f1160a313).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (f350e16ca31de7e867e4592f1160a313) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 0782331ebefc209457b04a440286626d.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 12a6b204bdaf9a0231457a7673772af5.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (5eebecbd565d4a1e4cbe5e1d0327f081) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 f350e16ca31de7e867e4592f1160a313.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (b995092b327a8c4857bd8077418ceec8) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (b995092b327a8c4857bd8077418ceec8).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (b995092b327a8c4857bd8077418ceec8) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (da94e1b0d69c2af384eeae3c640d1820) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 b995092b327a8c4857bd8077418ceec8.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (da94e1b0d69c2af384eeae3c640d1820).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (da94e1b0d69c2af384eeae3c640d1820) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (0782331ebefc209457b04a440286626d) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (61754e69cdd87ab26c6421e067c6b000) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (61754e69cdd87ab26c6421e067c6b000).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (61754e69cdd87ab26c6421e067c6b000) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 da94e1b0d69c2af384eeae3c640d1820.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (12a6b204bdaf9a0231457a7673772af5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 61754e69cdd87ab26c6421e067c6b000.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (f350e16ca31de7e867e4592f1160a313) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (8359497c0119ccbd1e90e1b8f0258a37) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (8359497c0119ccbd1e90e1b8f0258a37).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (8359497c0119ccbd1e90e1b8f0258a37) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (c5bb2f88e7fbbd8b83ac8db038a99793) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (c5bb2f88e7fbbd8b83ac8db038a99793).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (8986cea6e4a20e549bcdeca1aa8fdcb7) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (c5bb2f88e7fbbd8b83ac8db038a99793) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (8986cea6e4a20e549bcdeca1aa8fdcb7).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 8359497c0119ccbd1e90e1b8f0258a37.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (8986cea6e4a20e549bcdeca1aa8fdcb7) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (b995092b327a8c4857bd8077418ceec8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 c5bb2f88e7fbbd8b83ac8db038a99793.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (da94e1b0d69c2af384eeae3c640d1820) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 8986cea6e4a20e549bcdeca1aa8fdcb7.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (61754e69cdd87ab26c6421e067c6b000) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (8359497c0119ccbd1e90e1b8f0258a37) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (c5bb2f88e7fbbd8b83ac8db038a99793) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (8986cea6e4a20e549bcdeca1aa8fdcb7) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (97a867be2212cd85d0c2bbc5c1aa91e9) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (97a867be2212cd85d0c2bbc5c1aa91e9).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (97a867be2212cd85d0c2bbc5c1aa91e9) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 97a867be2212cd85d0c2bbc5c1aa91e9.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (97a867be2212cd85d0c2bbc5c1aa91e9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1123115201-965fbd12 (e83d9e9aeb8be79e9b931a8703a7ef73) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job e83d9e9aeb8be79e9b931a8703a7ef73.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job e83d9e9aeb8be79e9b931a8703a7ef73 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1123115201-965fbd12(e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job e83d9e9aeb8be79e9b931a8703a7ef73.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection b6d5af53fe6e1cfe0eb9548c17a67c1a: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager ab4b99f2dcce3b89abb258ab25be4a75@akka://flink/user/jobmanager_261 for job e83d9e9aeb8be79e9b931a8703a7ef73 from the resource manager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job e83d9e9aeb8be79e9b931a8703a7ef73 with leader id ab4b99f2dcce3b89abb258ab25be4a75 lost leadership.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher824c8fc0-edf1-4030-b5bd-1df4614e0f8e.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher824c8fc0-edf1-4030-b5bd-1df4614e0f8e.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{5066a43144f076053bcd93670abb7f4d}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{cc30921cb647abed81b6abf4a59982cb}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{f18250031a15dd28fec10ea065acbdd6}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{46410bef2a602e65b75163e173a131c1}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{2354f4225c7e2ac9f636f956e700febe}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{7aeee6a3a669902c2059fa4a7b9ac0a5}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{1b201d5b073356f8aeffcc4d5139c12b}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{e77ca3260c3a6cc378bf65678f1e19e2}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{afedce41289848e3b14af8b0c5591458}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{a925bfa37d9cc73f01c4ef22bd99ce6c}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{352bb38dd586efa2e3dcc0949388b18f}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{d62d17f6d66a19a350943ba0e4df54a9}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{a43fc5e507173a40bdf984e711dc1469}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{699f574bb013eb136cf5b215349e7b3a}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{bdb3966260bf6323897eb633caa5f1c8}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{b667d198ea5d0f62d2735141bd71fda7}, jobId: e83d9e9aeb8be79e9b931a8703a7ef73).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job e83d9e9aeb8be79e9b931a8703a7ef73 from job leader monitoring.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job e83d9e9aeb8be79e9b931a8703a7ef73.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-5db2dc29-06d7-4896-b666-a677ed3491c8
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher824c8fc0-edf1-4030-b5bd-1df4614e0f8e.
[ForkJoinPool.commonPool-worker-2] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:44943
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 6327 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Final accumulator values:
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@178678ea
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1123115201-965fbd12_f35cb3a8-8f72-4b70-9939-eb0a3c0df335/MANIFEST has 186 artifact locations
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1123115201-965fbd12_f35cb3a8-8f72-4b70-9939-eb0a3c0df335/
[pool-22513-thread-1] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:41711
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:32803
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
197 tests completed, 2 failed, 2 skipped
Finished generating test XML results (1.549 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunnerStreaming>
Generating HTML test report...
Finished generating test html results (1.032 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming>
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 32 mins 42.146 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 35m 33s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/isrhafrfarjik
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming
#2
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/2/display/redirect?page=changes>
Changes:
[ryan.blake.williams] gradle config for batch+streaming portable flink vr tests
[ryan.blake.williams] split flink PVR jenkins jobs for batch vs streaming
[mxm] [BEAM-5197] Fix flaky test UnboundedSourceWrapper#testWatermarkEmission
[thw] [BEAM-6116] [portable flink streaming] Emit pushed back watermark when
[ryan.blake.williams] fix batch vs stream job id
------------------------------------------
[...truncated 228.78 MB...]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) (1e883ee8828edf9369fa0fe7b83515ff) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16) (19d32e90788565bb32c2ebc0b5cca274) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (12/16) (3ba0cf84646fd33c7561c7b94f2f8108) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16) (aa42d1c957425820d8f67c9186b56aac) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (11/16) (73742a7e51f38037cfb90502bb196e28) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (3/16) (aef9ae6f8ae53549c73ff1ccfef0de97) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (3/16) (aef9ae6f8ae53549c73ff1ccfef0de97).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (3/16) (aef9ae6f8ae53549c73ff1ccfef0de97) [FINISHED]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (9f71b0135cf543500a4c8c8b781d8063) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (9f71b0135cf543500a4c8c8b781d8063).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (9f71b0135cf543500a4c8c8b781d8063) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 aef9ae6f8ae53549c73ff1ccfef0de97.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (1d7705a7cf6f4795712aba2439da2a9c) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (1d7705a7cf6f4795712aba2439da2a9c).
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (7/16) (07f325bd29db08d5f49cfe201af60762) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (7/16) (07f325bd29db08d5f49cfe201af60762).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (1d7705a7cf6f4795712aba2439da2a9c) [FINISHED]
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16) (07f325bd29db08d5f49cfe201af60762) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 9f71b0135cf543500a4c8c8b781d8063.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 1d7705a7cf6f4795712aba2439da2a9c.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (4/16) (9f1666596cac811b8ba8e15b114b51f7) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (4/16) (9f1666596cac811b8ba8e15b114b51f7).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (3/16) (aef9ae6f8ae53549c73ff1ccfef0de97) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (4/16) (9f1666596cac811b8ba8e15b114b51f7) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 07f325bd29db08d5f49cfe201af60762.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 9f1666596cac811b8ba8e15b114b51f7.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (9f71b0135cf543500a4c8c8b781d8063) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (3/16) (3f32d41adfc90ad70a3fa06525b64b78) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (3/16) (3f32d41adfc90ad70a3fa06525b64b78).
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (3/16) (3f32d41adfc90ad70a3fa06525b64b78) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 3f32d41adfc90ad70a3fa06525b64b78.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (1d7705a7cf6f4795712aba2439da2a9c) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (f1f56c1d8c011ad0cc562f2901f31917) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (f1f56c1d8c011ad0cc562f2901f31917).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (f1f56c1d8c011ad0cc562f2901f31917) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16) (07f325bd29db08d5f49cfe201af60762) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 f1f56c1d8c011ad0cc562f2901f31917.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16) (9f1666596cac811b8ba8e15b114b51f7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16) (3f32d41adfc90ad70a3fa06525b64b78) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (15/16) (40f924e57adbf4e441c34ed6c0eea9f1) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (15/16) (40f924e57adbf4e441c34ed6c0eea9f1).
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16) (40f924e57adbf4e441c34ed6c0eea9f1) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 40f924e57adbf4e441c34ed6c0eea9f1.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (f1f56c1d8c011ad0cc562f2901f31917) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (15/16) (40f924e57adbf4e441c34ed6c0eea9f1) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (1/16) (f20ab6f32db34477f78409e2d1e6cf1a) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (1/16) (f20ab6f32db34477f78409e2d1e6cf1a).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (1/16) (f20ab6f32db34477f78409e2d1e6cf1a) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 f20ab6f32db34477f78409e2d1e6cf1a.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (c3f3b41f69d17cb1fdb2d1adb69e953e) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (c3f3b41f69d17cb1fdb2d1adb69e953e).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (c3f3b41f69d17cb1fdb2d1adb69e953e) [FINISHED]
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/16) (042c4c02ba266f9c1d6f57016b5a48a0) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (1/16) (042c4c02ba266f9c1d6f57016b5a48a0).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 c3f3b41f69d17cb1fdb2d1adb69e953e.
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/16) (042c4c02ba266f9c1d6f57016b5a48a0) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (1/16) (f20ab6f32db34477f78409e2d1e6cf1a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 042c4c02ba266f9c1d6f57016b5a48a0.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (14/16) (a0c4f4fd9e51fa9310bbac0c1b1657d4) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (14/16) (a0c4f4fd9e51fa9310bbac0c1b1657d4).
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16) (a0c4f4fd9e51fa9310bbac0c1b1657d4) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (c3f3b41f69d17cb1fdb2d1adb69e953e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16) (042c4c02ba266f9c1d6f57016b5a48a0) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (0e660f3e302b0c0e579d44308ef0b17e) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (0e660f3e302b0c0e579d44308ef0b17e).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem a0c4f4fd9e51fa9310bbac0c1b1657d4.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (0e660f3e302b0c0e579d44308ef0b17e) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (14/16) (a0c4f4fd9e51fa9310bbac0c1b1657d4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 0e660f3e302b0c0e579d44308ef0b17e.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (2/16) (45166b48d7e86a11f19ff900ab69a902) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (45166b48d7e86a11f19ff900ab69a902).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (45166b48d7e86a11f19ff900ab69a902) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 45166b48d7e86a11f19ff900ab69a902.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (0e660f3e302b0c0e579d44308ef0b17e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (45166b48d7e86a11f19ff900ab69a902) switched from RUNNING to FINISHED.
[grpc-default-executor-144] WARN org.apache.beam.sdk.metrics.MetricsEnvironment - Reporting metrics are not supported in the current execution environment.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (83d780a337d945ebc3abc15025c17fe3) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (83d780a337d945ebc3abc15025c17fe3).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (83d780a337d945ebc3abc15025c17fe3) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 83d780a337d945ebc3abc15025c17fe3.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (26c70bb9c651d69917d3de56903b7537) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (8f98ae352ef579ace9db07b814607bbd) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (26c70bb9c651d69917d3de56903b7537).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (8f98ae352ef579ace9db07b814607bbd).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (83d780a337d945ebc3abc15025c17fe3) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (35ae041cb98ba8d0e9d033f424156c3c) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (35ae041cb98ba8d0e9d033f424156c3c).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (26c70bb9c651d69917d3de56903b7537) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (35ae041cb98ba8d0e9d033f424156c3c) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (8f98ae352ef579ace9db07b814607bbd) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 26c70bb9c651d69917d3de56903b7537.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (aaa1d461c3b90e0ef852dd6413c5551b) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (aaa1d461c3b90e0ef852dd6413c5551b).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (aaa1d461c3b90e0ef852dd6413c5551b) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 35ae041cb98ba8d0e9d033f424156c3c.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (26c70bb9c651d69917d3de56903b7537) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 8f98ae352ef579ace9db07b814607bbd.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 aaa1d461c3b90e0ef852dd6413c5551b.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (35ae041cb98ba8d0e9d033f424156c3c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (8f98ae352ef579ace9db07b814607bbd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (aaa1d461c3b90e0ef852dd6413c5551b) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (1ae76568aa21ffecfc25942f31495cdc) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (fa813b7b1835fec5eee3f96500ac18e7) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (fa813b7b1835fec5eee3f96500ac18e7).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (1ae76568aa21ffecfc25942f31495cdc).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (fa813b7b1835fec5eee3f96500ac18e7) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (1ae76568aa21ffecfc25942f31495cdc) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 fa813b7b1835fec5eee3f96500ac18e7.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 1ae76568aa21ffecfc25942f31495cdc.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (d35f54508f49aef2e2665a23eba9f2d0) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (d35f54508f49aef2e2665a23eba9f2d0).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (d35f54508f49aef2e2665a23eba9f2d0) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 d35f54508f49aef2e2665a23eba9f2d0.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (2b20c7e8d157611d7bf6d479ad08fad8) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (2b20c7e8d157611d7bf6d479ad08fad8).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (2b20c7e8d157611d7bf6d479ad08fad8) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (fa813b7b1835fec5eee3f96500ac18e7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 2b20c7e8d157611d7bf6d479ad08fad8.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (2f10f4c086de2265b165b9cf6c7dff3d) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (2f10f4c086de2265b165b9cf6c7dff3d).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (2f10f4c086de2265b165b9cf6c7dff3d) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (cb69fc997f4dd5f493e816f200d9e2cf) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (cb69fc997f4dd5f493e816f200d9e2cf).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (cb69fc997f4dd5f493e816f200d9e2cf) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 2f10f4c086de2265b165b9cf6c7dff3d.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (1ae76568aa21ffecfc25942f31495cdc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 cb69fc997f4dd5f493e816f200d9e2cf.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (ffd2f559e941c6e82aee63022e3c7d1c) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (ffd2f559e941c6e82aee63022e3c7d1c).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (d35f54508f49aef2e2665a23eba9f2d0) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (ffd2f559e941c6e82aee63022e3c7d1c) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 ffd2f559e941c6e82aee63022e3c7d1c.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (2b20c7e8d157611d7bf6d479ad08fad8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (2f10f4c086de2265b165b9cf6c7dff3d) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (102af668e1ab5d29dfc9cb5196aaa91c) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (102af668e1ab5d29dfc9cb5196aaa91c).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (102af668e1ab5d29dfc9cb5196aaa91c) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 102af668e1ab5d29dfc9cb5196aaa91c.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (148978c6c01549c113cda673641a4d31) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (148978c6c01549c113cda673641a4d31).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (44df5bec68b57debb9bd9c1cd96cda51) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (148978c6c01549c113cda673641a4d31) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (44df5bec68b57debb9bd9c1cd96cda51).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (44df5bec68b57debb9bd9c1cd96cda51) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (cb69fc997f4dd5f493e816f200d9e2cf) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 148978c6c01549c113cda673641a4d31.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 44df5bec68b57debb9bd9c1cd96cda51.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (ffd2f559e941c6e82aee63022e3c7d1c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (102af668e1ab5d29dfc9cb5196aaa91c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (148978c6c01549c113cda673641a4d31) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (44df5bec68b57debb9bd9c1cd96cda51) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (73868f3371d645916b220f28d3ac2213) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (73868f3371d645916b220f28d3ac2213).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (73868f3371d645916b220f28d3ac2213) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 73868f3371d645916b220f28d3ac2213.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (73868f3371d645916b220f28d3ac2213) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1123110455-b96ecb18 (0f48a67ecea41efe9f16960ea41569a0) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 0f48a67ecea41efe9f16960ea41569a0.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 0f48a67ecea41efe9f16960ea41569a0 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1123110455-b96ecb18(0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 0f48a67ecea41efe9f16960ea41569a0.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection cae180a66b2e56c1022ed25b2975c0c8: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager 845cb5c2459fef8e0839736945c04653@akka://flink/user/jobmanager_261 for job 0f48a67ecea41efe9f16960ea41569a0 from the resource manager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher2ae54ab5-c180-451c-a057-9c496f6a35dd.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher2ae54ab5-c180-451c-a057-9c496f6a35dd.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 0f48a67ecea41efe9f16960ea41569a0 with leader id 845cb5c2459fef8e0839736945c04653 lost leadership.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{0a9db8bc6b359b7cf906806efde93bfb}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{f6f88c77752ab680030a3a54bec94346}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{fdc4a0c8fa84266fb656a9750b2caa90}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{77d0c45b50726c456a13214611357b36}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{86f9b6b60a4f63808f99e143df9864a1}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{f29ba6008bed508235601019bf94c285}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{368845df1f71e09345243574a02bda3b}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{d6f5171daebb66e2991e0cdb663f8b92}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{ca057749d4f759d878fba7395b6a8600}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{f539c23b34e375238c81fd26889b8299}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{c65a194c445cd9c97a34860cd7a3b917}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{6259e4fd596210fdcedcf363f7c4352e}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{15152cd4dab2e81efabb04c6cf67d1a1}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{227e9708e0f0d4d6cdfe97e836b39b25}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{86025b544fc99d9c6b4bd3538bd8fca7}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{9043326193f9e244c6f33655b6b95479}, jobId: 0f48a67ecea41efe9f16960ea41569a0).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 0f48a67ecea41efe9f16960ea41569a0 from job leader monitoring.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 0f48a67ecea41efe9f16960ea41569a0.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-f1d1202f-b6e9-4b82-83c6-4c90fb6adb96
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher2ae54ab5-c180-451c-a057-9c496f6a35dd.
[ForkJoinPool.commonPool-worker-9] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-9] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:42429
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 6422 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Final accumulator values:
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@104820cc
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1123110455-b96ecb18_9aa917e1-6e15-4e94-8957-ba802b22d924/MANIFEST has 186 artifact locations
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1123110455-b96ecb18_9aa917e1-6e15-4e94-8957-ba802b22d924/
[pool-22513-thread-1] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:39193
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:33357
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
197 tests completed, 2 failed, 2 skipped
Finished generating test XML results (1.544 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.897 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming>
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming (Thread[Task worker for ':',5,main]) completed. Took 33 mins 32.29 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 35m 55s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/yixb6hx5xzs6e
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org