Created
March 18, 2016 16:45
-
-
Save maxd/9859eb8c4bcfb62b53b0 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
2016-03-18 16:24:03,226 WARN org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable | |
2016-03-18 16:24:03,360 INFO org.apache.flink.runtime.taskmanager.TaskManager - -------------------------------------------------------------------------------- | |
2016-03-18 16:24:03,360 INFO org.apache.flink.runtime.taskmanager.TaskManager - Starting TaskManager (Version: 1.0.0, Rev:94cd554, Date:03.03.2016 @ 08:34:27 UTC) | |
2016-03-18 16:24:03,361 INFO org.apache.flink.runtime.taskmanager.TaskManager - Current user: root | |
2016-03-18 16:24:03,361 INFO org.apache.flink.runtime.taskmanager.TaskManager - JVM: OpenJDK 64-Bit Server VM - Oracle Corporation - 1.8/25.71-b15 | |
2016-03-18 16:24:03,361 INFO org.apache.flink.runtime.taskmanager.TaskManager - Maximum heap size: 1963 MiBytes | |
2016-03-18 16:24:03,361 INFO org.apache.flink.runtime.taskmanager.TaskManager - JAVA_HOME: (not set) | |
2016-03-18 16:24:03,364 INFO org.apache.flink.runtime.taskmanager.TaskManager - Hadoop version: 2.7.2 | |
2016-03-18 16:24:03,364 INFO org.apache.flink.runtime.taskmanager.TaskManager - JVM Options: | |
2016-03-18 16:24:03,364 INFO org.apache.flink.runtime.taskmanager.TaskManager - -Xms2048M | |
2016-03-18 16:24:03,364 INFO org.apache.flink.runtime.taskmanager.TaskManager - -Xmx2048M | |
2016-03-18 16:24:03,364 INFO org.apache.flink.runtime.taskmanager.TaskManager - -XX:MaxDirectMemorySize=8388607T | |
2016-03-18 16:24:03,364 INFO org.apache.flink.runtime.taskmanager.TaskManager - -Dlog.file=/flink/log/flink--taskmanager-0-app-1.stag.local.log | |
2016-03-18 16:24:03,364 INFO org.apache.flink.runtime.taskmanager.TaskManager - -Dlog4j.configuration=file:/flink/conf/log4j.properties | |
2016-03-18 16:24:03,364 INFO org.apache.flink.runtime.taskmanager.TaskManager - -Dlogback.configurationFile=file:/flink/conf/logback.xml | |
2016-03-18 16:24:03,364 INFO org.apache.flink.runtime.taskmanager.TaskManager - -Djava.net.preferIPv4Stack=true | |
2016-03-18 16:24:03,364 INFO org.apache.flink.runtime.taskmanager.TaskManager - Program Arguments: | |
2016-03-18 16:24:03,365 INFO org.apache.flink.runtime.taskmanager.TaskManager - --configDir | |
2016-03-18 16:24:03,365 INFO org.apache.flink.runtime.taskmanager.TaskManager - /flink/conf | |
2016-03-18 16:24:03,365 INFO org.apache.flink.runtime.taskmanager.TaskManager - Classpath: /flink/lib/flink-dist_2.11-1.0.0.jar:/flink/lib/flink-python_2.11-1.0.0.jar:/flink/lib/log4j-1.2.17.jar:/flink/lib/slf4j-log4j12-1.7.7.jar::: | |
2016-03-18 16:24:03,365 INFO org.apache.flink.runtime.taskmanager.TaskManager - -------------------------------------------------------------------------------- | |
2016-03-18 16:24:03,366 INFO org.apache.flink.runtime.taskmanager.TaskManager - Registered UNIX signal handlers for [TERM, HUP, INT] | |
2016-03-18 16:24:03,369 INFO org.apache.flink.runtime.taskmanager.TaskManager - Maximum number of open file descriptors is 1048576 | |
2016-03-18 16:24:03,388 INFO org.apache.flink.runtime.taskmanager.TaskManager - Loading configuration from /flink/conf | |
2016-03-18 16:24:03,436 INFO org.apache.flink.runtime.taskmanager.TaskManager - Security is not enabled. Starting non-authenticated TaskManager. | |
2016-03-18 16:24:03,458 INFO org.apache.flink.runtime.util.LeaderRetrievalUtils - Trying to select the network interface and address to use by connecting to the leading JobManager. | |
2016-03-18 16:24:03,459 INFO org.apache.flink.runtime.util.LeaderRetrievalUtils - TaskManager will try to connect for 10000 milliseconds before falling back to heuristics | |
2016-03-18 16:24:03,463 INFO org.apache.flink.runtime.net.ConnectionUtils - Retrieved new target address /192.168.38.93:6123. | |
2016-03-18 16:24:03,469 INFO org.apache.flink.runtime.taskmanager.TaskManager - TaskManager will use hostname/address 'app-1.stag.local' (192.168.38.93) for communication. | |
2016-03-18 16:24:03,470 INFO org.apache.flink.runtime.taskmanager.TaskManager - Starting TaskManager | |
2016-03-18 16:24:03,471 INFO org.apache.flink.runtime.taskmanager.TaskManager - Starting TaskManager actor system at 192.168.38.93:0 | |
2016-03-18 16:24:03,885 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started | |
2016-03-18 16:24:03,940 INFO Remoting - Starting remoting | |
2016-03-18 16:24:04,200 INFO Remoting - Remoting started; listening on addresses :[akka.tcp://flink@192.168.38.93:38906] | |
2016-03-18 16:24:04,201 INFO org.apache.flink.runtime.taskmanager.TaskManager - Starting TaskManager actor | |
2016-03-18 16:24:04,210 INFO org.apache.flink.runtime.io.network.netty.NettyConfig - NettyConfig [server address: app-1.stag.local/192.168.38.93, server port: 44582, memory segment size (bytes): 32768, transport type: NIO, number of server threads: 4 (manual), number of client threads: 4 (manual), server connect backlog: 0 (use Netty's default), client connect timeout (sec): 120, send/receive buffer size (bytes): 0 (use Netty's default)] | |
2016-03-18 16:24:04,214 INFO org.apache.flink.runtime.taskmanager.TaskManager - Messages between TaskManager and JobManager have a max timeout of 10000 milliseconds | |
2016-03-18 16:24:04,218 INFO org.apache.flink.runtime.taskmanager.TaskManager - Temporary file directory '/tmp': total 24 GB, usable 18 GB (75.00% usable) | |
2016-03-18 16:24:04,268 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). | |
2016-03-18 16:24:04,364 INFO org.apache.flink.runtime.taskmanager.TaskManager - Limiting managed memory to 0.7 of the currently free heap space (1318 MB), memory will be allocated lazily. | |
2016-03-18 16:24:04,381 INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager uses directory /tmp/flink-io-dedc0fb2-104c-499a-ac6c-08bf53602e3e for spill files. | |
2016-03-18 16:24:04,390 INFO org.apache.flink.runtime.filecache.FileCache - User file cache uses directory /tmp/flink-dist-cache-621b68be-eeda-4df5-8b68-8c0221afce34 | |
2016-03-18 16:24:04,625 INFO org.apache.flink.runtime.taskmanager.TaskManager - Starting TaskManager actor at akka://flink/user/taskmanager#483787642. | |
2016-03-18 16:24:04,625 INFO org.apache.flink.runtime.taskmanager.TaskManager - TaskManager data connection information: app-1.stag.local (dataPort=44582) | |
2016-03-18 16:24:04,626 INFO org.apache.flink.runtime.taskmanager.TaskManager - TaskManager has 4 task slot(s). | |
2016-03-18 16:24:04,627 INFO org.apache.flink.runtime.taskmanager.TaskManager - Memory usage stats: [HEAP: 131/1963/1963 MB, NON HEAP: 32/32/-1 MB (used/committed/max)] | |
2016-03-18 16:24:04,631 INFO org.apache.flink.runtime.taskmanager.TaskManager - Trying to register at JobManager akka.tcp://flink@192.168.38.93:6123/user/jobmanager (attempt 1, timeout: 500 milliseconds) | |
2016-03-18 16:24:04,948 INFO org.apache.flink.runtime.taskmanager.TaskManager - Successful registration at JobManager (akka.tcp://flink@192.168.38.93:6123/user/jobmanager), starting network stack and library cache. | |
2016-03-18 16:24:05,200 INFO org.apache.flink.runtime.io.network.netty.NettyClient - Successful initialization (took 42 ms). | |
2016-03-18 16:24:05,243 INFO org.apache.flink.runtime.io.network.netty.NettyServer - Successful initialization (took 43 ms). Listening on SocketAddress /192.168.38.93:44582. | |
2016-03-18 16:24:05,244 INFO org.apache.flink.runtime.taskmanager.TaskManager - Determined BLOB server address to be /192.168.38.93:6130. Starting BLOB cache. | |
2016-03-18 16:24:05,247 INFO org.apache.flink.runtime.blob.BlobCache - Created BLOB cache storage directory /tmp/blobStore-bb77fa25-8fce-4564-a947-82b8dd935736 | |
2016-03-18 16:24:46,330 INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task Source: RSyslog Server Source (1/1) | |
2016-03-18 16:24:46,331 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Source: RSyslog Server Source (1/1) | |
2016-03-18 16:24:46,335 INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (1/8) | |
2016-03-18 16:24:46,335 INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (2/8) | |
2016-03-18 16:24:46,336 INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (3/8) | |
2016-03-18 16:24:46,339 INFO org.apache.flink.runtime.blob.BlobCache - Downloading e082fedf20e9b9e8c868bd49ce455e0b826362c0 from /192.168.38.93:6130 | |
2016-03-18 16:24:46,335 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (1/8) | |
2016-03-18 16:24:46,367 INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (4/8) | |
2016-03-18 16:24:46,336 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (3/8) | |
2016-03-18 16:24:46,336 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (2/8) | |
2016-03-18 16:24:46,394 INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task Calculate total traffic and duration (5/8) | |
2016-03-18 16:24:46,401 INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task Calculate total traffic and duration (6/8) | |
2016-03-18 16:24:46,406 INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task Calculate total traffic and duration (7/8) | |
2016-03-18 16:24:46,412 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Calculate total traffic and duration (5/8) | |
2016-03-18 16:24:46,413 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Calculate total traffic and duration (7/8) | |
2016-03-18 16:24:46,419 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Calculate total traffic and duration (7/8) [DEPLOYING] | |
2016-03-18 16:24:46,412 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (4/8) | |
2016-03-18 16:24:46,412 INFO org.apache.flink.runtime.taskmanager.TaskManager - Received task Calculate total traffic and duration (8/8) | |
2016-03-18 16:24:46,412 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Calculate total traffic and duration (6/8) | |
2016-03-18 16:24:46,425 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Calculate total traffic and duration (6/8) [DEPLOYING] | |
2016-03-18 16:24:46,425 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (4/8) [DEPLOYING] | |
2016-03-18 16:24:46,426 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Calculate total traffic and duration (8/8) | |
2016-03-18 16:24:46,437 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Calculate total traffic and duration (8/8) [DEPLOYING] | |
2016-03-18 16:24:46,425 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (3/8) [DEPLOYING] | |
2016-03-18 16:24:46,421 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Calculate total traffic and duration (5/8) [DEPLOYING] | |
2016-03-18 16:24:46,421 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (2/8) [DEPLOYING] | |
2016-03-18 16:24:46,439 INFO org.apache.flink.runtime.taskmanager.Task - Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (4/8) switched to RUNNING | |
2016-03-18 16:24:46,421 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Source: RSyslog Server Source (1/1) [DEPLOYING] | |
2016-03-18 16:24:46,419 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (1/8) [DEPLOYING] | |
2016-03-18 16:24:46,450 INFO org.apache.flink.runtime.taskmanager.Task - Calculate total traffic and duration (8/8) switched to RUNNING | |
2016-03-18 16:24:46,448 INFO org.apache.flink.runtime.taskmanager.Task - Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (3/8) switched to RUNNING | |
2016-03-18 16:24:46,447 INFO org.apache.flink.runtime.taskmanager.Task - Calculate total traffic and duration (5/8) switched to RUNNING | |
2016-03-18 16:24:46,446 INFO org.apache.flink.runtime.taskmanager.Task - Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (2/8) switched to RUNNING | |
2016-03-18 16:24:46,437 INFO org.apache.flink.runtime.taskmanager.Task - Calculate total traffic and duration (6/8) switched to RUNNING | |
2016-03-18 16:24:46,434 INFO org.apache.flink.runtime.taskmanager.Task - Calculate total traffic and duration (7/8) switched to RUNNING | |
2016-03-18 16:24:46,459 INFO org.apache.flink.runtime.taskmanager.Task - Source: RSyslog Server Source (1/1) switched to RUNNING | |
2016-03-18 16:24:46,452 INFO org.apache.flink.runtime.taskmanager.Task - Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (1/8) switched to RUNNING | |
2016-03-18 16:24:46,770 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:46,773 INFO streamer_sessions_aggregator.sources.rsyslog.RSyslogRFC3164StreamFunction - Open RSyslog UDP socket bind to 0.0.0.0:9002 | |
2016-03-18 16:24:46,775 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:46,775 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:46,784 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:46,797 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:46,899 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:46,900 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:46,907 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:46,908 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:46,913 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:46,914 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:46,916 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:46,917 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:47,093 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:47,115 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:47,121 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:24:47,131 INFO org.apache.flink.streaming.runtime.tasks.StreamTask - Using user-defined state backend: MemoryStateBackend (data in heap memory / checkpoints to JobManager) | |
2016-03-18 16:26:22,310 ERROR streamer_sessions_aggregator.LogItemParser - Can't convert session metadata from Base64 format. | |
java.lang.IllegalArgumentException: Illegal base64 character 25 | |
at java.util.Base64$Decoder.decode0(Base64.java:714) | |
at java.util.Base64$Decoder.decode(Base64.java:526) | |
at java.util.Base64$Decoder.decode(Base64.java:549) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:45) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:16) | |
at org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(StreamFlatMap.java:48) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:351) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:337) | |
at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:39) | |
at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168) | |
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65) | |
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224) | |
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
at java.lang.Thread.run(Thread.java:745) | |
2016-03-18 16:26:22,320 ERROR streamer_sessions_aggregator.LogItemParser - Can't convert session metadata from Base64 format. | |
java.lang.IllegalArgumentException: Illegal base64 character 25 | |
at java.util.Base64$Decoder.decode0(Base64.java:714) | |
at java.util.Base64$Decoder.decode(Base64.java:526) | |
at java.util.Base64$Decoder.decode(Base64.java:549) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:45) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:16) | |
at org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(StreamFlatMap.java:48) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:351) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:337) | |
at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:39) | |
at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168) | |
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65) | |
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224) | |
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
at java.lang.Thread.run(Thread.java:745) | |
2016-03-18 16:26:22,390 ERROR streamer_sessions_aggregator.LogItemParser - Can't convert session metadata from Base64 format. | |
java.lang.IllegalArgumentException: Illegal base64 character 25 | |
at java.util.Base64$Decoder.decode0(Base64.java:714) | |
at java.util.Base64$Decoder.decode(Base64.java:526) | |
at java.util.Base64$Decoder.decode(Base64.java:549) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:45) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:16) | |
at org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(StreamFlatMap.java:48) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:351) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:337) | |
at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:39) | |
at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168) | |
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65) | |
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224) | |
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
at java.lang.Thread.run(Thread.java:745) | |
2016-03-18 16:26:26,195 ERROR streamer_sessions_aggregator.LogItemParser - Can't convert session metadata from Base64 format. | |
java.lang.IllegalArgumentException: Illegal base64 character 25 | |
at java.util.Base64$Decoder.decode0(Base64.java:714) | |
at java.util.Base64$Decoder.decode(Base64.java:526) | |
at java.util.Base64$Decoder.decode(Base64.java:549) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:45) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:16) | |
at org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(StreamFlatMap.java:48) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:351) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:337) | |
at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:39) | |
at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168) | |
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65) | |
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224) | |
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
at java.lang.Thread.run(Thread.java:745) | |
2016-03-18 16:26:26,199 ERROR streamer_sessions_aggregator.LogItemParser - Can't convert session metadata from Base64 format. | |
java.lang.IllegalArgumentException: Illegal base64 character 25 | |
at java.util.Base64$Decoder.decode0(Base64.java:714) | |
at java.util.Base64$Decoder.decode(Base64.java:526) | |
at java.util.Base64$Decoder.decode(Base64.java:549) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:45) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:16) | |
at org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(StreamFlatMap.java:48) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:351) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:337) | |
at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:39) | |
at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168) | |
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65) | |
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224) | |
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
at java.lang.Thread.run(Thread.java:745) | |
2016-03-18 16:26:28,402 ERROR streamer_sessions_aggregator.LogItemParser - Can't convert session metadata from Base64 format. | |
java.lang.IllegalArgumentException: Illegal base64 character 25 | |
at java.util.Base64$Decoder.decode0(Base64.java:714) | |
at java.util.Base64$Decoder.decode(Base64.java:526) | |
at java.util.Base64$Decoder.decode(Base64.java:549) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:45) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:16) | |
at org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(StreamFlatMap.java:48) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:351) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:337) | |
at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:39) | |
at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168) | |
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65) | |
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224) | |
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
at java.lang.Thread.run(Thread.java:745) | |
2016-03-18 16:26:28,402 ERROR streamer_sessions_aggregator.LogItemParser - Can't convert session metadata from Base64 format. | |
java.lang.IllegalArgumentException: Illegal base64 character 25 | |
at java.util.Base64$Decoder.decode0(Base64.java:714) | |
at java.util.Base64$Decoder.decode(Base64.java:526) | |
at java.util.Base64$Decoder.decode(Base64.java:549) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:45) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:16) | |
at org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(StreamFlatMap.java:48) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:351) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:337) | |
at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:39) | |
at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168) | |
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65) | |
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224) | |
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
at java.lang.Thread.run(Thread.java:745) | |
2016-03-18 16:26:40,128 ERROR streamer_sessions_aggregator.LogItemParser - Can't convert session metadata from Base64 format. | |
java.lang.IllegalArgumentException: Illegal base64 character 25 | |
at java.util.Base64$Decoder.decode0(Base64.java:714) | |
at java.util.Base64$Decoder.decode(Base64.java:526) | |
at java.util.Base64$Decoder.decode(Base64.java:549) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:45) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:16) | |
at org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(StreamFlatMap.java:48) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:351) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:337) | |
at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:39) | |
at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168) | |
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65) | |
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224) | |
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
at java.lang.Thread.run(Thread.java:745) | |
2016-03-18 16:26:40,228 ERROR streamer_sessions_aggregator.LogItemParser - Can't convert session metadata from Base64 format. | |
java.lang.IllegalArgumentException: Illegal base64 character 25 | |
at java.util.Base64$Decoder.decode0(Base64.java:714) | |
at java.util.Base64$Decoder.decode(Base64.java:526) | |
at java.util.Base64$Decoder.decode(Base64.java:549) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:45) | |
at streamer_sessions_aggregator.LogItemParser.flatMap(LogItemParser.java:16) | |
at org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(StreamFlatMap.java:48) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:351) | |
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:337) | |
at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:39) | |
at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:168) | |
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65) | |
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224) | |
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
at java.lang.Thread.run(Thread.java:745) | |
2016-03-18 16:26:47,152 INFO org.apache.flink.runtime.taskmanager.TaskManager - Discarding the results produced by task execution e7ecb5a8255f48a53423931ade3712a4 | |
2016-03-18 16:26:47,154 INFO org.apache.flink.runtime.taskmanager.Task - Calculate total traffic and duration (6/8) switched to FAILED with exception. | |
java.io.IOException: Connecting the channel failed: Connecting to remote task manager + 'app-2.stag.local/192.168.38.98:35806' has failed. This might indicate that the remote task manager has been lost. | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.waitForChannel(PartitionRequestClientFactory.java:196) | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.access$000(PartitionRequestClientFactory.java:131) | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory.createPartitionRequestClient(PartitionRequestClientFactory.java:67) | |
at org.apache.flink.runtime.io.network.netty.NettyConnectionManager.createPartitionRequestClient(NettyConnectionManager.java:60) | |
at org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel.requestSubpartition(RemoteInputChannel.java:114) | |
at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.requestPartitions(SingleInputGate.java:388) | |
at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:411) | |
at org.apache.flink.streaming.runtime.io.BarrierTracker.getNextNonBlocked(BarrierTracker.java:75) | |
at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:175) | |
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65) | |
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224) | |
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
at java.lang.Thread.run(Thread.java:745) | |
Caused by: org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException: Connecting to remote task manager + 'app-2.stag.local/192.168.38.98:35806' has failed. This might indicate that the remote task manager has been lost. | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.operationComplete(PartitionRequestClientFactory.java:215) | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.operationComplete(PartitionRequestClientFactory.java:131) | |
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680) | |
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:603) | |
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:563) | |
at io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:424) | |
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:214) | |
at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38) | |
at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:120) | |
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:357) | |
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:357) | |
at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111) | |
... 1 more | |
Caused by: io.netty.channel.ConnectTimeoutException: connection timed out: app-2.stag.local/192.168.38.98:35806 | |
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:212) | |
... 6 more | |
2016-03-18 16:26:47,154 INFO org.apache.flink.runtime.taskmanager.Task - Calculate total traffic and duration (5/8) switched to FAILED with exception. | |
java.io.IOException: Connecting the channel failed: Connecting to remote task manager + 'app-2.stag.local/192.168.38.98:35806' has failed. This might indicate that the remote task manager has been lost. | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.waitForChannel(PartitionRequestClientFactory.java:196) | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.access$000(PartitionRequestClientFactory.java:131) | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory.createPartitionRequestClient(PartitionRequestClientFactory.java:67) | |
at org.apache.flink.runtime.io.network.netty.NettyConnectionManager.createPartitionRequestClient(NettyConnectionManager.java:60) | |
at org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel.requestSubpartition(RemoteInputChannel.java:114) | |
at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.requestPartitions(SingleInputGate.java:388) | |
at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:411) | |
at org.apache.flink.streaming.runtime.io.BarrierTracker.getNextNonBlocked(BarrierTracker.java:75) | |
at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:175) | |
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65) | |
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224) | |
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
at java.lang.Thread.run(Thread.java:745) | |
Caused by: org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException: Connecting to remote task manager + 'app-2.stag.local/192.168.38.98:35806' has failed. This might indicate that the remote task manager has been lost. | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.operationComplete(PartitionRequestClientFactory.java:215) | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.operationComplete(PartitionRequestClientFactory.java:131) | |
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680) | |
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:603) | |
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:563) | |
at io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:424) | |
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:214) | |
at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38) | |
at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:120) | |
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:357) | |
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:357) | |
at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111) | |
... 1 more | |
Caused by: io.netty.channel.ConnectTimeoutException: connection timed out: app-2.stag.local/192.168.38.98:35806 | |
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:212) | |
... 6 more | |
2016-03-18 16:26:47,154 INFO org.apache.flink.runtime.taskmanager.Task - Calculate total traffic and duration (7/8) switched to FAILED with exception. | |
java.io.IOException: Connecting the channel failed: Connecting to remote task manager + 'app-2.stag.local/192.168.38.98:35806' has failed. This might indicate that the remote task manager has been lost. | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.waitForChannel(PartitionRequestClientFactory.java:196) | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.access$000(PartitionRequestClientFactory.java:131) | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory.createPartitionRequestClient(PartitionRequestClientFactory.java:83) | |
at org.apache.flink.runtime.io.network.netty.NettyConnectionManager.createPartitionRequestClient(NettyConnectionManager.java:60) | |
at org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel.requestSubpartition(RemoteInputChannel.java:114) | |
at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.requestPartitions(SingleInputGate.java:388) | |
at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:411) | |
at org.apache.flink.streaming.runtime.io.BarrierTracker.getNextNonBlocked(BarrierTracker.java:75) | |
at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:175) | |
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65) | |
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224) | |
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
at java.lang.Thread.run(Thread.java:745) | |
Caused by: org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException: Connecting to remote task manager + 'app-2.stag.local/192.168.38.98:35806' has failed. This might indicate that the remote task manager has been lost. | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.operationComplete(PartitionRequestClientFactory.java:215) | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.operationComplete(PartitionRequestClientFactory.java:131) | |
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680) | |
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:603) | |
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:563) | |
at io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:424) | |
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:214) | |
at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38) | |
at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:120) | |
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:357) | |
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:357) | |
at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111) | |
... 1 more | |
Caused by: io.netty.channel.ConnectTimeoutException: connection timed out: app-2.stag.local/192.168.38.98:35806 | |
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:212) | |
... 6 more | |
2016-03-18 16:26:47,163 INFO org.apache.flink.runtime.taskmanager.Task - Calculate total traffic and duration (8/8) switched to FAILED with exception. | |
java.io.IOException: Connecting the channel failed: Connecting to remote task manager + 'app-2.stag.local/192.168.38.98:35806' has failed. This might indicate that the remote task manager has been lost. | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.waitForChannel(PartitionRequestClientFactory.java:196) | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.access$000(PartitionRequestClientFactory.java:131) | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory.createPartitionRequestClient(PartitionRequestClientFactory.java:67) | |
at org.apache.flink.runtime.io.network.netty.NettyConnectionManager.createPartitionRequestClient(NettyConnectionManager.java:60) | |
at org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel.requestSubpartition(RemoteInputChannel.java:114) | |
at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.requestPartitions(SingleInputGate.java:388) | |
at org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:411) | |
at org.apache.flink.streaming.runtime.io.BarrierTracker.getNextNonBlocked(BarrierTracker.java:75) | |
at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:175) | |
at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:65) | |
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:224) | |
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
at java.lang.Thread.run(Thread.java:745) | |
Caused by: org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException: Connecting to remote task manager + 'app-2.stag.local/192.168.38.98:35806' has failed. This might indicate that the remote task manager has been lost. | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.operationComplete(PartitionRequestClientFactory.java:215) | |
at org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.operationComplete(PartitionRequestClientFactory.java:131) | |
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680) | |
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:603) | |
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:563) | |
at io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:424) | |
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:214) | |
at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38) | |
at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:120) | |
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:357) | |
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:357) | |
at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111) | |
... 1 more | |
Caused by: io.netty.channel.ConnectTimeoutException: connection timed out: app-2.stag.local/192.168.38.98:35806 | |
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:212) | |
... 6 more | |
2016-03-18 16:26:47,180 INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Calculate total traffic and duration (8/8) | |
2016-03-18 16:26:47,181 INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Calculate total traffic and duration (5/8) | |
2016-03-18 16:26:47,182 INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Calculate total traffic and duration (7/8) | |
2016-03-18 16:26:47,182 INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Calculate total traffic and duration (6/8) | |
2016-03-18 16:26:47,217 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (1/8) | |
2016-03-18 16:26:47,217 INFO org.apache.flink.runtime.taskmanager.Task - Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (1/8) switched to CANCELING | |
2016-03-18 16:26:47,227 INFO org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task code Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (1/8) (c0f79881255b2bdd1d89923a64c7d831). | |
2016-03-18 16:26:47,234 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (2/8) | |
2016-03-18 16:26:47,234 INFO org.apache.flink.runtime.taskmanager.Task - Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (2/8) switched to CANCELING | |
2016-03-18 16:26:47,234 INFO org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task code Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (2/8) (cd602460f3542464e4a895ab0d084b2a). | |
2016-03-18 16:26:47,240 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (3/8) | |
2016-03-18 16:26:47,241 INFO org.apache.flink.runtime.taskmanager.Task - Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (3/8) switched to CANCELING | |
2016-03-18 16:26:47,241 INFO org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task code Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (3/8) (539e97e8f13152ba817083f2a6c5c692). | |
2016-03-18 16:26:47,242 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (4/8) | |
2016-03-18 16:26:47,242 INFO org.apache.flink.runtime.taskmanager.Task - Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (4/8) switched to CANCELING | |
2016-03-18 16:26:47,242 INFO org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task code Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (4/8) (f9f77a7be0e4ead44af2c3f9b09b27fe). | |
2016-03-18 16:26:47,243 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Calculate total traffic and duration (5/8) | |
2016-03-18 16:26:47,243 INFO org.apache.flink.runtime.taskmanager.Task - Task Calculate total traffic and duration (5/8) is already in state FAILED | |
2016-03-18 16:26:47,243 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Calculate total traffic and duration (6/8) | |
2016-03-18 16:26:47,243 INFO org.apache.flink.runtime.taskmanager.Task - Task Calculate total traffic and duration (6/8) is already in state FAILED | |
2016-03-18 16:26:47,243 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Calculate total traffic and duration (7/8) | |
2016-03-18 16:26:47,243 INFO org.apache.flink.runtime.taskmanager.Task - Task Calculate total traffic and duration (7/8) is already in state FAILED | |
2016-03-18 16:26:47,243 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Calculate total traffic and duration (8/8) | |
2016-03-18 16:26:47,243 INFO org.apache.flink.runtime.taskmanager.Task - Task Calculate total traffic and duration (8/8) is already in state FAILED | |
2016-03-18 16:26:47,244 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Source: RSyslog Server Source (1/1) | |
2016-03-18 16:26:47,244 INFO org.apache.flink.runtime.taskmanager.Task - Source: RSyslog Server Source (1/1) switched to CANCELING | |
2016-03-18 16:26:47,244 INFO org.apache.flink.runtime.taskmanager.Task - Triggering cancellation of task code Source: RSyslog Server Source (1/1) (e7ecb5a8255f48a53423931ade3712a4). | |
2016-03-18 16:26:47,244 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (1/8) | |
2016-03-18 16:26:47,244 INFO org.apache.flink.runtime.taskmanager.Task - Task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (1/8) is already in state CANCELING | |
2016-03-18 16:26:47,244 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (2/8) | |
2016-03-18 16:26:47,244 INFO org.apache.flink.runtime.taskmanager.Task - Task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (2/8) is already in state CANCELING | |
2016-03-18 16:26:47,244 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (3/8) | |
2016-03-18 16:26:47,244 INFO org.apache.flink.runtime.taskmanager.Task - Task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (3/8) is already in state CANCELING | |
2016-03-18 16:26:47,245 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (4/8) | |
2016-03-18 16:26:47,245 INFO org.apache.flink.runtime.taskmanager.Task - Task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (4/8) is already in state CANCELING | |
2016-03-18 16:26:47,245 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Calculate total traffic and duration (5/8) | |
2016-03-18 16:26:47,245 INFO org.apache.flink.runtime.taskmanager.Task - Task Calculate total traffic and duration (5/8) is already in state FAILED | |
2016-03-18 16:26:47,245 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Calculate total traffic and duration (6/8) | |
2016-03-18 16:26:47,245 INFO org.apache.flink.runtime.taskmanager.Task - Task Calculate total traffic and duration (6/8) is already in state FAILED | |
2016-03-18 16:26:47,245 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Calculate total traffic and duration (7/8) | |
2016-03-18 16:26:47,245 INFO org.apache.flink.runtime.taskmanager.Task - Task Calculate total traffic and duration (7/8) is already in state FAILED | |
2016-03-18 16:26:47,245 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Calculate total traffic and duration (8/8) | |
2016-03-18 16:26:47,245 INFO org.apache.flink.runtime.taskmanager.Task - Task Calculate total traffic and duration (8/8) is already in state FAILED | |
2016-03-18 16:26:47,245 INFO org.apache.flink.runtime.taskmanager.Task - Attempting to cancel task Source: RSyslog Server Source (1/1) | |
2016-03-18 16:26:47,245 INFO org.apache.flink.runtime.taskmanager.Task - Task Source: RSyslog Server Source (1/1) is already in state CANCELING | |
2016-03-18 16:26:47,258 INFO org.apache.flink.runtime.taskmanager.Task - Source: RSyslog Server Source (1/1) switched to CANCELED | |
2016-03-18 16:26:47,259 INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Source: RSyslog Server Source (1/1) | |
2016-03-18 16:26:47,267 INFO org.apache.flink.runtime.taskmanager.Task - Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (2/8) switched to CANCELED | |
2016-03-18 16:26:47,267 INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (2/8) | |
2016-03-18 16:26:47,280 INFO org.apache.flink.runtime.taskmanager.Task - Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (4/8) switched to CANCELED | |
2016-03-18 16:26:47,280 INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (4/8) | |
2016-03-18 16:26:47,281 INFO org.apache.flink.runtime.taskmanager.Task - Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (3/8) switched to CANCELED | |
2016-03-18 16:26:47,281 INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (3/8) | |
2016-03-18 16:26:47,281 INFO org.apache.flink.runtime.taskmanager.Task - Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (1/8) switched to CANCELED | |
2016-03-18 16:26:47,281 INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (1/8) | |
2016-03-18 16:26:47,294 INFO org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and sending final execution state FAILED to JobManager for task Calculate total traffic and duration (00eeb47cdfd986fd01de1ba14a190623) | |
2016-03-18 16:26:47,295 INFO org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and sending final execution state FAILED to JobManager for task Calculate total traffic and duration (e429450212757d1336c4c3f85b07b5ff) | |
2016-03-18 16:26:47,296 INFO org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and sending final execution state FAILED to JobManager for task Calculate total traffic and duration (ad95280be3f35fbf6176fb402d6cfe01) | |
2016-03-18 16:26:47,297 INFO org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and sending final execution state FAILED to JobManager for task Calculate total traffic and duration (95427bce597b0e97d09cd32fa5afc696) | |
2016-03-18 16:26:47,298 INFO org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and sending final execution state CANCELED to JobManager for task Source: RSyslog Server Source (e7ecb5a8255f48a53423931ade3712a4) | |
2016-03-18 16:26:47,298 INFO org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and sending final execution state CANCELED to JobManager for task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (cd602460f3542464e4a895ab0d084b2a) | |
2016-03-18 16:26:47,298 INFO org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and sending final execution state CANCELED to JobManager for task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (f9f77a7be0e4ead44af2c3f9b09b27fe) | |
2016-03-18 16:26:47,298 INFO org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and sending final execution state CANCELED to JobManager for task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (c0f79881255b2bdd1d89923a64c7d831) | |
2016-03-18 16:26:47,299 INFO org.apache.flink.runtime.taskmanager.TaskManager - Un-registering task and sending final execution state CANCELED to JobManager for task Extract content from RSyslog item -> Extract LogItem from RSyslog Content -> Extract timestamp (539e97e8f13152ba817083f2a6c5c692) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment