are not working well.
If so, could you please adjust the following settings and report back?
public enum SinkOption {
BULK_FLUSH_MAX_ACTIONS,
BULK_FLUSH_MAX_SIZE,
BULK_FLUSH_INTERVAL
}
On Wed, Mar 4, 2020 at 3:05 PM Castro, Fernando C.
mailto:fernando.cas...@leidos.com>> wrote:
Th
curr_careUnit
|""".stripMargin)
result.insertInto("transfersSum")
tEnv.toRetractStream[Row](result).print() //Just to see if something is
actually happening (and it is)
env.execute("Flink Streaming Demo Dump to Elasticsearch")
}
}
Than
Hello folks! I’m new to Flink and data streaming in general, just initial FYI ;)
I’m currently doing this successfully:
1 - streaming data from Kafka in Flink
2 - aggregating the data with Flink’s sqlQuery API
3 - outputting the result of #2 into STDOUT via toRetreatStream()
My objective is to ch
