[jira] [Closed] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

2024-05-27 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-35040. --- Resolution: Won't Fix Close this Jira first, you can get more details from https://lists.apache.org/thread/

Re: [PR] [FLINK-35463]Fixed issue for route rule changed when restored from checkpoint. [flink-cdc]

2024-05-27 Thread via GitHub
hk-lrzy commented on PR #3364: URL: https://github.com/apache/flink-cdc/pull/3364#issuecomment-2132921117 @leonardBang Can you review the code and there have a new question in the PR, maybe we can discuss it. -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-35463) CDC job failed when restored from checkpoint when route rule changed.

2024-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35463: --- Labels: pull-request-available (was: ) > CDC job failed when restored from checkpoint when

[PR] [FLINK-35463]Fixed issue for route rule changed when restored from checkpoint. [flink-cdc]

2024-05-27 Thread via GitHub
hk-lrzy opened a new pull request, #3364: URL: https://github.com/apache/flink-cdc/pull/3364 https://issues.apache.org/jira/browse/FLINK-35463 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

Re: [PR] [FLINK-34901][connectors/jdbc]Update clause must EXCLUDED unique index. [flink-connector-jdbc]

2024-05-27 Thread via GitHub
RocMarshal commented on code in PR #108: URL: https://github.com/apache/flink-connector-jdbc/pull/108#discussion_r1615654170 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/AbstractPostgresCompatibleDialect.java: ## @@ -50,12 +50,14 @@ public Strin

[jira] [Created] (FLINK-35463) CDC job failed when restored from checkpoint when route rule changed.

2024-05-27 Thread hk__lrzy (Jira)
hk__lrzy created FLINK-35463: Summary: CDC job failed when restored from checkpoint when route rule changed. Key: FLINK-35463 URL: https://issues.apache.org/jira/browse/FLINK-35463 Project: Flink

[jira] [Updated] (FLINK-35462) Introduce a parameter to control the chaining mode between a Flink SQL connector sink or source and its adjacent operator.

2024-05-27 Thread yuanfenghu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuanfenghu updated FLINK-35462: --- Description: When using the flinksql connector, we can set the parallelism of the sink. However, wh

[jira] [Updated] (FLINK-35462) Introduce a parameter to control the chaining mode between a Flink SQL connector sink or source and its adjacent operator.

2024-05-27 Thread yuanfenghu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuanfenghu updated FLINK-35462: --- Description: When using the flinksql connector, we can set the parallelism of the sink. However, wh

[jira] [Created] (FLINK-35462) Introduce a parameter to control the chaining mode between a Flink SQL connector sink or source and its adjacent operator.

2024-05-27 Thread yuanfenghu (Jira)
yuanfenghu created FLINK-35462: -- Summary: Introduce a parameter to control the chaining mode between a Flink SQL connector sink or source and its adjacent operator. Key: FLINK-35462 URL: https://issues.apache.org/jir

[jira] [Updated] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

2024-05-27 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35040: Priority: Major (was: Blocker) > The performance of serializerHeavyString regresses since April 3 > -

Re: [PR] [FLINK-35460][state] Adjust read size when ByteBuffer size is larger than file size for ForSt [flink]

2024-05-27 Thread via GitHub
zoltar9264 commented on code in PR #24847: URL: https://github.com/apache/flink/pull/24847#discussion_r1615605846 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java: ## @@ -99,7 +104,23 @@ publi

[jira] [Closed] (FLINK-35403) FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding

2024-05-27 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35403. Fix Version/s: 1.20.0 Resolution: Fixed Fixed in master: efcd146e0119cc7e67fea74cc46fbde083

Re: [PR] [FLINK-35129][cdc][postgres] Add checkpoint cycle option for commit offsets [flink-cdc]

2024-05-27 Thread via GitHub
morazow commented on code in PR #3349: URL: https://github.com/apache/flink-cdc/pull/3349#discussion_r1615606254 ## flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/test/java/org/apache/flink/cdc/connectors/postgres/source/reader/PostgresSourceReaderTest.ja

Re: [PR] [FLINK-35403] Allow Skipping Invocation of Function Calls While Constant-folding [flink]

2024-05-27 Thread via GitHub
twalthr merged PR #24814: URL: https://github.com/apache/flink/pull/24814 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apach

Re: [PR] [FLINK-34239][core] Add copy() method for SerializerConfig [flink]

2024-05-27 Thread via GitHub
kumar-mallikarjuna commented on PR #24544: URL: https://github.com/apache/flink/pull/24544#issuecomment-2132834467 Hi @reswqa , I've rebased the branch. Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]

2024-05-27 Thread via GitHub
19priyadhingra commented on code in PR #141: URL: https://github.com/apache/flink-connector-aws/pull/141#discussion_r1615603849 ## flink-connector-aws/flink-connector-sqs/src/main/java/org.apache.flink.connector.sqs/sink/SqsSinkWriter.java: ## @@ -0,0 +1,272 @@ +/* + * Licensed

Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]

2024-05-27 Thread via GitHub
19priyadhingra commented on code in PR #141: URL: https://github.com/apache/flink-connector-aws/pull/141#discussion_r1615590239 ## flink-connector-aws/flink-connector-sqs/src/main/java/org.apache.flink.connector.sqs/sink/SqsSinkWriter.java: ## @@ -0,0 +1,272 @@ +/* + * Licensed

[jira] [Updated] (FLINK-34993) Support MODEL syntax in parser

2024-05-27 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-34993: - Description: Adds all parser changes required for FLIP-437. > Support MODEL syntax in parser > -

[jira] [Closed] (FLINK-34993) Support MODEL syntax in parser

2024-05-27 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-34993. Fix Version/s: 1.20.0 Resolution: Fixed Fixed in master: 4d39738587e0f07a4776eebb83e2bcaf28

[jira] [Updated] (FLINK-34993) Support MODEL syntax in parser

2024-05-27 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-34993: - Summary: Support MODEL syntax in parser (was: Support Model CRUD in parser) > Support MODEL syn

Re: [PR] [FLINK-34993] parser changes to support model CRUD sql [flink]

2024-05-27 Thread via GitHub
twalthr merged PR #24769: URL: https://github.com/apache/flink/pull/24769 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apach

<    1   2   3