[jira] [Updated] (FLINK-35852) When used through the transform function, the decimal(10,2) type field value in the MySQL source table becomes 100 times the original value after being transferred to th

2024-08-02 Thread zheng_shengsheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zheng_shengsheng updated FLINK-35852: - Description: When I use CDC's yaml mode to collect MySQL data to Doris, I use the latest

[jira] [Updated] (FLINK-35852) When used through the transform function, the decimal(10,2) type field value in the MySQL source table becomes 100 times the original value after being transferred to th

2024-08-02 Thread zheng_shengsheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zheng_shengsheng updated FLINK-35852: - Description: When I use CDC's yaml mode to collect MySQL data to Doris, I use the latest

[jira] [Updated] (FLINK-35852) When used through the transform function, the decimal(10,2) type field value in the MySQL source table becomes 100 times the original value after being transferred to th

2024-08-02 Thread zheng_shengsheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zheng_shengsheng updated FLINK-35852: - Description: When I use CDC's yaml mode to collect MySQL data to Doris, I use the latest

Re: [PR] [FLINK-33875][runtime] Support slots wait mechanism at DeclarativeSlotPoolBridge side for Default Scheduler [flink]

2024-08-02 Thread via GitHub
RocMarshal commented on PR #25134: URL: https://github.com/apache/flink/pull/25134#issuecomment-2266352507 @flinkbot run azure -- 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] [WIP] [FLINK-XXXX] Generalized watermark wip [flink]

2024-08-02 Thread via GitHub
jeyhunkarimov commented on PR #24997: URL: https://github.com/apache/flink/pull/24997#issuecomment-2266239143 @flinkbot run azure -- 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 comm

Re: [PR] [WIP] [FLINK-XXXX] Generalized watermark wip [flink]

2024-08-02 Thread via GitHub
jeyhunkarimov commented on PR #24997: URL: https://github.com/apache/flink/pull/24997#issuecomment-226622 @flinkbot run azure -- 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 comm

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

2024-08-02 Thread via GitHub
eskabetxe commented on PR #108: URL: https://github.com/apache/flink-connector-jdbc/pull/108#issuecomment-2265871686 @Mrart can you rebase and add a test? -- 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

Re: [PR] [FLINK-33536] Fix Flink Table API CSV streaming sink fails with IOException: Stream closed [flink]

2024-08-02 Thread via GitHub
kellydkim commented on PR #23725: URL: https://github.com/apache/flink/pull/23725#issuecomment-2265826957 Hi @Samrat002, I am seeing that this bug also impacts `CompressWriterFactory` as it creates a `NoCompressionBulkWriter` which also uses a `FSDataOutputStream` thus has the same i

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

2024-08-02 Thread via GitHub
zakhalex commented on PR #3445: URL: https://github.com/apache/flink-cdc/pull/3445#issuecomment-2265783357 @ChengJie1053 - I have opened a pull request to your master branch, as well as to apache master branch with a list of fixes and changes to the code your proposed - my pull request to a

[PR] SQL Server CDC support - fixing the issues in the outstanding pull request by another author [flink-cdc]

2024-08-02 Thread via GitHub
zakhalex opened a new pull request, #3507: URL: https://github.com/apache/flink-cdc/pull/3507 This pull request reuses the contribution under https://github.com/apache/flink-cdc/pull/3445 and fixes the outstanding issues in the underlying code to get it fully operational. -- This is an a

Re: [PR] [FLINK-35265] Implement FlinkStateSnapshot custom resource [flink-kubernetes-operator]

2024-08-02 Thread via GitHub
mateczagany commented on PR #821: URL: https://github.com/apache/flink-kubernetes-operator/pull/821#issuecomment-2265719872 I rebased the branch on top of main, but I also pushed commit 566caf9ba7220e8a53dc520822621db2928eafa4 -- This is an automated message from the Apache Git Service.

Re: [PR] [FLINK-35969][state] Remove deprecated dataset based API from State Processor API [flink]

2024-08-02 Thread via GitHub
gaborgsomogyi commented on PR #25149: URL: https://github.com/apache/flink/pull/25149#issuecomment-2265710501 @flinkbot run azure -- 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 comm

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

