See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/138/display/redirect>
------------------------------------------
[...truncated 27.78 MB...]
[PAssert$17/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$17/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
PAssert$17/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$17/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)
(1a48a0ee1a358d9e08665e15348b129e) [DEPLOYING].
[PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)
(f703f0cc95866fe4dd8d34596201f048) [DEPLOYING].
[Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [15]{Create.TimestampedValues, Window.Into(), PAssert$17, PAssert$16} ->
(ToKeyedWorkItem, ToKeyedWorkItem) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [15]{Create.TimestampedValues, Window.Into(), PAssert$17, PAssert$16} ->
(ToKeyedWorkItem, ToKeyedWorkItem) (12/16) (980c45ddbab78c5434be9884a458f1f9)
[DEPLOYING].
[PAssert$16/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$16/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$16/GroupGlobally/GroupDummyAndContents -> [5]PAssert$16/{GroupGlobally,
GetPane, RunChecks, VerifyAssertions} (12/16)
(640322a8fcb92e1bf5b79b9fec5e421e) switched from DEPLOYING to RUNNING.
[PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(b0134d96f73fe24137bc3b8dde70cfa8) switched from CREATED to DEPLOYING.
[PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak
safety net for task
PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(b0134d96f73fe24137bc3b8dde70cfa8) [DEPLOYING]
[PAssert$16/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$16/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)]
INFO org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has
been configured, using default (Memory / JobManager) MemoryStateBackend (data
in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$16/GroupGlobally/GroupDummyAndContents -> [5]PAssert$16/{GroupGlobally,
GetPane, RunChecks, VerifyAssertions} (12/16)
(640322a8fcb92e1bf5b79b9fec5e421e) switched from DEPLOYING to RUNNING.
[PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task
PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(b0134d96f73fe24137bc3b8dde70cfa8) [DEPLOYING].
[Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [15]{Create.TimestampedValues, Window.Into(), PAssert$17, PAssert$16} ->
(ToKeyedWorkItem, ToKeyedWorkItem) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [15]{Create.TimestampedValues, Window.Into(), PAssert$17, PAssert$16} ->
(ToKeyedWorkItem, ToKeyedWorkItem) (12/16) (980c45ddbab78c5434be9884a458f1f9)
[DEPLOYING].
[PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)
(f703f0cc95866fe4dd8d34596201f048) [DEPLOYING].
[PAssert$17/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$17/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
PAssert$17/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$17/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)
(1a48a0ee1a358d9e08665e15348b129e) [DEPLOYING].
[PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Registering task at network:
PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(b0134d96f73fe24137bc3b8dde70cfa8) [DEPLOYING].
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (16/16) (48b4554cccbdf11a1402722b44884ceb) switched from
CREATED to DEPLOYING.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (16/16)
(48b4554cccbdf11a1402722b44884ceb) [DEPLOYING]
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (16/16)
(48b4554cccbdf11a1402722b44884ceb) [DEPLOYING].
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (16/16)
(48b4554cccbdf11a1402722b44884ceb) [DEPLOYING].
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (10/16) (e5f5477b377a32eb7f2b30f6d6ebbd45) switched from
CREATED to DEPLOYING.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (10/16)
(e5f5477b377a32eb7f2b30f6d6ebbd45) [DEPLOYING]
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (10/16)
(e5f5477b377a32eb7f2b30f6d6ebbd45) [DEPLOYING].
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (10/16)
(e5f5477b377a32eb7f2b30f6d6ebbd45) [DEPLOYING].
[PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)
(f703f0cc95866fe4dd8d34596201f048) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)
(f703f0cc95866fe4dd8d34596201f048) switched from DEPLOYING to RUNNING.
[PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[PAssert$17/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$17/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$17/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$17/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)
(362c434ee8ca1f3d72adf765eabcd705) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (3/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$17/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$17/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)
(362c434ee8ca1f3d72adf765eabcd705) switched from DEPLOYING to RUNNING.
[PAssert$17/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$17/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [15]{Create.TimestampedValues, Window.Into(), PAssert$17, PAssert$16} ->
(ToKeyedWorkItem, ToKeyedWorkItem) (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [15]{Create.TimestampedValues, Window.Into(), PAssert$17, PAssert$16} ->
(ToKeyedWorkItem, ToKeyedWorkItem) (12/16) (980c45ddbab78c5434be9884a458f1f9)
switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [15]{Create.TimestampedValues, Window.Into(), PAssert$17, PAssert$16} ->
(ToKeyedWorkItem, ToKeyedWorkItem) (12/16) (980c45ddbab78c5434be9884a458f1f9)
switched from DEPLOYING to RUNNING.
[Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [15]{Create.TimestampedValues, Window.Into(), PAssert$17, PAssert$16} ->
(ToKeyedWorkItem, ToKeyedWorkItem) (12/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[PAssert$16/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$16/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$16/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$16/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)
(d0116b00d23e6529865aefed83411dda) switched from DEPLOYING to RUNNING.
[PAssert$16/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$16/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$16/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$16/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)
(d0116b00d23e6529865aefed83411dda) switched from DEPLOYING to RUNNING.
[PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(b0134d96f73fe24137bc3b8dde70cfa8) switched from DEPLOYING to RUNNING.
[PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$16/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey
-> [9]PAssert$16/GroupGlobally/{Create.Values, WindowIntoDummy,
RemoveDummyTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(b0134d96f73fe24137bc3b8dde70cfa8) switched from DEPLOYING to RUNNING.
[PAssert$17/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$17/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$17/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$17/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)
(1a48a0ee1a358d9e08665e15348b129e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$17/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$17/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)
(1a48a0ee1a358d9e08665e15348b129e) switched from DEPLOYING to RUNNING.
[PAssert$17/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$17/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (10/16) (e5f5477b377a32eb7f2b30f6d6ebbd45) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(10/16) (e5f5477b377a32eb7f2b30f6d6ebbd45) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (10/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (3/16) (bcd010d0e59452426c84f2cf6b811f2a) switched from CREATED
to DEPLOYING.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (3/16)
(bcd010d0e59452426c84f2cf6b811f2a) [DEPLOYING]
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (3/16)
(bcd010d0e59452426c84f2cf6b811f2a) [DEPLOYING].
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (16/16) (48b4554cccbdf11a1402722b44884ceb) switched from
DEPLOYING to RUNNING.
[ToKeyedWorkItem (16/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(16/16) (48b4554cccbdf11a1402722b44884ceb) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (3/16)
(bcd010d0e59452426c84f2cf6b811f2a) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (16/16).
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (16/16) (7b2a3dea17a919e30d43ba62aee83e7e) switched from
CREATED to DEPLOYING.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (16/16)
(7b2a3dea17a919e30d43ba62aee83e7e) [DEPLOYING]
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (16/16)
(7b2a3dea17a919e30d43ba62aee83e7e) [DEPLOYING].
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (16/16)
(7b2a3dea17a919e30d43ba62aee83e7e) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (8/16).
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (8/16) (60a986b701472fd7714e1cd756bdaa5b) switched from CREATED
to DEPLOYING.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (8/16)
(60a986b701472fd7714e1cd756bdaa5b) [DEPLOYING]
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (8/16)
(60a986b701472fd7714e1cd756bdaa5b) [DEPLOYING].
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (3/16) (bcd010d0e59452426c84f2cf6b811f2a) switched from
DEPLOYING to RUNNING.
[ToKeyedWorkItem (3/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16)
(bcd010d0e59452426c84f2cf6b811f2a) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (8/16)
(60a986b701472fd7714e1cd756bdaa5b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (13/16).
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (13/16) (f69a6cdffdbe0fcd35cb609e18eaa6e9) switched from
CREATED to DEPLOYING.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (13/16)
(f69a6cdffdbe0fcd35cb609e18eaa6e9) [DEPLOYING]
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (13/16)
(f69a6cdffdbe0fcd35cb609e18eaa6e9) [DEPLOYING].
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (13/16)
(f69a6cdffdbe0fcd35cb609e18eaa6e9) [DEPLOYING].
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (16/16) (7b2a3dea17a919e30d43ba62aee83e7e) switched from
DEPLOYING to RUNNING.
[ToKeyedWorkItem (16/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(16/16) (7b2a3dea17a919e30d43ba62aee83e7e) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (13/16) (f69a6cdffdbe0fcd35cb609e18eaa6e9) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(13/16) (f69a6cdffdbe0fcd35cb609e18eaa6e9) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (8/16) (60a986b701472fd7714e1cd756bdaa5b) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (8/16).
[ToKeyedWorkItem (8/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16)
(60a986b701472fd7714e1cd756bdaa5b) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (13/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (8/16) (1a13bc1b7e64ed16199d2fa2611864aa) switched from CREATED
to DEPLOYING.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (8/16)
(1a13bc1b7e64ed16199d2fa2611864aa) [DEPLOYING]
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (8/16)
(1a13bc1b7e64ed16199d2fa2611864aa) [DEPLOYING].
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (8/16)
(1a13bc1b7e64ed16199d2fa2611864aa) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (11/16).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (6/16).
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (11/16) (17ca58707f2c1d679fc3b76afb56553b) switched from
CREATED to DEPLOYING.
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (11/16)
(17ca58707f2c1d679fc3b76afb56553b) [DEPLOYING]
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (11/16)
(17ca58707f2c1d679fc3b76afb56553b) [DEPLOYING].
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (11/16)
(17ca58707f2c1d679fc3b76afb56553b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (5/16).
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (6/16) (128afdc30372ad979a25d1f750d1e32f) switched from CREATED
to DEPLOYING.
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (6/16)
(128afdc30372ad979a25d1f750d1e32f) [DEPLOYING]
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (6/16)
(128afdc30372ad979a25d1f750d1e32f) [DEPLOYING].
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (6/16)
(128afdc30372ad979a25d1f750d1e32f) [DEPLOYING].
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (5/16) (cb71afe78449893466a86e7df35cbfe2) switched from CREATED
to DEPLOYING.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (5/16)
(cb71afe78449893466a86e7df35cbfe2) [DEPLOYING]
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (5/16)
(cb71afe78449893466a86e7df35cbfe2) [DEPLOYING].
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (6/16) (128afdc30372ad979a25d1f750d1e32f) switched from
DEPLOYING to RUNNING.
[ToKeyedWorkItem (6/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16)
(128afdc30372ad979a25d1f750d1e32f) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (5/16)
(cb71afe78449893466a86e7df35cbfe2) [DEPLOYING].
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (11/16) (17ca58707f2c1d679fc3b76afb56553b) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(11/16) (17ca58707f2c1d679fc3b76afb56553b) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (11/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (8/16) (1a13bc1b7e64ed16199d2fa2611864aa) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (10/16).
[ToKeyedWorkItem (8/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16)
(1a13bc1b7e64ed16199d2fa2611864aa) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (10/16) (134bb42c1419885e4a67fb7eb599ec41) switched from
CREATED to DEPLOYING.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (10/16)
(134bb42c1419885e4a67fb7eb599ec41) [DEPLOYING]
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (10/16)
(134bb42c1419885e4a67fb7eb599ec41) [DEPLOYING].
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (10/16)
(134bb42c1419885e4a67fb7eb599ec41) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (14/16).
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (14/16) (0b9285603caae3e08435be800fdc725d) switched from
CREATED to DEPLOYING.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (14/16)
(0b9285603caae3e08435be800fdc725d) [DEPLOYING]
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (14/16)
(0b9285603caae3e08435be800fdc725d) [DEPLOYING].
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (10/16) (134bb42c1419885e4a67fb7eb599ec41) switched from
DEPLOYING to RUNNING.
[ToKeyedWorkItem (10/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(10/16) (134bb42c1419885e4a67fb7eb599ec41) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (14/16)
(0b9285603caae3e08435be800fdc725d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (5/16).
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (5/16) (cb71afe78449893466a86e7df35cbfe2) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16)
(cb71afe78449893466a86e7df35cbfe2) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (5/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (7/16).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (2/16).
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (5/16) (b05aee864748e8f2148b8dc069f5120e) switched from CREATED
to DEPLOYING.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (5/16)
(b05aee864748e8f2148b8dc069f5120e) [DEPLOYING]
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (5/16)
(b05aee864748e8f2148b8dc069f5120e) [DEPLOYING].
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (7/16) (b13c2672ae9c9dd38bfe9a92a1a12781) switched from CREATED
to DEPLOYING.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (5/16)
(b05aee864748e8f2148b8dc069f5120e) [DEPLOYING].
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (7/16)
(b13c2672ae9c9dd38bfe9a92a1a12781) [DEPLOYING]
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (7/16)
(b13c2672ae9c9dd38bfe9a92a1a12781) [DEPLOYING].
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (7/16)
(b13c2672ae9c9dd38bfe9a92a1a12781) [DEPLOYING].
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (b104232d40a5927324830e06860bcd6a) switched from CREATED
to DEPLOYING.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (2/16)
(b104232d40a5927324830e06860bcd6a) [DEPLOYING]
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (2/16)
(b104232d40a5927324830e06860bcd6a) [DEPLOYING].
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (2/16)
(b104232d40a5927324830e06860bcd6a) [DEPLOYING].
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (14/16) (0b9285603caae3e08435be800fdc725d) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (12/16).
[ToKeyedWorkItem (14/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(14/16) (0b9285603caae3e08435be800fdc725d) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (7/16) (b13c2672ae9c9dd38bfe9a92a1a12781) switched from
DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (4/16).
[ToKeyedWorkItem (7/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16)
(b13c2672ae9c9dd38bfe9a92a1a12781) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (12/16) (f6278501057d329eb6048bfa82141fa8) switched from
CREATED to DEPLOYING.
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (12/16)
(f6278501057d329eb6048bfa82141fa8) [DEPLOYING]
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (12/16)
(f6278501057d329eb6048bfa82141fa8) [DEPLOYING].
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (4/16) (62fbd68fe97eb271ec4861636c0e6077) switched from CREATED
to DEPLOYING.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (4/16)
(62fbd68fe97eb271ec4861636c0e6077) [DEPLOYING]
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (5/16) (b05aee864748e8f2148b8dc069f5120e) switched from
DEPLOYING to RUNNING.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (4/16)
(62fbd68fe97eb271ec4861636c0e6077) [DEPLOYING].
[ToKeyedWorkItem (5/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (12/16)
(f6278501057d329eb6048bfa82141fa8) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16)
(b05aee864748e8f2148b8dc069f5120e) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (4/16)
(62fbd68fe97eb271ec4861636c0e6077) [DEPLOYING].
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (b104232d40a5927324830e06860bcd6a) switched from
DEPLOYING to RUNNING.
[ToKeyedWorkItem (2/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(b104232d40a5927324830e06860bcd6a) switched from DEPLOYING to RUNNING.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (4/16) (62fbd68fe97eb271ec4861636c0e6077) switched from
DEPLOYING to RUNNING.
[ToKeyedWorkItem (4/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16)
(62fbd68fe97eb271ec4861636c0e6077) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (2/16).
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (12/16) (f6278501057d329eb6048bfa82141fa8) switched from
DEPLOYING to RUNNING.
[ToKeyedWorkItem (12/16)] INFO
org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been
configured, using default (Memory / JobManager) MemoryStateBackend (data in
heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints:
'null', asynchronous: TRUE, maxStateSize: 5242880)
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(12/16) (f6278501057d329eb6048bfa82141fa8) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task
ToKeyedWorkItem (11/16).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (bb8728e9d10476a88876866adbcbd1bb) switched from CREATED
to DEPLOYING.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Creating FileSystem stream leak safety net for task ToKeyedWorkItem (2/16)
(bb8728e9d10476a88876866adbcbd1bb) [DEPLOYING]
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Loading JAR files for task ToKeyedWorkItem (2/16)
(bb8728e9d10476a88876866adbcbd1bb) [DEPLOYING].
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Registering task at network: ToKeyedWorkItem (2/16)
(bb8728e9d10476a88876866adbcbd1bb) [DEPLOYING].
[thread 140684670519040 also had an error]#
Java HotSpot(TM) 64-Bit Server VM warning: INFO:
os::commit_memory(0x00007f0a140f0000, 65536, 1) failed; error='Cannot allocate
memory' (errno=12)
#
# There is insufficient memory for the Java Runtime Environment to continue.
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 65536 bytes for committing
reserved memory.
# Native memory allocation (mmap) failed to map 12288 bytes for committing
reserved memory.
Java HotSpot(TM) 64-Bit Server VM warning: INFO:
os::commit_memory(0x00007ff4193d6000, 12288, 0) failed; error='Cannot allocate
memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO:
os::commit_memory(0x00007ff3b3bfc000, 12288, 0) failed; error='Cannot allocate
memory' (errno=12)
# An error report file with more information is saved as:
# An error report file with more information is saved as:
#
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/hs_err_pid7131.log>
#
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/hs_err_pid7132.log>
#
# Compiler replay data is saved as:
#
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/replay_pid7132.log>
Could not stop
org.gradle.internal.actor.internal.DefaultActorFactory$NonBlockingActor@5d18d420.
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 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
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$StateTests > testValueStateSimple
SKIPPED
org.apache.beam.sdk.testing.PAssertTest > testWindowedSerializablePredicate
SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
> FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
(Thread[Task worker for ':' Thread 11,5,main]) completed. Took 7 mins 0.553
secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> 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 11m 44s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/zo4mnyyhjgamu
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]
