Hi Balaji,
You forgot to execute your Flink program using
env.execute();
Cheers,
Max
On Wed, Mar 2, 2016 at 1:36 PM, Balaji Rajagopalan
wrote:
> def main(args: Array[String]): Unit = {
>
>
>
> val env: StreamExecutionEnvironment =
> StreamExecutionEnvironment.getExecutionEnvironment();
> e
Hi,
you need to explicitly trigger the execution by calling "env.execute()"
On Wed, Mar 2, 2016 at 1:36 PM, Balaji Rajagopalan <
balaji.rajagopa...@olacabs.com> wrote:
> def main(args: Array[String]): Unit = {
>
>
>
> val env: StreamExecutionEnvironment =
> StreamExecutionEnvironment.getExecut
def main(args: Array[String]): Unit = {
val env: StreamExecutionEnvironment =
StreamExecutionEnvironment.getExecutionEnvironment();
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
try {
val data1:DataStream[String] = env.readTextFile(“somefile.txt”);
data1.print()
