Re: [PR] [FLINK-35872][table] Fix the incorrect partition generation during period refresh in Full Mode [flink]

2024-07-21 Thread via GitHub
hackergin commented on PR #25108: URL: https://github.com/apache/flink/pull/25108#issuecomment-2242204010 @lsyldliu Thank you for reviewing. I have addressed the related comments; please have a look -- This is an automated message from the Apache Git Service. To respond to the message,

Re: [PR] [FLINK-35865][base] Support Byte and Short in ObjectUtils [flink-cdc]

2024-07-21 Thread via GitHub
GOODBOY008 commented on PR #3481: URL: https://github.com/apache/flink-cdc/pull/3481#issuecomment-2242135166 @lvyanquan PTAL -- 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 comme

[jira] [Resolved] (FLINK-35871) Add document for SNAPSHOT startup option mode

2024-07-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35871. Resolution: Fixed fixed via master(3.2-SNAPSHOT): a9eb4c68ef4a7f98a034ee2fba9ffc8b7904e41e > Add

Re: [PR] [FLINK-35871][doc] add "snapshot" to mysql connector startup options. [flink-cdc]

2024-07-21 Thread via GitHub
leonardBang merged PR #3484: URL: https://github.com/apache/flink-cdc/pull/3484 -- 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

[PR] [minor][cdc-connector][mysql] catch all exceptions to display the table info [flink-cdc]

2024-07-21 Thread via GitHub
lvyanquan opened a new pull request, #3485: URL: https://github.com/apache/flink-cdc/pull/3485 parseDDL doesn't always throw ParsingException, and table info will be missed in this case. ![image](https://github.com/user-attachments/assets/5d053c50-3b80-4a9b-9994-a86a8c9a6be9) -- T

Re: [PR] [FLINK-27355][runtime] Unregister JobManagerRunner after it's closed [flink]

2024-07-21 Thread via GitHub
kumar-mallikarjuna commented on code in PR #25027: URL: https://github.com/apache/flink/pull/25027#discussion_r1685926520 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistry.java: ## @@ -97,6 +106,14 @@ public JobManagerRunner unreg

Re: [PR] [FLINK-35872][table] Fix the incorrect partition generation during period refresh in Full Mode [flink]

2024-07-21 Thread via GitHub
lsyldliu commented on code in PR #25108: URL: https://github.com/apache/flink/pull/25108#discussion_r1685926056 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/materializedtable/MaterializedTableManagerTest.java: ## @@ -99,56 +103,340 @@ voi

Re: [PR] [FLINK-35872][table] Fix the incorrect partition generation during period refresh in Full Mode [flink]

2024-07-21 Thread via GitHub
lsyldliu commented on code in PR #25108: URL: https://github.com/apache/flink/pull/25108#discussion_r1685891811 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/MaterializedTableStatementITCase.java: ## @@ -1520,6 +1520,58 @@ void testRefres

[jira] [Assigned] (FLINK-35871) Add document for SNAPSHOT startup option mode

2024-07-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35871: -- Assignee: LvYanquan > Add document for SNAPSHOT startup option mode > --

[jira] [Updated] (FLINK-35871) Add document for SNAPSHOT startup option mode

2024-07-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35871: --- Component/s: Documentation > Add document for SNAPSHOT startup option mode > --

[jira] [Resolved] (FLINK-35237) Allow Sink to Choose HashFunction in PrePartitionOperator

2024-07-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35237. Resolution: Implemented via master(3.2-SNAPSHOT): 26ff6d2a081181f3df7aa49d65d804c57c634122 > Allo

[jira] [Assigned] (FLINK-35237) Allow Sink to Choose HashFunction in PrePartitionOperator

2024-07-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35237: -- Assignee: zhangdingxin > Allow Sink to Choose HashFunction in PrePartitionOperator >

[jira] [Updated] (FLINK-35237) Allow Sink to Choose HashFunction in PrePartitionOperator

2024-07-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35237: --- Affects Version/s: cdc-3.1.1 > Allow Sink to Choose HashFunction in PrePartitionOperator > -

Re: [PR] [FLINK-35237] Allow Sink to Choose HashFunction in PrePartitionOperator [flink-cdc]

2024-07-21 Thread via GitHub
leonardBang merged PR #3414: URL: https://github.com/apache/flink-cdc/pull/3414 -- 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

[jira] [Updated] (FLINK-35872) Fix the incorrect partition generation during period refresh in Full Mode

2024-07-21 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-35872: -- Priority: Blocker (was: Major) > Fix the incorrect partition generation during period refresh in Full

[jira] [Assigned] (FLINK-35872) Fix the incorrect partition generation during period refresh in Full Mode

2024-07-21 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-35872: - Assignee: Feng Jin > Fix the incorrect partition generation during period refresh in Full Mode

Re: [PR] [FLINK-34944] Use Incremental Source Framework in Flink CDC OceanBase Source Connector [flink-cdc]

2024-07-21 Thread via GitHub
github-actions[bot] commented on PR #3211: URL: https://github.com/apache/flink-cdc/pull/3211#issuecomment-2241824995 This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs. --

Re: [PR] [FLINK-23589][flink-avro] Support microsecond precision for timestamp [flink]

2024-07-21 Thread via GitHub
asantoz commented on PR #19537: URL: https://github.com/apache/flink/pull/19537#issuecomment-2241809600 Hey, why this blocked? -- 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

Re: [PR] [FLINK-35872][table] Fix the incorrect partition generation during period refresh in Full Mode [flink]

2024-07-21 Thread via GitHub
flinkbot commented on PR #25108: URL: https://github.com/apache/flink/pull/25108#issuecomment-2241624001 ## CI report: * 6bd73ab3f17dccbecb1113cd0f5aaedec0579f78 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-35872) Fix the incorrect partition generation during period refresh in Full Mode

2024-07-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35872: --- Labels: pull-request-available (was: ) > Fix the incorrect partition generation during peri

[PR] [FLINK-35872][table] Fix the incorrect partition generation during period refresh in Full Mode [flink]

2024-07-21 Thread via GitHub
hackergin opened a new pull request, #25108: URL: https://github.com/apache/flink/pull/25108 ## What is the purpose of the change *Fix the incorrect partition generation during period refresh in Full Mode* ## Brief change log - Fix the incorrect partition generation durin

[jira] [Created] (FLINK-35872) Fix the incorrect partition generation during period refresh in Full Mode

2024-07-21 Thread Feng Jin (Jira)
Feng Jin created FLINK-35872: Summary: Fix the incorrect partition generation during period refresh in Full Mode Key: FLINK-35872 URL: https://issues.apache.org/jira/browse/FLINK-35872 Project: Flink

Re: [PR] [cdc-connector][postgres]Flink cdc pipeline support postgres source [flink-cdc]

2024-07-21 Thread via GitHub
cobolbaby commented on PR #3442: URL: https://github.com/apache/flink-cdc/pull/3442#issuecomment-2241547050 Is there anyone who can help review this? -- 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

Re: [PR] [cdc-connector][sqlserver]Flink cdc pipeline support sqlserver source [flink-cdc]

2024-07-21 Thread via GitHub
cobolbaby commented on PR #3445: URL: https://github.com/apache/flink-cdc/pull/3445#issuecomment-2241546735 Is there anyone who can help review this? -- 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