??????????flink on yarn????rabbitmq?????? ????
????rabbitmq??????????????????????????????????idea????????????flink????????1.8????flink????????????1.7
2019-07-22 11:32:12.309 [Source: Custom Source (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (1/1)
(85cfdb83f536b26e07ca2aa4a1b66302) switched from DEPLOYING
to FAILED.
java.lang.NullPointerException: null
at
org.apache.flink.streaming.runtime.tasks.StreamTask.createRecordWriters(StreamTask.java:1175)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.<init>(StreamTask.java:212)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.<init>(StreamTask.java:190)
at
org.apache.flink.streaming.runtime.tasks.SourceStreamTask.<init>(SourceStreamTask.java:51)
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at
org.apache.flink.runtime.taskmanager.Task.loadAndInstantiateInvokable(Task.java:1405)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:689)
at java.lang.Thread.run(Thread.java:745)
2019-07-22 11:32:12.310 [Source: Custom Source (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Source:
Custom Source (1/1) (85cfdb83f536b26e07ca2aa4a1b663
02).
2019-07-22 11:32:12.321 [Source: Custom Source (1/1)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams
are closed for task Source: Custom Source (1/1) (85cfd
b83f536b26e07ca2aa4a1b66302) [FAILED]
2019-07-22 11:32:12.331 [flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FAILED to Job
Manager for task Source: Custom Source 85cfdb83f536b26e07ca2aa4a1b66302.
