[jira] [Created] (FLINK-37900) Support configurable jitter in rocksdb checkpoint file uploader

2025-06-04 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-37900: - Summary: Support configurable jitter in rocksdb checkpoint file uploader Key: FLINK-37900 URL: https://issues.apache.org/jira/browse/FLINK-37900 Project: Flink

[jira] [Closed] (FLINK-37832) Allow update checkpoint interval in update resource-requirements api

2025-05-23 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang closed FLINK-37832. - Resolution: Duplicate > Allow update checkpoint interval in update resource-requirements api > -

[jira] [Commented] (FLINK-37832) Allow update checkpoint interval in update resource-requirements api

2025-05-23 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17953798#comment-17953798 ] Zhenqiu Huang commented on FLINK-37832: --- I see. The FLIP-530 is the right directio

[jira] [Commented] (FLINK-37832) Allow update checkpoint interval in update resource-requirements api

2025-05-22 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17953551#comment-17953551 ] Zhenqiu Huang commented on FLINK-37832: --- The resource-requirements rest api is use

[jira] [Created] (FLINK-37832) Allow update checkpoint interval in update resource-requirements api

2025-05-22 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-37832: - Summary: Allow update checkpoint interval in update resource-requirements api Key: FLINK-37832 URL: https://issues.apache.org/jira/browse/FLINK-37832 Project: Flink

[jira] [Created] (FLINK-37709) Add file descriptor usage in default JVM metrics

2025-04-21 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-37709: - Summary: Add file descriptor usage in default JVM metrics Key: FLINK-37709 URL: https://issues.apache.org/jira/browse/FLINK-37709 Project: Flink Issue Typ

[jira] [Commented] (FLINK-37319) Add retry in RocksDBStateUploader for fault tolerant

2025-02-20 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928904#comment-17928904 ] Zhenqiu Huang commented on FLINK-37319: --- I agree. It is an SLA given by cloud prov

[jira] [Commented] (FLINK-37246) Delegation Token expire after enable delegation token framework

2025-02-20 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928895#comment-17928895 ] Zhenqiu Huang commented on FLINK-37246: --- [~gaborgsomogyi] Will the change resolve

[jira] [Commented] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

2025-02-20 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928894#comment-17928894 ] Zhenqiu Huang commented on FLINK-33155: --- [~gaborgsomogyi] It is possible to add a

[jira] [Updated] (FLINK-37319) Add retry in RocksDBStateUploader for fault tolerant

2025-02-13 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-37319: -- Component/s: Runtime / Async State Processing Affects Version/s: 1.20.0

[jira] [Commented] (FLINK-37319) Add retry in RocksDBStateUploader for fault tolerant

2025-02-13 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926984#comment-17926984 ] Zhenqiu Huang commented on FLINK-37319: --- For the Flink applications that use cloud

[jira] [Created] (FLINK-37319) Add retry in RocksDBStateUploader for fault tolerant

2025-02-13 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-37319: - Summary: Add retry in RocksDBStateUploader for fault tolerant Key: FLINK-37319 URL: https://issues.apache.org/jira/browse/FLINK-37319 Project: Flink Issue

[jira] [Commented] (FLINK-37271) Add network channel reconnect capability

2025-02-13 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926892#comment-17926892 ] Zhenqiu Huang commented on FLINK-37271: --- Thanks for the info. I think we need an o

[jira] [Commented] (FLINK-37271) Add network channel reconnect capability

2025-02-11 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926063#comment-17926063 ] Zhenqiu Huang commented on FLINK-37271: --- Yes, that is exactly the requirement. We

[jira] [Commented] (FLINK-25029) Hadoop Caller Context Setting In Flink

2025-02-07 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925084#comment-17925084 ] Zhenqiu Huang commented on FLINK-25029: --- [~liufangqi] Shall we finish the task? If

[jira] [Updated] (FLINK-37271) Add network channel reconnect capability

2025-02-06 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-37271: -- Description: In our org, we are using the security proxy to achieve inter host secured communi

[jira] [Created] (FLINK-37271) Add network channel reconnect capability

2025-02-06 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-37271: - Summary: Add network channel reconnect capability Key: FLINK-37271 URL: https://issues.apache.org/jira/browse/FLINK-37271 Project: Flink Issue Type: Improv

[jira] [Updated] (FLINK-37246) Delegation Token expire after enable delegation token framework

2025-02-03 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-37246: -- Priority: Blocker (was: Major) > Delegation Token expire after enable delegation token framew

[jira] [Created] (FLINK-37246) Delegation Token expire after enable delegation token framework

