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

Hi all, When we did the Window Interface work in FLIP32, we found `OverWindow` and `Window` are confusing in the API. It is mentioned that we want to rename it to `GroupWindow` many times. So, here just a suggestion, how about deprecated the `Window` in release-1.8, and remove the `Window` in

[jira] [Created] (FLINK-11918) Deprecated Window and Rename it to GroupWindow

sunjincheng created FLINK-11918: --- Summary: Deprecated Window and Rename it to GroupWindow Key: FLINK-11918 URL: https://issues.apache.org/jira/browse/FLINK-11918 Project: Flink Issue Type:

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

Hi Fokko, I've looked at FLINK-11911 (Make KafkaTopicPartition a POJO), and left a comment in the PR. Main gist is that this change would break state compatibility for previous versions of the FlinkKafkaConsumers, since changing that behind the scenes Flink would use different serializers for

[jira] [Created] (FLINK-11917) Allow state schema migration from Kryo to POJO / Avro

Tzu-Li (Gordon) Tai created FLINK-11917: --- Summary: Allow state schema migration from Kryo to POJO / Avro Key: FLINK-11917 URL: https://issues.apache.org/jira/browse/FLINK-11917 Project: Flink

[jira] [Created] (FLINK-11916) Join with a Temporal Table should throw exception for left join

Hequn Cheng created FLINK-11916: --- Summary: Join with a Temporal Table should throw exception for left join Key: FLINK-11916 URL: https://issues.apache.org/jira/browse/FLINK-11916 Project: Flink

[jira] [Created] (FLINK-11915) DataInputViewStream skip returns wrong value

Andrew Prudhomme created FLINK-11915: Summary: DataInputViewStream skip returns wrong value Key: FLINK-11915 URL: https://issues.apache.org/jira/browse/FLINK-11915 Project: Flink Issue

[jira] [Created] (FLINK-11914) Expose a REST endpoint in JobManager to disconnect specific TaskManager

Shuyi Chen created FLINK-11914: -- Summary: Expose a REST endpoint in JobManager to disconnect specific TaskManager Key: FLINK-11914 URL: https://issues.apache.org/jira/browse/FLINK-11914 Project: Flink

[jira] [Created] (FLINK-11913) Cassandra connector should shade it's usage of cassandra-driver classes to avoid conflicts

Gustavo Momenté created FLINK-11913: --- Summary: Cassandra connector should shade it's usage of cassandra-driver classes to avoid conflicts Key: FLINK-11913 URL: https://issues.apache.org/jira/browse/FLINK-11913

[jira] [Created] (FLINK-11910) Make Yarn Application Type Customizable with Flink Version

Zhenqiu Huang created FLINK-11910: - Summary: Make Yarn Application Type Customizable with Flink Version Key: FLINK-11910 URL: https://issues.apache.org/jira/browse/FLINK-11910 Project: Flink

Re: [DISCUSS] Create a Flink ecosystem website

@Bowen: I agree. Confluent Hub looks nicer, but it is on their company website. I guess the likelihood that they give out code from their company website is fairly low. @Nils: Beam's page is similar to our Ecosystem page, which we'll reactivate as part of this PR:

Status of FLINK-2491 (Checkpointing of shutdown sources)

Hi, Has there been any progress on https://issues.apache.org/jira/browse/FLINK-2491? For the Flink Runner in Apache Beam we keep operators alive to avoid checkpointing to stop working [1]. Users of Flink's native API have to take care of this themselves. To fix FLINK-2491 we have to:

Re: Backoff strategies for async IO functions?

Thanks for raising the concern @shuyi and the explanation @konstantin. Upon glancing on the Flink document, it seems like user have full control on the timeout behavior [1]. But unlike AsyncWaitOperator, it is not straightforward to access the internal state of the operator to, for example, put

[jira] [Created] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

Rong Rong created FLINK-11909: - Summary: Provide default failure/timeout handling strategy for AsyncIO functions Key: FLINK-11909 URL: https://issues.apache.org/jira/browse/FLINK-11909 Project: Flink

[jira] [Created] (FLINK-11908) Port window classes into flink-api-java

Hequn Cheng created FLINK-11908: --- Summary: Port window classes into flink-api-java Key: FLINK-11908 URL: https://issues.apache.org/jira/browse/FLINK-11908 Project: Flink Issue Type:

[jira] [Created] (FLINK-11907) GenericTypeInfoTest fails on Java 9

Chesnay Schepler created FLINK-11907: Summary: GenericTypeInfoTest fails on Java 9 Key: FLINK-11907 URL: https://issues.apache.org/jira/browse/FLINK-11907 Project: Flink Issue Type:

[jira] [Created] (FLINK-11906) Getting error while submitting job

Ramesh Srinivasalu created FLINK-11906: -- Summary: Getting error while submitting job Key: FLINK-11906 URL: https://issues.apache.org/jira/browse/FLINK-11906 Project: Flink Issue Type:

[jira] [Created] (FLINK-11905) BlockCompressionTest does not compile with Java 9

Chesnay Schepler created FLINK-11905: Summary: BlockCompressionTest does not compile with Java 9 Key: FLINK-11905 URL: https://issues.apache.org/jira/browse/FLINK-11905 Project: Flink

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

@Robert I was planning to do that, yes! :-) > On 13. Mar 2019, at 13:04, Robert Metzger wrote: > > Aljoscha, can you CC the user@ list on the next RC, so that a wider > audience of people sees it and can help testing with their prod jobs? > > On Wed, Mar 13, 2019 at 12:47 PM jincheng sun >

