[jira] [Created] (FLINK-5584) Support Sliding-count row-window on streaming sql

Yuhong Hong created FLINK-5584: -- Summary: Support Sliding-count row-window on streaming sql Key: FLINK-5584 URL: https://issues.apache.org/jira/browse/FLINK-5584 Project: Flink Issue Type: New F

Flink with Yarn on MapR

Hi, I am trying to setup flink with Yarn on Mapr cluster. I built flink (flink-1.3-SNAPSHOT) as follows: mvn clean install -DskipTests -Pvendor-repos -Dhadoop.version=2.7.0-mapr-1607 The build is successful. Then I try to run ./bin/yarn-session.sh -n 4 (without changing any config or whatsoever

[jira] [Created] (FLINK-5583) Support flexible error handling in the Kafka consumer

Haohui Mai created FLINK-5583: - Summary: Support flexible error handling in the Kafka consumer Key: FLINK-5583 URL: https://issues.apache.org/jira/browse/FLINK-5583 Project: Flink Issue Type: Imp

Re: [DISCUSS] Time-based releases in Flink

Thanks a lot for your response Greg! I'd like to hear a retrospective on the duration of the 1.2 release cycle. 164 days, or 5 months and 11 days have passed since the 1.1 release. The other release cycles are listed here: https://cwiki.apache.org/confluence/display/FLINK/Flink+Release+and+Featu

[jira] [Created] (FLINK-5582) Add a general distributive aggregate function

Stephan Ewen created FLINK-5582: --- Summary: Add a general distributive aggregate function Key: FLINK-5582 URL: https://issues.apache.org/jira/browse/FLINK-5582 Project: Flink Issue Type: New Fea

[jira] [Created] (FLINK-5581) Improve Kerberos security related documentation

Tzu-Li (Gordon) Tai created FLINK-5581: -- Summary: Improve Kerberos security related documentation Key: FLINK-5581 URL: https://issues.apache.org/jira/browse/FLINK-5581 Project: Flink Iss

[jira] [Created] (FLINK-5580) Kerberos keytabs not working for YARN deployment mode

Tzu-Li (Gordon) Tai created FLINK-5580: -- Summary: Kerberos keytabs not working for YARN deployment mode Key: FLINK-5580 URL: https://issues.apache.org/jira/browse/FLINK-5580 Project: Flink

[jira] [Created] (FLINK-5579) Kerberos not working for Kafka connector using ticket cache

Tzu-Li (Gordon) Tai created FLINK-5579: -- Summary: Kerberos not working for Kafka connector using ticket cache Key: FLINK-5579 URL: https://issues.apache.org/jira/browse/FLINK-5579 Project: Flink

[jira] [Created] (FLINK-5578) Each time application is submitted to yarn, application id increases by two

Yelei Feng created FLINK-5578: - Summary: Each time application is submitted to yarn, application id increases by two Key: FLINK-5578 URL: https://issues.apache.org/jira/browse/FLINK-5578 Project: Flink

[jira] [Created] (FLINK-5577) Each time application is submitted to yarn, application id increases by two

Yelei Feng created FLINK-5577: - Summary: Each time application is submitted to yarn, application id increases by two Key: FLINK-5577 URL: https://issues.apache.org/jira/browse/FLINK-5577 Project: Flink

[jira] [Created] (FLINK-5576) extend deserialization functions of KvStateRequestSerializer to detect unconsumed bytes

Nico Kruber created FLINK-5576: -- Summary: extend deserialization functions of KvStateRequestSerializer to detect unconsumed bytes Key: FLINK-5576 URL: https://issues.apache.org/jira/browse/FLINK-5576 Pro

[jira] [Created] (FLINK-5575) add redirect to latest stable docs

David Anderson created FLINK-5575: - Summary: add redirect to latest stable docs Key: FLINK-5575 URL: https://issues.apache.org/jira/browse/FLINK-5575 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5574) Add checkpoint statistics docs

Ufuk Celebi created FLINK-5574: -- Summary: Add checkpoint statistics docs Key: FLINK-5574 URL: https://issues.apache.org/jira/browse/FLINK-5574 Project: Flink Issue Type: Improvement Co

[jira] [Created] (FLINK-5573) Kafka08ITCase.testStartFromZookeeperCommitOffsets fails on Travis

Till Rohrmann created FLINK-5573: Summary: Kafka08ITCase.testStartFromZookeeperCommitOffsets fails on Travis Key: FLINK-5573 URL: https://issues.apache.org/jira/browse/FLINK-5573 Project: Flink

[jira] [Created] (FLINK-5572) ListState in SlidingEventTimeWindow and SlidingProcessingTimeWindow optimization

Syinchwun Leo created FLINK-5572: Summary: ListState in SlidingEventTimeWindow and SlidingProcessingTimeWindow optimization Key: FLINK-5572 URL: https://issues.apache.org/jira/browse/FLINK-5572 Projec

Re: New Flink team member - Kate Eri.

Hi Katherin, welcome to the Flink community. Always great to see new people joining the community :-) Cheers, Till On Tue, Jan 17, 2017 at 1:02 PM, Katherin Sotenko wrote: > ok, I've got it. > I will take a look at https://github.com/apache/flink/pull/2735. > > вт, 17 янв. 2017 г. в 14:36, Th

Re: Need guidance for write a client connector for 'Flink'

Thanks @Ruben for providing those Information. It will helpful for me. Seems You have written your own InputSplit for this task. (KuduInputSplit) On Thu, Jan 19, 2017 at 2:58 PM, wrote: > Hi, > > Just in case it could useful, we are working in Flink-Kudu integration > [1]. This is a still Work i

Re: Need guidance for write a client connector for 'Flink'

Hi, Just in case it could useful, we are working in Flink-Kudu integration [1]. This is a still Work in Progess but we had to implemente an InputFormat to read from Kudu tables so maybe the code is useful for you [2] Best [1] https://github.com/rubencasado/Flink-Kudu [2] https://github.com/ru