flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Pavel Ciorba <pavli...@gmail.com>
Subject Re: Flink mini IDEA runtime
Date Sun, 22 Jul 2018 15:16:03 GMT
Thanks Jorn!

2018-07-22 13:53 GMT+03:00 Jörn Franke <jornfranke@gmail.com>:

> 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/scala/org/zuinnote/flink/ethereum/example/
> FlinkEthereumBlockCounterFlinkMasterIntegrationSpec.scala
>
> On 22. Jul 2018, at 12:42, Pavel Ciorba <pavlick7@gmail.com> wrote:
>
> 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
> valid. So the plan is to run the job on a VM in a mini Flink runtime to see
> whether it will throw an exception or not. If it is healthy, deploy it in
> the main cluster.
>
> Maybe you have some advice about this, or just an answer to the first
> question :)
>
> Thanks!
>
>

Mime
View raw message