loserwang1024 commented on PR #3387:
URL: https://github.com/apache/flink-cdc/pull/3387#issuecomment-2148735709
@PatrickRen , CC
--
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
lsyldliu closed pull request #24877: [FLINK-35200][table] Support the
execution of suspend, resume materialized table in full refresh mode
URL: https://github.com/apache/flink/pull/24877
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-35201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-35201:
-
Assignee: Feng Jin
> Support the execution of drop materialized table in full refresh mode
> --
[
https://issues.apache.org/jira/browse/FLINK-35200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu resolved FLINK-35200.
---
Resolution: Fixed
> Support the execution of suspend, resume materialized table in full refresh
> m
[
https://issues.apache.org/jira/browse/FLINK-35200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852245#comment-17852245
]
dalongliu commented on FLINK-35200:
---
Merged in master: 8d1e043b0c4277582b8862c2bc33146
leonardBang merged PR #3323:
URL: https://github.com/apache/flink-cdc/pull/3323
--
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
Jiabao-Sun commented on code in PR #24881:
URL: https://github.com/apache/flink/pull/24881#discussion_r1626824660
##
flink-core/src/test/java/org/apache/flink/core/fs/AutoCloseableRegistryTest.java:
##
@@ -66,9 +64,9 @@ public void testSuppressedExceptions() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-35325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35325:
--
Assignee: tianzhu.wen
> Paimon connector miss the position of AddColumnEvent
> --
[
https://issues.apache.org/jira/browse/FLINK-35325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-35325.
Resolution: Implemented
via flink-cdc master: 02141660490855b033583e711152059c7652410f
> Paimon c
flinkbot commented on PR #24887:
URL: https://github.com/apache/flink/pull/24887#issuecomment-2148750895
## CI report:
* 40cb30f959a9a400f76b7e8b535d54d9594b4e5b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly commented on code in PR #24878:
URL: https://github.com/apache/flink/pull/24878#discussion_r1626851630
##
flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java:
##
@@ -210,11 +209,11 @@ public class CheckpointingOptions {
* Local recover
zhuzhurk commented on code in PR #24887:
URL: https://github.com/apache/flink/pull/24887#discussion_r1626862364
##
flink-tests/src/test/java/org/apache/flink/test/scheduling/SpeculativeExecutionITCase.java:
##
@@ -105,6 +109,8 @@ class SpeculativeExecutionITCase {
private
reswqa commented on code in PR #106:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/106#discussion_r1626868230
##
flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncWriter.java:
##
@@ -102,13 +103,15
zoltar9264 commented on PR #24879:
URL: https://github.com/apache/flink/pull/24879#issuecomment-2148784514
@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
leonardBang merged PR #2987:
URL: https://github.com/apache/flink-cdc/pull/2987
--
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
xuyangzhong commented on code in PR #24828:
URL: https://github.com/apache/flink/pull/24828#discussion_r1626871428
##
docs/data/sql_functions.yml:
##
@@ -687,7 +687,7 @@ collection:
description: Returns a map created from an arrays of keys and values. Note
that the lengths
Zakelly commented on code in PR #24873:
URL: https://github.com/apache/flink/pull/24873#discussion_r1626876357
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/SnapshotFileMergingCompatibilityITCase.java:
##
@@ -0,0 +1,126 @@
+/*
+ * Licensed to the Apache Softwa
hackergin opened a new pull request, #24888:
URL: https://github.com/apache/flink/pull/24888
## What is the purpose of the change
*Support the execution of drop materialized table in full refresh mode*
## Brief change log
* Support the execution of drop materialized t
[
https://issues.apache.org/jira/browse/FLINK-35201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35201:
---
Labels: pull-request-available (was: )
> Support the execution of drop materialized table i
leonardBang commented on code in PR #3348:
URL: https://github.com/apache/flink-cdc/pull/3348#discussion_r1626875255
##
flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslator.java:
##
@@ -152,4 +152,37 @@ private String generateSinkNam
flinkbot commented on PR #24888:
URL: https://github.com/apache/flink/pull/24888#issuecomment-2148801220
## CI report:
* f0ab631e7d9fea91593ec7550454fb926b265a60 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Myasuka commented on PR #24880:
URL: https://github.com/apache/flink/pull/24880#issuecomment-2148803082
@rkhachatryan since the manual compaction would introduce extra CPU & IO,
and it would impact the block-cache with the change of level structure. I think
we could also add a doc to tell u
[
https://issues.apache.org/jira/browse/FLINK-35485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852267#comment-17852267
]
Xingcan Cui commented on FLINK-35485:
-
Hi [~mapohl], unfortunately, I failed to fetc
LadyForest opened a new pull request, #24889:
URL: https://github.com/apache/flink/pull/24889
## What is the purpose of the change
This pull request implements
[FLIP-457](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=307136992&src=jira).
## Brief change log
liuml07 commented on code in PR #106:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/106#discussion_r1626901218
##
flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncWriter.java:
##
@@ -102,13 +103,15
flinkbot commented on PR #24889:
URL: https://github.com/apache/flink/pull/24889#issuecomment-2148823508
## CI report:
* dbc98f28e5eaa59a323807132c17d909fcc6133a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liuml07 commented on code in PR #106:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/106#discussion_r1626913771
##
flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncWriter.java:
##
@@ -102,13 +103,15
yuxiqian commented on PR #3348:
URL: https://github.com/apache/flink-cdc/pull/3348#issuecomment-2148866328
Done, seems I messed up the commit history during last rebase... Fixed it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
elon-X commented on PR #24757:
URL: https://github.com/apache/flink/pull/24757#issuecomment-2148906495
@1996fanrui I've made some changes based on your suggestions. Please review
the changes when you have a chance and let me know if there are any further
improvements needed. Thanks!
--
T
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852289#comment-17852289
]
Yun Tang commented on FLINK-9043:
-
[~mszacillo] After six years of launching this discuss
Jichao Wang created FLINK-35523:
---
Summary: When using the Hive connector to read a Hive table in
Parquet format, a null pointer exception is thrown.
Key: FLINK-35523
URL: https://issues.apache.org/jira/browse/FLINK-
snuyanzin commented on code in PR #24828:
URL: https://github.com/apache/flink/pull/24828#discussion_r1627027077
##
docs/data/sql_functions.yml:
##
@@ -687,7 +687,7 @@ collection:
description: Returns a map created from an arrays of keys and values. Note
that the lengths o
1996fanrui commented on code in PR #24757:
URL: https://github.com/apache/flink/pull/24757#discussion_r1626888044
##
flink-tests/src/test/java/org/apache/flink/test/streaming/api/datastream/WatermarkAlignmentITCase.java:
##
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache Softwar
19priyadhingra commented on code in PR #141:
URL:
https://github.com/apache/flink-connector-aws/pull/141#discussion_r1627068765
##
flink-connector-aws/flink-connector-sqs/src/main/java/org.apache.flink.connector.sqs/sink/SqsSinkElementConverter.java:
##
@@ -0,0 +1,105 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-35291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852300#comment-17852300
]
Yun Tang commented on FLINK-35291:
--
I think this is a useful observation. Since {{Strin
Myasuka commented on PR #3289:
URL: https://github.com/apache/flink-cdc/pull/3289#issuecomment-2149001433
@lzshlzsh What's the performance gain (or throughput improve) with this
patch?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852301#comment-17852301
]
yazgoo commented on FLINK-35138:
Hi,
Looks like there are still 2 binding votes missing
19priyadhingra commented on PR #141:
URL:
https://github.com/apache/flink-connector-aws/pull/141#issuecomment-2149019054
> We seem to be having quite a few `.` in the class folders. Can we change
them to `/` instead? e.g.
`[flink-connector-aws](https://issues.apache.org/jira/browse/FLINK-c
101 - 138 of 138 matches
Mail list logo
