Run simple flink application via "java -jar"

2018-12-06 Thread Krishna Kalyan
Hello, This is a very n00b question. Can we run a flink job (for example wordcount) using "java -jar " in standalone mode. I usually see examples using "$FLINK_HOME/bin/flink run ". If yes can someone please point me to an example. Regards, Krishna -- Standorte in Stuttgart und Berlin

Passing application configuring to Flink uber jar

2018-11-22 Thread Krishna Kalyan
t file to cluster. I could not find a lot of information online on how to do this. Regards, Krishna Reference: [1] https://stackoverflow.com/questions/46157479/apache-flink-how-do-i-specify-an-external-application-conf-file?rq=1 [2] https://github.com/lightbend/config/issues/84 -- Krishna K

Re: Making calls to external API wit Data Streams

2018-10-12 Thread Krishna Kalyan
at you > are using ?? > > > Best Regards, > Dom. > > pt., 12 paź 2018 o 16:11 Krishna Kalyan > napisał(a): > >> Hello All, >> >> I need some help making async API calls. I have tried the following code >> below. >> >> class AsyncWeathe

Making calls to external API wit Data Streams

2018-10-12 Thread Krishna Kalyan
Hello All, I need some help making async API calls. I have tried the following code below. class AsyncWeatherAPIRequest extends AsyncFunction[String, String] { override def asyncInvoke(input: String, resultFuture: ResultFuture[String]): Unit = { val query = url("") val response = Http.d