2025-02-03 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-37246: - Summary: Delegation Token expire after enable delegation token framework Key: FLINK-37246 URL: https://issues.apache.org/jira/browse/FLINK-37246 Project: Flink

[jira] [Commented] (FLINK-36871) Add internalRescale metrics to distinguish internalRestart Metrics

2025-01-17 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914291#comment-17914291 ] Zhenqiu Huang commented on FLINK-36871: --- The Diff is merged to master. https://gi

[jira] [Closed] (FLINK-36871) Add internalRescale metrics to distinguish internalRestart Metrics

2025-01-17 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang closed FLINK-36871. - Resolution: Fixed > Add internalRescale metrics to distinguish internalRestart Metrics > ---

[jira] [Commented] (FLINK-37018) Adaptive scheduler triggers multiple internal restarts for a single rescale event

2025-01-06 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910428#comment-17910428 ] Zhenqiu Huang commented on FLINK-37018: --- BTW, we are testing on Flink 1.18. > Ad

[jira] [Created] (FLINK-36871) Add internalRescale metrics to distinguish internalRestart Metrics

2024-12-09 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-36871: - Summary: Add internalRescale metrics to distinguish internalRestart Metrics Key: FLINK-36871 URL: https://issues.apache.org/jira/browse/FLINK-36871 Project: Flink

[jira] [Created] (FLINK-36625) Add helper classes for Lineage integration in connectors

2024-10-29 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-36625: - Summary: Add helper classes for Lineage integration in connectors Key: FLINK-36625 URL: https://issues.apache.org/jira/browse/FLINK-36625 Project: Flink Is

[jira] [Resolved] (FLINK-36410) Improve Lineage Info Collection for flink app

2024-10-29 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang resolved FLINK-36410. --- Resolution: Done > Improve Lineage Info Collection for flink app > -

[jira] [Commented] (FLINK-36410) Improve Lineage Info Collection for flink app

2024-10-29 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893955#comment-17893955 ] Zhenqiu Huang commented on FLINK-36410: --- PR is created and merged https://github.c

[jira] [Updated] (FLINK-36410) Improve Lineage Info Collection for flink app

2024-09-30 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-36410: -- Description: We find that lineage interface adoption is not easy for each of Flink connectors

[jira] [Updated] (FLINK-36410) Improve Lineage Info Collection for flink app

2024-09-30 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-36410: -- Component/s: Table SQL / Runtime > Improve Lineage Info Collection for flink app > ---

[jira] [Created] (FLINK-36410) Improve Lineage Info Collection for flink app

2024-09-30 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-36410: - Summary: Improve Lineage Info Collection for flink app Key: FLINK-36410 URL: https://issues.apache.org/jira/browse/FLINK-36410 Project: Flink Issue Type: S

[jira] [Created] (FLINK-36169) Support namespace level resource check before scaling up

2024-08-28 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-36169: - Summary: Support namespace level resource check before scaling up Key: FLINK-36169 URL: https://issues.apache.org/jira/browse/FLINK-36169 Project: Flink Is

[jira] [Closed] (FLINK-33211) Implement table lineage graph

2024-08-10 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang closed FLINK-33211. - Resolution: Fixed > Implement table lineage graph > - > >

[jira] [Comment Edited] (FLINK-35925) Remove hive connector from Flink main repo

2024-07-30 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869690#comment-17869690 ] Zhenqiu Huang edited comment on FLINK-35925 at 7/30/24 4:02 PM: --

[jira] [Commented] (FLINK-35925) Remove hive connector from Flink main repo

2024-07-30 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869690#comment-17869690 ] Zhenqiu Huang commented on FLINK-35925: --- [~Weijie Guo] Yes, it is. I think we clo

[jira] [Closed] (FLINK-35925) Remove hive connector from Flink main repo

2024-07-30 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang closed FLINK-35925. - Resolution: Duplicate > Remove hive connector from Flink main repo > ---

[jira] [Updated] (FLINK-35925) Remove hive connector from Flink main repo

2024-07-29 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-35925: -- Description: Given we have moved hive connector to standalone repo, we should remove the it f

[jira] [Created] (FLINK-35925) Remove hive connector from Flink main repo

2024-07-29 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-35925: - Summary: Remove hive connector from Flink main repo Key: FLINK-35925 URL: https://issues.apache.org/jira/browse/FLINK-35925 Project: Flink Issue Type: Tech

[jira] [Created] (FLINK-35745) Add namespace convention doc for Flink lineage

2024-07-02 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-35745: - Summary: Add namespace convention doc for Flink lineage Key: FLINK-35745 URL: https://issues.apache.org/jira/browse/FLINK-35745 Project: Flink Issue Type:

