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

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

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

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

Re: [DISCUSS] Flink 1.6 features

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:

Re: [DISCUSS] Flink 1.6 features

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

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

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

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

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

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

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

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

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

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

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