Re: [ANNOUNCE] New Apache Flink PMC Member - Qingsheng Ren

Congratulations, Qingsheng! Best regards, Yuxia - 原始邮件 - 发件人: "lincoln 86xy" 收件人: "dev" 发送时间: 星期日, 2023年 4 月 23日 上午 9:11:07 主题: Re: [ANNOUNCE] New Apache Flink PMC Member - Qingsheng Ren Congratulations, Qingsheng! Best, Lincoln Lee Yuxin Tan 于

Re: [NOTICE] Flink master branch now uses Maven 3.8.6

Thanks Chesnay for the efforts. Happy to see we can use Maven 3.8 finnally. Best regards, Yuxia - 原始邮件 - 发件人: "Jing Ge" 收件人: "dev" 发送时间: 星期六, 2023年 5 月 13日 下午 4:37:58 主题: Re: [NOTICE] Flink master branch now uses Maven 3.8.6 Great news! We can finally get rid of

Re: [DISCUSS] Release Flink 1.17.1

Thanks Weijie for the effort. Best regards, Yuxia - 原始邮件 - 发件人: "Jing Ge" 收件人: "dev" 抄送: "kevin lam" 发送时间: 星期五, 2023年 5 月 19日 下午 7:52:18 主题: Re: [DISCUSS] Release Flink 1.17.1 Hi Weijie, Thanks for your effort and sharing the status! Best regards, Ji

Re: [DISCUSS] FLIP-308: Support Time Travel In Batch Mode

ax in Calcite should be `FOR SYSTEM_TIME AS OF`, right? But the the syntax part in this FLIP, it seems to be `AS OF TIMESTAMP` instead of `FOR SYSTEM_TIME AS OF`. Is it just a mistake or by design? Best regards, Yuxia - 原始邮件 - 发件人: "Benchao Li" 收件人: "dev" 发送时间: 星期四, 20

[DISCUSS] FLIP-311: Support Call Stored Procedure

procedures, and then enables users to call these predefiend stored procedures. Looking forward to your feedbacks. [1]: https://cwiki.apache.org/confluence/display/FLINK/FLIP-311%3A+Support+Call+Stored+Procedure Best regards, Yuxia

[DISCUSS] Hive dialect shouldn't fall back to Flink's default dialect

78370b18e1b6c4a23e5ce08f8efd05675a0cc17/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParser.java#L348 [2]:https://issues.apache.org/jira/browse/FLINK-26681 [3]:https://issues.apache.org/jira/browse/FLINK-31413 [4]:https://issues.apache.org/jira/browse/FLINK-30064 Best regards, Yuxia

Re: [DISCUSS] FLIP 295: Support persistence of Catalog configuration and asynchronous registration

ize it and open it. right? Best regards, Yuxia - 原始邮件 - 发件人: "Jing Ge" 收件人: "dev" 发送时间: 星期一, 2023年 5 月 29日 下午 5:12:46 主题: Re: [DISCUSS] FLIP 295: Support persistence of Catalog configuration and asynchronous registration Hi Feng, Thanks for your effort! +1 for t

Re: [DISCUSS] FLIP-308: Support Time Travel In Batch Mode

Hi, Feng. Notice this FLIP only support batch mode for time travel. Would it also make sense to support stream mode to a read a snapshot of the table as a bounded stream? Best regards, Yuxia - 原始邮件 - 发件人: "Benchao Li" 收件人: "dev" 发送时间: 星期一, 2023年 5 月 29日 下午 6:04

Re: [DISCUSS] FLIP-311: Support Call Stored Procedure

data, I think we can change to return type from T[] to Iterable [1]: https://iceberg.apache.org/docs/latest/spark-procedures/#migrate [2]: https://github.com/apache/iceberg/blob/601c5af9b6abded79dabeba177331310d5487f43/spark/v3.2/spark/src/main/java/org/apache/spark/sql/connector/iceberg/catalog/Procedure.java#L44

Re: [DISCUSS] FLIP-294: Support Customized Job Meta Data Listener

rigin CatalogDatabase so that listener have ways to know what changes? Best regards, Yuxia - 原始邮件 - 发件人: "ron9 liu" 收件人: "dev" 发送时间: 星期三, 2023年 5 月 31日 上午 11:36:04 主题: Re: [DISCUSS] FLIP-294: Support Customized Job Meta Data Listener Hi, Shammon Thanks for d

Re: [DISCUSS] FLIP-294: Support Customized Job Meta Data Listener

to include ignoreIfNotExists method since alter database operation don't have such syntax like 'alter database if exists xxx'. Best regards, Yuxia - 原始邮件 - 发件人: "Shammon FY" 收件人: "dev" 发送时间: 星期三, 2023年 5 月 31日 下午 2:55:26 主题: Re: [DISCUSS] FLIP-294:

Re: [DISCUSS] Hive dialect shouldn't fall back to Flink's default dialect

ct to users and more user-friendly, I'll remind users may use set table.sql-dialect = default to switch to Flink's default dialect in error message when fail to parse the sql in HiveParser. Best regards, Yuxia Best regards, Yuxia - 原始邮件 - 发件人: "Jingsong Li" 收件人: &qu

Re: [DISCUSS] FLIP-294: Support Customized Job Meta Data Listener

