Re: 退订

Hi Please send an email to dev-unsubscr...@flink.apache.org for unsubscribing. You can read more information[1] here PS: I use Chinses because I thought that the email was sent to user-zh mail list. [1] https://flink.apache.org/community.html Best, Congxian Congxian Qiu

Re: 退订

Hi 退订请 发邮件到 user-zh-unsubscr...@flink.apache.org 详细的可以参考 [1] [1] https://flink.apache.org/zh/community.html#section-1 Best, Congxian 智子 <769257...@qq.com> 于2020年8月12日周三 上午11:15写道： >

[jira] [Created] (FLINK-18898) .flink-runtime.version.properties file does not exist in flink-dist.jar

Aki Tanaka created FLINK-18898: -- Summary: .flink-runtime.version.properties file does not exist in flink-dist.jar Key: FLINK-18898 URL: https://issues.apache.org/jira/browse/FLINK-18898 Project: Flink

Re: [DISCUSS] FLIP-107: Reading table columns from different parts of source records

+1 for FLIP-107 Reading different parts of source code should be the key feature for Flink SQL, like metadata in CDC data, key and timestamp in Kafka records. The scope of FLIP-107 is too big to finish in one version IMO, maybe we can start part work in 1.12. Best Leonard > 在

退订

[jira] [Created] (FLINK-18897) Add documentation for the maxwell-json format

Jark Wu created FLINK-18897: --- Summary: Add documentation for the maxwell-json format Key: FLINK-18897 URL: https://issues.apache.org/jira/browse/FLINK-18897 Project: Flink Issue Type: Sub-task

Re: [VOTE] FLIP-133: Rework PyFlink Documentation

+1 (binding) Best, Jincheng Shuiqiang Chen 于2020年8月12日周三 上午10:18写道： > +1 (non-binding) > > Best, > Shuiqiang > > Dian Fu 于2020年8月12日周三 上午10:10写道： > > > +1 (binding) > > > > Thanks, > > Dian > > > > > 在 2020年8月11日，下午10:41，Seth Wiesman 写道： > > > > > > +1 (binding) > > > > > > On Sun, Aug 9,

Re: [VOTE] FLIP-133: Rework PyFlink Documentation

+1 (non-binding) Best, Shuiqiang Dian Fu 于2020年8月12日周三 上午10:10写道： > +1 (binding) > > Thanks, > Dian > > > 在 2020年8月11日，下午10:41，Seth Wiesman 写道： > > > > +1 (binding) > > > > On Sun, Aug 9, 2020 at 8:15 PM jincheng sun > > wrote: > > > >> Hi Seth, > >> > >> Thank you for joining the

Re: [VOTE] FLIP-133: Rework PyFlink Documentation

+1 (non-binding) Best, Xingbo Wei Zhong 于2020年8月12日周三 上午10:12写道： > +1 (non-binding) > > Best, > Wei > > > 在 2020年8月11日，22:41，Seth Wiesman 写道： > > > > +1 (binding) > > > > On Sun, Aug 9, 2020 at 8:15 PM jincheng sun > > wrote: > > > >> Hi Seth, > >> > >> Thank you for joining the discussion

Re: [VOTE] FLIP-133: Rework PyFlink Documentation

+1 (binding) Best, Hequn On Wed, Aug 12, 2020 at 10:12 AM Wei Zhong wrote: > +1 (non-binding) > > Best, > Wei > > > 在 2020年8月11日，22:41，Seth Wiesman 写道： > > > > +1 (binding) > > > > On Sun, Aug 9, 2020 at 8:15 PM jincheng sun > > wrote: > > > >> Hi Seth, > >> > >> Thank you for joining the

Re: [VOTE] FLIP-133: Rework PyFlink Documentation

+1 (non-binding) Best, Wei > 在 2020年8月11日，22:41，Seth Wiesman 写道： > > +1 (binding) > > On Sun, Aug 9, 2020 at 8:15 PM jincheng sun > wrote: > >> Hi Seth, >> >> Thank you for joining the discussion and voting. Could you please have a >> look at the discussion thread. >> It would be great to

Re: [VOTE] FLIP-133: Rework PyFlink Documentation

+1 (binding) Thanks, Dian > 在 2020年8月11日，下午10:41，Seth Wiesman 写道： > > +1 (binding) > > On Sun, Aug 9, 2020 at 8:15 PM jincheng sun > wrote: > >> Hi Seth, >> >> Thank you for joining the discussion and voting. Could you please have a >> look at the discussion thread. >> It would be great

[jira] [Created] (FLINK-18896) Translate "stateful-functions" page into Chinese

Feng Jie created FLINK-18896: Summary: Translate "stateful-functions" page into Chinese Key: FLINK-18896 URL: https://issues.apache.org/jira/browse/FLINK-18896 Project: Flink Issue Type:

[jira] [Created] (FLINK-18895) Not able to access Flink 1.7.2 with HDP 3.0.1 cluster

Pasha Shaik created FLINK-18895: --- Summary: Not able to access Flink 1.7.2 with HDP 3.0.1 cluster Key: FLINK-18895 URL: https://issues.apache.org/jira/browse/FLINK-18895 Project: Flink Issue

