rkhachatryan commented on code in PR #25235:
URL: https://github.com/apache/flink/pull/25235#discussion_r1734094772
##
docs/content/docs/deployment/filesystems/s3.md:
##
@@ -164,4 +164,38 @@ The `s3.entropy.key` defines the string in paths that is
replaced by the random
If a f
yuxiqian commented on code in PR #3579:
URL: https://github.com/apache/flink-cdc/pull/3579#discussion_r1734086952
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomAlterTableParse
lvyanquan commented on code in PR #3579:
URL: https://github.com/apache/flink-cdc/pull/3579#discussion_r1734076317
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlPipelineITCase.java:
#
[
https://issues.apache.org/jira/browse/FLINK-35992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872210#comment-17872210
]
Weijie Guo edited comment on FLINK-35992 at 8/28/24 6:32 AM:
-
reswqa merged PR #25190:
URL: https://github.com/apache/flink/pull/25190
--
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
leonardBang commented on code in PR #3580:
URL: https://github.com/apache/flink-cdc/pull/3580#discussion_r1734063361
##
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MysqlE2eITCase.java:
##
@@ -333,16 +335,32 @@ public void te
[
https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thorne updated FLINK-36165:
---
Description:
Just like Datax,user just obtain data from database without all snapshot data.
{code:java}
sele
[
https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thorne updated FLINK-36165:
---
Attachment: image-2024-08-28-14-06-40-501.png
> Support obtaining snapshot data of the scope
> -
[
https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thorne updated FLINK-36165:
---
Description:
just like datax，user just obtain data from database without all sna
{code:java}
select * from w
[
https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thorne updated FLINK-36165:
---
Description:
Just like datax,user just obtain data from database without all snapshot data.
{code:java}
sele
[
https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thorne updated FLINK-36165:
---
Description:
just like datax，user can
{code:java}
select * from where col >x1 and col x1 and col Support o
Thorne created FLINK-36165:
--
Summary: Support obtaining snapshot data of the scope
Key: FLINK-36165
URL: https://issues.apache.org/jira/browse/FLINK-36165
Project: Flink
Issue Type: Improvement
yuxiqian opened a new pull request, #3580:
URL: https://github.com/apache/flink-cdc/pull/3580
In order to test if pipeline job could correctly handle dangling
`DropTableEvent`s (those ones without preceding `CreateTableEvent`s) during
binlog reading phase, this PR uses `specific-offset` sta
wqshr12345 commented on code in PR #25233:
URL: https://github.com/apache/flink/pull/25233#discussion_r1734036768
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptorUtils.java:
##
@@ -0,0 +1,53 @@
+/*
+ * Licensed to the Apache Software Foundation (A
wqshr12345 commented on code in PR #25233:
URL: https://github.com/apache/flink/pull/25233#discussion_r1734037008
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/adaptor/AsyncKeyedStateBackendAdaptor.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Softw
snuyanzin commented on PR #24545:
URL: https://github.com/apache/flink/pull/24545#issuecomment-2314345081
@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.
yuxiqian opened a new pull request, #3579:
URL: https://github.com/apache/flink-cdc/pull/3579
Currently, it is possible to parse correct CreateTableEvents from Binlog
with the following syntax:
```sql
CREATE TABLE table1 (
id INT,
... -- other columns
PRIMARY KEY
flinkbot commented on PR #25259:
URL: https://github.com/apache/flink/pull/25259#issuecomment-2314130250
## CI report:
* 84690a5819122d7cce9381f6aa364415ff7e25df UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tchivs updated FLINK-36164:
---
Description:
What's Wrong?
When synchronizing a PostgreSQL table using a connector, if the table contains
a
[
https://issues.apache.org/jira/browse/FLINK-36164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tchivs updated FLINK-36164:
---
Attachment: image-2024-08-28-11-28-21-496.png
> JdbcIncrementalSource CheckPoint Timeout Due to Retrieving S
[
https://issues.apache.org/jira/browse/FLINK-36164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tchivs updated FLINK-36164:
---
Attachment: image-2024-08-28-11-28-33-016.png
> JdbcIncrementalSource CheckPoint Timeout Due to Retrieving S
[
https://issues.apache.org/jira/browse/FLINK-36164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tchivs updated FLINK-36164:
---
Description:
What's Wrong?
When synchronizing a PostgreSQL table using a connector, if the table contains
a
morozov commented on PR #24692:
URL: https://github.com/apache/flink/pull/24692#issuecomment-2314127171
@GOODBOY008, please see https://github.com/apache/flink/pull/25259.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
morozov opened a new pull request, #25259:
URL: https://github.com/apache/flink/pull/25259
This is a backport of https://github.com/apache/flink/pull/24692.
--
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
[
https://issues.apache.org/jira/browse/FLINK-36164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tchivs updated FLINK-36164:
---
Description:
What's Wrong?
When synchronizing a PostgreSQL table using a connector, if the table contains
a
[
https://issues.apache.org/jira/browse/FLINK-36164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tchivs updated FLINK-36164:
---
Description:
When synchronizing a PostgreSQL table using a connector, if the table contains
a large number
tchivs created FLINK-36164:
--
Summary: JdbcIncrementalSource CheckPoint Timeout Due to
Retrieving Schemas for All Subpartitions When Synchronizing a Partitioned
PostgreSQL Table
Key: FLINK-36164
URL: https://issues.apach
mayuehappy commented on PR #25253:
URL: https://github.com/apache/flink/pull/25253#issuecomment-2314121275
@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
Hongshun Wang created FLINK-36163:
-
Summary: Kafka cdc pipeline source supports protobuf format.
Key: FLINK-36163
URL: https://issues.apache.org/jira/browse/FLINK-36163
Project: Flink
Issue T
GOODBOY008 commented on PR #24692:
URL: https://github.com/apache/flink/pull/24692#issuecomment-2314102983
@morozov Can you open another pr to branch `release-1.20` ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-35177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhongqiang Gong resolved FLINK-35177.
-
Fix Version/s: 2.0.0
Resolution: Fixed
Merged to branch: Master , Via : bc3afba5c
GOODBOY008 commented on PR #24692:
URL: https://github.com/apache/flink/pull/24692#issuecomment-2314045037
@morozov LGTM
--
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
GOODBOY008 merged PR #24692:
URL: https://github.com/apache/flink/pull/24692
--
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
[
https://issues.apache.org/jira/browse/FLINK-35599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35599:
---
Labels: pull-request-available (was: )
> Add JDBC Sink Plugin to Flink-CDC-Pipeline
> -
cobolbaby commented on PR #3433:
URL: https://github.com/apache/flink-cdc/pull/3433#issuecomment-2313956284
Does it only support jdbc-mysql? Can the jdbc be extended to a general sink
connector?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-35917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangkang updated FLINK-35917:
-
Description:
it occurred during the full to incremental phase:
Caused by: java.lang.RuntimeException: O
leonardBang commented on code in PR #3578:
URL: https://github.com/apache/flink-cdc/pull/3578#discussion_r1733762640
##
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/RouteE2eITCase.java:
##
@@ -719,6 +718,11 @@ public void tes
[
https://issues.apache.org/jira/browse/FLINK-35917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangkang updated FLINK-35917:
-
Description: Caused by: java.lang.RuntimeException: One or more fetchers
have encountered exception at
ChengJie1053 commented on PR #3445:
URL: https://github.com/apache/flink-cdc/pull/3445#issuecomment-2313885858
> @ChengJie1053 - do you have the privilege to approve the workflows?
I'm sorry. I don't have that clearance
--
This is an automated message from the Apache Git Service
yuxiqian commented on code in PR #3578:
URL: https://github.com/apache/flink-cdc/pull/3578#discussion_r1733730877
##
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/RouteE2eITCase.java:
##
@@ -719,6 +718,11 @@ public void testMe
github-actions[bot] commented on PR #3286:
URL: https://github.com/apache/flink-cdc/pull/3286#issuecomment-2313776592
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.
--
[
https://issues.apache.org/jira/browse/FLINK-35718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35718:
---
Labels: pull-request-available (was: )
> Cherrypick DBZ-5333 to fix frequently failover by
github-actions[bot] commented on PR #3440:
URL: https://github.com/apache/flink-cdc/pull/3440#issuecomment-2313776551
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.
--
jeyhunkarimov commented on PR #24997:
URL: https://github.com/apache/flink/pull/24997#issuecomment-2313665000
@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
klam-shop commented on code in PR #109:
URL:
https://github.com/apache/flink-connector-kafka/pull/109#discussion_r1733569499
##
flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableITCase.java:
##
@@ -188,6 +188,120 @@ public void test
klam-shop commented on code in PR #109:
URL:
https://github.com/apache/flink-connector-kafka/pull/109#discussion_r1733569499
##
flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableITCase.java:
##
@@ -188,6 +188,120 @@ public void test
[
https://issues.apache.org/jira/browse/FLINK-36162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877194#comment-17877194
]
Thomas Weise commented on FLINK-36162:
--
[~gyfora] I was surprised when you closed y
zakhalex commented on PR #3445:
URL: https://github.com/apache/flink-cdc/pull/3445#issuecomment-2313494810
@ChengJie1053 - do you have the privilege to approve the workflows?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-36056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36056.
Resolution: Fixed
fixed in master(3.2-SNAPSHOT): ab64eb3b574ebbeb81cf6b6500acbd211eea39ab
> chang
[
https://issues.apache.org/jira/browse/FLINK-36082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874876#comment-17874876
]
Leonard Xu edited comment on FLINK-36082 at 8/27/24 5:02 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36082.
Resolution: Fixed
> Fix NotSerializableException for KafkaDataSink
> -
[
https://issues.apache.org/jira/browse/FLINK-36076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36076.
Resolution: Fixed
> Hotfix: Set isSchemaChangeApplying as volatile for thread safe.
>
[
https://issues.apache.org/jira/browse/FLINK-36088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36088.
Resolution: Fixed
> Fix NPE in PaimonDataSink.
> --
>
> Ke
[
https://issues.apache.org/jira/browse/FLINK-36076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874940#comment-17874940
]
Leonard Xu edited comment on FLINK-36076 at 8/27/24 5:01 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874938#comment-17874938
]
Leonard Xu edited comment on FLINK-36088 at 8/27/24 5:01 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875326#comment-17875326
]
Leonard Xu edited comment on FLINK-36081 at 8/27/24 5:00 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36094.
Resolution: Fixed
fixed master: 6205a5a0f16d2cf72ff751573351c4e15ea59efb
release-3.2: 5a80757443e
[
https://issues.apache.org/jira/browse/FLINK-36081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36081:
---
Fix Version/s: cdc-3.2.0
> Flink CDC MySQL source connector missing some columns data of newly added
[
https://issues.apache.org/jira/browse/FLINK-36092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875826#comment-17875826
]
Leonard Xu edited comment on FLINK-36092 at 8/27/24 4:57 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875816#comment-17875816
]
Leonard Xu edited comment on FLINK-36114 at 8/27/24 4:58 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-35056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876041#comment-17876041
]
Leonard Xu edited comment on FLINK-35056 at 8/27/24 4:56 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-35056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-35056.
Resolution: Fixed
> when initial sqlserver table that's primary key is datetime type, it
> org.a
[
https://issues.apache.org/jira/browse/FLINK-36128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36128.
Resolution: Fixed
master: 2e938a92f5335515f7eb46077254aee25acd9107
release-3.2: debd43cdd75eb53ce
[
https://issues.apache.org/jira/browse/FLINK-36128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36128:
---
Fix Version/s: cdc-3.3.0
> The in-flight data will meet unrecoverable issue when restore from checkp
leonardBang commented on PR #3568:
URL: https://github.com/apache/flink-cdc/pull/3568#issuecomment-2313070670
Thanks @leosanqing for the contribution, could you also check other
connectors? I think some start up mode of debezium should not pass to
underlying debeziunm engine once the Flink
leonardBang merged PR #3566:
URL: https://github.com/apache/flink-cdc/pull/3566
--
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
[
https://issues.apache.org/jira/browse/FLINK-36150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36150.
Resolution: Fixed
master: afe9c3c0adb77594565b24c004daa6385d50d5fc
3.2: todo
> tables.exclude is
leonardBang merged PR #3577:
URL: https://github.com/apache/flink-cdc/pull/3577
--
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
leonardBang merged PR #3573:
URL: https://github.com/apache/flink-cdc/pull/3573
--
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
[
https://issues.apache.org/jira/browse/FLINK-36150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36150:
--
Assignee: Hongshun Wang
> tables.exclude is not valid if scan.binlog.newly-added-table.enable
[
https://issues.apache.org/jira/browse/FLINK-36150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36150:
---
Issue Type: Bug (was: Improvement)
> tables.exclude is not valid if scan.binlog.newly-added-table.e
[
https://issues.apache.org/jira/browse/FLINK-36162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877086#comment-17877086
]
Gyula Fora commented on FLINK-36162:
cc [~thw]
> Remove flinkStateSnapshotReferenc
[
https://issues.apache.org/jira/browse/FLINK-36145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877085#comment-17877085
]
Gyula Fora commented on FLINK-36145:
I will probably close this in favour of
https:
gyfora closed pull request #873: [FLINK-36145] Rename
flinkStateSnapshotReference to initialState
URL: https://github.com/apache/flink-kubernetes-operator/pull/873
--
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
Gyula Fora created FLINK-36162:
--
Summary: Remove flinkStateSnapshotReference and namespace from
FlinkStateSnapshot jobReference
Key: FLINK-36162
URL: https://issues.apache.org/jira/browse/FLINK-36162
Pro
gyfora commented on PR #873:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/873#issuecomment-2312807325
Actually @tweise @mateczagany , I have a slight concern about this
initialState reference field overall. It may make sense to simply keep the
current `initialSavepointPath
GOODBOY008 commented on code in PR #24692:
URL: https://github.com/apache/flink/pull/24692#discussion_r1733042779
##
flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/source/DataGeneratorSource.java:
##
@@ -76,14 +76,14 @@
* Long values
gyfora commented on PR #870:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/870#issuecomment-2312765821
I have opened a new PR with the further shortened `initialState` version
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
gyfora opened a new pull request, #873:
URL: https://github.com/apache/flink-kubernetes-operator/pull/873
## What is the purpose of the change
Rename JobSpec.flinkStateSnapshotReference to JobSpec.initialState. This
should make less verbose and easier to memorize for users.
fl
[
https://issues.apache.org/jira/browse/FLINK-35790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-35790.
Fix Version/s: 2.0.0
Assignee: Sergio Peña
Resolution: Fixed
Fixed in master: 8c11
twalthr merged PR #25238:
URL: https://github.com/apache/flink/pull/25238
--
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
[
https://issues.apache.org/jira/browse/FLINK-35708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-35708.
Fix Version/s: 2.0.0
Resolution: Fixed
Fixed in master: c1fa29ac91aeef64701d8d97b13644a4267
twalthr merged PR #25247:
URL: https://github.com/apache/flink/pull/25247
--
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
flinkbot commented on PR #25258:
URL: https://github.com/apache/flink/pull/25258#issuecomment-2312648935
## CI report:
* 65a84f3a32e91294c6227f460c6ce97bc0d73868 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Wolff Bock von Wuelfingen created FLINK-36161:
-
Summary: Integration Test Example uses deprecated SinkFunction
Key: FLINK-36161
URL: https://issues.apache.org/jira/browse/FLINK-36161
Projec
zhuanshenbsj1 opened a new pull request, #25258:
URL: https://github.com/apache/flink/pull/25258
## 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 t
zhuanshenbsj1 created FLINK-36160:
-
Summary: Support hive advanced configuration
Key: FLINK-36160
URL: https://issues.apache.org/jira/browse/FLINK-36160
Project: Flink
Issue Type: Improvement
leonardBang commented on PR #3566:
URL: https://github.com/apache/flink-cdc/pull/3566#issuecomment-2312518458
Thanks @yuxiqian for the backport, all CI passed, I'll organize the commits
and merge it soon.
--
This is an automated message from the Apache Git Service.
To respond to the messa
gaborgsomogyi commented on code in PR #25231:
URL: https://github.com/apache/flink/pull/25231#discussion_r1732814002
##
flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/writer/S3RecoverableFsDataOutputStream.java:
##
@@ -129,10 +129,9 @@ public void
gaborgsomogyi commented on code in PR #25231:
URL: https://github.com/apache/flink/pull/25231#discussion_r1732792672
##
flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/writer/S3RecoverableFsDataOutputStream.java:
##
@@ -129,10 +129,9 @@ public void
spena commented on code in PR #25247:
URL: https://github.com/apache/flink/pull/25247#discussion_r1732752338
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/MergeTableAsUtil.java:
##
@@ -63,9 +79,90 @@ public class MergeTableAsUtil {
mayuehappy commented on PR #25253:
URL: https://github.com/apache/flink/pull/25253#issuecomment-2312392245
@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
Zakelly commented on code in PR #25192:
URL: https://github.com/apache/flink/pull/25192#discussion_r1732616249
##
flink-runtime-web/src/test/resources/rest_api_v1.snapshot:
##
@@ -4190,4 +4190,4 @@
}
}
} ]
-}
Review Comment:
Ah, it's better to revert this chan
zhuzhurk closed pull request #25219: [FLINK-36063][runtime] Migrate StreamGraph
and its related classes from flink-streaming-java to flink-runtime.
URL: https://github.com/apache/flink/pull/25219
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
[
https://issues.apache.org/jira/browse/FLINK-36063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-36063.
---
Fix Version/s: 2.0.0
Resolution: Fixed
master: 51f1684be0214a1a8c47ffb4ae20b6ebf6f0fc0c
> Migrate St
pnowojski commented on PR #25246:
URL: https://github.com/apache/flink/pull/25246#issuecomment-2312192390
Thanks @rkhachatryan for looking into this. Let's try without reverting.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
pnowojski commented on PR #25245:
URL: https://github.com/apache/flink/pull/25245#issuecomment-2312186890
Thanks @rkhachatryan for looking into this. Let's try without reverting.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
pnowojski commented on code in PR #25245:
URL: https://github.com/apache/flink/pull/25245#discussion_r1732604961
##
pom.xml:
##
@@ -2355,8 +2355,6 @@ under the License.
@org.apache.flink.annotation.Experimental
Zakelly commented on code in PR #25233:
URL: https://github.com/apache/flink/pull/25233#discussion_r1732498188
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptorUtils.java:
##
@@ -0,0 +1,53 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
leosanqing commented on PR #109:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/109#issuecomment-2312079949
@schulzp @alpinegizmo @aljoscha @rmetzger Has any body to review my code?
thk ❤️❤️
--
This is an automated message from the Apache Git Service.
To respond to th
1 - 100 of 118 matches
Mail list logo
