Submitting jobs via Java code

Hi, I am a beginner in Flink and I'm trying to deploy a simple example using a java client in a remote Flink server (1.4.0). I'm using org.apache.flink.client.program.Client this is the used code: Configuration config = new Configuration(); config.setString("jobmanager.rpc.address",

Re: Submitting jobs via Java code

clear example. > > Do you have any idea to solve the error? > > > thanks > > 2018-01-18 12:54 GMT+01:00 Timo Walther <twal...@apache.org>: > >> Hi Luigi, >> >> I'm also working on a solution for submitting jobs programmatically. You >> can l

Re: Submitting jobs via Java code

NK-7594_rebased/ > flink-libraries/flink-sql-client/src/main/java/org/ > apache/flink/table/client/gateway/LocalExecutor.java > [2] https://ci.apache.org/projects/flink/flink-docs- > release-1.4/monitoring/rest_api.html#submitting-programs > > Am 1/18/18 um 11:41 AM schrieb Luigi Sgaglion

Re: Submitting jobs via Java code

StreamEnvironment? > > Regards, > Timo > > > Am 1/17/18 um 5:08 PM schrieb Luigi Sgaglione: > > Hi, > > I am a beginner in Flink and I'm trying to deploy a simple example using a > java client in a remote Flink server (1.4.0). > > I'm using org.apache.flink.clie

Json KAFKA producer

Hi, I'm trying to create a Flink example with kafka consumer and producer using Json data format. In particular, I'm able to consume and process Json data published on a Kafka topic, but not to publish the results. The problem is that I don't know what is the serialization schema that should be

timewindowall and aggregate(count): count 0 when no event in the window

Hi, I'm trying to count the number of events in a window (every 5 seconds). The code below works fine if there are events in the window, if there are no events in the window no output is emitted. What I want to achieve is a count of 0 when there are no events in the time window of 5 seconds.