Thanks for explanation. Make sense to me. Best regards, Yuxia - 原始邮件 - 发件人: "Shammon FY" 收件人: "dev" 发送时间: 星期四, 2023年 6 月 01日 上午 10:45:12 主题: Re: [DISCUSS] FLIP-294: Support Customized Job Meta Data Listener Thanks yuxia, you're right and I'll add the new

Re: [DISCUSS] FLIP-311: Support Call Stored Procedure

cautious about exposing too much too early to procedure devs. If someday we find we will need `TableEnvironment` to custom a procedure, we can then add a method like `getTableEnvironment()` in `ProcedureContext`. Best regards, Yuxia - 原始邮件 - 发件人: "Benchao Li" 收件人: "dev&qu

Re: [DISCUSS] FLIP-311: Support Call Stored Procedure

Sorry for missing the importart part, repeat it agin: "But we can't get the `StreamExecutionEnvironment` which is the entrypoint to build datastream from `TableEnvironment`; Best regards, Yuxia - 原始邮件 ----- 发件人: "yuxia" 收件人: "dev" 发送时间: 星期四, 2023年 6 月 01日 下午

Re: [DISCUSS] FLIP-311: Support Call Stored Procedure

7;t be effective as other sql statements since these table configurations are mainly be considerd by the TableEnvironment. 4: Yes, you're right. Best regards, Yuxia - 原始邮件 - 发件人: "Paul Lam" 收件人: "dev" 发送时间: 星期四, 2023年 6 月 01日 下午 6:34:24 主题: Re: [DISCUSS]

Re: [DISCUSS] FLIP-311: Support Call Stored Procedure

this FLIP. The other auxiliary commands maybe not suitable currently or need a further/dedicated dicussion. Let's keep this FLIP focus. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-297%3A+Improve+Auxiliary+Sql+Statements Best regards, Yuxia - 原始邮件 - 发件人: "Jane

Re: [DISCUSS] FLIP-311: Support Call Stored Procedure

tax to call a stored procedure. [1] https://dev.mysql.com/doc/refman/8.0/en/call.html [2] https://www.postgresql.org/docs/15/sql-call.html [3] https://docs.oracle.com/javadb/10.8.3.0/ref/rrefcallprocedure.html Best regards, Yuxia - 原始邮件 - 发件人: "Martijn Visser" 收件人: "dev"

Re: [DISCUSS] FLIP-308: Support Time Travel In Batch Mode

ino/blob/2433d9e60f1abb0d85c32374c1758525560e1a86/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergMetadata.java#L443 Best regards, Yuxia - 原始邮件 - 发件人: "Feng Jin" 收件人: "dev" 发送时间: 星期二, 2023年 6 月 06日 下午 10:15:47 主题: Re: [DISCUSS] FLIP-308: Support Time

Re: [DISCUSS] FLIP-311: Support Call Stored Procedure

Hi, all. Thanks everyone for the valuable input. If there are are no further concerns about this FLIP[1], I would like to start voting next monday (6/12). [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-311%3A+Support+Call+Stored+Procedure Best regards, Yuxia - 原始邮件 - 发件人

Re: [DISCUSS] Hive dialect shouldn't fall back to Flink's default dialect

Thanks all for the discussion. Since we reach the consensus about abandoning the fall back behavior for Hive dialect, if there's no other concern or objection, I'll close this discussion tomorrow(6/9). Best regards, Yuxia - 原始邮件 - 发件人: "Martijn Visser" 收件人: "

Re: [DISCUSS] Hive dialect shouldn't fall back to Flink's default dialect

Thanks all again. Then, I'll start to abandon the fall back behavior for Hive dialect in Flink 1.18. Best regards, Yuxia - 原始邮件 - 发件人: "yuxia" 收件人: "dev" 发送时间: 星期四, 2023年 6 月 08日 上午 11:53:32 主题: Re: [DISCUSS] Hive dialect shouldn't fall back to Flink

[VOTE] FLIP-311: Support Call Stored Procedure

insufficient number of votes. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-311%3A+Support+Call+Stored+Procedure [2] https://lists.apache.org/thread/k6s50gcgznon9v1oylyh396gb5kgrwmd Best regards, Yuxia

Re: [VOTE] FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement

+1 (binding) Thanks Mang driving it. Best regards, Yuxia - 原始邮件 - 发件人: "zhangmang1" 收件人: "dev" 发送时间: 星期一, 2023年 6 月 12日 下午 5:31:10 主题: [VOTE] FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement Hi everyone, Thanks for all the feedback about FLIP

Re: [DISCUSS] FLIP-322 Cooldown period for adaptive scheduler

causes it'll take a long time to finish all? Can we just take the last one event? [1]: https://issues.apache.org/jira/browse/FLINK-21883 Best regards, Yuxia - 原始邮件 - 发件人: "Etienne Chauchot" 收件人: "dev" , "Robert Metzger" 发送时间: 星期一, 2023年 6 月 12日

Re: [DISCUSS] FLIP-311: Support Call Stored Procedure

Yes, you're right. Best regards, Yuxia - 原始邮件 - 发件人: "Jing Ge" 收件人: "dev" 发送时间: 星期三, 2023年 6 月 14日 上午 4:46:58 主题: Re: [DISCUSS] FLIP-311: Support Call Stored Procedure Hi yuxia, Thanks for your proposal and sorry for the late reply. The FLIP is in good sh

Re: [DISCUSS] FLIP-324: Introduce Runtime Filter for Flink Batch Jobs

i'm wondering what's the real behavior, no filter will be injected or fake filter? 3: Does it also mean runtime-filter can only take effect in blocking shuffle? Best regards, Yuxia - 原始邮件 - 发件人: "ron9 liu" 收件人: "dev" 发送时间: 星期三, 2023年 6 月 14日 下午 5:29:28 主

Re: [VOTE] FLIP-311: Support Call Stored Procedure

]: https://cwiki.apache.org/confluence/display/FLINK/FLIP-311%3A+Support+Call+Stored+Procedure Best regards, Yuxia - 原始邮件 - 发件人: "Jane Chan" 收件人: "dev" 发送时间: 星期四, 2023年 6 月 15日 上午 11:11:33 主题: Re: Re: [VOTE] FLIP-311: Support Call Stored Procedure +1 (non-binding)

