[jira] [Commented] (FLINK-37697) ExecutionGraphInfo may not be archived when cluster shutdown in application mode

2025-04-18 Thread Yi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17945633#comment-17945633 ] Yi Zhang commented on FLINK-37697: -- Hi [~junrui] , I'd like to take this issue. Would y

[jira] [Created] (FLINK-37697) ExecutionGraphInfo may not be archived when cluster shutdown in application mode

2025-04-18 Thread Yi Zhang (Jira)
Yi Zhang created FLINK-37697: Summary: ExecutionGraphInfo may not be archived when cluster shutdown in application mode Key: FLINK-37697 URL: https://issues.apache.org/jira/browse/FLINK-37697 Project: Fli

[jira] [Commented] (FLINK-37567) Flink clusters not be clean up when using job cancellation as suspend mechanism

2025-03-28 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939254#comment-17939254 ] Alan Zhang commented on FLINK-37567: To make it clear for other people, a summary of

[jira] [Updated] (FLINK-37567) Flink clusters not be clean up when using job cancellation as suspend mechanism

2025-03-28 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alan Zhang updated FLINK-37567: --- Description: In general, for application mode, the Flink cluster lifecycle should be tight with the

[jira] [Commented] (FLINK-37567) Flink clusters not be clean up when using job cancellation as suspend mechanism

2025-03-28 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939252#comment-17939252 ] Alan Zhang commented on FLINK-37567: >I can see the value of a standalone model but

[jira] [Commented] (FLINK-37567) Flink clusters not be clean up when using job cancellation as suspend mechanism

2025-03-28 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939247#comment-17939247 ] Alan Zhang commented on FLINK-37567: Thanks for your suggestion [~gyfora] ! The limi

[jira] [Commented] (FLINK-37567) Flink clusters not be clean up when using job cancellation as suspend mechanism

2025-03-27 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939104#comment-17939104 ] Alan Zhang commented on FLINK-37567: Oh yes, we are using the standalone mode. You s

[jira] [Commented] (FLINK-37567) Flink clusters not be clean up when using job cancellation as suspend mechanism

2025-03-27 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939062#comment-17939062 ] Alan Zhang commented on FLINK-37567: [~gyfora] I should be clear that both JM and TM

[jira] [Updated] (FLINK-37567) Flink clusters not be clean up when using job cancellation as suspend mechanism

2025-03-26 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alan Zhang updated FLINK-37567: --- Component/s: Kubernetes Operator Affects Version/s: kubernetes-operator-1.11.0

[jira] [Created] (FLINK-37567) Flink clusters not be clean up when using job cancellation as suspend mechanism

2025-03-26 Thread Alan Zhang (Jira)
Alan Zhang created FLINK-37567: -- Summary: Flink clusters not be clean up when using job cancellation as suspend mechanism Key: FLINK-37567 URL: https://issues.apache.org/jira/browse/FLINK-37567 Project:

[jira] (FLINK-37265) Document of python elasticsearch connector exeample has a little mistake

2025-03-09 Thread Hirson Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37265 ] Hirson Zhang deleted comment on FLINK-37265: -- was (Author: JIRAUSER308616): Hello, [~reswqa], could you please help me review this PR or find the person in charge of it, thank you very much

[jira] [Commented] (FLINK-37265) Document of python elasticsearch connector exeample has a little mistake

2025-03-04 Thread Hirson Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932480#comment-17932480 ] Hirson Zhang commented on FLINK-37265: -- Hello, [~reswqa], could you please help me

[jira] [Commented] (FLINK-36673) Operator is not properly handling failed deployments without savepoints

2025-03-02 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931839#comment-17931839 ] Alan Zhang commented on FLINK-36673: Thanks [~gyfora] . This fix seems to work for s

[jira] [Comment Edited] (FLINK-36673) Operator is not properly handling failed deployments without savepoints

2025-03-01 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931738#comment-17931738 ] Alan Zhang edited comment on FLINK-36673 at 3/2/25 1:41 AM:

