Re: Dedicated ExecutionContext inside Flink

2016-06-08 Thread Till Rohrmann
Hi Soumya, except for the LocalFlinkMiniCluster, which is used by the LocalEnvironment to execute Flink programs in your IDE, we don't use the global ExecutionContext. Thus, it should be fine to use the global ExecutionContext for your futures without affecting Flink. However, I would recommend

Dedicated ExecutionContext inside Flink

2016-06-07 Thread Soumya Simanta
What is the recommended practice for using a dedicated ExecutionContexts inside Flink code? We are making some external network calls using Futures. Currently all of them are running on the global execution context (import scala.concurrent.ExecutionContext.Implicits.global). Thanks -Soumya