FLIP-303: Support REPLACE TABLE AS SELECT statement

3A+Support+atomic+for+CREATE+TABLE+AS+SELECT%28CTAS%29+statement [3]: https://cwiki.apache.org/confluence/display/FLINK/FLIP-303%3A+Support+REPLACE+TABLE+AS+SELECT+statement Best regards, Yuxia

Re: [VOTE] FLIP-294: Support Customized Catalog Modification Listener

+1 (binding) Best regards, Yuxia - 原始邮件 - 发件人: "Leonard Xu" 收件人: "dev" 发送时间: 星期四, 2023年 6 月 15日 下午 8:09:00 主题: Re: [VOTE] FLIP-294: Support Customized Catalog Modification Listener +1 (binding) Best, Leonard > On Jun 14, 2023, at 11:21 PM, Jing Ge

[DISCUSS] FLIP-303: Support REPLACE TABLE AS SELECT statement

correct email title. Please ignore the previous email and discuss in this thread. Sorry for the noise. [4]: https://lists.apache.org/thread/jy39xwxn1o2035y5411xynwtbyfgg76t Best regards, Yuxia

Re: [VOTE] FLIP-308: Support Time Travel

+1 (binding) Thanks Feng driving it. Best regards, Yuxia - 原始邮件 - 发件人: "Feng Jin" 收件人: "dev" 发送时间: 星期一, 2023年 6 月 19日 下午 7:22:06 主题: [VOTE] FLIP-308: Support Time Travel Hi everyone Thanks for all the feedback about the FLIP-308: Support Time Travel[1]. [2] is t

Re: [DISCUSS] FLIP-314: Support Customized Job Lineage Listener

s FLIP to make us know better about the interfaces. Best regards, Yuxia - 原始邮件 - 发件人: "Qingsheng Ren" 收件人: "dev" 抄送: "Shammon FY" 发送时间: 星期二, 2023年 6 月 20日 下午 6:19:10 主题: Re: [DISCUSS] FLIP-314: Support Customized Job Lineage Listener Hi Shammon, Thanks for

Re: [DISCUSS] Flexible Custom Commit Policy with Parameter Passing

