[jira] [Created] (FLINK-5991) Expose Broadcast Operator State through public APIs

2017-03-07 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-5991: -- Summary: Expose Broadcast Operator State through public APIs Key: FLINK-5991 URL: https://issues.apache.org/jira/browse/FLINK-5991 Project: Flink

[jira] [Created] (FLINK-5990) Add event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

2017-03-07 Thread sunjincheng (JIRA)
sunjincheng created FLINK-5990: -- Summary: Add event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL Key: FLINK-5990 URL: https://issues.apache.org/jira/browse/FLINK-5990 Project: Flink Is

[jira] [Created] (FLINK-5989) Protobuf in akka needs to be shaded

2017-03-07 Thread Wenlong Lyu (JIRA)
Wenlong Lyu created FLINK-5989: -- Summary: Protobuf in akka needs to be shaded Key: FLINK-5989 URL: https://issues.apache.org/jira/browse/FLINK-5989 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5988) Show start-cluster.sh failures

2017-03-07 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-5988: - Summary: Show start-cluster.sh failures Key: FLINK-5988 URL: https://issues.apache.org/jira/browse/FLINK-5988 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5987) Upgrade zookeeper dependency to 3.4.8

2017-03-07 Thread Ted Yu (JIRA)
Ted Yu created FLINK-5987: - Summary: Upgrade zookeeper dependency to 3.4.8 Key: FLINK-5987 URL: https://issues.apache.org/jira/browse/FLINK-5987 Project: Flink Issue Type: Improvement Rep

[jira] [Created] (FLINK-5986) Add forwarded field annotations to batch (window) aggregate operators

2017-03-07 Thread Timo Walther (JIRA)
Timo Walther created FLINK-5986: --- Summary: Add forwarded field annotations to batch (window) aggregate operators Key: FLINK-5986 URL: https://issues.apache.org/jira/browse/FLINK-5986 Project: Flink

[jira] [Created] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible)

2017-03-07 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-5985: - Summary: Flink treats every task as stateful (making topology changes impossible) Key: FLINK-5985 URL: https://issues.apache.org/jira/browse/FLINK-5985 Project: Flink

[jira] [Created] (FLINK-5984) Allow reusing of accumulators in AggregateFunction

2017-03-07 Thread Timo Walther (JIRA)
Timo Walther created FLINK-5984: --- Summary: Allow reusing of accumulators in AggregateFunction Key: FLINK-5984 URL: https://issues.apache.org/jira/browse/FLINK-5984 Project: Flink Issue Type: Im

Re: FLINK-5734 : Code Generation for NormalizedKeySorter

2017-03-07 Thread pat.chormai
Hi all, We have almost finished implementing the functionalities. The implementation is available at [1]. Also, we have included the benchmark result of FLINK-3722 into the FLIP[2] as well as other implementation details We would be appreciated if you could give us feedback on this before actual

[jira] [Created] (FLINK-5983) Replace for/foreach/map in aggregates by while loops

2017-03-07 Thread Timo Walther (JIRA)
Timo Walther created FLINK-5983: --- Summary: Replace for/foreach/map in aggregates by while loops Key: FLINK-5983 URL: https://issues.apache.org/jira/browse/FLINK-5983 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-17 Side Inputs

2017-03-07 Thread wenlong.lwl
Hi Aljoscha, thank you for the proposal, it is great to hear about the progress in side input. Following is my point of view: 1. I think there may be an option to block the processing of the main input instead of buffer the data in state because in production, the through put of the main input is

[jira] [Created] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-07 Thread Wei-Che Wei (JIRA)
Wei-Che Wei created FLINK-5982: -- Summary: Refactor AbstractInvokable and StatefulTask Key: FLINK-5982 URL: https://issues.apache.org/jira/browse/FLINK-5982 Project: Flink Issue Type: Improvement

Re: Incremental checkpoint branch

2017-03-07 Thread Stephan Ewen
Hi! The concrete storage location (HDFS / S3) should be independent of the imeplementation. The design should work for both. Stephan On Mon, Mar 6, 2017 at 5:38 PM, Vishnu Viswanath < vishnu.viswanat...@gmail.com> wrote: > Thanks everyone for the reply. > > @Xiaogang design document looks very

[jira] [Created] (FLINK-5981) SSL version and ciper suites cannot be constrained as configured

2017-03-07 Thread Tao Wang (JIRA)
Tao Wang created FLINK-5981: --- Summary: SSL version and ciper suites cannot be constrained as configured Key: FLINK-5981 URL: https://issues.apache.org/jira/browse/FLINK-5981 Project: Flink Issue T

[jira] [Created] (FLINK-5980) Expose max-parallelism value in RuntimeContext

2017-03-07 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5980: --- Summary: Expose max-parallelism value in RuntimeContext Key: FLINK-5980 URL: https://issues.apache.org/jira/browse/FLINK-5980 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5979) Backwards compatibility for HeapKeyedStateBackend serialization format (1.2 -> 1.3)

2017-03-07 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-5979: - Summary: Backwards compatibility for HeapKeyedStateBackend serialization format (1.2 -> 1.3) Key: FLINK-5979 URL: https://issues.apache.org/jira/browse/FLINK-5979 P

[jira] [Created] (FLINK-5978) JM WebFrontend address ConfigOption is defined in ConfigConstants

2017-03-07 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-5978: --- Summary: JM WebFrontend address ConfigOption is defined in ConfigConstants Key: FLINK-5978 URL: https://issues.apache.org/jira/browse/FLINK-5978 Project: Flink

Re: [DISCUSS] FLIP-17 Side Inputs

2017-03-07 Thread Ventura Del Monte
Hi Aljoscha, Thank you for the proposal and for bringing up again this discussion. Regarding the implementation aspect,I would say the first way could be easier/faster to implement but it could add some overhead when dealing with multiple side inputs through the current 2-streams union transform.

[jira] [Created] (FLINK-5977) Rename MAX_ATTEMPTS_HISTORY_SIZE key

2017-03-07 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-5977: --- Summary: Rename MAX_ATTEMPTS_HISTORY_SIZE key Key: FLINK-5977 URL: https://issues.apache.org/jira/browse/FLINK-5977 Project: Flink Issue Type: Bug