spoon-lz commented on code in PR #24374:
URL: https://github.com/apache/flink/pull/24374#discussion_r1612844096
##
flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java:
##
@@ -438,4 +445,332 @@ public class CheckpointingOptions {
[
https://issues.apache.org/jira/browse/FLINK-35431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-35431.
Resolution: Fixed
Fixed via
master:644b5c2ce1dea17df93bac6ddf5afd816c33fffb
[
https://issues.apache.org/jira/browse/FLINK-35431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35431:
---
Fix Version/s: cdc-3.2.0
> Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0
>
[
https://issues.apache.org/jira/browse/FLINK-35431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35431:
--
Assignee: Zhongqiang Gong
> Migrate references in Flink CDC documentation from Debezium 1.9
leonardBang merged PR #3353:
URL: https://github.com/apache/flink-cdc/pull/3353
--
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:
[
https://issues.apache.org/jira/browse/FLINK-35434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu reassigned FLINK-35434:
Assignee: Feifan Wang
> Support pass exception in StateExecutor to runtime
>
[
https://issues.apache.org/jira/browse/FLINK-35067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849161#comment-17849161
]
Hongshun Wang commented on FLINK-35067:
---
[~walls.flink.m], I hope you’re doing well. I’ve been
[
https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849160#comment-17849160
]
Weijie Guo commented on FLINK-35342:
1.20 test_cron_adaptive_scheduler:
[
https://issues.apache.org/jira/browse/FLINK-35443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35443:
---
Description:
{code:java}
May 24 01:55:13 01:55:13.114 [ERROR] Error occurred in starting fork,
Weijie Guo created FLINK-35443:
--
Summary: ChangelogLocalRecoveryITCase failed fatally with 239 exit
code
Key: FLINK-35443
URL: https://issues.apache.org/jira/browse/FLINK-35443
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35443:
---
Description:
{code:java}
May 24 01:55:13 01:55:13.115 [ERROR]at
masteryhx commented on code in PR #24833:
URL: https://github.com/apache/flink/pull/24833#discussion_r1612797978
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStWriteBatchOperation.java:
##
@@ -75,7 +74,10 @@ public
Zakelly closed pull request #24817: [FLINK-35400][checkpoint] Release
FileMergingSnapshotManager if all tasks finished
URL: https://github.com/apache/flink/pull/24817
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
19priyadhingra commented on code in PR #141:
URL:
https://github.com/apache/flink-connector-aws/pull/141#discussion_r1612742339
##
flink-connector-aws/pom.xml:
##
@@ -18,8 +18,8 @@ specific language governing permissions and limitations
under the License.
-->
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849151#comment-17849151
]
Roman Boyko edited comment on FLINK-34380 at 5/24/24 4:18 AM:
--
Hi
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849151#comment-17849151
]
Roman Boyko edited comment on FLINK-34380 at 5/24/24 4:17 AM:
--
Hi
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849151#comment-17849151
]
Roman Boyko commented on FLINK-34380:
-
Hi [~xu_shuai_] , [~xuyangzhong] !
I still think that
LvYanquan created FLINK-35442:
-
Summary: Kafka Pipeline Sink may distribute the same key to
different partitions after modify parallelism
Key: FLINK-35442
URL: https://issues.apache.org/jira/browse/FLINK-35442
leonardBang merged PR #3354:
URL: https://github.com/apache/flink-cdc/pull/3354
--
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:
[
https://issues.apache.org/jira/browse/FLINK-35347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849147#comment-17849147
]
dalongliu commented on FLINK-35347:
---
Merged in master: 71e6746727aaa57a6082f91576365807fa51b478
>
[
https://issues.apache.org/jira/browse/FLINK-35347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu resolved FLINK-35347.
---
Resolution: Fixed
> Implement InMemory workflow scheduler service and plugin to support
>
lsyldliu merged PR #24821:
URL: https://github.com/apache/flink/pull/24821
--
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:
GOODBOY008 commented on PR #3354:
URL: https://github.com/apache/flink-cdc/pull/3354#issuecomment-2128434527
@leonardBang @PatrickRen @Jiabao-Sun 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
1996fanrui commented on code in PR #24757:
URL: https://github.com/apache/flink/pull/24757#discussion_r1612651502
##
flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java:
##
@@ -201,8 +201,11 @@ void announceCombinedWatermark() {
1996fanrui commented on code in PR #24757:
URL: https://github.com/apache/flink/pull/24757#discussion_r1612639848
##
flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java:
##
@@ -201,8 +201,11 @@ void announceCombinedWatermark() {
hk-lrzy closed pull request #3352: [FLINK-35432]Support catch modify event for
the mysql.
URL: https://github.com/apache/flink-cdc/pull/3352
--
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
qg-lin commented on code in PR #3347:
URL: https://github.com/apache/flink-cdc/pull/3347#discussion_r1612629152
##
1996fanrui commented on code in PR #24717:
URL: https://github.com/apache/flink/pull/24717#discussion_r1612625523
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/NoFetchingInput.java:
##
@@ -114,18 +117,26 @@ public void readBytes(byte[] bytes, int
[
https://issues.apache.org/jira/browse/FLINK-35441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35441:
--
Assignee: yux
> Add CDC upgrade compatibility tests
> ---
>
Zakelly commented on PR #24810:
URL: https://github.com/apache/flink/pull/24810#issuecomment-2128382654
@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.
[
https://issues.apache.org/jira/browse/FLINK-35441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yux updated FLINK-35441:
Issue Type: Improvement (was: Bug)
> Add CDC upgrade compatibility tests
> ---
>
flinkbot commented on PR #24837:
URL: https://github.com/apache/flink/pull/24837#issuecomment-2128364710
## CI report:
* b1a349c36c4cc2024163df8b7fc1c0526889eb4f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849142#comment-17849142
]
yux commented on FLINK-35441:
-
[~renqs] I'd love to take this ticket if needed.
> Add CDC upgrade
yux created FLINK-35441:
---
Summary: Add CDC upgrade compatibility tests
Key: FLINK-35441
URL: https://issues.apache.org/jira/browse/FLINK-35441
Project: Flink
Issue Type: Bug
Components:
1996fanrui opened a new pull request, #24837:
URL: https://github.com/apache/flink/pull/24837
## What is the purpose of the change
add the demo from
[FLINK-34954](https://issues.apache.org/jira/browse/FLINK-34954) as a test to
prevent this bug happens in the future.
##
loserwang1024 commented on code in PR #3347:
URL: https://github.com/apache/flink-cdc/pull/3347#discussion_r1612579029
##
liuyongvs commented on code in PR #24526:
URL: https://github.com/apache/flink/pull/24526#discussion_r1612588115
##
.idea/vcs.xml:
##
@@ -22,4 +22,4 @@
Review Comment:
remoted @davidradl
--
This is an automated message from the Apache Git Service.
To
liuyongvs commented on code in PR #24526:
URL: https://github.com/apache/flink/pull/24526#discussion_r1612588115
##
.idea/vcs.xml:
##
@@ -22,4 +22,4 @@
Review Comment:
remoted
--
This is an automated message from the Apache Git Service.
To respond to the
liuyongvs commented on code in PR #24526:
URL: https://github.com/apache/flink/pull/24526#discussion_r1612587871
##
flink-python/pyflink/table/expression.py:
##
@@ -1618,6 +1618,15 @@ def array_except(self, array) -> 'Expression':
"""
return
liuyongvs commented on code in PR #24526:
URL: https://github.com/apache/flink/pull/24526#discussion_r1612586021
##
flink-python/pyflink/table/expression.py:
##
@@ -1618,6 +1618,15 @@ def array_except(self, array) -> 'Expression':
"""
return
liuyongvs commented on code in PR #24526:
URL: https://github.com/apache/flink/pull/24526#discussion_r1612586021
##
flink-python/pyflink/table/expression.py:
##
@@ -1618,6 +1618,15 @@ def array_except(self, array) -> 'Expression':
"""
return
[
https://issues.apache.org/jira/browse/FLINK-35221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia closed FLINK-35221.
Fix Version/s: hive-3.0.0
Assignee: Wencong Liu
Resolution: Fixed
> Support SQL 2011
[
https://issues.apache.org/jira/browse/FLINK-35221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849136#comment-17849136
]
luoyuxia commented on FLINK-35221:
--
master: bb9510914f7f2bfe3c19b40a6aaf658879dbd4c9
> Support SQL
boring-cyborg[bot] commented on PR #18:
URL:
https://github.com/apache/flink-connector-hive/pull/18#issuecomment-2128322457
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
luoyuxia merged PR #18:
URL: https://github.com/apache/flink-connector-hive/pull/18
--
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:
[
https://issues.apache.org/jira/browse/FLINK-35417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-35417:
--
Description:
flink is widely used in data integration scenarios, where a single concurrency
is not high, and
[
https://issues.apache.org/jira/browse/FLINK-35417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-35417:
--
Description: Spark is used in data integration scenarios (such as reading
data from mysql and writing data to
yuxiqian commented on code in PR #3357:
URL: https://github.com/apache/flink-cdc/pull/3357#discussion_r1612544048
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/JaninoCompiler.java:
##
@@ -298,4 +312,33 @@ private static Java.Rvalue
yuxiqian commented on code in PR #3357:
URL: https://github.com/apache/flink-cdc/pull/3357#discussion_r1612544048
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/JaninoCompiler.java:
##
@@ -298,4 +312,33 @@ private static Java.Rvalue
lsyldliu commented on code in PR #24821:
URL: https://github.com/apache/flink/pull/24821#discussion_r1612535733
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/workflow/scheduler/EmbeddedQuartzScheduler.java:
##
@@ -0,0 +1,228 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-35440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849132#comment-17849132
]
Zach commented on FLINK-35440:
--
After the above pull request, a new error is seen
lsyldliu commented on code in PR #24821:
URL: https://github.com/apache/flink/pull/24821#discussion_r1612532405
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/workflow/scheduler/QuartzSchedulerUtils.java:
##
@@ -0,0 +1,125 @@
+/*
+ * Licensed to
flinkbot commented on PR #24836:
URL: https://github.com/apache/flink/pull/24836#issuecomment-2128294022
## CI report:
* 7026b600c6bf0fd4b0225f946efa1ea3d5c4db7a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35440:
---
Labels: pull-request-available (was: )
> unable to connect tableau to jdbc flink url using
blaskovicz opened a new pull request, #24836:
URL: https://github.com/apache/flink/pull/24836
## What is the purpose of the change
Allow Tableau to connect to flink sql via jdbc driver. Currently, tableau
fails when FlinkConnection#isValid is called because it is not
Zach created FLINK-35440:
Summary: unable to connect tableau to jdbc flink url using flink
sql driver
Key: FLINK-35440
URL: https://issues.apache.org/jira/browse/FLINK-35440
Project: Flink
Issue
reta commented on PR #104:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/104#issuecomment-2128158649
> @reta and @snuyanzin Could you take a look?
Sure, I will do that within next few days, thank you @liuml07 !
--
This is an automated message from the Apache
reta commented on PR #104:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/104#issuecomment-2128158218
> Also I'm not sure how to fix the pre-check failure:
I think slight change to `[FLINK-35424] Elasticsearch connector 8 supports
SSL context` would make it pass
[
https://issues.apache.org/jira/browse/FLINK-35424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-35424:
--
Parent: FLINK-34369
Issue Type: Sub-task (was: Improvement)
> Elasticsearch
liuml07 commented on PR #104:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/104#issuecomment-2128004309
@reta and @snuyanzin Could you take a look?
Also I'm not sure how to fix the pre-check failure:
```
Title Validator — Wrong Commit title:
lihaosky commented on PR #24769:
URL: https://github.com/apache/flink/pull/24769#issuecomment-2127940071
@twalthr , does this repo have CI build? I can't see it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
lihaosky commented on code in PR #24769:
URL: https://github.com/apache/flink/pull/24769#discussion_r1612241200
##
tools/maven/suppressions-parser.xml:
##
@@ -0,0 +1,26 @@
+
+
+
+http://www.puppycrawl.com/dtds/suppressions_1_1.dtd;>
+
+
Review Comment:
I saw some other
lihaosky commented on code in PR #24769:
URL: https://github.com/apache/flink/pull/24769#discussion_r1612240751
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/FlinkPlannerImpl.scala:
##
@@ -147,6 +148,7 @@ class FlinkPlannerImpl(
flinkbot commented on PR #24835:
URL: https://github.com/apache/flink/pull/24835#issuecomment-2127917873
## CI report:
* e23f6d5c6a133afc8f7e8fadda7fbd64570c806f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
morazow commented on code in PR #3349:
URL: https://github.com/apache/flink-cdc/pull/3349#discussion_r1612232449
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDialect.java:
##
morazow commented on code in PR #3349:
URL: https://github.com/apache/flink-cdc/pull/3349#discussion_r1612231333
##
[
https://issues.apache.org/jira/browse/FLINK-35326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35326:
---
Labels: pull-request-available (was: )
> Implement lineage interface for hive connector
>
HuangZhenQiu opened a new pull request, #24835:
URL: https://github.com/apache/flink/pull/24835
## What is the purpose of the change
Implement LineageVertexProvider Interface for Hive connectors.
## Brief change log
- implement LineageVertexProvider in hive source,
liuml07 commented on PR #104:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/104#issuecomment-2127907729
@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
[
https://issues.apache.org/jira/browse/FLINK-34877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34877:
---
Labels: github-import pull-request-available (was: github-import)
> [Feature][Pipeline]
superdiaodiao commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1611984504
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to
davidradl commented on code in PR #24526:
URL: https://github.com/apache/flink/pull/24526#discussion_r1611987986
##
.idea/vcs.xml:
##
@@ -22,4 +22,4 @@
Review Comment:
can we remove this file from the pr
--
This is an automated message from the Apache
davidradl commented on code in PR #24526:
URL: https://github.com/apache/flink/pull/24526#discussion_r1611983897
##
flink-python/pyflink/table/expression.py:
##
@@ -1618,6 +1618,15 @@ def array_except(self, array) -> 'Expression':
"""
return
superdiaodiao commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1611984504
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to
davidradl commented on code in PR #24526:
URL: https://github.com/apache/flink/pull/24526#discussion_r1611982523
##
docs/data/sql_functions.yml:
##
@@ -688,6 +688,9 @@ collection:
- sql: ARRAY_EXCEPT(array1, array2)
table: arrayOne.arrayExcept(arrayTwo)
davidradl commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1611921523
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the
davidradl commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1611921523
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the
davidradl commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1611921523
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the
morazow commented on PR #24426:
URL: https://github.com/apache/flink/pull/24426#issuecomment-2127412535
Artifacts from new nightly run:
--
This is an
[
https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848998#comment-17848998
]
Muhammet Orazov commented on FLINK-34582:
-
At the moment the latest one for Linux is 3.10,
Greg Wills created FLINK-35439:
--
Summary: Python Support for AvroSchemaConverter
Key: FLINK-35439
URL: https://issues.apache.org/jira/browse/FLINK-35439
Project: Flink
Issue Type: Improvement
Ryan Skraba created FLINK-35438:
---
Summary: SourceCoordinatorTest.testErrorThrownFromSplitEnumerator
fails on wrong error
Key: FLINK-35438
URL: https://issues.apache.org/jira/browse/FLINK-35438
Project:
morazow commented on code in PR #24426:
URL: https://github.com/apache/flink/pull/24426#discussion_r1611819234
##
.github/workflows/nightly.yml:
##
@@ -94,3 +94,51 @@ jobs:
s3_bucket: ${{ secrets.IT_CASE_S3_BUCKET }}
s3_access_key: ${{
GOODBOY008 commented on PR #3353:
URL: https://github.com/apache/flink-cdc/pull/3353#issuecomment-2127288894
@leonardBang @PatrickRen 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
morazow commented on code in PR #24426:
URL: https://github.com/apache/flink/pull/24426#discussion_r1611807738
##
.github/workflows/nightly.yml:
##
@@ -94,3 +94,51 @@ jobs:
s3_bucket: ${{ secrets.IT_CASE_S3_BUCKET }}
s3_access_key: ${{
morazow commented on code in PR #24426:
URL: https://github.com/apache/flink/pull/24426#discussion_r1611806322
##
.github/workflows/nightly.yml:
##
@@ -94,3 +94,51 @@ jobs:
s3_bucket: ${{ secrets.IT_CASE_S3_BUCKET }}
s3_access_key: ${{
[
https://issues.apache.org/jira/browse/FLINK-35216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-35216.
Resolution: Implemented
Implemented in 0737220959fe52ee22535e7db55b015a46a6294e
>
dawidwys merged PR #24704:
URL: https://github.com/apache/flink/pull/24704
--
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:
snuyanzin commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1611771105
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-34901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-34901:
Summary: Update clause must EXCLUDED unique index (was: Improve the
performance of the update
[
https://issues.apache.org/jira/browse/FLINK-34901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-34901:
Description:
When writing Postgres data using flinke-connector-jdbc, using upsert mode, As
docs
Mrart commented on code in PR #108:
URL:
https://github.com/apache/flink-connector-jdbc/pull/108#discussion_r1611757713
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/AbstractPostgresCompatibleDialect.java:
##
@@ -56,6 +56,7 @@ public Optional
MartijnVisser commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1611754275
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to
He-Pin commented on PR #24823:
URL: https://github.com/apache/flink/pull/24823#issuecomment-2127181637
@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.
He-Pin closed pull request #24823: chore: Update pekko version
URL: https://github.com/apache/flink/pull/24823
--
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,
He-Pin commented on PR #24823:
URL: https://github.com/apache/flink/pull/24823#issuecomment-2127180445
@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.
davidradl commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1611739983
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/UrlDecodeFunction.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the
affo commented on PR #24471:
URL: https://github.com/apache/flink/pull/24471#issuecomment-2127135299
@XComp Hello!
Final touches done and your comments are addressed
I added the capability for `FromElementsSource` to accept a
`ElementsSupplier` at init phase.
The problem
yuxiqian commented on PR #3352:
URL: https://github.com/apache/flink-cdc/pull/3352#issuecomment-2127127618
Hi @hk-lrzy, thanks for your contribution! Missing of `MODIFY COLUMN` in
MySQL DDL parsing is a glitch and needs to be resolved.
As for downstream sink support, I'm currently
[
https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848958#comment-17848958
]
Muhammet Orazov commented on FLINK-34582:
-
Hello [~hxb] ,
Any idea why we don't also update
1 - 100 of 237 matches
Mail list logo