2024-08-02 Thread via GitHub
19priyadhingra commented on PR #141: URL: https://github.com/apache/flink-connector-aws/pull/141#issuecomment-2265687290 > > Do you have any suggestion on how can I fix my test case without reverting that PR? > > Hi @19priyadhingra, we can either debug the local stack issue, or consi

Re: [PR] [FLINK-35934] Add CompiledPlan annotations to BatchExecValues (#1) [flink]

2024-08-02 Thread via GitHub
flinkbot commented on PR #25150: URL: https://github.com/apache/flink/pull/25150#issuecomment-2265680671 ## CI report: * 548ffab03f77ac5c1c137c79b29b8912f3db9a69 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-35934) Add CompiledPlan annotations to BatchExecValues

2024-08-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35934: --- Labels: pull-request-available (was: ) > Add CompiledPlan annotations to BatchExecValues >

[PR] [FLINK-35934] Add CompiledPlan annotations to BatchExecValues (#1) [flink]

2024-08-02 Thread via GitHub
jnh5y opened a new pull request, #25150: URL: https://github.com/apache/flink/pull/25150 ## What is the purpose of the change * In addition to the annotations, implement a BatchRestoreTest for this operator. * Moves the ValuesTestPrograms to a common package for re-use between str

[jira] [Commented] (FLINK-34840) [3.1][pipeline-connectors] Add Implementation of DataSink in Iceberg.

2024-08-02 Thread Andrew Otto (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870577#comment-17870577 ] Andrew Otto commented on FLINK-34840: - I would love to see this!  At the Wikimedia F

Re: [PR] [FLINK-35969][state] Remove deprecated dataset based API from State Processor API [flink]

2024-08-02 Thread via GitHub
flinkbot commented on PR #25149: URL: https://github.com/apache/flink/pull/25149#issuecomment-2265557660 ## CI report: * 13ee40c5fdad32dd273464ea1623c46922cb63f1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-35969) Remove deprecated dataset based API from State Processor API

2024-08-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35969: --- Labels: pull-request-available (was: ) > Remove deprecated dataset based API from State Pro

[PR] [FLINK-35969][state] Remove deprecated dataset based API from State Processor API [flink]

2024-08-02 Thread via GitHub
gaborgsomogyi opened a new pull request, #25149: URL: https://github.com/apache/flink/pull/25149 ## What is the purpose of the change This PR removes deprecated dataset based API from State Processor API. ## Brief change log Remove deprecated dataset based API from State

[jira] [Closed] (FLINK-26050) Too many small sst files in rocksdb state backend when using time window created in ascending order

2024-08-02 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-26050. - Resolution: Fixed Merged as [cd722033fb326837a80a6233603d12ad176da15c|https://github.co

[jira] [Updated] (FLINK-35970) Update documentation about FLINK-26050 (merging small SST files)

2024-08-02 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35970: -- Summary: Update documentation about FLINK-26050 (merging small SST files) (was: Updat

[jira] [Updated] (FLINK-26050) Too many small sst files in rocksdb state backend when using time window created in ascending order

2024-08-02 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-26050: -- Fix Version/s: 1.20.0 (was: 2.0.0) > Too many small sst files i

[jira] [Comment Edited] (FLINK-26050) Too many small sst files in rocksdb state backend when using time window created in ascending order

2024-08-02 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870541#comment-17870541 ] Roman Khachatryan edited comment on FLINK-26050 at 8/2/24 2:29 PM: ---

[jira] [Commented] (FLINK-26050) Too many small sst files in rocksdb state backend when using time window created in ascending order

2024-08-02 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870541#comment-17870541 ] Roman Khachatryan commented on FLINK-26050: --- [~Weijie Guo] I created a separat

[jira] [Comment Edited] (FLINK-26050) Too many small sst files in rocksdb state backend when using time window created in ascending order

2024-08-02 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870541#comment-17870541 ] Roman Khachatryan edited comment on FLINK-26050 at 8/2/24 2:29 PM: ---

[jira] [Created] (FLINK-35970) Update documentation about FLINK-26050 (small file compaction)

2024-08-02 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-35970: - Summary: Update documentation about FLINK-26050 (small file compaction) Key: FLINK-35970 URL: https://issues.apache.org/jira/browse/FLINK-35970 Project: Fli

Re: [PR] [FLINK-35877] Shade protobuf in flink [flink]

2024-08-02 Thread via GitHub
wuchong commented on PR #25112: URL: https://github.com/apache/flink/pull/25112#issuecomment-2265359276 Hi @MartijnVisser , This is mainly for shading protobuf dependency in SQL format jars (ORC, protobuf) and flink-python. They are all not in the default distribution. So no changes in Flin

[jira] [Assigned] (FLINK-35877) Shade protobuf in flink

2024-08-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-35877: --- Assignee: zhuanshenbsj1 > Shade protobuf in flink > --- > > Key

[jira] [Updated] (FLINK-35877) Shade protobuf in flink

2024-08-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-35877: Fix Version/s: 2.0.0 (was: 1.19.2) > Shade protobuf in flink >

[jira] [Updated] (FLINK-35877) Shade protobuf in flink

2024-08-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-35877: Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) (was: BuildSystem / Shad

Re: [PR] [FLINK-35950][docker] Update Dockerfiles for 1.20.0 release [flink-docker]

2024-08-02 Thread via GitHub
reswqa commented on PR #200: URL: https://github.com/apache/flink-docker/pull/200#issuecomment-2265293796 Hi @EladLeev,thanks for reminding me, otherwise I wouldn't have noticed this. But this image is uploaded by docker official, would you mind also posting this issue to https://gith

Re: [PR] [FLINK-35950][docker] Update Dockerfiles for 1.20.0 release [flink-docker]

2024-08-02 Thread via GitHub
EladLeev commented on PR #200: URL: https://github.com/apache/flink-docker/pull/200#issuecomment-2265216886 Hey @reswqa @1996fanrui -- have you noticed that the `amd` build is missing? It's in the metadata file, but not on Docker Hub: https://github.com/user-attachments/assets/473d2794-d4

[jira] [Assigned] (FLINK-35969) Remove deprecated dataset based API from State Processor API

2024-08-02 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-35969: - Assignee: Gabor Somogyi > Remove deprecated dataset based API from State Processor API

[jira] [Created] (FLINK-35969) Remove deprecated dataset based API from State Processor API

2024-08-02 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-35969: - Summary: Remove deprecated dataset based API from State Processor API Key: FLINK-35969 URL: https://issues.apache.org/jira/browse/FLINK-35969 Project: Flink

Re: [PR] [hotfix] Fix npm issue in document Build [flink]

2024-08-02 Thread via GitHub
rmetzger commented on PR #25147: URL: https://github.com/apache/flink/pull/25147#issuecomment-2265125302 Minor note: the commit message does not include the `[hotfix]` prefix. I don't understand how this change is fixing the npm build issue. Can you explain? -- This is an automated

[jira] [Closed] (FLINK-35933) Skip distributing maxAllowedWatermark if there are no subtasks

2024-08-02 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-35933. - Resolution: Fixed cdf43aecafa33a50a4b4b6841c4cf505b195994a > Skip distributing maxAllow

Re: [PR] [FLINK-35933] Skip distributing maxAllowedWatermark if there are no subtasks [flink]

2024-08-02 Thread via GitHub
rkhachatryan merged PR #25136: URL: https://github.com/apache/flink/pull/25136 -- 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] [Commented] (FLINK-35968) Remove flink-cdc-runtime depedency from connectors

2024-08-02 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870454#comment-17870454 ] Jiabao Sun commented on FLINK-35968: Thanks [~loserwang1024] for the volunteering, a

[jira] [Assigned] (FLINK-35968) Remove flink-cdc-runtime depedency from connectors

2024-08-02 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-35968: -- Assignee: Hongshun Wang > Remove flink-cdc-runtime depedency from connectors > --

[jira] [Commented] (FLINK-35968) Remove flink-cdc-runtime depedency from connectors

2024-08-02 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870453#comment-17870453 ] Hongshun Wang commented on FLINK-35968: --- [~Leonard] , [~ruanhang1993] , [~jiabaosu

[jira] [Created] (FLINK-35968) Remove flink-cdc-runtime depedency from connectors

2024-08-02 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-35968: - Summary: Remove flink-cdc-runtime depedency from connectors Key: FLINK-35968 URL: https://issues.apache.org/jira/browse/FLINK-35968 Project: Flink Issue Ty

Re: [PR] [tests][cdc-connectors][mongo] Fix unstable test cases for snapshot back-filling [flink-cdc]

2024-08-02 Thread via GitHub
yuxiqian commented on PR #3506: URL: https://github.com/apache/flink-cdc/pull/3506#issuecomment-2265007350 Could @Jiabao-Sun @loserwang1024 please take a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

Re: [PR] [FLINK-35344][cdc-base] Move same code from multiple subclasses to JdbcSourceChunkSplitter [flink-cdc]

2024-08-02 Thread via GitHub
ruanhang1993 merged PR #3319: URL: https://github.com/apache/flink-cdc/pull/3319 -- 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...@flin

Re: [PR] [FLINK-35953][release] Update japicmp configuration for 1.20.0 [flink]

2024-08-02 Thread via GitHub
flinkbot commented on PR #25148: URL: https://github.com/apache/flink/pull/25148#issuecomment-2264988127 ## CI report: * 603514127980c4ad15105353a62e061bc18a3f7f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-35953][release] Update japicmp configuration for 1.20.0 [flink]

2024-08-02 Thread via GitHub
reswqa opened a new pull request, #25148: URL: https://github.com/apache/flink/pull/25148 (no comment) -- 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-mai

[jira] [Resolved] (FLINK-35957) Other announcements

2024-08-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-35957. Resolution: Done > Other announcements > --- > > Key: FLINK-35957

[jira] [Resolved] (FLINK-35954) Merge website pull request

2024-08-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-35954. Resolution: Done > Merge website pull request > -- > > Key

Re: [PR] [hotfix] Fix npm issue in document Build [flink]

2024-08-02 Thread via GitHub
flinkbot commented on PR #25147: URL: https://github.com/apache/flink/pull/25147#issuecomment-2264953408 ## CI report: * 77a55b95c7f6fd9bbd767dbf275e69822aeead47 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Resolved] (FLINK-35956) Apache mailing lists announcements

2024-08-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-35956. Resolution: Done > Apache mailing lists announcements > -- > >

Re: [PR] [FLINK-35931][table] Add REGEXP_EXTRACT_ALL function [flink]

2024-08-02 Thread via GitHub
dylanhz commented on PR #25137: URL: https://github.com/apache/flink/pull/25137#issuecomment-2264916761 @flinkbot run azure -- 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-35963][table] Add REGEXP_SUBSTR function [flink]

2024-08-02 Thread via GitHub
dylanhz commented on PR #25146: URL: https://github.com/apache/flink/pull/25146#issuecomment-2264915459 @flinkbot run azure -- 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.

[PR] [hotfix] Fix npm issue in document Build [flink]

2024-08-02 Thread via GitHub
Samrat002 opened a new pull request, #25147: URL: https://github.com/apache/flink/pull/25147 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

Re: [PR] [FLINK-35858][State] Default namespace in async state [flink]

2024-08-02 Thread via GitHub
Zakelly commented on code in PR #25135: URL: https://github.com/apache/flink/pull/25135#discussion_r1701529111 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java: ## @@ -179,9 +181,12 @@ public

Re: [PR] Rebuild website [flink-web]

2024-08-02 Thread via GitHub
1996fanrui merged PR #752: URL: https://github.com/apache/flink-web/pull/752 -- 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.ap

[jira] [Comment Edited] (FLINK-35678) [Release-1.20] Review and update documentation

2024-08-02 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870069#comment-17870069 ] Rui Fan edited comment on FLINK-35678 at 8/2/24 8:33 AM: - Merged

[jira] [Resolved] (FLINK-35678) [Release-1.20] Review and update documentation

2024-08-02 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35678. - Resolution: Fixed > [Release-1.20] Review and update documentation > ---

Re: [PR] [FLINK-35678][doc] Update compatibility matrix for 1.20 release [flink]

2024-08-02 Thread via GitHub
1996fanrui merged PR #25140: URL: https://github.com/apache/flink/pull/25140 -- 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.ap

Re: [PR] [FLINK-35912] SqlServer CDC doesn't chunk UUID-typed columns correctly [flink-cdc]

2024-08-02 Thread via GitHub
GOODBOY008 commented on PR #3497: URL: https://github.com/apache/flink-cdc/pull/3497#issuecomment-2264851637 @LiPL2017 I make some change about uuid compare method by refering to MS source code. Can you doule check ? -- This is an automated message from the Apache Git Service. To respond

[PR] Rebuild website [flink-web]

2024-08-02 Thread via GitHub
1996fanrui opened a new pull request, #752: URL: https://github.com/apache/flink-web/pull/752 Rebuild website for 1.20 announcement. -- 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 c

Re: [PR] [FLINK-35858][State] Default namespace in async state [flink]

2024-08-02 Thread via GitHub
fredia commented on code in PR #25135: URL: https://github.com/apache/flink/pull/25135#discussion_r1701487658 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java: ## @@ -179,9 +181,12 @@ public

Re: [PR] [FLINK-35931][table] Add REGEXP_EXTRACT_ALL function [flink]

2024-08-02 Thread via GitHub
dylanhz commented on code in PR #25137: URL: https://github.com/apache/flink/pull/25137#discussion_r1701484163 ## docs/data/sql_functions.yml: ## @@ -304,7 +304,13 @@ string: not exceed the number of the defined groups. E.g. REGEXP_EXTRACT('foothebar', 'foo(.*?)(

Re: [PR] [FLINK-35877] Shade protobuf in flink [flink]

2024-08-02 Thread via GitHub
zhuanshenbsj1 commented on PR #25112: URL: https://github.com/apache/flink/pull/25112#issuecomment-2264822929 > Thanks for the contribution. I left 2 minor comments. Done~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [FLINK-35344][cdc-base] Move same code from multiple subclasses to JdbcSourceChunkSplitter [flink-cdc]

2024-08-02 Thread via GitHub
loserwang1024 commented on PR #3319: URL: https://github.com/apache/flink-cdc/pull/3319#issuecomment-2264818839 Just rebase this pr to master. -- 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

[jira] [Commented] (FLINK-35965) Add ENDSWITH function

2024-08-02 Thread Eaugene Thomas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870403#comment-17870403 ] Eaugene Thomas commented on FLINK-35965: Sure [~dylanhz]  > Add ENDSWITH functi

Re: [PR] [FLINK-35931][table] Add REGEXP_EXTRACT_ALL function [flink]

2024-08-02 Thread via GitHub
superdiaodiao commented on code in PR #25137: URL: https://github.com/apache/flink/pull/25137#discussion_r1701430328 ## docs/data/sql_functions.yml: ## @@ -304,7 +304,13 @@ string: not exceed the number of the defined groups. E.g. REGEXP_EXTRACT('foothebar', 'foo

Re: [PR] [FLINK-35931][table] Add REGEXP_EXTRACT_ALL function [flink]

2024-08-02 Thread via GitHub
superdiaodiao commented on code in PR #25137: URL: https://github.com/apache/flink/pull/25137#discussion_r1701430328 ## docs/data/sql_functions.yml: ## @@ -304,7 +304,13 @@ string: not exceed the number of the defined groups. E.g. REGEXP_EXTRACT('foothebar', 'foo

[jira] [Comment Edited] (FLINK-35864) Add CONV function

2024-08-02 Thread Dylan He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867725#comment-17867725 ] Dylan He edited comment on FLINK-35864 at 8/2/24 7:22 AM: -- The

Re: [PR] [FLINK-35963][table] Add REGEXP_SUBSTR function [flink]

2024-08-02 Thread via GitHub
luotianyou349 commented on PR #25146: URL: https://github.com/apache/flink/pull/25146#issuecomment-2264734633 Wow! -- 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 unsubs

Re: [PR] [FLINK-35847] Add 1.20 release announcement [flink-web]

2024-08-02 Thread via GitHub
reswqa merged PR #751: URL: https://github.com/apache/flink-web/pull/751 -- 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.apache