[jira] [Closed] (FLINK-33211) Implement table lineage graph

2024-07-02 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang closed FLINK-33211. - Resolution: Done The PR is merged to upstream > Implement table lineage graph > ---

[jira] [Closed] (FLINK-33212) Introduce job status changed listener for lineage

2024-07-02 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang closed FLINK-33212. - Resolution: Done The PR is merged to upstream. > Introduce job status changed listener for line

[jira] [Commented] (FLINK-33211) Implement table lineage graph

2024-07-02 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862638#comment-17862638 ] Zhenqiu Huang commented on FLINK-33211: --- PR is merged to upstream > Implement tab

[jira] [Updated] (FLINK-33212) Introduce job status changed listener for lineage

2024-05-19 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-33212: -- Description: # Introduce job status changed listener relevant interfaces and its implementatio

[jira] [Updated] (FLINK-33212) Introduce job status changed listener for lineage

2024-05-19 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-33212: -- Description: Introduce job status changed listener relevant interfaces and its implementation.

[jira] [Created] (FLINK-35326) Implement lineage interface for hive connector

2024-05-09 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-35326: - Summary: Implement lineage interface for hive connector Key: FLINK-35326 URL: https://issues.apache.org/jira/browse/FLINK-35326 Project: Flink Issue Type:

[jira] [Commented] (FLINK-34651) The HiveTableSink of Flink does not support writing to S3

2024-05-09 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845177#comment-17845177 ] Zhenqiu Huang commented on FLINK-34651: --- Have you tried to put lib into your Flink

[jira] [Updated] (FLINK-33212) Introduce job status changed listener for lineage

2024-04-29 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-33212: -- Affects Version/s: 1.20.0 (was: 1.19.0) > Introduce job status chan

[jira] [Commented] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration

2024-04-04 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834045#comment-17834045 ] Zhenqiu Huang commented on FLINK-35015: --- After taking deeper look on the code, Avr

[jira] [Updated] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration

2024-04-04 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-35015: -- Priority: Minor (was: Critical) > Flink Parquet Reader doesn't honor parquet configuration >

[jira] [Created] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration

2024-04-04 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-35015: - Summary: Flink Parquet Reader doesn't honor parquet configuration Key: FLINK-35015 URL: https://issues.apache.org/jira/browse/FLINK-35015 Project: Flink Is

[jira] [Created] (FLINK-34657) Implement Lineage Graph for streaming API use cases

2024-03-12 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-34657: - Summary: Implement Lineage Graph for streaming API use cases Key: FLINK-34657 URL: https://issues.apache.org/jira/browse/FLINK-34657 Project: Flink Issue T

[jira] [Created] (FLINK-34468) Implement Lineage Interface in Cassandra Connector

2024-02-19 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-34468: - Summary: Implement Lineage Interface in Cassandra Connector Key: FLINK-34468 URL: https://issues.apache.org/jira/browse/FLINK-34468 Project: Flink Issue Ty

[jira] [Created] (FLINK-34467) Implement Lineage Interface in Jdbc Connector

2024-02-19 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-34467: - Summary: Implement Lineage Interface in Jdbc Connector Key: FLINK-34467 URL: https://issues.apache.org/jira/browse/FLINK-34467 Project: Flink Issue Type: S

[jira] [Created] (FLINK-34466) Implement Lineage Interface in Kafka Connector

2024-02-19 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-34466: - Summary: Implement Lineage Interface in Kafka Connector Key: FLINK-34466 URL: https://issues.apache.org/jira/browse/FLINK-34466 Project: Flink Issue Type:

[jira] [Commented] (FLINK-33244) Not Able To Pass the Configuration On Flink Session

2024-02-19 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818458#comment-17818458 ] Zhenqiu Huang commented on FLINK-33244: --- [~amar1509] Is it still an issue for the

[jira] [Created] (FLINK-34250) Add formats options to docs

2024-01-26 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-34250: - Summary: Add formats options to docs Key: FLINK-34250 URL: https://issues.apache.org/jira/browse/FLINK-34250 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-01-18 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808334#comment-17808334 ] Zhenqiu Huang commented on FLINK-34007: --- [~mapohl] Ack. There are no new observati

[jira] [Comment Edited] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2024-01-16 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807486#comment-17807486 ] Zhenqiu Huang edited comment on FLINK-31275 at 1/16/24 10:59 PM: -

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2024-01-16 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807486#comment-17807486 ] Zhenqiu Huang commented on FLINK-31275: --- Hi Everyone, I also want to bump the thre