[jira] [Updated] (FLINK-36673) Operator is not properly handling failed deployments without savepoints

2025-03-01 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alan Zhang updated FLINK-36673: --- Attachment: Screenshot 2025-02-28 at 8.55.36 PM.png > Operator is not properly handling failed deplo

[jira] [Comment Edited] (FLINK-36673) Operator is not properly handling failed deployments without savepoints

2025-03-01 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931738#comment-17931738 ] Alan Zhang edited comment on FLINK-36673 at 3/2/25 1:40 AM:

[jira] [Commented] (FLINK-36673) Operator is not properly handling failed deployments without savepoints

2025-03-01 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931738#comment-17931738 ] Alan Zhang commented on FLINK-36673: > Checkpointing is enabled as a very last step

[jira] [Updated] (FLINK-36673) Operator is not properly handling failed deployments without savepoints

2025-03-01 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alan Zhang updated FLINK-36673: --- Attachment: Screenshot 2025-02-28 at 4.15.26 PM.png > Operator is not properly handling failed deplo

[jira] [Updated] (FLINK-36673) Operator is not properly handling failed deployments without savepoints

2025-03-01 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alan Zhang updated FLINK-36673: --- Attachment: Screenshot 2025-02-28 at 8.51.37 PM.png > Operator is not properly handling failed deplo

[jira] [Updated] (FLINK-37357) Migrating SqlNode conversion logic from SqlNodeToOperationConversion to SqlNodeConverters

2025-02-20 Thread Hirson Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hirson Zhang updated FLINK-37357: - Summary: Migrating SqlNode conversion logic from SqlNodeToOperationConversion to SqlNodeConvert

[jira] [Updated] (FLINK-37357) Migrating SqlNode conversion logic from to SqlNodeConverters

