API tools faq
paste
Guest User

Untitled

a guest
Jun 1st, 2019
111
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 61.15 KB | None | 0 0
raw download clone embed print report
  1. INFO: Reader-0: first record offset 0
  2. Row:[1]
  3. Row:[1]
  4. Row:[55280]
  5. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task failExternally
  6. INFO: Attempting to fail task externally SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (8/8) (16bd7d0cfa9c99b074be67b11604f1a9).
  7. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task transitionState
  8. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (8/8) (16bd7d0cfa9c99b074be67b11604f1a9) switched from RUNNING to FAILED.
  9. TimerException{org.apache.beam.sdk.util.UserCodeException: java.lang.OutOfMemoryError: GC overhead limit exceeded}
  10. at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService$TriggerTask.run(SystemProcessingTimeService.java:288)
  11. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  12. at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  13. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
  14. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
  15. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
  16. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
  17. at java.lang.Thread.run(Thread.java:748)
  18. Caused by: org.apache.beam.sdk.util.UserCodeException: java.lang.OutOfMemoryError: GC overhead limit exceeded
  19. at org.apache.beam.sdk.util.UserCodeException.wrap(UserCodeException.java:34)
  20. at org.apache.beam.runners.core.GroupAlsoByWindowViaWindowSetNewDoFn$DoFnInvoker.invokeProcessElement(Unknown Source)
  21. at org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:213)
  22. at org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:178)
  23. at org.apache.beam.runners.core.LateDataDroppingDoFnRunner.processElement(LateDataDroppingDoFnRunner.java:80)
  24. at org.apache.beam.runners.flink.metrics.DoFnRunnerWithMetricsUpdate.processElement(DoFnRunnerWithMetricsUpdate.java:63)
  25. at org.apache.beam.runners.flink.translation.wrappers.streaming.WindowDoFnOperator.fireTimer(WindowDoFnOperator.java:128)
  26. at org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator.onProcessingTime(DoFnOperator.java:774)
  27. at org.apache.flink.streaming.api.operators.HeapInternalTimerService.onProcessingTime(HeapInternalTimerService.java:266)
  28. at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService$TriggerTask.run(SystemProcessingTimeService.java:285)
  29. ... 7 more
  30. Caused by: java.lang.OutOfMemoryError: GC overhead limit exceeded
  31. at org.apache.beam.sdk.coders.StringUtf8Coder.readString(StringUtf8Coder.java:59)
  32. at org.apache.beam.sdk.coders.StringUtf8Coder.decode(StringUtf8Coder.java:100)
  33. at org.apache.beam.sdk.coders.StringUtf8Coder.decode(StringUtf8Coder.java:90)
  34. at org.apache.beam.sdk.coders.StringUtf8Coder.decode(StringUtf8Coder.java:37)
  35. at org.apache.beam.sdk.coders.RowCoderGenerator$DecodeInstruction.decodeDelegate(RowCoderGenerator.java:298)
  36. at org.apache.beam.sdk.coders.Coder$ByteBuddy$ul5zgWp3.decode(Unknown Source)
  37. at org.apache.beam.sdk.coders.Coder$ByteBuddy$ul5zgWp3.decode(Unknown Source)
  38. at org.apache.beam.sdk.coders.IterableLikeCoder.decode(IterableLikeCoder.java:124)
  39. at org.apache.beam.sdk.coders.IterableLikeCoder.decode(IterableLikeCoder.java:60)
  40. at org.apache.beam.sdk.coders.RowCoderGenerator$DecodeInstruction.decodeDelegate(RowCoderGenerator.java:298)
  41. at org.apache.beam.sdk.coders.Coder$ByteBuddy$QGthxifd.decode(Unknown Source)
  42. at org.apache.beam.sdk.coders.Coder$ByteBuddy$QGthxifd.decode(Unknown Source)
  43. at org.apache.beam.sdk.coders.RowCoder.decode(RowCoder.java:112)
  44. at org.apache.beam.sdk.schemas.SchemaCoder.decode(SchemaCoder.java:86)
  45. at org.apache.beam.sdk.coders.IterableLikeCoder.decode(IterableLikeCoder.java:124)
  46. at org.apache.beam.sdk.coders.IterableLikeCoder.decode(IterableLikeCoder.java:60)
  47. at org.apache.beam.sdk.coders.Coder.decode(Coder.java:159)
  48. at org.apache.beam.sdk.coders.KvCoder.decode(KvCoder.java:82)
  49. at org.apache.beam.sdk.coders.KvCoder.decode(KvCoder.java:36)
  50. at org.apache.beam.sdk.util.WindowedValue$FullWindowedValueCoder.decode(WindowedValue.java:543)
  51. at org.apache.beam.sdk.util.WindowedValue$FullWindowedValueCoder.decode(WindowedValue.java:480)
  52. at org.apache.beam.sdk.util.CoderUtils.decodeFromSafeStream(CoderUtils.java:115)
  53. at org.apache.beam.sdk.util.CoderUtils.decodeFromByteArray(CoderUtils.java:98)
  54. at org.apache.beam.sdk.util.CoderUtils.decodeFromByteArray(CoderUtils.java:92)
  55. at org.apache.beam.sdk.util.CoderUtils.clone(CoderUtils.java:141)
  56. at org.apache.beam.runners.flink.translation.types.CoderTypeSerializer.copy(CoderTypeSerializer.java:64)
  57. at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:556)
  58. at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:533)
  59. at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:513)
  60. at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:705)
  61. at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:683)
  62. at org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator$BufferedOutputManager.emit(DoFnOperator.java:883)
  63.  
  64. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  65. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (5/8) (234f9b5e254194302d5bb90763b6cb4c) switched from RUNNING to FAILED.
  66. java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id 12054323-4613-4791-bb5b-e0a0e17e9860 timed out.
  67. at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1609)
  68. at org.apache.flink.runtime.heartbeat.HeartbeatManagerImpl$HeartbeatMonitor.run(HeartbeatManagerImpl.java:339)
  69. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  70. at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  71. at org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:154)
  72. at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
  73. at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415)
  74. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  75. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  76. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  77. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  78.  
  79. May 31, 2019 10:37:44 PM org.apache.flink.runtime.resourcemanager.ResourceManager$TaskManagerHeartbeatListener$1 run
  80. INFO: The heartbeat of TaskManager with id 12054323-4613-4791-bb5b-e0a0e17e9860 timed out.
  81. May 31, 2019 10:37:44 PM org.apache.flink.runtime.resourcemanager.ResourceManager closeTaskManagerConnection
  82. INFO: Closing TaskExecutor connection 12054323-4613-4791-bb5b-e0a0e17e9860 because: The heartbeat of TaskManager with id 12054323-4613-4791-bb5b-e0a0e17e9860 timed out.
  83. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
  84. INFO: Job myexample-deklan-0601023335-2031257e (8f8cb65604a1e4f369c87539cab58e59) switched from state RUNNING to FAILING.
  85. java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id 12054323-4613-4791-bb5b-e0a0e17e9860 timed out.
  86. at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1609)
  87. at org.apache.flink.runtime.heartbeat.HeartbeatManagerImpl$HeartbeatMonitor.run(HeartbeatManagerImpl.java:339)
  88. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  89. at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  90. at org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:154)
  91. at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
  92. at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415)
  93. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  94. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  95. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  96. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  97.  
  98. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task cancelOrFailAndCancelInvokable
  99. INFO: Triggering cancellation of task code SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (8/8) (16bd7d0cfa9c99b074be67b11604f1a9).
  100. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  101. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (1/8) (dc7c62dc3054cf3ebffb2ed7a751b34f) switched from RUNNING to CANCELING.
  102. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  103. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (2/8) (a0d3b743ce00554a0fae550894dc19da) switched from RUNNING to CANCELING.
  104. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  105. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (3/8) (c4200ca7f2b1f2b72804147238b7c88a) switched from RUNNING to CANCELING.
  106. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  107. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (4/8) (232ad5ac403c6c28da22dba38f21b5ea) switched from RUNNING to CANCELING.
  108. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  109. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (5/8) (d3b8695748a79cd11884ae34b47ee339) switched from RUNNING to CANCELING.
  110. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  111. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (6/8) (3632ab94bd3d34fe108b413d21077ee9) switched from RUNNING to CANCELING.
  112. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  113. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (7/8) (15d045b871fec88a12cb27d920c3d720) switched from RUNNING to CANCELING.
  114. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  115. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (8/8) (d43a6ef2bb5f2d6823e00fabf2451c3a) switched from RUNNING to CANCELING.
  116. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  117. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (1/8) (cdeb3f59982cc0910435e88b57bada5c) switched from RUNNING to CANCELING.
  118. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  119. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (2/8) (7bf344ddcd592a1eb7dc0d5919c3f345) switched from RUNNING to CANCELING.
  120. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  121. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (3/8) (08add9d7f3f7ceb92fff786fb7a2c87c) switched from RUNNING to CANCELING.
  122. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  123. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (4/8) (fafeb3f4cc3d74458aa3f909c18ed883) switched from RUNNING to CANCELING.
  124. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  125. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (6/8) (b58ff01930d1ff0abfcadaec73f251ec) switched from RUNNING to CANCELING.
  126. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  127. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (7/8) (3edca1ad87a4a55baab8742e7b85cd8e) switched from RUNNING to CANCELING.
  128. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  129. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (8/8) (16bd7d0cfa9c99b074be67b11604f1a9) switched from RUNNING to CANCELING.
  130. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  131. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (4/8) (232ad5ac403c6c28da22dba38f21b5ea) switched from CANCELING to CANCELED.
  132. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  133. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (4/8) (fafeb3f4cc3d74458aa3f909c18ed883) switched from CANCELING to CANCELED.
  134. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  135. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (1/8) (dc7c62dc3054cf3ebffb2ed7a751b34f) switched from CANCELING to CANCELED.
  136. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  137. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (8/8) (16bd7d0cfa9c99b074be67b11604f1a9) switched from CANCELING to CANCELED.
  138. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  139. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (2/8) (a0d3b743ce00554a0fae550894dc19da) switched from CANCELING to CANCELED.
  140. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  141. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (1/8) (cdeb3f59982cc0910435e88b57bada5c) switched from CANCELING to CANCELED.
  142. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  143. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (3/8) (c4200ca7f2b1f2b72804147238b7c88a) switched from CANCELING to CANCELED.
  144. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  145. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (7/8) (3edca1ad87a4a55baab8742e7b85cd8e) switched from CANCELING to CANCELED.
  146. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  147. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (7/8) (15d045b871fec88a12cb27d920c3d720) switched from CANCELING to CANCELED.
  148. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  149. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (3/8) (08add9d7f3f7ceb92fff786fb7a2c87c) switched from CANCELING to CANCELED.
  150. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  151. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (6/8) (3632ab94bd3d34fe108b413d21077ee9) switched from CANCELING to CANCELED.
  152. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  153. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (6/8) (b58ff01930d1ff0abfcadaec73f251ec) switched from CANCELING to CANCELED.
  154. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  155. INFO: Freeing task resources for SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (8/8) (16bd7d0cfa9c99b074be67b11604f1a9).
  156. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  157. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (5/8) (d3b8695748a79cd11884ae34b47ee339) switched from CANCELING to CANCELED.
  158. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  159. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (2/8) (7bf344ddcd592a1eb7dc0d5919c3f345) switched from CANCELING to CANCELED.
  160. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.Execution transitionState
  161. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (8/8) (d43a6ef2bb5f2d6823e00fabf2451c3a) switched from CANCELING to CANCELED.
  162. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.ExecutionGraph tryRestartOrFail
  163. INFO: Try to restart or fail the job myexample-deklan-0601023335-2031257e (8f8cb65604a1e4f369c87539cab58e59) if no longer possible.
  164. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.ExecutionGraph transitionState
  165. INFO: Job myexample-deklan-0601023335-2031257e (8f8cb65604a1e4f369c87539cab58e59) switched from state FAILING to FAILED.
  166. java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id 12054323-4613-4791-bb5b-e0a0e17e9860 timed out.
  167. at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1609)
  168. at org.apache.flink.runtime.heartbeat.HeartbeatManagerImpl$HeartbeatMonitor.run(HeartbeatManagerImpl.java:339)
  169. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  170. at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  171. at org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:154)
  172. at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
  173. at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415)
  174. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  175. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  176. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  177. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  178.  
  179. May 31, 2019 10:37:44 PM org.apache.flink.runtime.executiongraph.ExecutionGraph tryRestartOrFail
  180. INFO: Could not restart the job myexample-deklan-0601023335-2031257e (8f8cb65604a1e4f369c87539cab58e59) because the restart strategy prevented it.
  181. java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id 12054323-4613-4791-bb5b-e0a0e17e9860 timed out.
  182. at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1609)
  183. at org.apache.flink.runtime.heartbeat.HeartbeatManagerImpl$HeartbeatMonitor.run(HeartbeatManagerImpl.java:339)
  184. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  185. at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  186. at org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:154)
  187. at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
  188. at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415)
  189. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  190. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  191. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  192. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  193.  
  194. May 31, 2019 10:37:44 PM org.apache.flink.runtime.checkpoint.CheckpointCoordinator shutdown
  195. INFO: Stopping checkpoint coordinator for job 8f8cb65604a1e4f369c87539cab58e59.
  196. May 31, 2019 10:37:44 PM org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore shutdown
  197. INFO: Shutting down
  198. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskexecutor.TaskExecutor closeJobManagerConnection
  199. INFO: Close JobManager connection for job 8f8cb65604a1e4f369c87539cab58e59.
  200. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task failExternally
  201. INFO: Attempting to fail task externally Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (6/8) (3632ab94bd3d34fe108b413d21077ee9).
  202. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task transitionState
  203. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (6/8) (3632ab94bd3d34fe108b413d21077ee9) switched from RUNNING to FAILED.
  204. org.apache.flink.util.FlinkException: JobManager responsible for 8f8cb65604a1e4f369c87539cab58e59 lost the leadership.
  205. at org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnection(TaskExecutor.java:1167)
  206. at org.apache.flink.runtime.taskexecutor.TaskExecutor.disconnectJobManager(TaskExecutor.java:850)
  207. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  208. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  209. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  210. at java.lang.reflect.Method.invoke(Method.java:498)
  211. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:242)
  212. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:162)
  213. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:142)
  214. at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
  215. at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
  216. at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
  217. at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
  218. at akka.actor.ActorCell.invoke(ActorCell.scala:495)
  219. at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
  220. at akka.dispatch.Mailbox.run(Mailbox.scala:224)
  221. at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
  222. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  223. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  224. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  225. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  226. Caused by: java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id 12054323-4613-4791-bb5b-e0a0e17e9860 timed out.
  227. at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1609)
  228. at org.apache.flink.runtime.heartbeat.HeartbeatManagerImpl$HeartbeatMonitor.run(HeartbeatManagerImpl.java:339)
  229. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  230. at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  231. at org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:154)
  232. at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
  233. at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415)
  234. ... 4 more
  235.  
  236. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task cancelOrFailAndCancelInvokable
  237. INFO: Triggering cancellation of task code Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (6/8) (3632ab94bd3d34fe108b413d21077ee9).
  238. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task failExternally
  239. INFO: Attempting to fail task externally SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (3/8) (08add9d7f3f7ceb92fff786fb7a2c87c).
  240. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task transitionState
  241. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (3/8) (08add9d7f3f7ceb92fff786fb7a2c87c) switched from RUNNING to FAILED.
  242. org.apache.flink.util.FlinkException: JobManager responsible for 8f8cb65604a1e4f369c87539cab58e59 lost the leadership.
  243. at org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnection(TaskExecutor.java:1167)
  244. at org.apache.flink.runtime.taskexecutor.TaskExecutor.disconnectJobManager(TaskExecutor.java:850)
  245. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  246. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  247. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  248. at java.lang.reflect.Method.invoke(Method.java:498)
  249. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:242)
  250. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:162)
  251. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:142)
  252. at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
  253. at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
  254. at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
  255. at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
  256. at akka.actor.ActorCell.invoke(ActorCell.scala:495)
  257. at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
  258. at akka.dispatch.Mailbox.run(Mailbox.scala:224)
  259. at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
  260. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  261. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  262. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  263. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  264. Caused by: java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id 12054323-4613-4791-bb5b-e0a0e17e9860 timed out.
  265. at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1609)
  266. at org.apache.flink.runtime.heartbeat.HeartbeatManagerImpl$HeartbeatMonitor.run(HeartbeatManagerImpl.java:339)
  267. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  268. at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  269. at org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:154)
  270. at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
  271. at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415)
  272. ... 4 more
  273.  
  274. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  275. INFO: Freeing task resources for Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (6/8) (3632ab94bd3d34fe108b413d21077ee9).
  276. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task cancelOrFailAndCancelInvokable
  277. INFO: Triggering cancellation of task code SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (3/8) (08add9d7f3f7ceb92fff786fb7a2c87c).
  278. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  279. INFO: Ensuring all FileSystem streams are closed for task SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (8/8) (16bd7d0cfa9c99b074be67b11604f1a9) [FAILED]
  280. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  281. INFO: Ensuring all FileSystem streams are closed for task Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (6/8) (3632ab94bd3d34fe108b413d21077ee9) [FAILED]
  282. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task failExternally
  283. INFO: Attempting to fail task externally Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (4/8) (232ad5ac403c6c28da22dba38f21b5ea).
  284. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task transitionState
  285. INFO: Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (4/8) (232ad5ac403c6c28da22dba38f21b5ea) switched from RUNNING to FAILED.
  286. org.apache.flink.util.FlinkException: JobManager responsible for 8f8cb65604a1e4f369c87539cab58e59 lost the leadership.
  287. at org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnection(TaskExecutor.java:1167)
  288. at org.apache.flink.runtime.taskexecutor.TaskExecutor.disconnectJobManager(TaskExecutor.java:850)
  289. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  290. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  291. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  292. at java.lang.reflect.Method.invoke(Method.java:498)
  293. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:242)
  294. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:162)
  295. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:142)
  296. at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
  297. at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
  298. at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
  299. at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
  300. at akka.actor.ActorCell.invoke(ActorCell.scala:495)
  301. at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
  302. at akka.dispatch.Mailbox.run(Mailbox.scala:224)
  303. at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
  304. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  305. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  306. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  307. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  308. Caused by: java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id 12054323-4613-4791-bb5b-e0a0e17e9860 timed out.
  309. at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1609)
  310. at org.apache.flink.runtime.heartbeat.HeartbeatManagerImpl$HeartbeatMonitor.run(HeartbeatManagerImpl.java:339)
  311. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  312. at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  313. at org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:154)
  314. at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
  315. at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415)
  316. ... 4 more
  317.  
  318. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  319. INFO: Freeing task resources for SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (3/8) (08add9d7f3f7ceb92fff786fb7a2c87c).
  320. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  321. INFO: Ensuring all FileSystem streams are closed for task SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (3/8) (08add9d7f3f7ceb92fff786fb7a2c87c) [FAILED]
  322. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task cancelOrFailAndCancelInvokable
  323. INFO: Triggering cancellation of task code Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (4/8) (232ad5ac403c6c28da22dba38f21b5ea).
  324. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task failExternally
  325. INFO: Attempting to fail task externally SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (5/8) (234f9b5e254194302d5bb90763b6cb4c).
  326. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task transitionState
  327. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (5/8) (234f9b5e254194302d5bb90763b6cb4c) switched from RUNNING to FAILED.
  328. org.apache.flink.util.FlinkException: JobManager responsible for 8f8cb65604a1e4f369c87539cab58e59 lost the leadership.
  329. at org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnection(TaskExecutor.java:1167)
  330. at org.apache.flink.runtime.taskexecutor.TaskExecutor.disconnectJobManager(TaskExecutor.java:850)
  331. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  332. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  333. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  334. at java.lang.reflect.Method.invoke(Method.java:498)
  335. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:242)
  336. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:162)
  337. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:142)
  338. at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
  339. at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
  340. at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
  341. at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
  342. at akka.actor.ActorCell.invoke(ActorCell.scala:495)
  343. at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
  344. at akka.dispatch.Mailbox.run(Mailbox.scala:224)
  345. at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
  346. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  347. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  348. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  349. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  350. Caused by: java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id 12054323-4613-4791-bb5b-e0a0e17e9860 timed out.
  351. at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1609)
  352. at org.apache.flink.runtime.heartbeat.HeartbeatManagerImpl$HeartbeatMonitor.run(HeartbeatManagerImpl.java:339)
  353. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  354. at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  355. at org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:154)
  356. at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
  357. at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415)
  358. ... 4 more
  359.  
  360. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  361. INFO: Freeing task resources for Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (4/8) (232ad5ac403c6c28da22dba38f21b5ea).
  362. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  363. INFO: Ensuring all FileSystem streams are closed for task Source: KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource) -> Flat Map -> KafkaIO.Read/Remove Kafka Metadata/ParMultiDo(Anonymous) -> Values/Values/Map/ParMultiDo(Anonymous) -> Window.Into()/Window.Assign.out -> ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamIOSourceRel_3/Convert.ConvertTransform/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/Group by fields/ParMultiDo(Anonymous) -> ToKeyedWorkItem (4/8) (232ad5ac403c6c28da22dba38f21b5ea) [FAILED]
  364. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task transitionState
  365. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (7/8) (3edca1ad87a4a55baab8742e7b85cd8e) switched from RUNNING to CANCELED.
  366. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task transitionState
  367. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (1/8) (cdeb3f59982cc0910435e88b57bada5c) switched from RUNNING to CANCELED.
  368. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  369. INFO: Freeing task resources for SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (7/8) (3edca1ad87a4a55baab8742e7b85cd8e).
  370. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  371. INFO: Freeing task resources for SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (1/8) (cdeb3f59982cc0910435e88b57bada5c).
  372. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task transitionState
  373. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (4/8) (fafeb3f4cc3d74458aa3f909c18ed883) switched from RUNNING to CANCELED.
  374. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  375. INFO: Ensuring all FileSystem streams are closed for task SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (7/8) (3edca1ad87a4a55baab8742e7b85cd8e) [CANCELED]
  376. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  377. INFO: Freeing task resources for SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (4/8) (fafeb3f4cc3d74458aa3f909c18ed883).
  378. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task transitionState
  379. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (6/8) (b58ff01930d1ff0abfcadaec73f251ec) switched from RUNNING to CANCELED.
  380. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  381. INFO: Freeing task resources for SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (6/8) (b58ff01930d1ff0abfcadaec73f251ec).
  382. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  383. INFO: Ensuring all FileSystem streams are closed for task SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (4/8) (fafeb3f4cc3d74458aa3f909c18ed883) [CANCELED]
  384. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  385. INFO: Ensuring all FileSystem streams are closed for task SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (1/8) (cdeb3f59982cc0910435e88b57bada5c) [CANCELED]
  386. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task run
  387. INFO: Ensuring all FileSystem streams are closed for task SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (6/8) (b58ff01930d1ff0abfcadaec73f251ec) [CANCELED]
  388. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task cancelOrFailAndCancelInvokable
  389. INFO: Triggering cancellation of task code SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (5/8) (234f9b5e254194302d5bb90763b6cb4c).
  390. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task failExternally
  391. INFO: Attempting to fail task externally SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (2/8) (7bf344ddcd592a1eb7dc0d5919c3f345).
  392. May 31, 2019 10:37:44 PM org.apache.flink.runtime.taskmanager.Task transitionState
  393. INFO: SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Group.ByFields/GroupByKey -> SqlTransform/BeamAggregationRel_35/Group.CombineFieldsByFields/Combine.GroupedValues/ParDo(Anonymous)/ParMultiDo(Anonymous) -> SqlTransform/BeamAggregationRel_35/mergeRecord/ParMultiDo(Anonymous) -> ParDo(Anonymous)2/ParMultiDo(Anonymous) (2/8) (7bf344ddcd592a1eb7dc0d5919c3f345) switched from RUNNING to FAILED.
  394. org.apache.flink.util.FlinkException: JobManager responsible for 8f8cb65604a1e4f369c87539cab58e59 lost the leadership.
  395. at org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnection(TaskExecutor.java:1167)
  396. at org.apache.flink.runtime.taskexecutor.TaskExecutor.disconnectJobManager(TaskExecutor.java:850)
  397. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  398. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  399. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  400. at java.lang.reflect.Method.invoke(Method.java:498)
  401. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:242)
  402. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:162)
  403. at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:142)
  404. at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
  405. at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
  406. at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
  407. at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
  408. at akka.actor.ActorCell.invoke(ActorCell.scala:495)
  409. at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
  410. at akka.dispatch.Mailbox.run(Mailbox.scala:224)
  411. at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
  412. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  413. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  414. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  415. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  416. Caused by: java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id 12054323-4613-4791-bb5b-e0a0e17e9860 timed out.
  417. at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1609)
  418. at org.apache.flink.runtime.heartbeat.HeartbeatManagerImpl$HeartbeatMonitor.run(HeartbeatManagerImpl.java:339)
  419. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  420. at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  421. at org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:154)
  422. at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
  423. at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415)
  424. ... 4 more
  425.  
  426.  
  427. .....................................
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!