[jira] [Created] (FLINK-11896) Introduce stream physical nodes

godfrey he created FLINK-11896: -- Summary: Introduce stream physical nodes Key: FLINK-11896 URL: https://issues.apache.org/jira/browse/FLINK-11896 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11895) Allow FileSystem Configs to be altered at Runtime

Luka Jurukovski created FLINK-11895: --- Summary: Allow FileSystem Configs to be altered at Runtime Key: FLINK-11895 URL: https://issues.apache.org/jira/browse/FLINK-11895 Project: Flink

Re: [DISCUSS] Using Guava in Flink "core" packages

I want to bring this back to attention - with the concern raised here we are still looking for a potentially better answer to the original issue [1]. We have a class that depends on Guava (in its implementation, not the public interface) and we want to make it available for use with multiple

[jira] [Created] (FLINK-11894) AbstractRowSerializer.serializeToPages return type should be void

Jingsong Lee created FLINK-11894: Summary: AbstractRowSerializer.serializeToPages return type should be void Key: FLINK-11894 URL: https://issues.apache.org/jira/browse/FLINK-11894 Project: Flink

Submitting a Flink Job via the Flink Dash Board

Hi Folks, We developed a Flink Application DataStreamSource reading from a Kafka Topic. Now we need to deploy this via the Flink Dash Board. This program runs perfectly fine via the command line bin/flink run But with the Dash Board it doesn't work. Should there be any changes done -

[jira] [Created] (FLINK-11893) Update ecosystem page and add it to the navigation bar

Jiangjie Qin created FLINK-11893: Summary: Update ecosystem page and add it to the navigation bar Key: FLINK-11893 URL: https://issues.apache.org/jira/browse/FLINK-11893 Project: Flink Issue

[jira] [Created] (FLINK-11891) Fix some script or test case bug in 1.8 RC

sunjincheng created FLINK-11891: --- Summary: Fix some script or test case bug in 1.8 RC Key: FLINK-11891 URL: https://issues.apache.org/jira/browse/FLINK-11891 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-11890) Replace Table API string-based expressions by a Java DSL

Timo Walther created FLINK-11890: Summary: Replace Table API string-based expressions by a Java DSL Key: FLINK-11890 URL: https://issues.apache.org/jira/browse/FLINK-11890 Project: Flink

Re: [VOTE] Release 1.8.0, release candidate #1

I agree with @Robert Metzger 's suggestion! The 1.8 version is a big release, we have a lot of enhancements, and letting users participate in the test is very helpful for the quality of the release. BTW: I am also doing RC verification, but I haven't fully verified it yet, And I have already

Re: [DISCUSS] FLIP-33: Terminate/Suspend Job with Savepoint

Thanks a lot Aljoscha! On Tue, Mar 12, 2019 at 2:50 PM Aljoscha Krettek wrote: > I agree and already created a Jira issue for removing the old “stop” > feature as preparation: https://issues.apache.org/jira/browse/FLINK-11889 > > > Aljoscha >

Re: [DISCUSS] FLIP-33: Terminate/Suspend Job with Savepoint

I agree and already created a Jira issue for removing the old “stop” feature as preparation: https://issues.apache.org/jira/browse/FLINK-11889 Aljoscha > On 7. Mar 2019, at 11:08, Kostas Kloudas wrote: > > Hi, > > Thanks for the comments.

[jira] [Created] (FLINK-11889) Remove "stop" signal along with Stoppable interfaces

Aljoscha Krettek created FLINK-11889: Summary: Remove "stop" signal along with Stoppable interfaces Key: FLINK-11889 URL: https://issues.apache.org/jira/browse/FLINK-11889 Project: Flink

[jira] [Created] (FLINK-11888) Refine document of how to run end-to-end tests

Yu Li created FLINK-11888: - Summary: Refine document of how to run end-to-end tests Key: FLINK-11888 URL: https://issues.apache.org/jira/browse/FLINK-11888 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-11887) Operator's Latency Metrics continues to increase

Suxing Lee created FLINK-11887: -- Summary: Operator's Latency Metrics continues to increase Key: FLINK-11887 URL: https://issues.apache.org/jira/browse/FLINK-11887 Project: Flink Issue Type: Bug

[DISCUSS] FLIP-36 - Support Interactive Programming in Flink Table API

Hi folks, We would like to start the discussion thread about FLIP-36 support interactive programming in Flink Table API. https://cwiki.apache.org/confluence/display/FLINK/FLIP-36%3A+Support+Interactive+Programming+in+Flink There has been an extended discussion[1] in the mailing list. To quick

Re: [VOTE] Release 1.8.0, release candidate #1

I'm wondering whether we should tweet about this release candidate, and also post on the user@ mailing list to ask for some help with testing the RC in production environments? On Tue, Mar 12, 2019 at 11:23 AM Kurt Young wrote: > +1 (non-binding) > > Checked items: > - checked checksums and

Re: [VOTE] Release 1.8.0, release candidate #1

+1 (non-binding) Checked items: - checked checksums and GPG files - verified that the source archives do not contains any binaries - checked that all POM files point to the same version - build from source Best, Kurt On Tue, Mar 12, 2019 at 9:20 AM Congxian Qiu wrote: > +1 (non-binding) > >

[jira] [Created] (FLINK-11886) update the output of cluster management script in jobmanager_high_availability doc

chunpinghe created FLINK-11886: -- Summary: update the output of cluster management script in jobmanager_high_availability doc Key: FLINK-11886 URL: https://issues.apache.org/jira/browse/FLINK-11886

[jira] [Created] (FLINK-11885) Introduce RecordWriterBuilder for creating RecordWriter instance

zhijiang created FLINK-11885: Summary: Introduce RecordWriterBuilder for creating RecordWriter instance Key: FLINK-11885 URL: https://issues.apache.org/jira/browse/FLINK-11885 Project: Flink

[jira] [Created] (FLINK-11884) Port Table to flink-api-java

Dawid Wysakowicz created FLINK-11884: Summary: Port Table to flink-api-java Key: FLINK-11884 URL: https://issues.apache.org/jira/browse/FLINK-11884 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11883) Harmonize the versions of the

Fokko Driesprong created FLINK-11883: Summary: Harmonize the versions of the Key: FLINK-11883 URL: https://issues.apache.org/jira/browse/FLINK-11883 Project: Flink Issue Type: Bug

Flink contributor application

Hi Flink community! I want to contribute to Apache Flink. Would you please give methe contributor permission? My JIRA ID is zgl1989. Thanks and Regard Guoliang Zhu

[jira] [Created] (FLINK-11882) Introduce BytesHashMap to batch hash agg

Jingsong Lee created FLINK-11882: Summary: Introduce BytesHashMap to batch hash agg Key: FLINK-11882 URL: https://issues.apache.org/jira/browse/FLINK-11882 Project: Flink Issue Type: New

contributor permission application

Hi there, I want to be a Flink contributor. Could you please give me contributor permissions? My jira id is: 10fish. Thanks. Y Gao