[jira] [Created] (FLINK-6201) move python example files to the examples dir

shijinkui created FLINK-6201: Summary: move python example files to the examples dir Key: FLINK-6201 URL: https://issues.apache.org/jira/browse/FLINK-6201 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6200) Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

sunjincheng created FLINK-6200: -- Summary: Add event time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL Key: FLINK-6200 URL: https://issues.apache.org/jira/browse/FLINK-6200 Project: Flink

[jira] [Created] (FLINK-6199) Single outstanding Async I/O operation per key

Jamie Grier created FLINK-6199: -- Summary: Single outstanding Async I/O operation per key Key: FLINK-6199 URL: https://issues.apache.org/jira/browse/FLINK-6199 Project: Flink Issue Type:

Re: Java library for Flink-Kudu integration

Hi Ruben, thanks for sharing this! A Flink Kudu connector is a great contribution and Bahir seems to be the right place for it. Thanks, Fabian 2017-03-27 15:35 GMT+02:00 : > Hi all, > > I apologize for sending the email to both accounts, but not sure where

Re: FW: [DISCUSS] Table API / SQL indicators for event and processing time

Hi Timo, I had a look at your branch. Thanks for all the refactoring and work you put into this. I like the proposal a lot. I think indicating the time attribute in the schema is a good idea. I'm not sure if we should support the rowtime expression for batch table though. For batch, any long or

[jira] [Created] (FLINK-6198) Update the documentation of the CEP library to include all the new features.

Kostas Kloudas created FLINK-6198: - Summary: Update the documentation of the CEP library to include all the new features. Key: FLINK-6198 URL: https://issues.apache.org/jira/browse/FLINK-6198

[jira] [Created] (FLINK-6197) Add support for iterative conditions.

Kostas Kloudas created FLINK-6197: - Summary: Add support for iterative conditions. Key: FLINK-6197 URL: https://issues.apache.org/jira/browse/FLINK-6197 Project: Flink Issue Type: Bug

[CANCEL][VOTE] Release Apache Flink 1.2.1 (RC1)

I'll cancel the vote. Once the fixes are in, I'll create a new RC. On Mon, Mar 27, 2017 at 11:59 AM, Chesnay Schepler wrote: > If possible I would like to include FLINK-6183 & FLINK-6184 as well. > > They fix 2 metric-related issues that could arise when a Task is cancelled

[jira] [Created] (FLINK-6196) Support dynamic schema in Table Function

Zhuoluo Yang created FLINK-6196: --- Summary: Support dynamic schema in Table Function Key: FLINK-6196 URL: https://issues.apache.org/jira/browse/FLINK-6196 Project: Flink Issue Type: Improvement

Re: Question about flink client

Hi Yelei, I think you're right that we should not only rely on the response of the JobManager but also ask the Yarn client what the status of the application is. If the application status is something different than Succeeded, then it should be save to shut down the cluster. If this is not the

[jira] [Created] (FLINK-6195) Move gelly-examples jar from opt to examples

Greg Hogan created FLINK-6195: - Summary: Move gelly-examples jar from opt to examples Key: FLINK-6195 URL: https://issues.apache.org/jira/browse/FLINK-6195 Project: Flink Issue Type: Sub-task

Java library for Flink-Kudu integration

Hi all, I apologize for sending the email to both accounts, but not sure where this topic fits better. In my team, we have been working in some PoCs and PoVs about new data architectures. As part of this work, we have implemented a library to connect Kudu and Flink. The library allows

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

If possible I would like to include FLINK-6183 & FLINK-6184 as well. They fix 2 metric-related issues that could arise when a Task is cancelled very early. (like, right away) FLINK-6183 fixes a memory leak where the TaskMetricGroup was never closed FLINK-6184 fixes a NullPointerExceptions in

[jira] [Created] (FLINK-6194) More broken links in docs

Patrick Lucas created FLINK-6194: Summary: More broken links in docs Key: FLINK-6194 URL: https://issues.apache.org/jira/browse/FLINK-6194 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6193) Flink dist directory normalize

shijinkui created FLINK-6193: Summary: Flink dist directory normalize Key: FLINK-6193 URL: https://issues.apache.org/jira/browse/FLINK-6193 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Flink dist directory management

Hi, Fabian, Jark Wu, Greg Thank for your feedback and support. I’ll create some sub-issue to complete the every task of code refactor. 在 2017/3/27 下午3:38， "Fabian Hueske" 写入: >Hi Jinkui, > >I agree with you, moving all examples into ./examples would be nice. >Note, that for

Re: [DISCUSS] Flink dist directory management

Hi Jinkui, I agree with you, moving all examples into ./examples would be nice. Note, that for the DataSet and DataStream APIs, each example is packaged as a separate JAR with the main class being included in the MANIFEST file. I think we should select a few representative examples of the Table

[jira] [Created] (FLINK-6192) reuse zookeeer client created by CuratorFramework

Tao Wang created FLINK-6192: --- Summary: reuse zookeeer client created by CuratorFramework Key: FLINK-6192 URL: https://issues.apache.org/jira/browse/FLINK-6192 Project: Flink Issue Type:

Re: Question about flink client

Hi Till, Thanks for your help, I merged your code into my branch and the issue is gone. BTW, do you have some insights for the first problem? "Once the yarn session CLI can't get cluster status(e.g. jobmanager is down), it will try to shutdown the cluster and cleanup related files even if new

[jira] [Created] (FLINK-6191) Make non-primitive, internal built-in serializers reconfigurable

Tzu-Li (Gordon) Tai created FLINK-6191: -- Summary: Make non-primitive, internal built-in serializers reconfigurable Key: FLINK-6191 URL: https://issues.apache.org/jira/browse/FLINK-6191 Project: