API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Jan 7th, 2022
126
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 31.67 KB | None | 0 0
raw download clone embed print report
  1. 2022-01-07 17:08:53,090 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - --------------------------------------------------------------------------------
  2. 2022-01-07 17:08:53,092 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  Preconfiguration:
  3. 2022-01-07 17:08:53,092 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -
  4.  
  5.  
  6. RESOURCE_PARAMS extraction logs:
  7. jvm_params: -Xmx1073741824 -Xms1073741824 -XX:MaxMetaspaceSize=268435456
  8. dynamic_configs: -D jobmanager.memory.off-heap.size=134217728b -D jobmanager.memory.jvm-overhead.min=201326592b -D jobmanager.memory.jvm-metaspace.size=268435456b -D jobmanager.memory.heap.size=1073741824b -D jobmanager.memory.jvm-overhead.max=201326592b
  9. logs: WARNING: sun.reflect.Reflection.getCallerClass is not supported. This will impact performance.
  10. INFO  [] - Loading configuration property: jobmanager.rpc.address, localhost
  11. INFO  [] - Loading configuration property: jobmanager.rpc.port, 6123
  12. INFO  [] - Loading configuration property: jobmanager.memory.process.size, 1600m
  13. INFO  [] - Loading configuration property: taskmanager.memory.process.size, 1728m
  14. INFO  [] - Loading configuration property: taskmanager.numberOfTaskSlots, 1
  15. INFO  [] - Loading configuration property: parallelism.default, 1
  16. INFO  [] - Loading configuration property: jobmanager.execution.failover-strategy, region
  17. INFO  [] - The derived from fraction jvm overhead memory (160.000mb (167772162 bytes)) is less than its min value 192.000mb (201326592 bytes), min value will be used instead
  18. INFO  [] - Final Master Memory configuration:
  19. INFO  [] -   Total Process Memory: 1.563gb (1677721600 bytes)
  20. INFO  [] -     Total Flink Memory: 1.125gb (1207959552 bytes)
  21. INFO  [] -       JVM Heap:         1024.000mb (1073741824 bytes)
  22. INFO  [] -       Off-heap:         128.000mb (134217728 bytes)
  23. INFO  [] -     JVM Metaspace:      256.000mb (268435456 bytes)
  24. INFO  [] -     JVM Overhead:       192.000mb (201326592 bytes)
  25.  
  26. 2022-01-07 17:08:53,093 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - --------------------------------------------------------------------------------
  27. 2022-01-07 17:08:53,093 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  Starting StandaloneSessionClusterEntrypoint (Version: 1.14.2, Scala: 2.12, Rev:6fd4b1c, Date:2021-12-14T23:22:57+01:00)
  28. 2022-01-07 17:08:53,093 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  OS current user: tampakc
  29. 2022-01-07 17:08:53,093 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  Current Hadoop/Kerberos user: <no hadoop dependency found>
  30. 2022-01-07 17:08:53,093 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  JVM: OpenJDK 64-Bit Server VM - Ubuntu - 11/11.0.13+8-Ubuntu-0ubuntu1.20.04
  31. 2022-01-07 17:08:53,094 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  Maximum heap size: 1024 MiBytes
  32. 2022-01-07 17:08:53,094 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  JAVA_HOME: (not set)
  33. 2022-01-07 17:08:53,094 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  No Hadoop Dependency available
  34. 2022-01-07 17:08:53,094 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  JVM Options:
  35. 2022-01-07 17:08:53,094 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -Xmx1073741824
  36. 2022-01-07 17:08:53,094 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -Xms1073741824
  37. 2022-01-07 17:08:53,095 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -XX:MaxMetaspaceSize=268435456
  38. 2022-01-07 17:08:53,095 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -Dlog.file=/home/tampakc/Documents/flink/log/flink-tampakc-standalonesession-0-Chris-PC.log
  39. 2022-01-07 17:08:53,095 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -Dlog4j.configuration=file:/home/tampakc/Documents/flink/conf/log4j.properties
  40. 2022-01-07 17:08:53,095 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -Dlog4j.configurationFile=file:/home/tampakc/Documents/flink/conf/log4j.properties
  41. 2022-01-07 17:08:53,095 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -Dlogback.configurationFile=file:/home/tampakc/Documents/flink/conf/logback.xml
  42. 2022-01-07 17:08:53,095 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  Program Arguments:
  43. 2022-01-07 17:08:53,096 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     --configDir
  44. 2022-01-07 17:08:53,096 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     /home/tampakc/Documents/flink/conf
  45. 2022-01-07 17:08:53,097 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     --executionMode
  46. 2022-01-07 17:08:53,097 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     cluster
  47. 2022-01-07 17:08:53,097 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -D
  48. 2022-01-07 17:08:53,097 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     jobmanager.memory.off-heap.size=134217728b
  49. 2022-01-07 17:08:53,097 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -D
  50. 2022-01-07 17:08:53,097 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     jobmanager.memory.jvm-overhead.min=201326592b
  51. 2022-01-07 17:08:53,098 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -D
  52. 2022-01-07 17:08:53,098 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     jobmanager.memory.jvm-metaspace.size=268435456b
  53. 2022-01-07 17:08:53,098 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -D
  54. 2022-01-07 17:08:53,098 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     jobmanager.memory.heap.size=1073741824b
  55. 2022-01-07 17:08:53,098 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     -D
  56. 2022-01-07 17:08:53,098 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -     jobmanager.memory.jvm-overhead.max=201326592b
  57. 2022-01-07 17:08:53,098 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] -  Classpath: /home/tampakc/Documents/flink/lib/flink-csv-1.14.2.jar:/home/tampakc/Documents/flink/lib/flink-json-1.14.2.jar:/home/tampakc/Documents/flink/lib/flink-shaded-zookeeper-3.4.14.jar:/home/tampakc/Documents/flink/lib/flink-table_2.12-1.14.2.jar:/home/tampakc/Documents/flink/lib/log4j-1.2-api-2.16.0.jar:/home/tampakc/Documents/flink/lib/log4j-api-2.16.0.jar:/home/tampakc/Documents/flink/lib/log4j-core-2.16.0.jar:/home/tampakc/Documents/flink/lib/log4j-slf4j-impl-2.16.0.jar:/home/tampakc/Documents/flink/lib/flink-dist_2.12-1.14.2.jar:::
  58. 2022-01-07 17:08:53,099 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - --------------------------------------------------------------------------------
  59. 2022-01-07 17:08:53,100 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Registered UNIX signal handlers for [TERM, HUP, INT]
  60. 2022-01-07 17:08:53,112 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.rpc.address, localhost
  61. 2022-01-07 17:08:53,113 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.rpc.port, 6123
  62. 2022-01-07 17:08:53,113 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.memory.process.size, 1600m
  63. 2022-01-07 17:08:53,113 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.memory.process.size, 1728m
  64. 2022-01-07 17:08:53,113 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.numberOfTaskSlots, 1
  65. 2022-01-07 17:08:53,113 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: parallelism.default, 1
  66. 2022-01-07 17:08:53,114 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.execution.failover-strategy, region
  67. 2022-01-07 17:08:53,143 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Starting StandaloneSessionClusterEntrypoint.
  68. 2022-01-07 17:08:53,188 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Install default filesystem.
  69. 2022-01-07 17:08:53,192 INFO  org.apache.flink.core.fs.FileSystem                          [] - Hadoop is not in the classpath/dependencies. The extended set of supported File Systems via Hadoop is not available.
  70. 2022-01-07 17:08:53,230 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Install security context.
  71. 2022-01-07 17:08:53,242 INFO  org.apache.flink.runtime.security.modules.HadoopModuleFactory [] - Cannot create Hadoop Security Module because Hadoop cannot be found in the Classpath.
  72. 2022-01-07 17:08:53,248 INFO  org.apache.flink.runtime.security.modules.JaasModule         [] - Jaas file will be created as /tmp/jaas-14732463281454905794.conf.
  73. 2022-01-07 17:08:53,257 INFO  org.apache.flink.runtime.security.contexts.HadoopSecurityContextFactory [] - Cannot install HadoopSecurityContext because Hadoop cannot be found in the Classpath.
  74. 2022-01-07 17:08:53,260 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Initializing cluster services.
  75. 2022-01-07 17:08:54,146 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils        [] - Trying to start actor system, external address localhost:6123, bind address 0.0.0.0:6123.
  76. 2022-01-07 17:08:55,147 INFO  akka.event.slf4j.Slf4jLogger                                 [] - Slf4jLogger started
  77. 2022-01-07 17:08:55,185 INFO  akka.remote.RemoteActorRefProvider                           [] - Akka Cluster not in use - enabling unsafe features anyway because `akka.remote.use-unsafe-remote-features-outside-cluster` has been enabled.
  78. 2022-01-07 17:08:55,186 INFO  akka.remote.Remoting                                         [] - Starting remoting
  79. 2022-01-07 17:08:55,349 INFO  akka.remote.Remoting                                         [] - Remoting started; listening on addresses :[akka.tcp://flink@localhost:6123]
  80. 2022-01-07 17:08:55,490 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils        [] - Actor system started at akka.tcp://flink@localhost:6123
  81. 2022-01-07 17:08:55,523 INFO  org.apache.flink.configuration.Configuration                 [] - Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'
  82. 2022-01-07 17:08:55,530 INFO  org.apache.flink.runtime.blob.BlobServer                     [] - Created BLOB server storage directory /tmp/blobStore-00b3bb9c-062e-4485-a278-6e52d74ed67e
  83. 2022-01-07 17:08:55,533 INFO  org.apache.flink.runtime.blob.BlobServer                     [] - Started BLOB server at 0.0.0.0:39263 - max concurrent requests: 50 - max backlog: 1000
  84. 2022-01-07 17:08:55,543 INFO  org.apache.flink.runtime.metrics.MetricRegistryImpl          [] - No metrics reporter configured, no metrics will be exposed/reported.
  85. 2022-01-07 17:08:55,547 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils        [] - Trying to start actor system, external address localhost:0, bind address 0.0.0.0:0.
  86. 2022-01-07 17:08:55,575 INFO  akka.event.slf4j.Slf4jLogger                                 [] - Slf4jLogger started
  87. 2022-01-07 17:08:55,582 INFO  akka.remote.RemoteActorRefProvider                           [] - Akka Cluster not in use - enabling unsafe features anyway because `akka.remote.use-unsafe-remote-features-outside-cluster` has been enabled.
  88. 2022-01-07 17:08:55,583 INFO  akka.remote.Remoting                                         [] - Starting remoting
  89. 2022-01-07 17:08:55,598 INFO  akka.remote.Remoting                                         [] - Remoting started; listening on addresses :[akka.tcp://flink-metrics@localhost:36249]
  90. 2022-01-07 17:08:55,616 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils        [] - Actor system started at akka.tcp://flink-metrics@localhost:36249
  91. 2022-01-07 17:08:55,631 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService             [] - Starting RPC endpoint for org.apache.flink.runtime.metrics.dump.MetricQueryService at akka://flink-metrics/user/rpc/MetricQueryService .
  92. 2022-01-07 17:08:55,658 INFO  org.apache.flink.runtime.dispatcher.FileExecutionGraphInfoStore [] - Initializing FileExecutionGraphInfoStore: Storage directory /tmp/executionGraphStore-b5a98316-f4c8-47d5-a476-aa9a98b1bb19, expiration time 3600000, maximum cache size 52428800 bytes.
  93. 2022-01-07 17:08:55,702 INFO  org.apache.flink.configuration.Configuration                 [] - Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'
  94. 2022-01-07 17:08:55,702 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Upload directory /tmp/flink-web-3e7d77f1-0a26-44ab-a3d9-68a2a888a401/flink-web-upload does not exist.
  95. 2022-01-07 17:08:55,703 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Created directory /tmp/flink-web-3e7d77f1-0a26-44ab-a3d9-68a2a888a401/flink-web-upload for file uploads.
  96. 2022-01-07 17:08:55,706 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Starting rest endpoint.
  97. 2022-01-07 17:08:55,979 INFO  org.apache.flink.runtime.webmonitor.WebMonitorUtils          [] - Determined location of main cluster component log file: /home/tampakc/Documents/flink/log/flink-tampakc-standalonesession-0-Chris-PC.log
  98. 2022-01-07 17:08:55,979 INFO  org.apache.flink.runtime.webmonitor.WebMonitorUtils          [] - Determined location of main cluster component stdout file: /home/tampakc/Documents/flink/log/flink-tampakc-standalonesession-0-Chris-PC.out
  99. 2022-01-07 17:08:56,153 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Rest endpoint listening at localhost:8081
  100. 2022-01-07 17:08:56,155 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - http://localhost:8081 was granted leadership with leaderSessionID=00000000-0000-0000-0000-000000000000
  101. 2022-01-07 17:08:56,155 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint   [] - Web frontend listening at http://localhost:8081.
  102. 2022-01-07 17:08:56,183 INFO  org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner [] - DefaultDispatcherRunner was granted leadership with leader id 00000000-0000-0000-0000-000000000000. Creating new DispatcherLeaderProcess.
  103. 2022-01-07 17:08:56,188 INFO  org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Start SessionDispatcherLeaderProcess.
  104. 2022-01-07 17:08:56,190 INFO  org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] - Starting resource manager service.
  105. 2022-01-07 17:08:56,190 INFO  org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Recover all persisted job graphs.
  106. 2022-01-07 17:08:56,190 INFO  org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Successfully recovered 0 persisted job graphs.
  107. 2022-01-07 17:08:56,190 INFO  org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] - Resource manager service is granted leadership with session id 00000000-0000-0000-0000-000000000000.
  108. 2022-01-07 17:08:56,201 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService             [] - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/rpc/dispatcher_0 .
  109. 2022-01-07 17:08:56,218 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService             [] - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at akka://flink/user/rpc/resourcemanager_1 .
  110. 2022-01-07 17:08:56,231 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Starting the resource manager.
  111. 2022-01-07 17:08:57,849 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Registering TaskManager with ResourceID 127.0.1.1:41579-c1f60e (akka.tcp://flink@127.0.1.1:41579/user/rpc/taskmanager_0) at ResourceManager
  112. 2022-01-07 17:08:57,903 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Registering TaskManager with ResourceID 127.0.1.1:41579-c1f60e (akka.tcp://flink@127.0.1.1:41579/user/rpc/taskmanager_0) at ResourceManager
  113. 2022-01-07 17:09:19,100 WARN  org.apache.flink.runtime.webmonitor.handlers.JarRunHandler   [] - Configuring the job submission via query parameters is deprecated. Please migrate to submitting a JSON request instead.
  114. 2022-01-07 17:09:19,128 INFO  org.apache.flink.client.ClientUtils                          [] - Starting program (detached: true)
  115. 2022-01-07 17:09:19,211 INFO  org.apache.flink.api.java.utils.PlanGenerator                [] - The job has 0 registered types and 0 default Kryo serializers
  116. 2022-01-07 17:09:19,268 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.rpc.address, localhost
  117. 2022-01-07 17:09:19,268 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.rpc.port, 6123
  118. 2022-01-07 17:09:19,269 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.memory.process.size, 1600m
  119. 2022-01-07 17:09:19,269 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.memory.process.size, 1728m
  120. 2022-01-07 17:09:19,269 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.numberOfTaskSlots, 1
  121. 2022-01-07 17:09:19,269 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: parallelism.default, 1
  122. 2022-01-07 17:09:19,269 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.execution.failover-strategy, region
  123. 2022-01-07 17:09:19,318 INFO  org.apache.flink.client.deployment.application.executors.EmbeddedExecutor [] - Job 0f421eb9d3f7fa69eb805a2698050ef8 is submitted.
  124. 2022-01-07 17:09:19,318 INFO  org.apache.flink.client.deployment.application.executors.EmbeddedExecutor [] - Submitting Job with JobId=0f421eb9d3f7fa69eb805a2698050ef8.
  125. 2022-01-07 17:09:19,413 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher     [] - Received JobGraph submission 'Flink Java Job at Fri Jan 07 17:09:19 EET 2022' (0f421eb9d3f7fa69eb805a2698050ef8).
  126. 2022-01-07 17:09:19,414 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher     [] - Submitting job 'Flink Java Job at Fri Jan 07 17:09:19 EET 2022' (0f421eb9d3f7fa69eb805a2698050ef8).
  127. 2022-01-07 17:09:19,442 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService             [] - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/rpc/jobmanager_2 .
  128. 2022-01-07 17:09:19,454 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Initializing job 'Flink Java Job at Fri Jan 07 17:09:19 EET 2022' (0f421eb9d3f7fa69eb805a2698050ef8).
  129. 2022-01-07 17:09:19,477 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Using restart back off time strategy NoRestartBackoffTimeStrategy for Flink Java Job at Fri Jan 07 17:09:19 EET 2022 (0f421eb9d3f7fa69eb805a2698050ef8).
  130. 2022-01-07 17:09:19,512 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Running initialization on master for job Flink Java Job at Fri Jan 07 17:09:19 EET 2022 (0f421eb9d3f7fa69eb805a2698050ef8).
  131. 2022-01-07 17:09:19,517 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Successfully ran initialization on master in 5 ms.
  132. 2022-01-07 17:09:19,540 INFO  org.apache.flink.runtime.scheduler.adapter.DefaultExecutionTopology [] - Built 1 pipelined regions in 0 ms
  133. 2022-01-07 17:09:19,546 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Using failover strategy org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy@79c08027 for Flink Java Job at Fri Jan 07 17:09:19 EET 2022 (0f421eb9d3f7fa69eb805a2698050ef8).
  134. 2022-01-07 17:09:19,560 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Starting execution of job 'Flink Java Job at Fri Jan 07 17:09:19 EET 2022' (0f421eb9d3f7fa69eb805a2698050ef8) under job master id 00000000000000000000000000000000.
  135. 2022-01-07 17:09:19,562 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Starting scheduling with scheduling strategy [org.apache.flink.runtime.scheduler.strategy.PipelinedRegionSchedulingStrategy]
  136. 2022-01-07 17:09:19,562 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job Flink Java Job at Fri Jan 07 17:09:19 EET 2022 (0f421eb9d3f7fa69eb805a2698050ef8) switched from state CREATED to RUNNING.
  137. 2022-01-07 17:09:19,569 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - CHAIN DataSource (at main(WordCount.java:33) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at main(WordCount.java:42)) -> Combine (SUM(1), at main(WordCount.java:45) (1/1) (b647932d29983be488099804c81b62f3) switched from CREATED to SCHEDULED.
  138. 2022-01-07 17:09:19,570 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Reduce (SUM(1), at main(WordCount.java:45) (1/1) (f6e10b11a130d005079082d75cbfc501) switched from CREATED to SCHEDULED.
  139. 2022-01-07 17:09:19,570 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - DataSink (collect()) (1/1) (1bc0a9c8e9cb4fb375bf0c59cffd69f1) switched from CREATED to SCHEDULED.
  140. 2022-01-07 17:09:19,586 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Connecting to ResourceManager akka.tcp://flink@localhost:6123/user/rpc/resourcemanager_*(00000000000000000000000000000000)
  141. 2022-01-07 17:09:19,590 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Resolved ResourceManager address, beginning registration
  142. 2022-01-07 17:09:19,592 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Registering job manager 00000000000000000000000000000000@akka.tcp://flink@localhost:6123/user/rpc/jobmanager_2 for job 0f421eb9d3f7fa69eb805a2698050ef8.
  143. 2022-01-07 17:09:19,607 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Registered job manager 00000000000000000000000000000000@akka.tcp://flink@localhost:6123/user/rpc/jobmanager_2 for job 0f421eb9d3f7fa69eb805a2698050ef8.
  144. 2022-01-07 17:09:19,600 WARN  org.apache.flink.client.deployment.application.DetachedApplicationRunner [] - Could not execute application:
  145. org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Job was submitted in detached mode. Results of job execution, such as accumulators, runtime, etc. are not available. Please make sure your program doesn't call an eager execution function [collect, print, printToErr, count].
  146.     at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372) ~[flink-dist_2.12-1.14.2.jar:1.14.2]
  147.     at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222) ~[flink-dist_2.12-1.14.2.jar:1.14.2]
  148.     at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114) ~[flink-dist_2.12-1.14.2.jar:1.14.2]
  149.     at org.apache.flink.client.deployment.application.DetachedApplicationRunner.tryExecuteJobs(DetachedApplicationRunner.java:84) ~[flink-dist_2.12-1.14.2.jar:1.14.2]
  150.     at org.apache.flink.client.deployment.application.DetachedApplicationRunner.run(DetachedApplicationRunner.java:70) ~[flink-dist_2.12-1.14.2.jar:1.14.2]
  151.     at org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleRequest$0(JarRunHandler.java:102) ~[flink-dist_2.12-1.14.2.jar:1.14.2]
  152.     at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) [?:?]
  153.     at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
  154.     at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
  155.     at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) [?:?]
  156.     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
  157.     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
  158.     at java.lang.Thread.run(Thread.java:829) [?:?]
  159. Caused by: org.apache.flink.api.common.InvalidProgramException: Job was submitted in detached mode. Results of job execution, such as accumulators, runtime, etc. are not available. Please make sure your program doesn't call an eager execution function [collect, print, printToErr, count].
  160.     at org.apache.flink.core.execution.DetachedJobExecutionResult.getAccumulatorResult(DetachedJobExecutionResult.java:56) ~[flink-dist_2.12-1.14.2.jar:1.14.2]
  161.     at org.apache.flink.api.java.DataSet.collect(DataSet.java:419) ~[flink-dist_2.12-1.14.2.jar:1.14.2]
  162.     at org.apache.flink.api.java.DataSet.print(DataSet.java:1748) ~[flink-dist_2.12-1.14.2.jar:1.14.2]
  163.     at ntua.WordCount.main(WordCount.java:48) ~[?:?]
  164.     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
  165.     at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:?]
  166.     at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
  167.     at java.lang.reflect.Method.invoke(Method.java:566) ~[?:?]
  168.     at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355) ~[flink-dist_2.12-1.14.2.jar:1.14.2]
  169.     ... 12 more
  170. 2022-01-07 17:09:19,610 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - JobManager successfully registered at ResourceManager, leader id: 00000000000000000000000000000000.
  171. 2022-01-07 17:09:19,612 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Received resource requirements from job 0f421eb9d3f7fa69eb805a2698050ef8: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]
  172. 2022-01-07 17:09:19,613 ERROR org.apache.flink.runtime.webmonitor.handlers.JarRunHandler   [] - Exception occurred in REST handler: Could not execute application.
  173. 2022-01-07 17:09:19,713 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - CHAIN DataSource (at main(WordCount.java:33) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at main(WordCount.java:42)) -> Combine (SUM(1), at main(WordCount.java:45) (1/1) (b647932d29983be488099804c81b62f3) switched from SCHEDULED to DEPLOYING.
  174. 2022-01-07 17:09:19,713 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying CHAIN DataSource (at main(WordCount.java:33) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at main(WordCount.java:42)) -> Combine (SUM(1), at main(WordCount.java:45) (1/1) (attempt #0) with attempt id b647932d29983be488099804c81b62f3 to 127.0.1.1:41579-c1f60e @ Chris-PC (dataPort=40297) with allocation id 62f82cc9661e7c2e6362bb19435d9367
  175. 2022-01-07 17:09:19,720 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Reduce (SUM(1), at main(WordCount.java:45) (1/1) (f6e10b11a130d005079082d75cbfc501) switched from SCHEDULED to DEPLOYING.
  176. 2022-01-07 17:09:19,720 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Reduce (SUM(1), at main(WordCount.java:45) (1/1) (attempt #0) with attempt id f6e10b11a130d005079082d75cbfc501 to 127.0.1.1:41579-c1f60e @ Chris-PC (dataPort=40297) with allocation id 62f82cc9661e7c2e6362bb19435d9367
  177. 2022-01-07 17:09:19,729 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - DataSink (collect()) (1/1) (1bc0a9c8e9cb4fb375bf0c59cffd69f1) switched from SCHEDULED to DEPLOYING.
  178. 2022-01-07 17:09:19,730 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying DataSink (collect()) (1/1) (attempt #0) with attempt id 1bc0a9c8e9cb4fb375bf0c59cffd69f1 to 127.0.1.1:41579-c1f60e @ Chris-PC (dataPort=40297) with allocation id 62f82cc9661e7c2e6362bb19435d9367
  179. 2022-01-07 17:09:19,891 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - CHAIN DataSource (at main(WordCount.java:33) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at main(WordCount.java:42)) -> Combine (SUM(1), at main(WordCount.java:45) (1/1) (b647932d29983be488099804c81b62f3) switched from DEPLOYING to INITIALIZING.
  180. 2022-01-07 17:09:19,893 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - DataSink (collect()) (1/1) (1bc0a9c8e9cb4fb375bf0c59cffd69f1) switched from DEPLOYING to INITIALIZING.
  181. 2022-01-07 17:09:19,894 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - CHAIN DataSource (at main(WordCount.java:33) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at main(WordCount.java:42)) -> Combine (SUM(1), at main(WordCount.java:45) (1/1) (b647932d29983be488099804c81b62f3) switched from INITIALIZING to RUNNING.
  182. 2022-01-07 17:09:19,895 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - DataSink (collect()) (1/1) (1bc0a9c8e9cb4fb375bf0c59cffd69f1) switched from INITIALIZING to RUNNING.
  183. 2022-01-07 17:09:19,904 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Reduce (SUM(1), at main(WordCount.java:45) (1/1) (f6e10b11a130d005079082d75cbfc501) switched from DEPLOYING to INITIALIZING.
  184. 2022-01-07 17:09:19,905 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Reduce (SUM(1), at main(WordCount.java:45) (1/1) (f6e10b11a130d005079082d75cbfc501) switched from INITIALIZING to RUNNING.
  185. 2022-01-07 17:09:20,102 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - CHAIN DataSource (at main(WordCount.java:33) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at main(WordCount.java:42)) -> Combine (SUM(1), at main(WordCount.java:45) (1/1) (b647932d29983be488099804c81b62f3) switched from RUNNING to FINISHED.
  186. 2022-01-07 17:09:20,108 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Reduce (SUM(1), at main(WordCount.java:45) (1/1) (f6e10b11a130d005079082d75cbfc501) switched from RUNNING to FINISHED.
  187. 2022-01-07 17:09:20,112 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - DataSink (collect()) (1/1) (1bc0a9c8e9cb4fb375bf0c59cffd69f1) switched from RUNNING to FINISHED.
  188. 2022-01-07 17:09:20,115 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Clearing resource requirements of job 0f421eb9d3f7fa69eb805a2698050ef8
  189. 2022-01-07 17:09:20,115 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job Flink Java Job at Fri Jan 07 17:09:19 EET 2022 (0f421eb9d3f7fa69eb805a2698050ef8) switched from state RUNNING to FINISHED.
  190. 2022-01-07 17:09:20,121 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher     [] - Job 0f421eb9d3f7fa69eb805a2698050ef8 reached terminal state FINISHED.
  191. 2022-01-07 17:09:20,140 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Stopping the JobMaster for job 'Flink Java Job at Fri Jan 07 17:09:19 EET 2022' (0f421eb9d3f7fa69eb805a2698050ef8).
  192. 2022-01-07 17:09:20,144 INFO  org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool [] - Releasing slot [62f82cc9661e7c2e6362bb19435d9367].
  193. 2022-01-07 17:09:20,152 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Close ResourceManager connection 60ab0e30f1fd2fe49fb2489647bb7e00: Stopping JobMaster for job 'Flink Java Job at Fri Jan 07 17:09:19 EET 2022' (0f421eb9d3f7fa69eb805a2698050ef8).
  194. 2022-01-07 17:09:20,154 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Disconnect job manager 00000000000000000000000000000000@akka.tcp://flink@localhost:6123/user/rpc/jobmanager_2 for job 0f421eb9d3f7fa69eb805a2698050ef8 from the resource manager.
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
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!