Thanks Ziyad. That was a cut and paste error. Anyway, I figured out a
solution to the issue. All of my Flink dependancies were pointing at 1.3.1.
Pointing at 1.3.0 resolved the issue.
On Wed, Jul 12, 2017 at 2:17 AM, Ziyad Muhammed wrote:
> Hi Sridhar
>
> Are you using *ParameterTool *to set the
Hi Sridhar
Are you using *ParameterTool *to set the properties? I couldn't see it in
your code, but you use it in the below line:
FlinkKafkaConsumer010 flinkConsumer =
new FlinkKafkaConsumer010(
Arrays.asList(parameterTool.getRequired("topic").split(",")), new
LogDeserializationS