[jira] [Created] (FLINK-11904) Improve MemoryStateBackendTest by using JUnit's Parameterized

Congxian Qiu(klion26) created FLINK-11904: - Summary: Improve MemoryStateBackendTest by using JUnit's Parameterized Key: FLINK-11904 URL: https://issues.apache.org/jira/browse/FLINK-11904

Re: Submitting a Flink Job via the Flink Dash Board

Thanks for the prompt reply - now i used the fully qualified class Name - it gives this error (it works fine via the CLI bin/flink run org.apache.flink.client.program.ProgramInvocationException: The main method caused an error. This is in my pom.xml <*properties*> <*debug.port*>

[jira] [Created] (FLINK-11903) Improve FileStateBackendTest by using JUnit's Parameterized

Congxian Qiu(klion26) created FLINK-11903: - Summary: Improve FileStateBackendTest by using JUnit's Parameterized Key: FLINK-11903 URL: https://issues.apache.org/jira/browse/FLINK-11903

[jira] [Created] (FLINK-11902) JarRunHandler wraps all exceptions in a RestHandlerException

Chesnay Schepler created FLINK-11902: Summary: JarRunHandler wraps all exceptions in a RestHandlerException Key: FLINK-11902 URL: https://issues.apache.org/jira/browse/FLINK-11902 Project: Flink

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

Aljoscha, can you CC the user@ list on the next RC, so that a wider audience of people sees it and can help testing with their prod jobs? On Wed, Mar 13, 2019 at 12:47 PM jincheng sun wrote: > Thanks for prepare the new RC. Aljoscha! > > I also merged the FLINK-11892 >

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

Thanks for prepare the new RC. Aljoscha! I also merged the FLINK-11892 (end-to-end test doc improve) into release-1.8 branch, and thanks for the quick fix @Yu. Looking forward to the new RC. Best, Jincheng Aljoscha Krettek 于2019年3月13日周三

[CANCEL][VOTE] Release 1.8.0, release candidate #1

Hi, I’m hereby canceling the vote for RC1 of Flink 1.8.0 because of the aforementioned issues. I’ll create a new RC as soon as those issues are resolved. Best, Aljoscha > On 13. Mar 2019, at 12:24, Aljoscha Krettek wrote: > > Hi, > > Thanks for the verification performed so far. It seems I

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

Hi, Thanks for the verification performed so far. It seems I have to cancel this vote and create a new RC. I’ll wait for - https://issues.apache.org/jira/browse/FLINK-11901 to be resolved. There have also been two blockers that are now

Re: Submitting a Flink Job via the Flink Dash Board

Looks like the wrong main class is being passed to the REST API. It is "MyFlinkApplication" but should be "com.foo.bar.MyFlinkApplication". Are you setting the class manually during the job-submission or is it written into the jar manifest? On 13.03.2019 03:21, Durga Durga wrote: Hi Folks,

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

I just found https://issues.apache.org/jira/browse/FLINK-11901 According to Chesnay, this is a release blocker. Regards, Timo Am 13.03.19 um 09:48 schrieb Driesprong, Fokko: -1 (non-binding) I'd like to see both get into Flink 1.8: https://github.com/apache/flink/pull/7547

[jira] [Created] (FLINK-11901) Update the year in NOTICE files

Timo Walther created FLINK-11901: Summary: Update the year in NOTICE files Key: FLINK-11901 URL: https://issues.apache.org/jira/browse/FLINK-11901 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-11900) Flink on Kubernetes sensitive about arguments placement

Mario Georgiev created FLINK-11900: --- Summary: Flink on Kubernetes sensitive about arguments placement Key: FLINK-11900 URL: https://issues.apache.org/jira/browse/FLINK-11900 Project: Flink

[jira] [Created] (FLINK-11899) Introduce VectorizedColumnRowInputParquetFormat for blink runtime

Jingsong Lee created FLINK-11899: Summary: Introduce VectorizedColumnRowInputParquetFormat for blink runtime Key: FLINK-11899 URL: https://issues.apache.org/jira/browse/FLINK-11899 Project: Flink

[jira] [Created] (FLINK-11898) Implement BinaryString call code generator

Jark Wu created FLINK-11898: --- Summary: Implement BinaryString call code generator Key: FLINK-11898 URL: https://issues.apache.org/jira/browse/FLINK-11898 Project: Flink Issue Type: New Feature

Re: Flink contributor application

You now have contributor permissions. On 12.03.2019 09:08, 朱国梁 wrote: 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

Re: contributor permission application

You now have contributor permissions. On 12.03.2019 08:54, Yan Gao wrote: Hi there, I want to be a Flink contributor. Could you please give me contributor permissions? My jira id is: 10fish. Thanks. Y Gao

[jira] [Created] (FLINK-11897) ExecutionGraphSuspendTest.testSuspendedOutOfRunning failed

chunpinghe created FLINK-11897: -- Summary: ExecutionGraphSuspendTest.testSuspendedOutOfRunning failed Key: FLINK-11897 URL: https://issues.apache.org/jira/browse/FLINK-11897 Project: Flink

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

Hi Becket, Thank you for driving the effort and writing down the detailed proposal. To me this FLIP looks good and it has +1 from me. Piotr Nowojski > On 12 Mar 2019, at 13:21, Becket Qin wrote: > > Hi folks, > > We would like to start the discussion thread about FLIP-36 support >