Hi, Bangui Dunn. Thanks for reaching us out. Generally + 1 for the configuration. But will it better to make it asList? Something like: `.stringType().asList()`. Best regards, Yuxia - 原始邮件 - 发件人: "Gary Ccc" 收件人: "dev" 发送时间: 星期二, 2023年 6 月 20日 下午 5:44:10 主题: [DISC

Re: [DISCUSS] Flexible Custom Commit Policy with Parameter Passing

Correct what I said in the previous email: "But will it better to make it asList ? Something like:`.stringType().asList()`." => "But will it better to make it no default value? Something like:`.stringType().asList().noDefaultValue`." Best regards, Yuxia - 原始邮件

Re: [VOTE] FLIP-324: Introduce Runtime Filter for Flink Batch Jobs

+1 (binding) Thanks Lijie driving it. Best regards, Yuxia - 原始邮件 - 发件人: "Yuepeng Pan" 收件人: "dev" 发送时间: 星期六, 2023年 6 月 24日 下午 9:06:53 主题: Re:[VOTE] FLIP-324: Introduce Runtime Filter for Flink Batch Jobs +1 (non-binding) Thanks, Yuepeng Pan At

Re: [DISCUSS] Graduate the FileSink to @PublicEvolving

eSink. Btw, seems it's really a big headache for migrating to Sink, we may need to pay more attention to this ticket and try to fix it. Best regards, Yuxia - 原始邮件 - 发件人: "Galen Warren" 收件人: "dev" 发送时间: 星期五, 2023年 6 月 23日 下午 7:47:24 主题: Re: [DISCUSS] Graduate t

Re: [DISCUSS] Flexible Custom Commit Policy with Parameter Passing

Hi, Bangui Dunn Review done. But please remember we should reach consensus about it in the dicsussion before we can merge it. Let's keep the discussion for a while to see any further feedback. Best regards, Yuxia - 原始邮件 - 发件人: "Dunn Bangui" 收件人: "dev" 发送时间:

Re: [DISCUSS] FLIP-303: Support REPLACE TABLE AS SELECT statement

d=199541185 Best regards, Yuxia - 原始邮件 - 发件人: "yuxia" 收件人: "dev" 发送时间: 星期四, 2023年 6 月 15日 下午 7:58:27 主题: [DISCUSS] FLIP-303: Support REPLACE TABLE AS SELECT statement Hi, devs. As the FLIPs FLIP-218[1] & FLIP-305[2] for Flink to supports CREATE TABLE AS SELECT sta

Re: [DISCUSS] FLIP-303: Support REPLACE TABLE AS SELECT statement

stead, we will only expose `table.rtas-ctas.atomicity-enabled` to users. Best regards, Yuxia - 原始邮件 - 发件人: "lincoln 86xy" 收件人: "dev" 发送时间: 星期一, 2023年 6 月 26日 上午 10:27:18 主题: Re: [DISCUSS] FLIP-303: Support REPLACE TABLE AS SELECT statement Hi yuxia, +1 for this

Re: [DISCUSS] Flexible Custom Commit Policy with Parameter Passing

I have another round of review and left comment in your pr. But please let's keep discuss about adding the Custom Commit Policy with Parameter itself in this thread instead of talk about the pr. Best regards, Yuxia - 原始邮件 - 发件人: "Dunn Bangui" 收件人: "dev" 发送时间

Re: [DISCUSS] FLIP-303: Support REPLACE TABLE AS SELECT statement

Hi, all. Thanks for the feedback. If there are no other questions or concerns for the FLIP[1], I'd like to start the vote tomorrow (6.28). [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-303%3A+Support+REPLACE+TABLE+AS+SELECT+statement Best regards, Yuxia 发件人: "

Re: [DISCUSS] FLIP-303: Support REPLACE TABLE AS SELECT statement

Hi, jing. Thanks for pointing it out. Yes, it's a typo. I should be option. Now, I have updated the FLIP. Best regards, Yuxia - 原始邮件 - 发件人: "Jing Ge" 收件人: "dev" 抄送: "zhangmang1" 发送时间: 星期二, 2023年 6 月 27日 下午 4:26:20 主题: Re: [DISCUSS] FLIP-303: Suppor

[VOTE] FLIP-303: Support REPLACE TABLE AS SELECT statement

objection or an insufficient number of votes. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-303%3A+Support+REPLACE+TABLE+AS+SELECT+statement [2] https://lists.apache.org/thread/39mwckdsdgck48tzsdfm66hhnxorjtz3 Best regards, Yuxia

Re: [VOTE] FLIP-309: Support using larger checkpointing interval when source is processing backlog

+1 (binding) Best regards, Yuxia - 原始邮件 - 发件人: "Yuepeng Pan" 收件人: "dev" 发送时间: 星期四, 2023年 6 月 29日 下午 8:21:14 主题: Re: [VOTE] FLIP-309: Support using larger checkpointing interval when source is processing backlog +1 non-binding. Best. Yuepeng Pan Replied

Re: [VOTE] FLIP-303: Support REPLACE TABLE AS SELECT statement

+1 (binding) from my sides. Best regards, Yuxia - 原始邮件 - 发件人: "lincoln 86xy" 收件人: "dev" 发送时间: 星期四, 2023年 6 月 29日 下午 2:12:08 主题: Re: [VOTE] FLIP-303: Support REPLACE TABLE AS SELECT statement +1 (binding) Best, Lincoln Lee liu ron 于2023年6月29日周四 13:22写道： >

Re: [VOTE] FLIP-303: Support REPLACE TABLE AS SELECT statement

Hi, all. FLIP-303[1] has been accepted. There are 3 binding votes, and 3 non-binding votes: - Jing Ge (binding) - Lincoln (binding) - Yuxia Luo (binding) - Mang Zhang (non-binding) - Ron (non-binding) - Feng Jin (non-binding) Thanks everyone. [1]: https://cwiki.apache.org/confluence/display

Re: [ANNOUNCE] Apache Flink has won the 2023 SIGMOD Systems Award

Congratulations! Best regards, Yuxia 发件人: "Pushpa Ramakrishnan" 收件人: "Xintong Song" 抄送: "dev" , "User" 发送时间: 星期一, 2023年 7 月 03日 下午 8:36:30 主题: Re: [ANNOUNCE] Apache Flink has won the 2023 SIGMOD Systems Award Congratulations \uD83E\uDD73

Re: [ANNOUNCE] Flink 1.18 Feature Freeze Extended until July 24th, 2023

Thanks for the update and thanks for your efforts. Best regards, Yuxia - 原始邮件 - 发件人: "Rui Fan" <1996fan...@gmail.com> 收件人: "dev" , re...@apache.org 抄送: "Jing Ge" , snuyan...@gmail.com, "Konstantin Knauf" 发送时间: 星期四, 2023年 7 月 06日 下午 3:06:2

Re: [VOTE] Release 2.0 must-have work items

much effort to fully cover the missing api. [1] https://lists.apache.org/thread/syjmt8f74gh8ok3z4lhgt95zl4dzn168 Best regards, Yuxia - 原始邮件 - 发件人: "Jing Ge" 收件人: "dev" 发送时间: 星期三, 2023年 7 月 12日 上午 1:23:40 主题: Re: [VOTE] Release 2.0 must-have work items agree with wha

Re: [VOTE] Release 2.0 must-have work items

Thanks Xintong for clarification. A guideline to help users migrating from DataSet to DataStream will definitely be helpful. Best regards, Yuxia - 原始邮件 - 发件人: "Xintong Song" 收件人: "dev" 发送时间: 星期三, 2023年 7 月 12日 上午 11:40:12 主题: Re: [VOTE] Release 2.0 must-have wor

Re: Issue with flink 1.16 and hive dialect

metastore,success-file'); [1] https://issues.apache.org/jira/browse/FLINK-27450 [2] https://issues.apache.org/jira/browse/HIVE-21584 [3] https://issues.apache.org/jira/browse/FLINK-32596 Best regards, Yuxia 发件人: "ramkrishna vasudevan" 收件人: "User" , "dev"

Re: [VOTE] FLIP-309: Support using larger checkpointing interval when source is processing backlog

+1（binding) Best regards, Yuxia - 原始邮件 - 发件人: "Guowei Ma" 收件人: "dev" 发送时间: 星期三, 2023年 7 月 19日 下午 1:54:52 主题: Re: [VOTE] FLIP-309: Support using larger checkpointing interval when source is processing backlog +1（binding） Best, Guowei On Wed, Jul 19, 2023 at 11:18

