ing.connectors.kafka.api.KafkaSource;
>>> import org.apache.flink.streaming.util.serialization.SimpleStringSchema;
>>>
>>> public class StreamData {
>>>
>>> public static void main(String[] args) {
>>>
>>> StreamExecutionEnvironment e
ot;localhost:2181",
> > "syslog_framework", new SimpleStringSchema())).print();
> >
> >
> > try {
> > env.execute("MyJob");
> > } catch (Exception e) {
> > // TODO Auto-generated catch block
> > e.printStackTrace();
> > }
> >
> > }
> >
> > }
> >
> >
> >
> >
> >
> > --
> > View this message in context:
> http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Getting-an-eeror-while-running-the-code-tp7154.html
> > Sent from the Apache Flink Mailing List archive. mailing list archive at
> Nabble.com.
>
>
>
t; try {
> env.execute("MyJob");
> } catch (Exception e) {
> // TODO Auto-generated catch block
> e.printStackTrace();
> }
>
> }
>
> }
>
>
>
>
>
> --
> View this message in context:
> http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Getting-an-eeror-while-running-the-code-tp7154.html
> Sent from the Apache Flink Mailing List archive. mailing list archive at
> Nabble.com.
}
}
--
View this message in context:
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Getting-an-eeror-while-running-the-code-tp7154.html
Sent from the Apache Flink Mailing List archive. mailing list archive at
Nabble.com.