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()
}
catch {
case e: Exception => println(e)
}
}
I have non empty file that this does not print anything.
