[
https://issues.apache.org/jira/browse/FLINK-8072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16251816#comment-16251816
]
Aljoscha Krettek commented on FLINK-8072:
-----------------------------------------
[~Zentol] There is this snipped in the log:
{code}
Found exception in log files:
2017-11-14 12:45:08,780 INFO org.apache.flink.client.CliFrontend
-
--------------------------------------------------------------------------------
2017-11-14 12:45:08,782 INFO org.apache.flink.client.CliFrontend
- Starting Command Line Client (Version: 1.5-SNAPSHOT,
Rev:1ab029e, Date:14.11.2017 @ 10:11:10 UTC)
2017-11-14 12:45:08,782 INFO org.apache.flink.client.CliFrontend
- OS current user: travis
2017-11-14 12:45:09,167 INFO org.apache.flink.client.CliFrontend
- Current Hadoop/Kerberos user: travis
2017-11-14 12:45:09,168 INFO org.apache.flink.client.CliFrontend
- JVM: OpenJDK 64-Bit Server VM - Oracle Corporation -
1.8/25.141-b15
2017-11-14 12:45:09,168 INFO org.apache.flink.client.CliFrontend
- Maximum heap size: 1662 MiBytes
2017-11-14 12:45:09,168 INFO org.apache.flink.client.CliFrontend
- JAVA_HOME: /usr/lib/jvm/java-8-openjdk-amd64
2017-11-14 12:45:09,170 INFO org.apache.flink.client.CliFrontend
- Hadoop version: 2.4.1
2017-11-14 12:45:09,170 INFO org.apache.flink.client.CliFrontend
- JVM Options:
2017-11-14 12:45:09,170 INFO org.apache.flink.client.CliFrontend
-
-Dlog.file=/home/travis/build/zentol/flink/flink-dist/target/flink-1.5-SNAPSHOT-bin/flink-1.5-SNAPSHOT/log/flink-travis-client-travis-job-3ea0a296-db89-42a6-b995-b62b79c9d422.log
2017-11-14 12:45:09,170 INFO org.apache.flink.client.CliFrontend
-
-Dlog4j.configuration=file:/home/travis/build/zentol/flink/flink-dist/target/flink-1.5-SNAPSHOT-bin/flink-1.5-SNAPSHOT/conf/log4j-cli.properties
2017-11-14 12:45:09,170 INFO org.apache.flink.client.CliFrontend
-
-Dlogback.configurationFile=file:/home/travis/build/zentol/flink/flink-dist/target/flink-1.5-SNAPSHOT-bin/flink-1.5-SNAPSHOT/conf/logback.xml
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- Program Arguments:
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- run
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- -d
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- build-target/examples/streaming/Kafka010Example.jar
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- --input-topic
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- test-input
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- --output-topic
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- test-output
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- --prefix=PREFIX
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- --bootstrap.servers
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- localhost:9092
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- --zookeeper.connect
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- localhost:2181
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- --group.id
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- myconsumer
2017-11-14 12:45:09,171 INFO org.apache.flink.client.CliFrontend
- --auto.offset.reset
2017-11-14 12:45:09,172 INFO org.apache.flink.client.CliFrontend
- earliest
2017-11-14 12:45:09,172 INFO org.apache.flink.client.CliFrontend
- Classpath:
:/home/travis/build/zentol/flink/flink-dist/target/flink-1.5-SNAPSHOT-bin/flink-1.5-SNAPSHOT/lib/flink-dist_2.11-1.5-SNAPSHOT.jar:/home/travis/build/zentol/flink/flink-dist/target/flink-1.5-SNAPSHOT-bin/flink-1.5-SNAPSHOT/lib/flink-python_2.11-1.5-SNAPSHOT.jar:/home/travis/build/zentol/flink/flink-dist/target/flink-1.5-SNAPSHOT-bin/flink-1.5-SNAPSHOT/lib/flink-shaded-hadoop2-uber-1.5-SNAPSHOT.jar:/home/travis/build/zentol/flink/flink-dist/target/flink-1.5-SNAPSHOT-bin/flink-1.5-SNAPSHOT/lib/log4j-1.2.17.jar:/home/travis/build/zentol/flink/flink-dist/target/flink-1.5-SNAPSHOT-bin/flink-1.5-SNAPSHOT/lib/slf4j-log4j12-1.7.7.jar:::
2017-11-14 12:45:09,172 INFO org.apache.flink.client.CliFrontend
-
--------------------------------------------------------------------------------
2017-11-14 12:45:09,172 INFO org.apache.flink.client.CliFrontend
- Using configuration directory
/home/travis/build/zentol/flink/flink-dist/target/flink-1.5-SNAPSHOT-bin/flink-1.5-SNAPSHOT/conf
2017-11-14 12:45:09,172 INFO org.apache.flink.client.CliFrontend
- Trying to load configuration file
2017-11-14 12:45:09,176 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.rpc.address, localhost
2017-11-14 12:45:09,176 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.rpc.port, 6123
2017-11-14 12:45:09,176 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.heap.mb, 1024
2017-11-14 12:45:09,176 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: taskmanager.heap.mb, 1024
2017-11-14 12:45:09,176 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: taskmanager.numberOfTaskSlots, 1
2017-11-14 12:45:09,176 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: taskmanager.memory.preallocate, false
2017-11-14 12:45:09,177 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: parallelism.default, 1
2017-11-14 12:45:09,177 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.web.port, 8081
2017-11-14 12:45:09,396 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.rpc.address, localhost
2017-11-14 12:45:09,396 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.rpc.port, 6123
2017-11-14 12:45:09,397 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.heap.mb, 1024
2017-11-14 12:45:09,397 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: taskmanager.heap.mb, 1024
2017-11-14 12:45:09,397 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: taskmanager.numberOfTaskSlots, 1
2017-11-14 12:45:09,397 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: taskmanager.memory.preallocate, false
2017-11-14 12:45:09,397 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: parallelism.default, 1
2017-11-14 12:45:09,397 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading
configuration property: jobmanager.web.port, 8081
2017-11-14 12:45:09,490 INFO
org.apache.flink.runtime.security.modules.HadoopModule - Hadoop user set
to travis (auth:SIMPLE)
2017-11-14 12:45:09,525 INFO org.apache.flink.client.CliFrontend
- Running 'run' command.
2017-11-14 12:45:09,531 INFO org.apache.flink.client.CliFrontend
- Building program from JAR file
2017-11-14 12:45:09,617 INFO org.apache.flink.client.CliFrontend
- Cluster configuration: Standalone cluster with JobManager at
localhost/127.0.0.1:6123
2017-11-14 12:45:09,617 INFO org.apache.flink.client.CliFrontend
- Using address localhost:6123 to connect to JobManager.
2017-11-14 12:45:09,619 WARN org.apache.flink.configuration.Configuration
- Config uses deprecated configuration key 'jobmanager.web.port'
instead of proper key 'web.port'
2017-11-14 12:45:09,626 INFO org.apache.flink.client.CliFrontend
- JobManager web interface address http://localhost:8081
2017-11-14 12:45:09,626 INFO org.apache.flink.client.CliFrontend
- Starting execution of program
2017-11-14 12:45:09,626 INFO
org.apache.flink.client.program.StandaloneClusterClient - Starting
program in interactive mode
2017-11-14 12:45:09,749 WARN
org.apache.flink.streaming.api.environment.StreamContextEnvironment - Job was
executed in detached mode, the results will be available on completion.
2017-11-14 12:45:09,795 INFO
org.apache.flink.client.program.StandaloneClusterClient - Starting client
actor system.
2017-11-14 12:45:09,796 INFO
org.apache.flink.runtime.util.LeaderRetrievalUtils - Trying to
select the network interface and address to use by connecting to the leading
JobManager.
2017-11-14 12:45:09,797 INFO
org.apache.flink.runtime.util.LeaderRetrievalUtils - TaskManager
will try to connect for 10000 milliseconds before falling back to heuristics
2017-11-14 12:45:09,798 INFO org.apache.flink.runtime.net.ConnectionUtils
- Retrieved new target address localhost/127.0.0.1:6123.
2017-11-14 12:45:09,807 INFO
org.apache.flink.client.program.StandaloneClusterClient - Trying to start
actor system at travis-job-3ea0a296-db89-42a6-b995-b62b79c9d422:0
2017-11-14 12:45:10,274 INFO akka.event.slf4j.Slf4jLogger
- Slf4jLogger started
2017-11-14 12:45:10,349 INFO akka.remote.Remoting
- Starting remoting
2017-11-14 12:45:10,500 INFO akka.remote.Remoting
- Remoting started; listening on addresses
:[akka.tcp://flink@travis-job-3ea0a296-db89-42a6-b995-b62b79c9d422:36679]
2017-11-14 12:45:10,515 INFO
org.apache.flink.client.program.StandaloneClusterClient - Actor system
started at
akka.tcp://flink@travis-job-3ea0a296-db89-42a6-b995-b62b79c9d422:36679
2017-11-14 12:45:10,673 INFO
org.apache.flink.client.program.StandaloneClusterClient - Submitting Job
with JobID: c9e7e4118412d530ff54c88539382c3b. Returning after job submission.
2017-11-14 12:45:10,677 INFO org.apache.flink.runtime.client.JobClient
- Checking and uploading JAR files
2017-11-14 12:45:10,703 WARN akka.serialization.Serialization(akka://flink)
- Using the default Java serializer for class
[org.apache.flink.runtime.messages.JobManagerMessages$RequestBlobManagerPort$]
which is not recommended because of performance implications. Use another
serializer or disable this warning using the setting
'akka.actor.warn-about-java-serializer-usage'
2017-11-14 12:45:10,871 WARN akka.serialization.Serialization(akka://flink)
- Using the default Java serializer for class
[org.apache.flink.runtime.messages.JobManagerMessages$LeaderSessionMessage]
which is not recommended because of performance implications. Use another
serializer or disable this warning using the setting
'akka.actor.warn-about-java-serializer-usage'
2017-11-14 12:45:10,996 INFO org.apache.flink.client.CliFrontend
- Job has been submitted with JobID c9e7e4118412d530ff54c88539382c3b
2017-11-14 12:45:11,003 INFO
akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting down
remote daemon.
2017-11-14 12:45:11,030 INFO
akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote daemon
shut down; proceeding with flushing remote transports.
2017-11-14 12:45:11,081 WARN
org.apache.flink.shaded.akka.org.jboss.netty.channel.DefaultChannelPipeline -
An exception was thrown by an exception handler.
java.util.concurrent.RejectedExecutionException: Worker has already been
shutdown
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.socket.nio.AbstractNioSelector.registerTask(AbstractNioSelector.java:120)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.socket.nio.AbstractNioWorker.executeInIoThread(AbstractNioWorker.java:72)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.socket.nio.NioWorker.executeInIoThread(NioWorker.java:36)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.socket.nio.AbstractNioWorker.executeInIoThread(AbstractNioWorker.java:56)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.socket.nio.NioWorker.executeInIoThread(NioWorker.java:36)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.socket.nio.AbstractNioChannelSink.execute(AbstractNioChannelSink.java:34)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.DefaultChannelPipeline.execute(DefaultChannelPipeline.java:636)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.Channels.fireExceptionCaughtLater(Channels.java:496)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.AbstractChannelSink.exceptionCaught(AbstractChannelSink.java:46)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.DefaultChannelPipeline.notifyHandlerException(DefaultChannelPipeline.java:658)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendDownstream(DefaultChannelPipeline.java:781)
at
org.apache.flink.shaded.akka.org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:591)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendDownstream(DefaultChannelPipeline.java:784)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.SimpleChannelHandler.disconnectRequested(SimpleChannelHandler.java:320)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.SimpleChannelHandler.handleDownstream(SimpleChannelHandler.java:274)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:591)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.DefaultChannelPipeline.sendDownstream(DefaultChannelPipeline.java:582)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.Channels.disconnect(Channels.java:781)
at
org.apache.flink.shaded.akka.org.jboss.netty.channel.AbstractChannel.disconnect(AbstractChannel.java:219)
at
akka.remote.transport.netty.NettyTransport$$anonfun$gracefulClose$1.apply(NettyTransport.scala:241)
at
akka.remote.transport.netty.NettyTransport$$anonfun$gracefulClose$1.apply(NettyTransport.scala:240)
at scala.util.Success.foreach(Try.scala:236)
at scala.concurrent.Future$$anonfun$foreach$1.apply(Future.scala:206)
at scala.concurrent.Future$$anonfun$foreach$1.apply(Future.scala:206)
at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
at
akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)
at
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91)
at
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
at
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
at
scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72)
at
akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:90)
at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
{code}
> Travis job marked as failed for no apparent reason
> --------------------------------------------------
>
> Key: FLINK-8072
> URL: https://issues.apache.org/jira/browse/FLINK-8072
> Project: Flink
> Issue Type: Bug
> Components: Travis
> Affects Versions: 1.4.0, 1.5.0
> Environment: https://travis-ci.org/zentol/flink/jobs/301867616
> Reporter: Chesnay Schepler
>
> The linked travis job failed for no apparent reason. Compilation, tests and
> end-to-end tests all ran and reporter no problem.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
