See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/129/display/redirect>
------------------------------------------
[...truncated 139.21 MB...]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) b3ee1629af27a01fad03da95dbd70603.
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (13/16) (dc5e1675d45c53034d352ff8bda5b4f4) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) 0ab5f0a45311d2b1c190ed0c2b12f87f.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (3/16) (04e11b1b152a11f0c7b0ae841c1c0648) switched from
RUNNING to FINISHED.
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (13/16) (dc5e1675d45c53034d352ff8bda5b4f4)
[DEPLOYING].
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16)
(dc5e1675d45c53034d352ff8bda5b4f4) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (9/16) (b3ee1629af27a01fad03da95dbd70603) switched from
RUNNING to FINISHED.
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16)
(dc5e1675d45c53034d352ff8bda5b4f4) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (13/16) (dc5e1675d45c53034d352ff8bda5b4f4).
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (13/16)
(dc5e1675d45c53034d352ff8bda5b4f4) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (11/16) (0ab5f0a45311d2b1c190ed0c2b12f87f) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) dc5e1675d45c53034d352ff8bda5b4f4.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (13/16) (dc5e1675d45c53034d352ff8bda5b4f4) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (13/16) (dc5e1675d45c53034d352ff8bda5b4f4) switched from
RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions}) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (13/16)
(5ffcba28450115bf71837e8d9ff4a9fe) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions}) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks,
VerifyAssertions}) (13/16) (5ffcba28450115bf71837e8d9ff4a9fe).
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions}) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally,
GetPane, RunChecks, VerifyAssertions}) (13/16)
(5ffcba28450115bf71837e8d9ff4a9fe) [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 MapPartition
(MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks,
VerifyAssertions}) 5ffcba28450115bf71837e8d9ff4a9fe.
[jobmanager-future-thread-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c) switched from
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (13/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks,
VerifyAssertions}) (13/16) (5ffcba28450115bf71837e8d9ff4a9fe) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (13/16).
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16)
(b528999c3b25970dbf73a8daf472673c) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (13/16)
(b528999c3b25970dbf73a8daf472673c) [DEPLOYING]
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c) [DEPLOYING].
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c)
[DEPLOYING].
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16)
(b528999c3b25970dbf73a8daf472673c) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16)
(b528999c3b25970dbf73a8daf472673c) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$78/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions}) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[5]PAssert$78/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (2/16)
(05746ceb9b72a2a3c63438818fc5ffa8) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$78/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions}) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at [5]PAssert$78/{GroupGlobally, GetPane, RunChecks,
VerifyAssertions}) (2/16) (05746ceb9b72a2a3c63438818fc5ffa8).
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c).
[jobmanager-future-thread-10] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60) switched from
CREATED to SCHEDULED.
[MapPartition (MapPartition at [5]PAssert$78/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions}) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task MapPartition (MapPartition at [5]PAssert$78/{GroupGlobally,
GetPane, RunChecks, VerifyAssertions}) (2/16)
(05746ceb9b72a2a3c63438818fc5ffa8) [FINISHED]
[DataSink (DiscardingOutput) (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (13/16)
(b528999c3b25970dbf73a8daf472673c) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [5]PAssert$78/{GroupGlobally, GetPane, RunChecks,
VerifyAssertions}) 05746ceb9b72a2a3c63438818fc5ffa8.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (2/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) b528999c3b25970dbf73a8daf472673c.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [5]PAssert$78/{GroupGlobally, GetPane, RunChecks,
VerifyAssertions}) (2/16) (05746ceb9b72a2a3c63438818fc5ffa8) switched from
RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions}) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (15/16)
(eecf93ca92c9253075414215033832c2) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions}) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks,
VerifyAssertions}) (15/16) (eecf93ca92c9253075414215033832c2).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c) switched from
RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions}) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally,
GetPane, RunChecks, VerifyAssertions}) (15/16)
(eecf93ca92c9253075414215033832c2) [FINISHED]
[jobmanager-future-thread-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd) switched from
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (2/16).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (15/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks,
VerifyAssertions}) eecf93ca92c9253075414215033832c2.
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16)
(a221f1fc5e2597d3702f38d5ee4b6a60) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (2/16)
(a221f1fc5e2597d3702f38d5ee4b6a60) [DEPLOYING]
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks,
VerifyAssertions}) (15/16) (eecf93ca92c9253075414215033832c2) switched from
RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60)
[DEPLOYING].
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16)
(a221f1fc5e2597d3702f38d5ee4b6a60) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (15/16).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16)
(a221f1fc5e2597d3702f38d5ee4b6a60) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60).
[DataSink (DiscardingOutput) (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (2/16)
(a221f1fc5e2597d3702f38d5ee4b6a60) [FINISHED]
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16)
(f14bf5d1ddbc92dd809a088839ce16bd) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (15/16)
(f14bf5d1ddbc92dd809a088839ce16bd) [DEPLOYING]
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd) [DEPLOYING].
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions}) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (4/16)
(d2edf14a2b863abbc04e3860f82545bc) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions}) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks,
VerifyAssertions}) (4/16) (d2edf14a2b863abbc04e3860f82545bc).
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions}) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally,
GetPane, RunChecks, VerifyAssertions}) (4/16)
(d2edf14a2b863abbc04e3860f82545bc) [FINISHED]
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd)
[DEPLOYING].
[jobmanager-future-thread-9] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) switched from
CREATED to SCHEDULED.
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16)
(f14bf5d1ddbc92dd809a088839ce16bd) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (4/16) (attempt #0) to localhost
[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 DataSink
(DiscardingOutput) a221f1fc5e2597d3702f38d5ee4b6a60.
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16)
(f14bf5d1ddbc92dd809a088839ce16bd) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd).
[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 MapPartition
(MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks,
VerifyAssertions}) d2edf14a2b863abbc04e3860f82545bc.
[DataSink (DiscardingOutput) (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (15/16)
(f14bf5d1ddbc92dd809a088839ce16bd) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks,
VerifyAssertions}) (4/16) (d2edf14a2b863abbc04e3860f82545bc) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (4/16).
[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 DataSink
(DiscardingOutput) f14bf5d1ddbc92dd809a088839ce16bd.
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16)
(ec899b05458a7ffba12e3ae3353bdba3) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (4/16)
(ec899b05458a7ffba12e3ae3353bdba3) [DEPLOYING]
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd) switched from
RUNNING to FINISHED.
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3)
[DEPLOYING].
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16)
(ec899b05458a7ffba12e3ae3353bdba3) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16)
(ec899b05458a7ffba12e3ae3353bdba3) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3).
[DataSink (DiscardingOutput) (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (4/16)
(ec899b05458a7ffba12e3ae3353bdba3) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) ec899b05458a7ffba12e3ae3353bdba3.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) switched from
RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions}) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at
[5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (14/16)
(087f4b1b31d9c67a7cd1102470382dc5) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions}) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks,
VerifyAssertions}) (14/16) (087f4b1b31d9c67a7cd1102470382dc5).
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane,
RunChecks, VerifyAssertions}) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally,
GetPane, RunChecks, VerifyAssertions}) (14/16)
(087f4b1b31d9c67a7cd1102470382dc5) [FINISHED]
[jobmanager-future-thread-10] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2) switched from
CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks,
VerifyAssertions}) 087f4b1b31d9c67a7cd1102470382dc5.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2) switched from
SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(DiscardingOutput) (14/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks,
VerifyAssertions}) (14/16) (087f4b1b31d9c67a7cd1102470382dc5) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(DiscardingOutput) (14/16).
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16)
(d819f09a6086f0439dcce596e89150a2) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task DataSink (DiscardingOutput) (14/16)
(d819f09a6086f0439dcce596e89150a2) [DEPLOYING]
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink
(DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2) [DEPLOYING].
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
DataSink (DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2)
[DEPLOYING].
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16)
(d819f09a6086f0439dcce596e89150a2) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2) switched from
DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16)
(d819f09a6086f0439dcce596e89150a2) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink
(DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2).
[DataSink (DiscardingOutput) (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task DataSink (DiscardingOutput) (14/16)
(d819f09a6086f0439dcce596e89150a2) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(DiscardingOutput) d819f09a6086f0439dcce596e89150a2.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2) switched from
RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
pardotest0multipleinputsandoutputtests0testpardowithtaggedoutput-jenkins-1209002812-fe4b69d
(2a4ea4345883a88d1258995dcae79622) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
2a4ea4345883a88d1258995dcae79622 reached globally terminal state FINISHED.
[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/dispatcherdd828368-1b34-46bb-91ea-7e70bb6e088c.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_90.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
pardotest0multipleinputsandoutputtests0testpardowithtaggedoutput-jenkins-1209002812-fe4b69d(2a4ea4345883a88d1258995dcae79622).
[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-7] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherdd828368-1b34-46bb-91ea-7e70bb6e088c.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
8b666e580f3c15bf472d13092e1428ff: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-17773f69-24d4-4238-bd98-6c929aa0f1e9
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcActor - The rpc endpoint
org.apache.flink.runtime.jobmaster.slotpool.SlotPool has not been started yet.
Discarding message org.apache.flink.runtime.rpc.messages.LocalRpcInvocation
until processing is started.
[ForkJoinPool.commonPool-worker-8] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-6] 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
2a4ea4345883a88d1258995dcae79622 with leader id
92f4c70ed65214167252714114f342bf lost leadership.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-8] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcherdd828368-1b34-46bb-91ea-7e70bb6e088c.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_90.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:36743
[flink-akka.actor.default-dispatcher-7] 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 16319 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/pardotest0multipleinputsandoutputtests0testpardowithtaggedoutput-jenkins-1209002812-fe4b69d_fe0a40a2-617e-4d6d-be3a-dd5fbc176d49/MANIFEST
has 186 artifact locations
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
- Removed dir
/tmp/beam-artifact-staging/pardotest0multipleinputsandoutputtests0testpardowithtaggedoutput-jenkins-1209002812-fe4b69d_fe0a40a2-617e-4d6d-be3a-dd5fbc176d49/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:40833
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:43909
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests >
testMultiOutputParDoWithSideInputsIsCumulative STANDARD_ERROR
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingService started on localhost:44523
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobService started on localhost:46461
[Test worker] INFO org.apache.beam.runners.reference.PortableRunner - Using
job server endpoint: localhost:46461
[Test worker] INFO org.apache.beam.runners.reference.PortableRunner -
PrepareJobResponse: preparation_id:
"pardotest0multipleinputsandoutputtests0testmultioutputpardowithsideinputsiscumulative-jenkins-1209002834-2ca25140_7cd84ea3-0ede-4cad-9d7e-dd91807db38e"
artifact_staging_endpoint {
url: "localhost:44523"
}
staging_session_token:
"{\"sessionId\":\"pardotest0multipleinputsandoutputtests0testmultioutputpardowithsideinputsiscumulative-jenkins-1209002834-2ca25140_7cd84ea3-0ede-4cad-9d7e-dd91807db38e\",\"basePath\":\"/tmp/beam-artifact-staging\"}"
[Test worker] INFO
org.apache.beam.runners.core.construction.ArtifactServiceStager - Staging 186
files (token:
{"sessionId":"pardotest0multipleinputsandoutputtests0testmultioutputpardowithsideinputsiscumulative-jenkins-1209002834-2ca25140_7cd84ea3-0ede-4cad-9d7e-dd91807db38e","basePath":"/tmp/beam-artifact-staging"})
[Test worker] INFO
org.apache.beam.runners.core.construction.ArtifactServiceStager - Staged 186
files (token:
{"sessionId":"pardotest0multipleinputsandoutputtests0testmultioutputpardowithsideinputsiscumulative-jenkins-1209002834-2ca25140_7cd84ea3-0ede-4cad-9d7e-dd91807db38e","basePath":"/tmp/beam-artifact-staging"})
[grpc-default-executor-220] INFO
org.apache.beam.runners.flink.FlinkJobInvoker - Invoking job
pardotest0multipleinputsandoutputtests0testmultioutputpardowithsideinputsiscumulative-jenkins-1209002834-2ca25140_bc37553f-a995-49b4-bddd-fa558c15ceb3
[grpc-default-executor-220] INFO
org.apache.beam.runners.flink.FlinkJobInvocation - Starting job invocation
pardotest0multipleinputsandoutputtests0testmultioutputpardowithsideinputsiscumulative-jenkins-1209002834-2ca25140_bc37553f-a995-49b4-bddd-fa558c15ceb3
[flink-runner-job-server] INFO
org.apache.beam.runners.flink.FlinkJobInvocation - Translating pipeline to
Flink program.
[Test worker] INFO org.apache.beam.runners.reference.PortableRunner -
RunJobResponse: job_id:
"pardotest0multipleinputsandoutputtests0testmultioutputpardowithsideinputsiscumulative-jenkins-1209002834-2ca25140_bc37553f-a995-49b4-bddd-fa558c15ceb3"
[flink-runner-job-server] INFO
org.apache.beam.runners.flink.FlinkExecutionEnvironments - Creating a Batch
Execution Environment.
[flink-runner-job-server] INFO
org.apache.flink.api.java.ExecutionEnvironment - The job has 0 registered types
and 0 default Kryo serializers
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting Flink Mini Cluster
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting Metrics Registry
[flink-runner-job-server] INFO
org.apache.flink.runtime.metrics.MetricRegistryImpl - No metrics reporter
configured, no metrics will be exposed/reported.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting RPC Service(s)
[flink-akka.actor.default-dispatcher-3] INFO akka.event.slf4j.Slf4jLogger -
Slf4jLogger started
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting high-availability
services
[flink-runner-job-server] INFO org.apache.flink.runtime.blob.BlobServer -
Created BLOB server storage directory
/tmp/blobStore-6c69d45c-59f9-4a49-9d08-8cdc971f3a86
[flink-runner-job-server] INFO org.apache.flink.runtime.blob.BlobServer -
Started BLOB server at 0.0.0.0:37245 - max concurrent requests: 50 - max
backlog: 1000
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting ResourceManger
[flink-runner-job-server] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at
akka://flink/user/resourcemanager_679813f2-746e-4abf-8940-d45a8b975dab .
[flink-runner-job-server] INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Proposing leadership to contender
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager@14702078 @
akka://flink/user/resourcemanager_679813f2-746e-4abf-8940-d45a8b975dab
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
ResourceManager
akka://flink/user/resourcemanager_679813f2-746e-4abf-8940-d45a8b975dab was
granted leadership with fencing token b8ceeadc1985c4b8788dcaccafb54170
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Starting the
SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
- Received confirmation of leadership for leader
akka://flink/user/resourcemanager_679813f2-746e-4abf-8940-d45a8b975dab ,
session=788dcacc-afb5-4170-b8ce-eadc1985c4b8
[flink-runner-job-server] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Created BLOB cache storage
directory /tmp/blobStore-dada382b-72d7-4fd9-8174-3327f9a28631
[flink-runner-job-server] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Created BLOB cache storage
directory /tmp/blobStore-afe9fa3a-0693-4df8-b7cd-c7228882e3bd
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Starting 1 TaskManger(s)
[flink-runner-job-server] INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Starting TaskManager
with ResourceID: 10218d34-4e13-4e39-81b0-a8d04c5dd63a
[flink-runner-job-server] INFO
org.apache.flink.runtime.taskexecutor.TaskManagerServices - Temporary file
directory '/tmp': total 484 GB, usable 291 GB (60.12% usable)
Could not stop
org.gradle.internal.actor.internal.DefaultActorFactory$NonBlockingActor@324c93ac.
org.gradle.internal.dispatch.DispatchException: Could not dispatch message
[MethodInvocation method: stop()].
at
org.gradle.internal.dispatch.ExceptionTrackingFailureHandler.dispatchFailed(ExceptionTrackingFailureHandler.java:34)
at
org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:31)
at
org.gradle.internal.dispatch.AsyncDispatch.dispatchMessages(AsyncDispatch.java:133)
at
org.gradle.internal.dispatch.AsyncDispatch.access$000(AsyncDispatch.java:34)
at
org.gradle.internal.dispatch.AsyncDispatch$1.run(AsyncDispatch.java:73)
at
org.gradle.internal.operations.CurrentBuildOperationPreservingRunnable.run(CurrentBuildOperationPreservingRunnable.java:42)
at
org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
at
org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at
org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.gradle.process.internal.ExecException: Process 'Gradle Test
Executor 1' finished with non-zero exit value 137
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at
https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
at
org.gradle.api.internal.tasks.testing.worker.ForkingTestClassProcessor.stop(ForkingTestClassProcessor.java:155)
at
org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.endBatch(RestartEveryNTestClassProcessor.java:77)
at
org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.stop(RestartEveryNTestClassProcessor.java:62)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:29)
... 10 more
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests >
testMultiOutputParDoWithSideInputsIsCumulative SKIPPED
org.apache.beam.sdk.testing.PAssertTest > testGlobalWindowContainsInAnyOrder
SKIPPED
63 tests completed, 1 failed, 3 skipped
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task
worker for ':' Thread 8,5,main]) completed. Took 23 mins 40.4 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch'.
> Process 'Gradle Test Executor 2' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at
https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
* 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 28m 32s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/ayv7simkxrmiw
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