Re: [VOTE] FLIP-346: Deprecate ManagedTable related APIs

+1（binging） Best regards, Yuxia - 原始邮件 - 发件人: "Jane Chan" 收件人: "dev" 发送时间: 星期五, 2023年 7 月 21日 下午 3:41:11 主题: [VOTE] FLIP-346: Deprecate ManagedTable related APIs Hi developers, Thanks for all the feedback on FLIP-346: Deprecate ManagedTable related APIs[1]. Based

Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang

Congrats, Shammon! Best regards, Yuxia - 原始邮件 - 发件人: "Benchao Li" 收件人: "dev" 抄送: "Shammon FY" 发送时间: 星期一, 2023年 7 月 24日 下午 1:23:55 主题: Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang Congratulations, Yong! Well deserved! Yangze Guo 于2023年7月24

Re: [ANNOUNCE] New Apache Flink Committer - Hong Teoh

Congratulations, Hong Teoh! Best regards, Yuxia - 原始邮件 - 发件人: "Matthias Pohl" 收件人: "dev" 发送时间: 星期四, 2023年 8 月 03日 下午 11:24:39 主题: Re: [ANNOUNCE] New Apache Flink Committer - Hong Teoh Congratulations, Hong! :) On Thu, Aug 3, 2023 at 3:39 PM Leonard Xu wrote: >

Re: [ANNOUNCE] New Apache Flink PMC Member - Matthias Pohl

Congratulation, Matthias! Best regards, Yuxia - 原始邮件 - 发件人: "Yun Tang" 收件人: "dev" 发送时间: 星期五, 2023年 8 月 04日 下午 3:04:52 主题: Re: [ANNOUNCE] New Apache Flink PMC Member - Matthias Pohl Congratulation, Matthias! Best Yun Tang From: J

Re: [ANNOUNCE] New Apache Flink Committer - Weihua Hu

Congratulations, Weihua! Best regards, Yuxia - 原始邮件 - 发件人: "Yun Tang" 收件人: "dev" 发送时间: 星期五, 2023年 8 月 04日 下午 3:05:30 主题: Re: [ANNOUNCE] New Apache Flink Committer - Weihua Hu Congratulations, Weihua! Best Yun Tang From: Jark Wu

Re: [ANNOUNCE] New Apache Flink Committer - Yanfei Lei

Congratulations, Yanfei! Best regards, Yuxia - 原始邮件 - 发件人: "ron9 liu" 收件人: "dev" 发送时间: 星期一, 2023年 8 月 07日 下午 11:44:23 主题: Re: [ANNOUNCE] New Apache Flink Committer - Yanfei Lei Congratulations Yanfei! Best, Ron Zakelly Lan 于2023年8月7日周一 23:15写道： > Congratula

Re: [ANNOUNCE] New Apache Flink Committer - Hangxiang Yu

Congratulations, Hangxiang ! Best regards, Yuxia - 原始邮件 - 发件人: "Wencong Liu" 收件人: "dev" 发送时间: 星期一, 2023年 8 月 07日 下午 11:55:24 主题: Re:[ANNOUNCE] New Apache Flink Committer - Hangxiang Yu Congratulations, Hangxiang ! Best, Wencong At 2023-08-07

Re: Proposal for Implementing Keyed Watermarks in Apache Flink

Hi, Tawfik Yasser. Thanks for the proposal. It sounds exciting. I can't wait the research paper for more details. Best regards, Yuxia - 原始邮件 - 发件人: "David Morávek" 收件人: "dev" 发送时间: 星期二, 2023年 9 月 05日 下午 4:36:51 主题: Re: Proposal for Implementing Keyed Water

Re: [ANNOUNCE] New Apache Flink Committer - Ron Liu

