Executing TwitterStream example with built-in default data.
  Provide parameters to read input data from a file.
  USAGE: TwitterStream <pathToPropertiesFile>
Exception in thread "Thread-20" java.lang.RuntimeException: java.io.IOException: Could not find the receiver for Job 7abf3f336476edfbb9e62d0b72f2a328, channel with source id 874e2f469ea37e0519af78bf3fb5643a
    at org.apache.flink.streaming.io.StreamRecordWriter$OutputFlusher.run(StreamRecordWriter.java:131)
Caused by: java.io.IOException: Could not find the receiver for Job 7abf3f336476edfbb9e62d0b72f2a328, channel with source id 874e2f469ea37e0519af78bf3fb5643a
    at org.apache.flink.runtime.io.network.ChannelManager.getReceiverList(ChannelManager.java:389)
    at org.apache.flink.runtime.io.network.ChannelManager.getReceiverListForEnvelope(ChannelManager.java:594)
    at org.apache.flink.runtime.io.network.ChannelManager.dispatchFromOutputChannel(ChannelManager.java:428)
    at org.apache.flink.runtime.io.network.channels.OutputChannel.sendBuffer(OutputChannel.java:81)
    at org.apache.flink.runtime.io.network.gates.OutputGate.sendBuffer(OutputGate.java:56)
    at org.apache.flink.runtime.io.network.api.BufferWriter.sendBuffer(BufferWriter.java:41)
    at org.apache.flink.streaming.io.StreamRecordWriter.flush(StreamRecordWriter.java:113)
    at org.apache.flink.streaming.io.StreamRecordWriter$OutputFlusher.run(StreamRecordWriter.java:129)
Error: The program execution failed: java.lang.Exception: Failed to deploy the task flatMap-2 (1/1) - execution #0 to slot SubSlot 1 (cc86cfe5b5c7c62f423a2e94c1c85407 (0) - ALLOCATED/ALIVE): java.lang.RuntimeException: Cannot deserialize invokable object
    at org.apache.flink.streaming.api.StreamConfig.getFunction(StreamConfig.java:193)
    at org.apache.flink.streaming.api.streamvertex.StreamVertex.initialize(StreamVertex.java:63)
    at org.apache.flink.streaming.api.streamvertex.StreamVertex.registerInputOutput(StreamVertex.java:53)
    at org.apache.flink.runtime.execution.RuntimeEnvironment.<init>(RuntimeEnvironment.java:175)
    at org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.java:594)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:418)
    at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:947)
Caused by: org.apache.commons.lang3.SerializationException: java.lang.ClassNotFoundException: org.apache.flink.streaming.examples.twitter.TwitterStream$SelectEnglishAndTokenizeFlatMap
    at org.apache.commons.lang3.SerializationUtils.deserialize(SerializationUtils.java:230)
    at org.apache.commons.lang3.SerializationUtils.deserialize(SerializationUtils.java:268)
    at org.apache.flink.streaming.api.StreamConfig.getFunction(StreamConfig.java:191)
    ... 10 more
Caused by: java.lang.ClassNotFoundException: org.apache.flink.streaming.examples.twitter.TwitterStream$SelectEnglishAndTokenizeFlatMap
    at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
    at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
    at java.security.AccessController.doPrivileged(Native Method)
    at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:274)
    at java.io.ObjectInputStream.resolveClass(ObjectInputStream.java:625)
    at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1612)
    at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1517)
    at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1771)
    at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
    at java.io.ObjectInputStream.readObject(ObjectInputStream.java:370)
    at org.apache.commons.lang3.SerializationUtils.deserialize(SerializationUtils.java:224)
    ... 12 more


Error: The program execution failed: java.lang.Exception: Failed to deploy the task flatMap-2 (1/4) - execution #0 to slot SubSlot 1 (e81b7705b52333a378cf56c0840590bc (0) - ALLOCATED/ALIVE): java.lang.RuntimeException: Cannot deserialize invokable object
    at org.apache.flink.streaming.api.StreamConfig.getFunction(StreamConfig.java:193)
    at org.apache.flink.streaming.api.streamvertex.StreamVertex.initialize(StreamVertex.java:63)
    at org.apache.flink.streaming.api.streamvertex.StreamVertex.registerInputOutput(StreamVertex.java:53)
    at org.apache.flink.runtime.execution.RuntimeEnvironment.<init>(RuntimeEnvironment.java:175)
    at org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.java:594)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at org.apache.flink.runtime.ipc.RPC$Server.call(RPC.java:418)
    at org.apache.flink.runtime.ipc.Server$Handler.run(Server.java:947)
Caused by: org.apache.commons.lang3.SerializationException: java.lang.ClassNotFoundException: org.apache.flink.streaming.examples.wordcount.WordCount$Tokenizer
    at org.apache.commons.lang3.SerializationUtils.deserialize(SerializationUtils.java:230)
    at org.apache.commons.lang3.SerializationUtils.deserialize(SerializationUtils.java:268)
    at org.apache.flink.streaming.api.StreamConfig.getFunction(StreamConfig.java:191)
    ... 10 more
Caused by: java.lang.ClassNotFoundException: org.apache.flink.streaming.examples.wordcount.WordCount$Tokenizer
    at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
    at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
    at java.security.AccessController.doPrivileged(Native Method)
    at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:274)
    at java.io.ObjectInputStream.resolveClass(ObjectInputStream.java:625)
    at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1612)
    at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1517)
    at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1771)
    at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1350)
    at java.io.ObjectInputStream.readObject(ObjectInputStream.java:370)
    at org.apache.commons.lang3.SerializationUtils.deserialize(SerializationUtils.java:224)
    ... 12 more

    at org.apache.flink.runtime.executiongraph.Execution$2.run(Execution.java:284)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
    at java.util.concurrent.FutureTask.run(FutureTask.java:262)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    at java.lang.Thread.run(Thread.java:745)