[jira] [Created] (FLINK-9560) RateLimiting for FileSystem

2018-06-08 Thread Etienne CARRIERE (JIRA)
Etienne CARRIERE created FLINK-9560: --- Summary: RateLimiting for FileSystem Key: FLINK-9560 URL: https://issues.apache.org/jira/browse/FLINK-9560 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR

2018-06-08 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-9559: -- Summary: The type of a union of CHAR columns of different lengths should be VARCHAR Key: FLINK-9559 URL: https://issues.apache.org/jira/browse/FLINK-9559 Project: Flink

[Proposal] Code Reviewer List

2018-06-08 Thread Yaz Sh
Hi Flink Community, I am working with Flink for last couple of months and still learning it. Recently, I have started as a contributor in Flink to perform some minor changes and I am very excited to start working on bigger tasks. Questions I always have in mind, when I make a PR, are “Who shoul

Re: [DISCUSS] Flink 1.6 features

2018-06-08 Thread Elias Levy
Since wishes are free: - Standalone cluster job isolation: https://issues.apache.org/jira/browse/FLINK-8886 - Proper sliding window joins (not overlapping hoping window joins): https://issues.apache.org/jira/browse/FLINK-6243 - Sharing state across operators: https://issues.apache.org/jira/browse/

Re: [DISCUSS] Flink 1.6 features

2018-06-08 Thread Stephan Ewen
Hi all! Thanks for the discussion and good input. Many suggestions fit well with the proposal above. Please bear in mind that with a time-based release model, we would release whatever is mature by end of July. The good thing is we could schedule the next release not too far after that, so that t

[jira] [Created] (FLINK-9558) Memory leaks during usage with disabled checkpointing

2018-06-08 Thread Rinat Sharipov (JIRA)
Rinat Sharipov created FLINK-9558: - Summary: Memory leaks during usage with disabled checkpointing Key: FLINK-9558 URL: https://issues.apache.org/jira/browse/FLINK-9558 Project: Flink Issue T

[jira] [Created] (FLINK-9557) FlinkTypeFactory should support BigInteger type

2018-06-08 Thread JIRA
Dominik Wosiński created FLINK-9557: --- Summary: FlinkTypeFactory should support BigInteger type Key: FLINK-9557 URL: https://issues.apache.org/jira/browse/FLINK-9557 Project: Flink Issue Typ

[jira] [Created] (FLINK-9556) Scala TypeAnalyzer does not consider ResultTypeQueryable

2018-06-08 Thread Timo Walther (JIRA)
Timo Walther created FLINK-9556: --- Summary: Scala TypeAnalyzer does not consider ResultTypeQueryable Key: FLINK-9556 URL: https://issues.apache.org/jira/browse/FLINK-9556 Project: Flink Issue Ty

[jira] [Created] (FLINK-9555) Support table api in scala shell

2018-06-08 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-9555: - Summary: Support table api in scala shell Key: FLINK-9555 URL: https://issues.apache.org/jira/browse/FLINK-9555 Project: Flink Issue Type: New Feature Co

Re: [DISCUSS] Adding new interfaces in [Stream]ExecutionEnvironment

2018-06-08 Thread Shuyi Chen
Thanks a lot for the comments, Till and Fabian. The RemoteEnvrionment does provide a way to specify jar files at construction, but we want the jar files to be specified dynamically in the user code, e.g. in a DDL statement, and the jar files might be in a remote DFS. As we discussed, I think there