Congratulations, Ron! Best regards, Yuxia - 原始邮件 - 发件人: "Feng Jin" 收件人: "dev" 发送时间: 星期一, 2023年 10 月 16日 上午 11:29:55 主题: Re: [ANNOUNCE] New Apache Flink Committer - Ron Liu Congratulations, Ron! Best, Feng On Mon, Oct 16, 2023 at 11:22 AM yh z wrote: &g

Re: [ANNOUNCE] New Apache Flink Committer - Jane Chan

Congratulations Jane! Best regards, Yuxia - 原始邮件 - 发件人: "Feng Jin" 收件人: "dev" 发送时间: 星期一, 2023年 10 月 16日 上午 11:29:26 主题: Re: [ANNOUNCE] New Apache Flink Committer - Jane Chan Congratulations Jane! Best, Feng On Mon, Oct 16, 2023 at 11:23 AM yh z wrote: &g

Re: [PROPOSAL] Contribute Flink CDC Connectors project to Apache Flink

+1 for this. Thanks all the contributors of Flink CDC for the great work. Best regards, Yuxia - 原始邮件 - 发件人: "Martijn Visser" 收件人: "dev" 发送时间: 星期四, 2023年 12 月 07日 下午 8:14:36 主题: Re: [PROPOSAL] Contribute Flink CDC Connectors project to Apache Flink Hi Leonard, +1 f

Re: [NOTICE] Hive connector externalization

Thanks Sergey for the work. Happy to see we can externalize Hive connector finally. Best regards, Yuxia - 原始邮件 - 发件人: "snuyanzin" 收件人: "dev" 发送时间: 星期六, 2023年 12 月 09日 上午 6:24:35 主题: [NOTICE] Hive connector externalization Hi everyone We are getting close to th

Re: [VOTE] FLIP-273: Improve Catalog API to Support ALTER TABLE syntax

+1 (non-binding) Best regards, Yuxia - 原始邮件 - 发件人: "Yaroslav Tkachenko" 收件人: "dev" 发送时间: 星期五, 2022年 12 月 02日 上午 12:27:24 主题: Re: [VOTE] FLIP-273: Improve Catalog API to Support ALTER TABLE syntax +1 (non-binding). Looking forward to it! On Thu, Dec 1, 2022 at 5:0

Re: [DISCUSS] FLIP-277: Native GlueCatalog Support in Flink

pdd780wl4f26p447fohvm9osky2r9fhh [2] https://issues.apache.org/jira/browse/FLINK-22540 Best regards, Yuxia - 原始邮件 - 发件人: "Samrat Deb" 收件人: "dev" 抄送: "prabhujose gates" 发送时间: 星期六, 2022年 12 月 03日 下午 12:29:16 主题: [DISCUSS] FLIP-277: Native GlueCatalog Support in Fl

Re: Patch to support Parquet schema evolution

Hi, Shun. Thanks for the contribution. I'll have a look first and then find some committers help review & merge. Best regards, Yuxia - 原始邮件 - 发件人: "sunshun18" 收件人: "dev" 发送时间: 星期一, 2022年 12 月 05日 上午 11:54:38 主题: Patch to support Parquet schema evolutio

Re: [DISCUSS] the bug with column lost comment

The connectors are expected to migrate to new schema framwork. And it's in the plan that migrate TableSchema to new schema framwork Hive connector[1] [1] https://issues.apache.org/jira/browse/FLINK-29585 Best regards, Yuxia - 原始邮件 - 发件人: "李宇彬" 收件人: "dev" 抄送

Re: [VOTE] FLIP-277: Glue catalog support in Flink

+1 (non-binding) Thanks for driving it. Best regards, Yuxia - 原始邮件 - 发件人: "Danny Cranmer" 收件人: "dev" 发送时间: 星期五, 2022年 12 月 16日 下午 6:46:12 主题: Re: [VOTE] FLIP-277: Glue catalog support in Flink +1 (binding) Thanks for driving this Samrat, looking forward to it. Da

Re: [Discuss] SQL Client syntax to show a configuration

may be used to it, seems use "SET 'key'" is also acceptable. But I have no much strong preference, use some other thing like "SHOW" statement also sounds good to me. Best regards, Yuxia - 原始邮件 - 发件人: "Martijn Visser" 收件人: "dev" 发送

[DISCUSS] FLIP-282: Introduce Delete & Update API

ps://cwiki.apache.org/confluence/pages/viewpage.action?pageId=235838061 Best regards, Yuxia

Re: [DISCUSS] FLIP-281 Sink Supports Speculative Execution For Batch Job

executions? IIUC, if the taks failover, it also generate a new attempt. Does it make difference in isolating data produced? Best regards, Yuxia - 原始邮件 - 发件人: "Biao Liu" 收件人: "dev" 发送时间: 星期四, 2022年 12 月 22日 下午 8:16:21 主题: [DISCUSS] FLIP-281 Sink Supports Speculati

Re: [DISCUSS] FLIP-280: Introduce a new explain mode to provide SQL advice

e with that. 3: Is there a way only show advice? For me, it seems the advice will be more useful and the nodes may contains to many details. 4: I'm curious about what't the global advice will look like. Is it possible to provide an example? Best regards, Yuxia - 原始邮件 - 发件

