From a first glance, this sounds like a version conflict, most likely in the Hadoop jars. Can you try running it with the Hadoop-free Flink release?
Best, Aljoscha > On 26. Apr 2018, at 03:26, Qi Yu <yuqi4...@gmail.com> wrote: > > Can you provide more detail about this problem. e.g the version of flink,the > corresponding configuration, hadoop, yarn version and so on. > >> 在 2018年4月24日,04:07,Qiong Wei <q...@microsoft.com.INVALID> 写道: >> >> This is Qiong Wei, from Microsoft. I’m trying to create a Flink streaming >> job which consumer the data from Kafka and then write the data into Azure >> Blob Storage. I have a Hadoop cluster (yarn cluster), but it failed when I >> run the streaming job, I’m not sure if anybody can help me to solve the >> problem. Here is the full log file. Really appreciate 😊 >