[jira] [Comment Edited] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-01-15 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807017#comment-17807017 ] Zhenqiu Huang edited comment on FLINK-34007 at 1/16/24 3:40 AM: --

[jira] [Comment Edited] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-01-15 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807017#comment-17807017 ] Zhenqiu Huang edited comment on FLINK-34007 at 1/16/24 3:34 AM: --

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-01-15 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807017#comment-17807017 ] Zhenqiu Huang commented on FLINK-34007: --- [~mapohl] I am intensively testing flink

[jira] [Updated] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-01-15 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-34007: -- Attachment: LeaderElector-Debug.json > Flink Job stuck in suspend state after losing leadershi

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-01-13 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806410#comment-17806410 ] Zhenqiu Huang commented on FLINK-34007: --- [~mapohl] Yes, from the observation on th

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-01-10 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805294#comment-17805294 ] Zhenqiu Huang commented on FLINK-34007: --- [~mapohl] Yes, I mistakenly looked into t

[jira] [Updated] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-01-10 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-34007: -- Attachment: Debug.log > Flink Job stuck in suspend state after losing leadership in HA Mode >

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-01-10 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805203#comment-17805203 ] Zhenqiu Huang commented on FLINK-34007: --- I have been investigating the io.fabric8

[jira] [Updated] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-01-09 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-34007: -- Attachment: job-manager.log > Flink Job stuck in suspend state after losing leadership in HA M

