Hey Hilmi,
here is a great example of how to use the Checkpointed interface:
https://github.com/StephanEwen/flink-demos/blob/master/streaming-state-machine/src/main/scala/com/dataartisans/flink/example/eventpattern/StreamingDemo.scala#L82
On Wed, Jun 17, 2015 at 12:44 AM, Hilmi Yildirim wrote
You don't have to enable the logging thread.
You can also get the metrics of the job manager via the job manager web
frontend. There, they also available in a JSON representation.
So if you want, you can periodically (say every 5 seconds) do a HTTP
request to get the metrics of all TMs.
On Mon, Ju
Okay, it seems like we have consensus on this. Who is interested in working
on this? https://issues.apache.org/jira/browse/FLINK-2200
On Mon, Jun 15, 2015 at 1:26 AM, Till Rohrmann wrote:
> +1 for giving only those modules a version suffix which depend on Scala.
>
>
> On Sun, Jun 14, 2015 at 8:0
can combine between tow table but not use join
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/how-can-Combine-between-two-dataset-in-on-datset-and-execution-more-condition-in-the-same-time-tp1605p1712.html
Sent from the Apache Flink User Mai
