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
I am pretty sure I am doing something wrong here. Just that I do not
understand why?
I wrote a small program that reads messages from Kafka and prints it out.
public class Main {
private static final int CHECKPOINT_INTERVAL = 10;
private static Properties getpropsFromEnv() {
