Created
December 4, 2015 05:37
-
-
Save nmadhire/be23d54ed14c5e41ab7c to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 334 [main] INFO org.apache.flink.api.java.typeutils.TypeExtractor - Class org.apache.flink.storm.api.FlinkOutputFieldsDeclarer$DefaultComparable is not public, cannot treat it as a POJO type. Will be handled as GenericType | |
| 357 [main] INFO org.apache.flink.api.java.typeutils.TypeExtractor - Class org.apache.flink.storm.api.FlinkOutputFieldsDeclarer$DefaultComparable is not public, cannot treat it as a POJO type. Will be handled as GenericType | |
| 378 [main] INFO org.apache.flink.api.java.typeutils.TypeExtractor - Class org.apache.flink.storm.api.FlinkOutputFieldsDeclarer$DefaultComparable is not public, cannot treat it as a POJO type. Will be handled as GenericType | |
| 378 [main] INFO org.apache.flink.api.java.typeutils.TypeExtractor - Class org.apache.flink.storm.api.FlinkOutputFieldsDeclarer$DefaultComparable is not public, cannot treat it as a POJO type. Will be handled as GenericType | |
| 379 [main] INFO org.apache.flink.storm.api.FlinkLocalCluster - Running Storm topology on FlinkLocalCluster | |
| 613 [main] INFO org.apache.flink.runtime.minicluster.FlinkMiniCluster - Starting FlinkMiniCluster. | |
| 851 [flink-akka.actor.default-dispatcher-4] INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started | |
| 870 [main] INFO org.apache.flink.runtime.blob.BlobServer - Created BLOB server storage directory /var/folders/lk/qksz6d2n2213lycfq66x988mf_yb7w/T/blobStore-be0277ed-d05f-4ed4-83ab-9dd827b8ece9 | |
| 871 [main] INFO org.apache.flink.runtime.blob.BlobServer - Started BLOB server at 0.0.0.0:57874 - max concurrent requests: 50 - max backlog: 1000 | |
| 884 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmanager.MemoryArchivist - Started memory archivist akka://flink/user/archive_1 | |
| 884 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager at akka://flink/user/jobmanager_1. | |
| 888 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmanager.JobManager - JobManager akka://flink/user/jobmanager_1 was granted leadership with leader session ID None. | |
| 897 [main] INFO org.apache.flink.runtime.taskmanager.TaskManager - Messages between TaskManager and JobManager have a max timeout of 100000 milliseconds | |
| 900 [main] INFO org.apache.flink.runtime.taskmanager.TaskManager - Temporary file directory '/var/folders/lk/qksz6d2n2213lycfq66x988mf_yb7w/T': total 464 GB, usable 385 GB (82.97% usable) | |
| 927 [main] INFO org.apache.flink.runtime.io.network.buffer.NetworkBufferPool - Allocated 64 MB for network buffer pool (number of memory segments: 2048, bytes per segment: 32768). | |
| 928 [main] INFO org.apache.flink.runtime.taskmanager.TaskManager - Using 1227 MB for Flink managed memory. | |
| 931 [main] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager uses directory /var/folders/lk/qksz6d2n2213lycfq66x988mf_yb7w/T/flink-io-820920ae-d319-4f37-887b-436fec39dd9a for spill files. | |
| 980 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.filecache.FileCache - User file cache uses directory /var/folders/lk/qksz6d2n2213lycfq66x988mf_yb7w/T/flink-dist-cache-ab276022-1e51-4fbf-b87b-40604c9becc5 | |
| 1162 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Starting TaskManager actor at akka://flink/user/taskmanager_1#1048499339. | |
| 1162 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - TaskManager data connection information: localhost (dataPort=57875) | |
| 1162 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - TaskManager has 6 task slot(s). | |
| 1164 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Memory usage stats: [HEAP: 90/333/3641 MB, NON HEAP: 29/30/-1 MB (used/committed/max)] | |
| 1168 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Trying to register at JobManager akka://flink/user/jobmanager_1 (attempt 1, timeout: 500 milliseconds) | |
| 1175 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.instance.InstanceManager - Registered TaskManager at localhost (akka://flink/user/taskmanager_1) as 7f75a0571a12d0e4d89653b1acd08f5d. Current number of registered hosts is 1. Current number of alive task slots is 6. | |
| 1178 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Successful registration at JobManager (akka://flink/user/jobmanager_1), starting network stack and library cache. | |
| 1183 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Determined BLOB server address to be localhost/127.0.0.1:57874. Starting BLOB cache. | |
| 1183 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.BlobCache - Created BLOB cache storage directory /var/folders/lk/qksz6d2n2213lycfq66x988mf_yb7w/T/blobStore-49401a33-115c-4b71-8ebe-c01b287b5f16 | |
| 1190 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmanager.JobManager - Submitting job 2129a1b3ef64e8e5fc21409051f916c3 (word-count). | |
| 1229 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmanager.JobManager - Scheduling job 2129a1b3ef64e8e5fc21409051f916c3 (word-count). | |
| 1231 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: spout (1/2) (aa757c971b9a64422fe972c2c93734d4) switched from CREATED to SCHEDULED | |
| 1233 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmanager.JobManager - Status of job 2129a1b3ef64e8e5fc21409051f916c3 (word-count) changed to RUNNING. | |
| 1234 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: spout (1/2) (aa757c971b9a64422fe972c2c93734d4) switched from SCHEDULED to DEPLOYING | |
| 1234 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: spout (1/2) (attempt #0) to localhost | |
| 1237 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: spout (2/2) (efa79de8145fa8566712e3ce25dc4aa4) switched from CREATED to SCHEDULED | |
| 1237 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: spout (2/2) (efa79de8145fa8566712e3ce25dc4aa4) switched from SCHEDULED to DEPLOYING | |
| 1237 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: spout (2/2) (attempt #0) to localhost | |
| 1237 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - split (1/4) (a94adb09d8cbf686fd8851b262cf888c) switched from CREATED to SCHEDULED | |
| 1238 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - split (1/4) (a94adb09d8cbf686fd8851b262cf888c) switched from SCHEDULED to DEPLOYING | |
| 1238 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying split (1/4) (attempt #0) to localhost | |
| 1240 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - split (2/4) (1cca14e38155518fbdb4f812176f61c3) switched from CREATED to SCHEDULED | |
| 1240 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - split (2/4) (1cca14e38155518fbdb4f812176f61c3) switched from SCHEDULED to DEPLOYING | |
| 1240 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying split (2/4) (attempt #0) to localhost | |
| 1241 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - split (3/4) (0dbdd7016e62bc0148e977d5c6717f70) switched from CREATED to SCHEDULED | |
| 1241 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - split (3/4) (0dbdd7016e62bc0148e977d5c6717f70) switched from SCHEDULED to DEPLOYING | |
| 1241 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying split (3/4) (attempt #0) to localhost | |
| 1242 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - split (4/4) (6651880d9af4debe4cc1bba7cb900b2f) switched from CREATED to SCHEDULED | |
| 1242 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - split (4/4) (6651880d9af4debe4cc1bba7cb900b2f) switched from SCHEDULED to DEPLOYING | |
| 1242 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying split (4/4) (attempt #0) to localhost | |
| 1243 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (1/6) (47ee2a5d944cff7f34b2ec77e4a5c992) switched from CREATED to SCHEDULED | |
| 1243 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (1/6) (47ee2a5d944cff7f34b2ec77e4a5c992) switched from SCHEDULED to DEPLOYING | |
| 1243 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying count (1/6) (attempt #0) to localhost | |
| 1244 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (2/6) (914cac663a0c474f0eb375f8a743049e) switched from CREATED to SCHEDULED | |
| 1244 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (2/6) (914cac663a0c474f0eb375f8a743049e) switched from SCHEDULED to DEPLOYING | |
| 1244 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying count (2/6) (attempt #0) to localhost | |
| 1245 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (3/6) (a951c9409f85590e862f1b208b05464a) switched from CREATED to SCHEDULED | |
| 1246 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (3/6) (a951c9409f85590e862f1b208b05464a) switched from SCHEDULED to DEPLOYING | |
| 1246 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying count (3/6) (attempt #0) to localhost | |
| 1247 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (4/6) (2855792c043a37ef4cb91aad303be303) switched from CREATED to SCHEDULED | |
| 1247 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (4/6) (2855792c043a37ef4cb91aad303be303) switched from SCHEDULED to DEPLOYING | |
| 1247 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying count (4/6) (attempt #0) to localhost | |
| 1248 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (5/6) (cbb7f20adec07dfa042e639b31a3542b) switched from CREATED to SCHEDULED | |
| 1249 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (5/6) (cbb7f20adec07dfa042e639b31a3542b) switched from SCHEDULED to DEPLOYING | |
| 1249 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying count (5/6) (attempt #0) to localhost | |
| 1250 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (6/6) (f9e637e36285e28bc239d9ad1f416295) switched from CREATED to SCHEDULED | |
| 1250 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (6/6) (f9e637e36285e28bc239d9ad1f416295) switched from SCHEDULED to DEPLOYING | |
| 1250 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying count (6/6) (attempt #0) to localhost | |
| 1251 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - printmsg (1/1) (4235c856a3533e7c3d6b9c7705af1061) switched from CREATED to SCHEDULED | |
| 1251 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - printmsg (1/1) (4235c856a3533e7c3d6b9c7705af1061) switched from SCHEDULED to DEPLOYING | |
| 1251 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying printmsg (1/1) (attempt #0) to localhost | |
| 1258 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task Source: spout (1/2) | |
| 1258 [Source: spout (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Source: spout (1/2) | |
| 1259 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task Source: spout (2/2) | |
| 1259 [Source: spout (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Source: spout (2/2) | |
| 1260 [Source: spout (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Source: spout (1/2) [DEPLOYING] | |
| 1260 [Source: spout (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Source: spout (2/2) [DEPLOYING] | |
| 1262 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task split (1/4) | |
| 1262 [split (1/4)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task split (1/4) | |
| 1262 [split (1/4)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: split (1/4) [DEPLOYING] | |
| 1263 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task split (2/4) | |
| 1264 [split (2/4)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task split (2/4) | |
| 1264 [split (2/4)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: split (2/4) [DEPLOYING] | |
| 1265 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task split (3/4) | |
| 1265 [split (3/4)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task split (3/4) | |
| 1265 [split (3/4)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: split (3/4) [DEPLOYING] | |
| 1271 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task split (4/4) | |
| 1271 [split (4/4)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task split (4/4) | |
| 1272 [split (4/4)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: split (4/4) [DEPLOYING] | |
| 1272 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task count (1/6) | |
| 1272 [count (1/6)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task count (1/6) | |
| 1273 [count (1/6)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: count (1/6) [DEPLOYING] | |
| 1274 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task count (2/6) | |
| 1274 [count (2/6)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task count (2/6) | |
| 1274 [count (2/6)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: count (2/6) [DEPLOYING] | |
| 1279 [Source: spout (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Source: spout (1/2) switched to RUNNING | |
| 1280 [Source: spout (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Source: spout (2/2) switched to RUNNING | |
| 1280 [Source: spout (1/2)] WARN org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been specified, using default state backend (Memory / JobManager) | |
| 1280 [Source: spout (1/2)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - State backend is set to heap memory (checkpoint to jobmanager) | |
| 1280 [Source: spout (2/2)] WARN org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been specified, using default state backend (Memory / JobManager) | |
| 1280 [Source: spout (2/2)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - State backend is set to heap memory (checkpoint to jobmanager) | |
| 1284 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task count (3/6) | |
| 1285 [count (3/6)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task count (3/6) | |
| 1285 [count (3/6)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: count (3/6) [DEPLOYING] | |
| 1286 [split (1/4)] INFO org.apache.flink.runtime.taskmanager.Task - split (1/4) switched to RUNNING | |
| 1286 [count (2/6)] INFO org.apache.flink.runtime.taskmanager.Task - count (2/6) switched to RUNNING | |
| 1286 [split (3/4)] INFO org.apache.flink.runtime.taskmanager.Task - split (3/4) switched to RUNNING | |
| 1286 [split (2/4)] INFO org.apache.flink.runtime.taskmanager.Task - split (2/4) switched to RUNNING | |
| 1286 [split (4/4)] INFO org.apache.flink.runtime.taskmanager.Task - split (4/4) switched to RUNNING | |
| 1286 [split (3/4)] WARN org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been specified, using default state backend (Memory / JobManager) | |
| 1286 [count (2/6)] WARN org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been specified, using default state backend (Memory / JobManager) | |
| 1286 [split (1/4)] WARN org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been specified, using default state backend (Memory / JobManager) | |
| 1286 [count (1/6)] INFO org.apache.flink.runtime.taskmanager.Task - count (1/6) switched to RUNNING | |
| 1286 [split (1/4)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - State backend is set to heap memory (checkpoint to jobmanager) | |
| 1286 [count (2/6)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - State backend is set to heap memory (checkpoint to jobmanager) | |
| 1286 [split (3/4)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - State backend is set to heap memory (checkpoint to jobmanager) | |
| 1286 [split (4/4)] WARN org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been specified, using default state backend (Memory / JobManager) | |
| 1286 [split (2/4)] WARN org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been specified, using default state backend (Memory / JobManager) | |
| 1287 [split (4/4)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - State backend is set to heap memory (checkpoint to jobmanager) | |
| 1286 [count (1/6)] WARN org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been specified, using default state backend (Memory / JobManager) | |
| 1287 [count (1/6)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - State backend is set to heap memory (checkpoint to jobmanager) | |
| 1287 [split (2/4)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - State backend is set to heap memory (checkpoint to jobmanager) | |
| 1286 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task count (4/6) | |
| 1287 [count (4/6)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task count (4/6) | |
| 1287 [count (4/6)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: count (4/6) [DEPLOYING] | |
| 1288 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task count (5/6) | |
| 1288 [count (5/6)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task count (5/6) | |
| 1288 [count (5/6)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: count (5/6) [DEPLOYING] | |
| 1289 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task count (6/6) | |
| 1289 [count (6/6)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task count (6/6) | |
| 1289 [count (6/6)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: count (6/6) [DEPLOYING] | |
| 1291 [count (3/6)] INFO org.apache.flink.runtime.taskmanager.Task - count (3/6) switched to RUNNING | |
| 1291 [count (3/6)] WARN org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been specified, using default state backend (Memory / JobManager) | |
| 1292 [count (3/6)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - State backend is set to heap memory (checkpoint to jobmanager) | |
| 1293 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task printmsg (1/1) | |
| 1293 [printmsg (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task printmsg (1/1) | |
| 1293 [printmsg (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: printmsg (1/1) [DEPLOYING] | |
| 1294 [count (4/6)] INFO org.apache.flink.runtime.taskmanager.Task - count (4/6) switched to RUNNING | |
| 1294 [count (4/6)] WARN org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been specified, using default state backend (Memory / JobManager) | |
| 1294 [count (4/6)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - State backend is set to heap memory (checkpoint to jobmanager) | |
| 1295 [count (5/6)] INFO org.apache.flink.runtime.taskmanager.Task - count (5/6) switched to RUNNING | |
| 1295 [count (5/6)] WARN org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been specified, using default state backend (Memory / JobManager) | |
| 1295 [count (5/6)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - State backend is set to heap memory (checkpoint to jobmanager) | |
| 1295 [count (6/6)] INFO org.apache.flink.runtime.taskmanager.Task - count (6/6) switched to RUNNING | |
| 1295 [count (6/6)] WARN org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been specified, using default state backend (Memory / JobManager) | |
| 1295 [count (6/6)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - State backend is set to heap memory (checkpoint to jobmanager) | |
| 1295 [printmsg (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - printmsg (1/1) switched to RUNNING | |
| 1295 [printmsg (1/1)] WARN org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been specified, using default state backend (Memory / JobManager) | |
| 1295 [printmsg (1/1)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - State backend is set to heap memory (checkpoint to jobmanager) | |
| 1296 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: spout (1/2) (aa757c971b9a64422fe972c2c93734d4) switched from DEPLOYING to RUNNING | |
| 1297 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: spout (2/2) (efa79de8145fa8566712e3ce25dc4aa4) switched from DEPLOYING to RUNNING | |
| 1297 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - split (1/4) (a94adb09d8cbf686fd8851b262cf888c) switched from DEPLOYING to RUNNING | |
| 1297 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (2/6) (914cac663a0c474f0eb375f8a743049e) switched from DEPLOYING to RUNNING | |
| 1297 [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - split (3/4) (0dbdd7016e62bc0148e977d5c6717f70) switched from DEPLOYING to RUNNING | |
| 1297 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - split (2/4) (1cca14e38155518fbdb4f812176f61c3) switched from DEPLOYING to RUNNING | |
| 1298 [flink-akka.actor.default-dispatcher-10] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - split (4/4) (6651880d9af4debe4cc1bba7cb900b2f) switched from DEPLOYING to RUNNING | |
| 1298 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (1/6) (47ee2a5d944cff7f34b2ec77e4a5c992) switched from DEPLOYING to RUNNING | |
| 1298 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (3/6) (a951c9409f85590e862f1b208b05464a) switched from DEPLOYING to RUNNING | |
| 1298 [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (4/6) (2855792c043a37ef4cb91aad303be303) switched from DEPLOYING to RUNNING | |
| 1298 [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (5/6) (cbb7f20adec07dfa042e639b31a3542b) switched from DEPLOYING to RUNNING | |
| 1298 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - count (6/6) (f9e637e36285e28bc239d9ad1f416295) switched from DEPLOYING to RUNNING | |
| 1298 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - printmsg (1/1) (4235c856a3533e7c3d6b9c7705af1061) switched from DEPLOYING to RUNNING | |
| 11233 [Thread-7] INFO org.apache.flink.runtime.blob.BlobCache - Shutting down BlobCache | |
| 11238 [I/O manager shutdown hook] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /var/folders/lk/qksz6d2n2213lycfq66x988mf_yb7w/T/flink-io-820920ae-d319-4f37-887b-436fec39dd9a | |
| 11238 [Thread-2] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:57874 | |
| Process finished with exit code 0 |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment