Re: [VOTE] Release flink-connector-rabbitmq v3.0.1, release candidate #1

2023-05-04 Thread Khanh Vu
+1 (non-binding) - Verified sha512 checksum matches file archive. - Verified file archive is signed and signature is authorized. - Verified no binaries exist in the source archive. - Verified source archive is consistent with Github source code with tag v3.0.1-rc1, at commit 73e56edb2aa4513f6a73dc

Re: 您好,退订

2023-05-04 Thread Leonard Xu
Please send email to dev-unsubscr...@flink.apache.org if you want to unsubscribe the mail from dev@flink.apache.org, and you can refer[1][2] for more details. 请发送任意内容的邮件到 dev-unsubscr...@flink.apache.org 地址来取消订阅来自 dev@flink.apache.org 邮件组的邮件,你可以参考[1][2] 管理邮件订阅。 Best, Leonard [1]https://flink.a

[jira] [Created] (FLINK-32008) Protobuf format throws exception with Map datatype

2023-05-04 Thread Xuannan Su (Jira)
Xuannan Su created FLINK-32008: -- Summary: Protobuf format throws exception with Map datatype Key: FLINK-32008 URL: https://issues.apache.org/jira/browse/FLINK-32008 Project: Flink Issue Type: Bu

Re: 您好,退订

2023-05-04 Thread Biao Geng
你好,可以通过发送包含任意内容的邮件到 dev-unsubscr...@flink.apache.org 来取消dev订阅。 Best, Biao Geng Fang jun 于2023年5月5日周五 14:07写道: > > > Sent from my iPhone >

Re: 退订

2023-05-04 Thread Biao Geng
你好,可以通过发送包含任意内容的邮件到 dev-unsubscr...@flink.apache.org 来取消dev订阅。 Best, Biao Geng houyui <2008-ho...@163.com> 于2023年5月5日周五 13:33写道: > 您好: >退订!

退订

2023-05-04 Thread houyui
您好: 退订!

Re: [DISCUSS] FLIP-306: Unified File Merging Mechanism for Checkpoints

2023-05-04 Thread Zakelly Lan
Hi all, @Yun Tang and I have an offline discussion, and we agreed that: 1. The design of this FLIP is pretty much like the option 3 in design doc[1] for FLINK-23342, and it is almost the best solution in general. Based on our production experience, this FLIP can solve the file flood problem very

Re: [DISCUSS] FLIP-306: Unified File Merging Mechanism for Checkpoints

2023-05-04 Thread Zakelly Lan
Hi Rui Fan, Thanks for your reply. > Maybe re-uploaded in the next checkpoint is also a general solution > for shared state? If yes, could we consider it as an optimization? > And we can do it after the FLIP is done. Yes, it is a general solution for shared states. Maybe in the first version we

退订

2023-05-04 Thread 谢浩天
您好: 退订! 谢浩天

[jira] [Created] (FLINK-32007) Implement Python Wrappers for DynamoDB Connector

2023-05-04 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-32007: --- Summary: Implement Python Wrappers for DynamoDB Connector Key: FLINK-32007 URL: https://issues.apache.org/jira/browse/FLINK-32007 Project: Flink Issue Type: Ne

[jira] [Created] (FLINK-32006) AsyncWaitOperatorTest.testProcessingTimeWithTimeoutFunctionOrderedWithRetry times out on Azure

2023-05-04 Thread Jira
David Morávek created FLINK-32006: - Summary: AsyncWaitOperatorTest.testProcessingTimeWithTimeoutFunctionOrderedWithRetry times out on Azure Key: FLINK-32006 URL: https://issues.apache.org/jira/browse/FLINK-32006

[jira] [Created] (FLINK-32005) Add a per-deployment error metric to signal about potential issues

2023-05-04 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-32005: -- Summary: Add a per-deployment error metric to signal about potential issues Key: FLINK-32005 URL: https://issues.apache.org/jira/browse/FLINK-32005 Projec

[jira] [Created] (FLINK-32004) Intermittent ingress creation when JobManager is restarted via autoscaler

2023-05-04 Thread Tan Kim (Jira)
Tan Kim created FLINK-32004: --- Summary: Intermittent ingress creation when JobManager is restarted via autoscaler Key: FLINK-32004 URL: https://issues.apache.org/jira/browse/FLINK-32004 Project: Flink

[jira] [Created] (FLINK-32003) Release 3.0.0-1.16 and 1.16.1 doesn't work with OAuth2

2023-05-04 Thread Neng Lu (Jira)
Neng Lu created FLINK-32003: --- Summary: Release 3.0.0-1.16 and 1.16.1 doesn't work with OAuth2 Key: FLINK-32003 URL: https://issues.apache.org/jira/browse/FLINK-32003 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-32002) Revisit autoscaler defaults for next release

2023-05-04 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-32002: -- Summary: Revisit autoscaler defaults for next release Key: FLINK-32002 URL: https://issues.apache.org/jira/browse/FLINK-32002 Project: Flink Issu

[jira] [Created] (FLINK-32001) SupportsRowLevelUpdate does not support returning only a part of the columns.

2023-05-04 Thread Ming Li (Jira)
Ming Li created FLINK-32001: --- Summary: SupportsRowLevelUpdate does not support returning only a part of the columns. Key: FLINK-32001 URL: https://issues.apache.org/jira/browse/FLINK-32001 Project: Flink

[jira] [Created] (FLINK-32000) Expose vertex max parallelism in the WebUI

2023-05-04 Thread Jira
David Morávek created FLINK-32000: - Summary: Expose vertex max parallelism in the WebUI Key: FLINK-32000 URL: https://issues.apache.org/jira/browse/FLINK-32000 Project: Flink Issue Type: Impr

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

2023-05-04 Thread Feng Jin
Hi Jing, Thanks for your reply. > There might be more such issues. I would suggest you completely walk through the FLIP again and fix those issues I am very sorry for my carelessness and at the same time, I greatly appreciate your careful review. I have thoroughly checked the entire FLIP and ma

[jira] [Created] (FLINK-31999) CI fails in preparing the e2e test runs due openssl unavailable

2023-05-04 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-31999: - Summary: CI fails in preparing the e2e test runs due openssl unavailable Key: FLINK-31999 URL: https://issues.apache.org/jira/browse/FLINK-31999 Project: Flink

[jira] [Created] (FLINK-31998) Flink Operator Deadlock on run job Failure

2023-05-04 Thread Ahmed Hamdy (Jira)
Ahmed Hamdy created FLINK-31998: --- Summary: Flink Operator Deadlock on run job Failure Key: FLINK-31998 URL: https://issues.apache.org/jira/browse/FLINK-31998 Project: Flink Issue Type: Bug

Re: [VOTE] Release flink-connector-cassandra v3.1.0, release candidate #1

2023-05-04 Thread Etienne Chauchot
@Danny, the fix is merged and the ticket is closed. You can open a RC2 whenever you want. Best Etienne Le 04/05/2023 à 06:17, Leonard Xu a écrit : -1 (binding) as the blocker issue FLINK-31927[1] found - Reviewed the PR [2] and left one comment that the linked issue is incorrect. Best, Le

[jira] [Created] (FLINK-31997) Update to Fabric8 6.5.1+ in flink-kubernetes

2023-05-04 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-31997: -- Summary: Update to Fabric8 6.5.1+ in flink-kubernetes Key: FLINK-31997 URL: https://issues.apache.org/jira/browse/FLINK-31997 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-31996) Chaining operators with different max parallelism prevents rescaling

2023-05-04 Thread Jira
David Morávek created FLINK-31996: - Summary: Chaining operators with different max parallelism prevents rescaling Key: FLINK-31996 URL: https://issues.apache.org/jira/browse/FLINK-31996 Project: Flink

Re: [DISCUSS] FLIP-306: Unified File Merging Mechanism for Checkpoints

2023-05-04 Thread Rui Fan
Hi Zakelly, Sorry for the late reply, I still have some minor questions. >> (3) When rescaling, do all shared files need to be copied? > > I agree with you that only sst files of the base DB need to be copied > (or re-uploaded in the next checkpoint). However, section 4.2 > simplifies file copyin

[jira] [Created] (FLINK-31995) DirectExecutorService doesn't follow the ExecutorService contract throwing a RejectedExecutionException in case it's already shut down

2023-05-04 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-31995: - Summary: DirectExecutorService doesn't follow the ExecutorService contract throwing a RejectedExecutionException in case it's already shut down Key: FLINK-31995 URL: https://iss