Re: [DISCUSS] FLIP-282: Introduce Delete & Update API

Hi, Lincoln Lee; 1: Yes, it's a typo; Thanks for pointing out. I have fixed the typo. 2: For stream users, assuming for delete, they will receive TableException("DELETE TABLE is not supported for streaming mode now"); Update is similar. I also update them to the FLIP. Best

Re: [DISCUSS] FLIP-283: Use adaptive batch scheduler as default scheduler for batch jobs

arallelism derivation is what adaptive batch scheduler aim to do. If use want to diable auto parallelism derivation, can they just disable adaptive batch scheduler.? Best regards, Yuxia - 原始邮件 - 发件人: "JunRui Lee" 收件人: "dev" 发送时间: 星期四, 2022年 12 月 29日 下午 7:45:36 主题: [D

Re: [DISCUSS] FLIP-282: Introduce Delete & Update API

see this method. But it won't bring any compatibility issues for in here we just tell the source scan what's scan purpose without touching any other logic. If sources ignore this method, it just works as normally. So I think there's no necessary to add a new interface like Su

Re: [DISCUSS] FLIP-282: Introduce Delete & Update API

GMT) if there's no any other question. If you have any other question, please reply it in this discuss thread.[2] [1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=235838061 [2] https://lists.apache.org/thread/6h64v7v6gj916pkvmc3ql3vxxccr46r3 Best regards, Yuxia -

[VOTE] FLIP-282: Introduce Delete & Update API