[jira] [Updated] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-01-09 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-34007: -- Summary: Flink Job stuck in suspend state after losing leadership in HA Mode (was: Flink Job

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after recovery from failure in HA Mode

2024-01-09 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804840#comment-17804840 ] Zhenqiu Huang commented on FLINK-34007: --- >From initial investigation, the job mana

[jira] [Created] (FLINK-34007) Flink Job stuck in suspend state after recovery from failure in HA Mode

2024-01-05 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-34007: - Summary: Flink Job stuck in suspend state after recovery from failure in HA Mode Key: FLINK-34007 URL: https://issues.apache.org/jira/browse/FLINK-34007 Project: Fl

[jira] [Comment Edited] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-11-01 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781841#comment-17781841 ] Zhenqiu Huang edited comment on FLINK-31275 at 11/1/23 6:23 PM: --

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-11-01 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781841#comment-17781841 ] Zhenqiu Huang commented on FLINK-31275: --- I am recently working Flink with open lin

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-10-15 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775527#comment-17775527 ] Zhenqiu Huang commented on FLINK-31275: --- [~zjureel] We have similar requirements.

[jira] [Updated] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-09 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-33200: -- Affects Version/s: 1.17.1 1.18.0 1.18.1 > ItemAt

[jira] [Commented] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-09 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773373#comment-17773373 ] Zhenqiu Huang commented on FLINK-33200: --- We tried both 1.17.1 and 1.18-SNAPSHOT >

[jira] [Commented] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-06 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772723#comment-17772723 ] Zhenqiu Huang commented on FLINK-33200: --- [~lzljs3620320] As StringDataTypeInfo is

[jira] [Created] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-06 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-33200: - Summary: ItemAt Expression validation fail in Table API due to type mismatch Key: FLINK-33200 URL: https://issues.apache.org/jira/browse/FLINK-33200 Project: Flink

[jira] [Created] (FLINK-33198) Add timestamp with local time zone support in Avro converters

2023-10-06 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-33198: - Summary: Add timestamp with local time zone support in Avro converters Key: FLINK-33198 URL: https://issues.apache.org/jira/browse/FLINK-33198 Project: Flink

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-10-05 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772399#comment-17772399 ] Zhenqiu Huang commented on FLINK-31275: --- [~jark] This JIRA is mentioned in FLIP-31

[jira] [Comment Edited] (FLINK-32777) Upgrade Okhttp version to support IPV6

2023-09-06 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762137#comment-17762137 ] Zhenqiu Huang edited comment on FLINK-32777 at 9/7/23 3:52 AM: ---

[jira] [Commented] (FLINK-32777) Upgrade Okhttp version to support IPV6

2023-09-05 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762137#comment-17762137 ] Zhenqiu Huang commented on FLINK-32777: --- [~heywxl] Thanks for the confirmation.

[jira] [Commented] (FLINK-32777) Upgrade Okhttp version to support IPV6

2023-08-07 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751882#comment-17751882 ] Zhenqiu Huang commented on FLINK-32777: --- Flink operator is already using the lates

[jira] [Commented] (FLINK-32777) Upgrade Okhttp version to support IPV6

2023-08-07 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751880#comment-17751880 ] Zhenqiu Huang commented on FLINK-32777: --- >From the discussion in OKHttp community.

[jira] [Updated] (FLINK-32777) Upgrade Okhttp version to support IPV6

2023-08-07 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-32777: -- Priority: Minor (was: Major) > Upgrade Okhttp version to support IPV6 > -

[jira] [Created] (FLINK-32777) Upgrade Okhttp version to support IPV6

2023-08-07 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-32777: - Summary: Upgrade Okhttp version to support IPV6 Key: FLINK-32777 URL: https://issues.apache.org/jira/browse/FLINK-32777 Project: Flink Issue Type: Improvem

[jira] [Updated] (FLINK-32729) allow create an initial deployment with suspend state

2023-08-02 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-32729: -- Description: With this feature, Users could create an application in suspend status as a backu

[jira] [Created] (FLINK-32729) allow create an initial deployment with suspend state

2023-08-01 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-32729: - Summary: allow create an initial deployment with suspend state Key: FLINK-32729 URL: https://issues.apache.org/jira/browse/FLINK-32729 Project: Flink Issue

[jira] [Created] (FLINK-32597) Drop Yarn specific get rest endpoints

2023-07-16 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-32597: - Summary: Drop Yarn specific get rest endpoints Key: FLINK-32597 URL: https://issues.apache.org/jira/browse/FLINK-32597 Project: Flink Issue Type: Improvem

[jira] [Commented] (FLINK-31849) Enforce some some simple validation directly through the CRD

2023-05-13 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722435#comment-17722435 ] Zhenqiu Huang commented on FLINK-31849: --- [~gyfora] May I take this? > Enforce so

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

2023-05-13 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722434#comment-17722434 ] Zhenqiu Huang commented on FLINK-31998: --- [~gyfora] Technically, if a session job i

[jira] [Created] (FLINK-31947) Enable stdout redirect in flink-console.sh

2023-04-26 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-31947: - Summary: Enable stdout redirect in flink-console.sh Key: FLINK-31947 URL: https://issues.apache.org/jira/browse/FLINK-31947 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-31730) Support Ephemeral Storage in KubernetesConfigOptions

2023-04-04 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-31730: - Summary: Support Ephemeral Storage in KubernetesConfigOptions Key: FLINK-31730 URL: https://issues.apache.org/jira/browse/FLINK-31730 Project: Flink Issue

[jira] [Commented] (FLINK-30609) Add ephemeral storage to CRD

2023-04-03 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708165#comment-17708165 ] Zhenqiu Huang commented on FLINK-30609: --- [~nfraison.datadog] Please review the PR

[jira] [Commented] (FLINK-30609) Add ephemeral storage to CRD

2023-04-03 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708033#comment-17708033 ] Zhenqiu Huang commented on FLINK-30609: --- [~nfraison.datadog] We are glad that you

[jira] [Commented] (FLINK-30363) Disable HadoppConf and Kerboros Decorator by default

2022-12-11 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17645924#comment-17645924 ] Zhenqiu Huang commented on FLINK-30363: --- Discussed with [~gyfora] offline, the cha

[jira] [Comment Edited] (FLINK-30363) Disable HadoppConf and Kerboros Decorator by default

2022-12-11 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17645844#comment-17645844 ] Zhenqiu Huang edited comment on FLINK-30363 at 12/11/22 7:34 PM: -

[jira] [Commented] (FLINK-30363) Disable HadoppConf and Kerboros Decorator by default

2022-12-11 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17645844#comment-17645844 ] Zhenqiu Huang commented on FLINK-30363: --- [~gyfora] Would you please assign this j

[jira] [Created] (FLINK-30363) Disable HadoppConf and Kerboros Decorator by default

2022-12-11 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-30363: - Summary: Disable HadoppConf and Kerboros Decorator by default Key: FLINK-30363 URL: https://issues.apache.org/jira/browse/FLINK-30363 Project: Flink Issue

[jira] [Commented] (FLINK-27831) Provide example of Beam on the k8s operator

2022-12-06 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17644076#comment-17644076 ] Zhenqiu Huang commented on FLINK-27831: --- [~mbalassi] I am interested with task. Wo

[jira] [Comment Edited] (FLINK-29655) Split Flink CRD from flink-kubernates-operator module

2022-10-17 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618947#comment-17618947 ] Zhenqiu Huang edited comment on FLINK-29655 at 10/17/22 2:58 PM: -

[jira] [Commented] (FLINK-29655) Split Flink CRD from flink-kubernates-operator module

2022-10-17 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618947#comment-17618947 ] Zhenqiu Huang commented on FLINK-29655: --- [~gyfora] I feel flink-kubernetes-operat

  1   2   3   4   >