// OUTPUT OF https://gist.github.com/f248187b9638023b95ba8bd9d7f06215
[02:06:11] Topology snapshot [ver=355, servers=1, clients=1, CPUs=4, heap=9.0GB]
**~~~ Constructor called!**
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#1003013902] 04/25/2017 02:06:11 Job execution switched to status RUNNING. 04/25/2017 02:06:11 Source: Custom Source -> Map(1/1) switched to SCHEDULED 04/25/2017 02:06:11 Source: Custom Source -> Map(1/1) switched to DEPLOYING 04/25/2017 02:06:11 Source: Custom Source -> Map(1/1) switched to RUNNING 04/25/2017 02:06:11 Source: Custom Source -> Map(1/1) switched to FAILED
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot load user class: com.myproj.Test$1$2 ClassLoader info: URL ClassLoader: Class not resolvable through given classloader. at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:210) at org.apache.flink.streaming.runtime.tasks.OperatorChain.(OperatorChain.java:81) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:235) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:655) at java.lang.Thread.run(Thread.java:745)
04/25/2017 02:06:11 Job execution switched to status FAILING. org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot load user class: com.myproj.Test$1$2 ClassLoader info: URL ClassLoader: Class not resolvable through given classloader. at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:210) at org.apache.flink.streaming.runtime.tasks.OperatorChain.(OperatorChain.java:81) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:235) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:655) at java.lang.Thread.run(Thread.java:745) 04/25/2017 02:06:11 Job execution switched to status FAILED.
ERROR #####
Job execution failed. org.apache.flink.runtime.client.JobExecutionException: Job execution failed. at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$6.apply$mcV$sp(JobManager.scala:900) at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$6.apply(JobManager.scala:843) at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$6.apply(JobManager.scala:843) at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24) at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24) at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40) at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397) 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)
Caused by: org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot load user class: com.myproj.Test$1$2
ClassLoader info: URL ClassLoader:
Class not resolvable through given classloader.
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:210) at org.apache.flink.streaming.runtime.tasks.OperatorChain.(OperatorChain.java:81) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:235) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:655) at java.lang.Thread.run(Thread.java:745)