Hi all!
>From what I know, Flink jobs can be run straight from the IDE because IDEA
will create a mini Flink runtime.
What is the underlying CLI command that Jetbarins IDEA issues to run a
Flink job in a mini-runtime?
My use case is that I want to see if the job written using the SQL API is
vali
You can run them in a localenvironment. I do it for my integration tests
everytime:
flinkEnvironment = ExecutionEnvironment.createLocalEnvironment(1)
Eg (even together with a local HDFS cluster)
https://github.com/ZuInnoTe/hadoopcryptoledger/blob/master/examples/scala-flink-ethereumblock/src/it/
Thanks Jorn!
2018-07-22 13:53 GMT+03:00 Jörn Franke :
> You can run them in a localenvironment. I do it for my integration tests
> everytime:
> flinkEnvironment = ExecutionEnvironment.createLocalEnvironment(1)
>
> Eg (even together with a local HDFS cluster) https://github.com/
> ZuInnoTe/hadoopc
