Check-pointing configuration

2016-08-28 Thread Bhupesh Chawda
Hi, I have a question on enabling checkpointing for one of my Flink jobs. I understand that I can call *enableCheckpointing* on the *StreamExecutionEnvironment* to enable it. In my case, I don't have access to the source code; Is there also an option to enable it through configuration? Thanks. ~

Re: [DISCUSS] Some thoughts about unify Stream SQL and Batch SQL grammer

2016-08-28 Thread Jark Wu
Hi Fabian, Timo, I have created a prototype for removing STREAM keyword and using batch sql parser for stream jobs. This is the working brach: https://github.com/wuchong/flink/tree/remove-stream Looking forward to your feedback. - Jark

[jira] [Created] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp

2016-08-28 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-4523: -- Summary: Allow Kinesis Consumer to start from specific timestamp Key: FLINK-4523 URL: https://issues.apache.org/jira/browse/FLINK-4523 Project: Flink

[jira] [Created] (FLINK-4522) Gelly link broken in homepage

2016-08-28 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-4522: Summary: Gelly link broken in homepage Key: FLINK-4522 URL: https://issues.apache.org/jira/browse/FLINK-4522 Project: Flink Issue Type: Bug Compone

[jira] [Created] (FLINK-4521) Fix "Submit new Job" panel in development mode

2016-08-28 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-4521: - Summary: Fix "Submit new Job" panel in development mode Key: FLINK-4521 URL: https://issues.apache.org/jira/browse/FLINK-4521 Project: Flink Issue Type: Bu