onfluence/pages/viewpage.action?pageId=235838061 | https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=235838061 ] [2] [ https://lists.apache.org/thread/6h64v7v6gj916pkvmc3ql3vxxccr46r3 | https://lists.apache.org/thread/6h64v7v6gj916pkvmc3ql3vxxccr46r3 ] Best regards, Yuxia

Re: [DISCUSS] FLIP-282: Introduce Delete & Update API

Hi, all. I have started voting[1] for this FLIP. If you have question, you can reply in this discuss thread. [1]: https://lists.apache.org/thread/3m91zys8dgnzyypoq88gkb2t55lqvgh1 Best regards, Yuxia - 原始邮件 - 发件人: "yuxia" 收件人: "dev" 发送时间: 星期五, 2023年 1 月 06日 下午 8:16

Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee

Congratulations, Lincoln! Best regards, Yuxia - 原始邮件 - 发件人: "Shuiqiang Chen" 收件人: "dev" 发送时间: 星期二, 2023年 1 月 10日 下午 1:50:50 主题: Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee Congratulations, Lincoln! Best, Shuiqiang Benchao Li 于2023年1月10日 周二13:48写道

Re: [VOTE] FLIP-283: Use adaptive batch scheduler as default scheduler for batch jobs

+1 (non-binding) Best regards, Yuxia - 原始邮件 - 发件人: "Zhu Zhu" 收件人: "dev" 发送时间: 星期二, 2023年 1 月 10日 下午 5:49:58 主题: Re: [VOTE] FLIP-283: Use adaptive batch scheduler as default scheduler for batch jobs +1 (binding) Thanks, Zhu Lijie Wang 于2023年1月10日周二 17:4

Re: [Discussion] externalize Hive connector

xternal Hive connector can't be released as offical Hive connector unless we resolve the problem I refered above. So, why not wait any thing is ready before externalize the Hive connector? Best regards, Yuxia - 原始邮件 - 发件人: "Chen Qin" 收件人: "dev" 发送时间: 星期二, 2023年 1

Re: [Discussion] externalize Hive connector

think it's expected be a external repo maintained by Flink community. Best regards, Yuxia - 原始邮件 - 发件人: "Péter Váry" 收件人: "dev" 发送时间: 星期二, 2023年 1 月 10日 下午 6:17:48 主题: Re: [Discussion] externalize Hive connector Hi Team, Somewhat, but not strictly related: - W

Re: [VOTE] FLIP-281: Sink Supports Speculative Execution For Batch Job

+1 (non-binding). Best regards, Yuxia - 原始邮件 - 发件人: "Zhu Zhu" 收件人: "dev" 发送时间: 星期二, 2023年 1 月 10日 下午 5:50:39 主题: Re: [VOTE] FLIP-281: Sink Supports Speculative Execution For Batch Job +1 (binding) Thanks, Zhu Biao Liu 于2023年1月5日周四 10:37写道： > > Hi Martijn

Re: [Discussion] externalize Hive connector

Hi, Chen. Cool! Of course not. Much appreciated that you can help continue this work. If you have any question about it, please let me know. Best regards, Yuxia - 原始邮件 - 发件人: "Chen Qin" 收件人: "dev" 发送时间: 星期三, 2023年 1 月 11日 上午 11:24:48 主题: Re: [Discussion] extern

Re: [VOTE] FLIP-282: Introduce Delete & Update API

ttps://cwiki.apache.org/confluence/pages/viewpage.action?pageId=235838061 [2] https://lists.apache.org/thread/3m91zys8dgnzyypoq88gkb2t55lqvgh1 Best regards, Yuxia - 原始邮件 - 发件人: "Jark Wu" 收件人: "dev" 发送时间: 星期二, 2023年 1 月 10日 下午 5:42:10 主题: Re: [VOTE] FLIP-282: Introduce

[RESULT][VOTE] FLIP-282: Introduce Delete & Update API

btw, sorry for the nosiy vote result email in vote thread[2] [1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=235838061 [2] https://lists.apache.org/thread/3m91zys8dgnzyypoq88gkb2t55lqvgh1 Best regards, Yuxia

Re: [DISCUSS] Promote SinkV2 to @Public and deprecate SinkFunction

, Yuxia - 原始邮件 - 发件人: "Jing Ge" 收件人: "dev" 抄送: "Yun Gao" , "Qingsheng Ren" , "Jark Wu" 发送时间: 星期二, 2023年 1 月 24日 下午 7:25:59 主题: Re: [DISCUSS] Promote SinkV2 to @Public and deprecate SinkFunction Hi Martijn, Thanks for sharing more info

Re: [VOTE] Externalize AWS formats to flink-connector-aws

+1 (non-binding). Thanks for driving it. Best regards, Yuxia - 原始邮件 - 发件人: "Ahmed Hamdy" 收件人: "dev" 发送时间: 星期一, 2023年 1 月 30日 下午 4:01:14 主题: Re: [VOTE] Externalize AWS formats to flink-connector-aws +1 (non-binding) Thanks, Ahmed On Fri, 27 Jan 2023 at 17:24, J

Re: unsucscribe

To unsubscribe, you can send email to dev-unsubscr...@flink.apache.org with any contents or subject. Please see more in the Flink Doc[1] [1] https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list Best regards, Yuxia - 原始邮件 - 发件人: "Liu Haoyang" 收件人: "

Re: Need help how to use Table API to join two Kafka streams

uot;ssn" === $"ssn1"); Also, you can refer here for more detail[1]. [1] https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/tableapi/#joins Best regards, Yuxia - 原始邮件 - 发件人: "Amir Hossein Sharifzadeh" 收件人: "dev" 发送时间: 星期五, 2023年 2 月 03日 上午 4:45:08

Re: Need help how to use Table API to join two Kafka streams

Hi, thanks for reaching me out. For your question, you don't need to cosume data in my cosumer class seperately and then insert them into those tables. The data will be consumed from what we implemented here. Best regards, Yuxia 发件人: "Amir Hossein Sharifzadeh&quo

Re: [DISCUSS] Promote SinkV2 to @Public and deprecate SinkFunction

Hi Konstantin, Just FYI, the FileSystemTableSink are still using SinkFunction. Best regards, Yuxia - 原始邮件 - 发件人: "Dong Lin" 收件人: "dev" 抄送: "Jing Ge" , "Yun Tang" 发送时间: 星期二, 2023年 2 月 07日 上午 9:41:07 主题: Re: [DISCUSS] Promote SinkV2 to @Public a

Re: Need help how to use Table API to join two Kafka streams

Hi, could you please share us the root cause? Seems the error message you posted hadn't contained the root cause. Maybe you can post the full error message . Best regards, Yuxia 发件人: "Amir Hossein Sharifzadeh" 收件人: "yuxia" 抄送: "dev" 发送时间: 星期二, 2023

Re: [Discussion] externalize Hive connector

Best regards, Yuxia 发件人: "Chen Qin" 收件人: luoyu...@alumni.sjtu.edu.cn 抄送: "dev" 发送时间: 星期五, 2023年 1 月 20日 上午 7:35:43 主题: Re: [Discussion] externalize Hive connector Hi Yuxia, [ https://issues.apache.org/jira/browse/FLINK-30667 | FLINK-30667 ] aims to address hiv

Re: Looking for a jira to get started with contributing

you're interested in and ask some one(may be the creator of the jira or other one) to assign. [1]https://issues.apache.org/jira/browse/FLINK-6810 [2] https://issues.apache.org/jira/browse/FLINK-20787 Best regards, Yuxia - 原始邮件 - 发件人: "Joern Kottmann" 收件人: "dev"

Re: Confusion about some overlapping functionality of SupportsProjectionPushDown and SupportsReadingMetadata

t the applyProjection will be called before method applyReadableMetadata in the java doc of applyReadableMetadata. Best regards, Yuxia - 原始邮件 - 发件人: "Ran Tao" 收件人: "dev" 发送时间: 星期三, 2023年 2 月 08日 下午 8:46:45 主题: Confusion about some overlapping functionality of Suppo

Re: Confusion about some overlapping functionality of SupportsProjectionPushDown and SupportsReadingMetadata

o the sequence problem, but I don't think we have no other better way to avoid it. Best regards, Yuxia - 原始邮件 - 发件人: "fskmine" 收件人: "dev" 发送时间: 星期五, 2023年 2 月 10日 下午 12:02:36 主题: Re: Confusion about some overlapping functionality of SupportsProjectionPushDown and Su

Re: Confusion about some overlapping functionality of SupportsProjectionPushDown and SupportsReadingMetadata

Sorry for the misktake, correct it. "but I'm afraid that we have no other better way to avoid it. Best regards, Yuxia - 原始邮件 ----- 发件人: "yuxia" 收件人: "dev" 发送时间: 星期一, 2023年 2 月 13日 上午 10:11:53 主题: Re: Confusion about some overlapping functionality of

  1   2   >