[jira] [Created] (FLINK-18894) StateFun job stalls on stop-with-savepoint

Seth Wiesman created FLINK-18894: Summary: StateFun job stalls on stop-with-savepoint Key: FLINK-18894 URL: https://issues.apache.org/jira/browse/FLINK-18894 Project: Flink Issue Type:

[jira] [Created] (FLINK-18893) Python tests fails with "AppendStreamTableSink requires that Table has only insert changes."

Robert Metzger created FLINK-18893: -- Summary: Python tests fails with "AppendStreamTableSink requires that Table has only insert changes." Key: FLINK-18893 URL: https://issues.apache.org/jira/browse/FLINK-18893

[jira] [Created] (FLINK-18892) Upgrade Guava to version 28.2-jre

Igor Dvorzhak created FLINK-18892: - Summary: Upgrade Guava to version 28.2-jre Key: FLINK-18892 URL: https://issues.apache.org/jira/browse/FLINK-18892 Project: Flink Issue Type: Task

Re: [VOTE] FLIP-133: Rework PyFlink Documentation

+1 (binding) On Sun, Aug 9, 2020 at 8:15 PM jincheng sun wrote: > Hi Seth, > > Thank you for joining the discussion and voting. Could you please have a > look at the discussion thread. > It would be great to know that did the follow-up discussion allay your > concerns and any feedback is

[VOTE] Release 1.10.2, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 1.10.2, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1],

Re: [DISCUSS] Retrieve savepoint location after suspension of jobclusters

This sounds like a bug in Flink. Could you share the logs of the cluster (ideally with TRACE log level) with us? Cheers, Till On Tue, Aug 11, 2020 at 9:49 AM Fabian Paul wrote: > Hi Till, > > The problem is reproducible with a basic shell script doing the following > operations. > > 1. Post

Re: [DISCUSS] FLIP-107: Reading table columns from different parts of source records

The content length of FLIP-107 is relatively short but the scope and implications it will cause is actually very big. >From what I can tell now, I think there is a good chance that we can deliver part of this FLIP in 1.12, e.g. accessing the metadata field just like you mentioned. Best, Kurt On

Re: Flink cluster deployment strategy

Hi Sidhant, I am not an expert on AWS services but I believe that EMR might be a bit easier to start with since AWS EMR comes with Flink support out of the box [1]. On ECS I believe that you would have to set up the containers yourself. Another interesting deployment option could be to use

Re: [DISCUSS] FLIP-107: Reading table columns from different parts of source records

Big +1 for this FLIP. Recently I'm working on some Kafka topics that have timestamps as metadata, not in the message body. I want to declare a table from the topics with DDL but "rowtime_column_name" in seems to accept only existing columns. > : > WATERMARK FOR rowtime_column_name AS

[jira] [Created] (FLINK-18891) flink job failed but yarn application still running via yarn-per-job mode

Peng created FLINK-18891: Summary: flink job failed but yarn application still running via yarn-per-job mode Key: FLINK-18891 URL: https://issues.apache.org/jira/browse/FLINK-18891 Project: Flink

Re: Error with Flink-Gelly, lastJobExecutionResult is null

Does this mean this is a valid issue? If so, we could track it as a starter issue? On Mon, Aug 3, 2020 at 10:59 AM Aljoscha Krettek wrote: > Thanks for the pointer! > > On 03.08.20 10:29, Till Rohrmann wrote: > > Hi Xia Rui, > > > > thanks for reporting this issue. I think FLINK-15116 [1]

Re: [DISCUSS] Retrieve savepoint location after suspension of jobclusters

Hi Till, The problem is reproducible with a basic shell script doing the following operations. 1. Post request to /jobs/${JOB_ID}/savepoints with the payload {"cancel-job": true,"target-directory": $(LOCATION)} and store the trigger ID 2. Sleep 10 seconds 3. Get

[jira] [Created] (FLINK-18890) Update AsyncTableFunctions to the new type system

Timo Walther created FLINK-18890: Summary: Update AsyncTableFunctions to the new type system Key: FLINK-18890 URL: https://issues.apache.org/jira/browse/FLINK-18890 Project: Flink Issue

Flink cluster deployment strategy

Hi all, I'm kind of new to flink cluster deployment. I wanted to know which flink cluster deployment and which job mode in aws is better in terms of ease of deployment, maintenance, HA, cost, etc. As of now I am considering aws EMR vs ECS (docker containers). We have a usecase of setting up a

Re: [DISCUSS][Release 1.12] Stale blockers and build instabilities

Hi team, 2 weeks have passed since the last update. None of the test stabilities I've mentioned have been addressed since then. Here's an updated status report of Blockers and Test instabilities: Blockers : Currently 3 blockers

[jira] [Created] (FLINK-18889) New Async Table Function type inference fails

Mulan created FLINK-18889: - Summary: New Async Table Function type inference fails Key: FLINK-18889 URL: https://issues.apache.org/jira/browse/FLINK-18889 Project: Flink Issue Type: Bug