2025-02-20 Thread Hirson Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hirson Zhang updated FLINK-37357: - Summary: Migrating SqlNode conversion logic from to SqlNodeConverters (was: Migrating conversi

[jira] [Commented] (FLINK-37357) Migrating conversion logic to SqlNodeConverters

2025-02-19 Thread Hirson Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928630#comment-17928630 ] Hirson Zhang commented on FLINK-37357: -- I will try to deal with this. > Migrating

[jira] [Updated] (FLINK-37357) Migrating conversion logic to SqlNodeConverters

2025-02-19 Thread Hirson Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hirson Zhang updated FLINK-37357: - Description: There is a "TODO" at class "SqlNodeToOperationConversion", method "convertValidate

[jira] [Updated] (FLINK-37357) Migrating conversion logic to SqlNodeConverters

2025-02-19 Thread Hirson Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hirson Zhang updated FLINK-37357: - Description: There is a "TODO" at class "SqlNodeToOperationConversion", method "convertValidate

[jira] [Updated] (FLINK-37357) Migrating conversion logic to SqlNodeConverters

2025-02-19 Thread Hirson Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hirson Zhang updated FLINK-37357: - Description: There is a "TODO" at class "SqlNodeToOperationConversion", method "convertValidate

[jira] [Updated] (FLINK-37357) Migrating conversion logic to SqlNodeConverters

2025-02-19 Thread Hirson Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hirson Zhang updated FLINK-37357: - Fix Version/s: (was: 2.1.0) > Migrating conversion logic to SqlNodeConverters >

[jira] [Created] (FLINK-37357) Migrating conversion logic to SqlNodeConverters

2025-02-19 Thread Hirson Zhang (Jira)
Hirson Zhang created FLINK-37357: Summary: Migrating conversion logic to SqlNodeConverters Key: FLINK-37357 URL: https://issues.apache.org/jira/browse/FLINK-37357 Project: Flink Issue Type: I

[jira] [Comment Edited] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs"

2025-02-18 Thread Yi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927892#comment-17927892 ] Yi Zhang edited comment on FLINK-37073 at 2/19/25 6:59 AM: --- Ve

[jira] [Updated] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs"

2025-02-17 Thread Yi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Zhang updated FLINK-37073: - Attachment: adaptive-image.png > Cross-team verification for "Adaptive optimization for batch jobs" > --

[jira] [Comment Edited] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs"

2025-02-17 Thread Yi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927892#comment-17927892 ] Yi Zhang edited comment on FLINK-37073 at 2/18/25 2:00 AM: --- Ve

[jira] [Commented] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs"

2025-02-17 Thread Yi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927892#comment-17927892 ] Yi Zhang commented on FLINK-37073: -- Verification Steps: # Start the Flink cluster, cons

[jira] [Updated] (FLINK-37265) Document of python elasticsearch connector exeample has a little mistake

2025-02-07 Thread Hirson Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hirson Zhang updated FLINK-37265: - Summary: Document of python elasticsearch connector exeample has a little mistake (was: Documen

[jira] [Comment Edited] (FLINK-37265) Document of python elasticsearch connector exeample has a little mistake

2025-02-07 Thread Hirson Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924827#comment-17924827 ] Hirson Zhang edited comment on FLINK-37265 at 2/7/25 9:57 AM:

[jira] [Comment Edited] (FLINK-37265) Document of python elasticsearch connector exeample has a little mistake

2025-02-07 Thread Hirson Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924827#comment-17924827 ] Hirson Zhang edited comment on FLINK-37265 at 2/7/25 9:34 AM:

[jira] [Closed] (FLINK-37081) The debezium version of sqlserver cdc needs to be upgraded to 2.6 or higher

2025-01-10 Thread zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhang closed FLINK-37081. - Resolution: Later > The debezium version of sqlserver cdc needs to be upgraded to 2.6 or higher > --

[jira] [Commented] (FLINK-37081) The debezium version of sqlserver cdc needs to be upgraded to 2.6 or higher

2025-01-09 Thread zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911780#comment-17911780 ] zhang commented on FLINK-37081: --- @[~Leonard] Can you help me with this? > The debezium ve

[jira] [Created] (FLINK-37081) The debezium version of sqlserver cdc needs to be upgraded to 2.6 or higher

2025-01-08 Thread zhang (Jira)
zhang created FLINK-37081: - Summary: The debezium version of sqlserver cdc needs to be upgraded to 2.6 or higher Key: FLINK-37081 URL: https://issues.apache.org/jira/browse/FLINK-37081 Project: Flink

[jira] [Created] (FLINK-36635) PhysicalSlotRequestBulkImpl is not used and can be removed

2024-10-30 Thread Yi Zhang (Jira)
Yi Zhang created FLINK-36635: Summary: PhysicalSlotRequestBulkImpl is not used and can be removed Key: FLINK-36635 URL: https://issues.apache.org/jira/browse/FLINK-36635 Project: Flink Issue Type

[jira] [Updated] (FLINK-36599) Correct the name of the config which enables response codes group

2024-10-24 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alan Zhang updated FLINK-36599: --- Description: In the "Metrics and Logging" doc, it doesn't use the full name of the operator config(

[jira] [Created] (FLINK-36599) Correct the name of the config which enables response codes group

2024-10-24 Thread Alan Zhang (Jira)
Alan Zhang created FLINK-36599: -- Summary: Correct the name of the config which enables response codes group Key: FLINK-36599 URL: https://issues.apache.org/jira/browse/FLINK-36599 Project: Flink

[jira] [Created] (FLINK-35332) Manually setting rest.bind-address does not work for Flink running on Hadoop Yarn dual network environment

2024-05-13 Thread Yao Zhang (Jira)
Yao Zhang created FLINK-35332: - Summary: Manually setting rest.bind-address does not work for Flink running on Hadoop Yarn dual network environment Key: FLINK-35332 URL: https://issues.apache.org/jira/browse/FLINK-353

[jira] [Updated] (FLINK-35279) Support "last-state" upgrade mode for FlinkSessionJob

2024-04-30 Thread Alan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alan Zhang updated FLINK-35279: --- Description: The "last-state" upgrade mode is only supported for Flink application mode today[1], w

[jira] [Created] (FLINK-35279) Support "last-state" upgrade mode for FlinkSessionJob

2024-04-30 Thread Alan Zhang (Jira)
Alan Zhang created FLINK-35279: -- Summary: Support "last-state" upgrade mode for FlinkSessionJob Key: FLINK-35279 URL: https://issues.apache.org/jira/browse/FLINK-35279 Project: Flink Issue Type

[jira] [Created] (FLINK-35219) [Flink SQL]Support deserialize json string into Map

2024-04-23 Thread zhihao zhang (Jira)
zhihao zhang created FLINK-35219: Summary: [Flink SQL]Support deserialize json string into Map Key: FLINK-35219 URL: https://issues.apache.org/jira/browse/FLINK-35219 Project: Flink Issue Typ

[jira] [Created] (FLINK-34618) Migrate SplitPythonConditionFromJoinRule

2024-03-07 Thread Yongming Zhang (Jira)
Yongming Zhang created FLINK-34618: -- Summary: Migrate SplitPythonConditionFromJoinRule Key: FLINK-34618 URL: https://issues.apache.org/jira/browse/FLINK-34618 Project: Flink Issue Type: Sub-

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2024-01-29 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812169#comment-17812169 ] Yao Zhang commented on FLINK-26760: --- Hi community, I submitted a PR and could someone

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2024-01-23 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17809842#comment-17809842 ] Yao Zhang commented on FLINK-26760: --- Hi community, The encoding issue could be solved

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2024-01-07 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804098#comment-17804098 ] Yao Zhang commented on FLINK-26760: --- Hi community, I got the same issue with Flink 1.

[jira] [Commented] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-29 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791426#comment-17791426 ] Lyn Zhang commented on FLINK-33670: --- Making "temporary view" as a real "common table e

[jira] [Updated] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-33670: -- Description: Dear all:    I find that some public operators cannot be reused when submit a job with

[jira] [Updated] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-33670: -- Description: Dear all:    I find that some public operators cannot be reused when submit a job with

[jira] [Updated] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-33670: -- Description: Dear all:    I find that some public operators cannot be reused when submit a job with

[jira] [Updated] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-33670: -- Description: Dear all:    I find that some public operators cannot be reused when submit a job with

[jira] [Updated] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-33670: -- Description: Dear all:    I find that some public operators cannot be reused when submit a job with

[jira] [Created] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-27 Thread Lyn Zhang (Jira)
Lyn Zhang created FLINK-33670: - Summary: Public operators cannot be reused in multi sinks Key: FLINK-33670 URL: https://issues.apache.org/jira/browse/FLINK-33670 Project: Flink Issue Type: Improv

[jira] [Commented] (FLINK-18473) Optimize RocksDB disk load balancing strategy

2023-11-16 Thread Yi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786887#comment-17786887 ] Yi Zhang commented on FLINK-18473: -- Thanks [~masteryhx] for the pointers! yes, round-ro

[jira] [Commented] (FLINK-18473) Optimize RocksDB disk load balancing strategy

2023-11-15 Thread Yi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786462#comment-17786462 ] Yi Zhang commented on FLINK-18473: -- [~masteryhx] what do you think of random initial pi

[jira] [Commented] (FLINK-18473) Optimize RocksDB disk load balancing strategy

2023-11-13 Thread Yi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785621#comment-17785621 ] Yi Zhang commented on FLINK-18473: -- [~yunta] [~fanrui] the current logic of picking fro

[jira] [Commented] (FLINK-32721) agg max/min supports char type

2023-11-07 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783908#comment-17783908 ] Yao Zhang commented on FLINK-32721: --- Hi Community,   It seems that there is a contra

[jira] [Commented] (FLINK-32721) agg max/min supports char type

2023-11-05 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783126#comment-17783126 ] Yao Zhang commented on FLINK-32721: ---  Hi [~jackylau], [~libenchao] and [~lsy], It see

[jira] [Commented] (FLINK-32763) Uncaught exceptions cause retry not to take effect in SocketTextStreamFunction

2023-11-05 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783074#comment-17783074 ] Yao Zhang commented on FLINK-32763: --- Hi community, I got the same issue and wanna wor

[jira] [Commented] (FLINK-33355) can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.

2023-10-26 Thread zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779800#comment-17779800 ] zhang commented on FLINK-33355: --- [~martijnvisser]  I found that the {{.with()}} method is

[jira] [Commented] (FLINK-33355) can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.

2023-10-25 Thread zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779768#comment-17779768 ] zhang commented on FLINK-33355: --- [~martijnvisser]  Sorry, could you please explain to me w

[jira] [Commented] (FLINK-33090) CheckpointsCleaner clean individual checkpoint states in parallel

2023-10-25 Thread Yi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779619#comment-17779619 ] Yi Zhang commented on FLINK-33090: --  [~masteryhx],  [~pnowojski] really appreciate your

[jira] [Reopened] (FLINK-33355) can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.

2023-10-25 Thread zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhang reopened FLINK-33355: --- > can't reduce the parallelism from 'n' to '1' when recovering through a > savepoint. > ---

[jira] [Commented] (FLINK-33355) can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.

2023-10-25 Thread zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779367#comment-17779367 ] zhang commented on FLINK-33355: --- [~yunta] I've almost assigned a UID to every operator, bu

[jira] [Commented] (FLINK-33355) can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.

2023-10-24 Thread zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779359#comment-17779359 ] zhang commented on FLINK-33355: --- [~yunta] yes > can't reduce the parallelism from 'n' to

[jira] [Commented] (FLINK-33355) can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.

2023-10-24 Thread zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779352#comment-17779352 ] zhang commented on FLINK-33355: --- [~yunta]  {code:java} StreamExecutionEnvironment env = S

[jira] [Commented] (FLINK-33355) can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.

2023-10-24 Thread zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779336#comment-17779336 ] zhang commented on FLINK-33355: --- [~yunta]   I know that modifying the max parallelism is n

[jira] [Created] (FLINK-33355) can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.

2023-10-24 Thread zhang (Jira)
zhang created FLINK-33355: - Summary: can't reduce the parallelism from 'n' to '1' when recovering through a savepoint. Key: FLINK-33355 URL: https://issues.apache.org/jira/browse/FLINK-33355 Project: Flink

[jira] [Commented] (FLINK-33112) Support placement constraint

2023-10-22 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17778513#comment-17778513 ] Junfan Zhang commented on FLINK-33112: -- [https://hadoop.apache.org/docs/stable/hado

[jira] [Commented] (FLINK-32716) Give 'Default'(or maybe 'None') option for 'scheduler-mode'

2023-10-22 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17778491#comment-17778491 ] Yao Zhang commented on FLINK-32716: --- Hi [~kination], The title of your PR now is [FLI

[jira] [Commented] (FLINK-32716) Give 'Default'(or maybe 'None') option for 'scheduler-mode'

2023-10-19 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1520#comment-1520 ] Yao Zhang commented on FLINK-32716: --- Hi [~kination] , The issue ID in your commit mes

[jira] [Commented] (FLINK-32721) agg max/min supports char type

2023-10-19 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1518#comment-1518 ] Yao Zhang commented on FLINK-32721: --- Hi [~jackylau], Are you still working on this? B

[jira] [Commented] (FLINK-33112) Support placement constraint

2023-10-08 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773083#comment-17773083 ] Junfan Zhang commented on FLINK-33112: -- PTAL [~guoyangze]  > Support placement con

[jira] [Commented] (FLINK-33090) CheckpointsCleaner clean individual checkpoint states in parallel

2023-09-27 Thread Yi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17769854#comment-17769854 ] Yi Zhang commented on FLINK-33090: -- some of our users jobs having large number of state

[jira] [Created] (FLINK-33127) HeapKeyedStateBackend: use buffered I/O to speed up local recovery

2023-09-20 Thread Yangyang ZHANG (Jira)
Yangyang ZHANG created FLINK-33127: -- Summary: HeapKeyedStateBackend: use buffered I/O to speed up local recovery Key: FLINK-33127 URL: https://issues.apache.org/jira/browse/FLINK-33127 Project: Flink

[jira] [Created] (FLINK-33112) Support placement constraint

2023-09-18 Thread Junfan Zhang (Jira)
Junfan Zhang created FLINK-33112: Summary: Support placement constraint Key: FLINK-33112 URL: https://issues.apache.org/jira/browse/FLINK-33112 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-33090) CheckpointsCleaner clean individual checkpoint states in parallel

2023-09-15 Thread Yi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765536#comment-17765536 ] Yi Zhang commented on FLINK-33090: -- [~masteryhx] Can you help review?  I am new to Flin

[jira] [Commented] (FLINK-33090) CheckpointsCleaner clean individual checkpoint states in parallel

2023-09-14 Thread Yi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765458#comment-17765458 ] Yi Zhang commented on FLINK-33090: -- Yes I would like to contribute, I will send a PR fo

[jira] [Updated] (FLINK-33090) CheckpointsCleaner clean individual checkpoint states in parallel

2023-09-14 Thread Yi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Zhang updated FLINK-33090: - Description: Currently CheckpointsCleaner clean multiple checkpoints in parallel with JobManager's ioEx

[jira] [Created] (FLINK-33090) CheckpointsCleaner clean individual checkpoint states in parallel

2023-09-14 Thread Yi Zhang (Jira)
Yi Zhang created FLINK-33090: Summary: CheckpointsCleaner clean individual checkpoint states in parallel Key: FLINK-33090 URL: https://issues.apache.org/jira/browse/FLINK-33090 Project: Flink Is

[jira] [Resolved] (FLINK-32810) Improve managed memory usage in ListStateWithCache

2023-09-04 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang resolved FLINK-32810. --- Fix Version/s: ml-2.4.0 Assignee: Fan Hong Resolution: Fixed > Improve manag

[jira] [Commented] (FLINK-9631) use Files.createDirectories instead of directory.mkdirs

2023-09-01 Thread Yangyang ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761218#comment-17761218 ] Yangyang ZHANG commented on FLINK-9631: --- [~hangxiang] I would like to fix this issu

[jira] [Commented] (FLINK-29359) Pulsar Table Connector pom config and packaging

2023-08-30 Thread Yufei Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760716#comment-17760716 ] Yufei Zhang commented on FLINK-29359: - [~tison] Yeah I think when the ticket is crea

[jira] [Comment Edited] (FLINK-29359) Pulsar Table Connector pom config and packaging

2023-08-30 Thread Yufei Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760716#comment-17760716 ] Yufei Zhang edited comment on FLINK-29359 at 8/31/23 4:56 AM:

[jira] [Closed] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang closed FLINK-32969. - Fix Version/s: 1.18.0 Resolution: Fixed > IfCallGen NullPointException Bug >

[jira] [Commented] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759427#comment-17759427 ] Lyn Zhang commented on FLINK-32969: --- [~luoyuxia] looks like it has been fixed in 1.17.

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Function will cause NullPointException when the third param is other functions. h1. E

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Function will cause NullPointException when the third param is a udf. h1. Example: {co

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Function will cause NullPointException when the third param is other function. h1. Ex

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Attachment: image-2023-08-28-11-02-03-842.png > IfCallGen NullPointException Bug > ---

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Function will cause NullPointException when the third param is other function. h1. Ex

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Function will cause NullPointException when the third param is other function. h1. Ex

[jira] [Commented] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759423#comment-17759423 ] Lyn Zhang commented on FLINK-32969: --- [~jark] [~godfreyhe]  Please help to check this i

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Functions will cause NullPointException when the third param is other function. h1. E

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Functions will cause NullPointException when the third param is other function. h1. E

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Functions will cause NullPointException when the third param is other function. h1. E

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Functions will cause NullPointException when the third param is other function. h1. E

[jira] [Updated] (FLINK-32969) IfCallGen NullPointException Bug

2023-08-27 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-32969: -- Description: If Functions will cause NullPointException when the third param is other function. h1. E

  1   2   3   4   5   6   7   8   9   10   >