eskabetxe commented on code in PR #109:
URL:
https://github.com/apache/flink-connector-jdbc/pull/109#discussion_r1605664750
##
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oceanbase/catalog/OceanBaseOracleCatalogITCase.java:
##
@@ -0,0 +1,120 @@
[
https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847467#comment-17847467
]
Thomas Weise commented on FLINK-16686:
--
Flink 1.17:
{code:java}
Exception in thread "Thread-14"
[
https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-16686:
-
Affects Version/s: 1.17.0
> [State TTL] Make user class loader available in native RocksDB
[
https://issues.apache.org/jira/browse/FLINK-24298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847399#comment-17847399
]
Sergey Nuyanzin commented on FLINK-24298:
-
thanks for driving this [~chalixar], assigned to you
[
https://issues.apache.org/jira/browse/FLINK-24298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-24298:
---
Assignee: Ahmed Hamdy
> Refactor Google PubSub sink to use Unified Sink API
>
PONYLEE opened a new pull request, #3334:
URL: https://github.com/apache/flink-cdc/pull/3334
(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,
JunRuiLee commented on code in PR #24782:
URL: https://github.com/apache/flink/pull/24782#discussion_r1605210185
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/event/FsBatchFlushOutputStream.java:
##
@@ -107,9 +114,6 @@ public void flush() throws IOException
davidradl commented on PR #24715:
URL: https://github.com/apache/flink/pull/24715#issuecomment-2117817612
@mnuttall thank you very much for the review I will have a look.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-35392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Glauber M Dantas updated FLINK-35392:
-
Description:
When transforming a DataStream to a Table and then using that table in a
[
https://issues.apache.org/jira/browse/FLINK-35392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847315#comment-17847315
]
Glauber M Dantas commented on FLINK-35392:
--
I see there is an old bug that might relate to this
[
https://issues.apache.org/jira/browse/FLINK-35392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Glauber M Dantas updated FLINK-35392:
-
Description:
When transforming a DataStream to a Table and then using that table in a
[
https://issues.apache.org/jira/browse/FLINK-35392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Glauber M Dantas updated FLINK-35392:
-
Description:
When transforming a DataStream to a Table and then using that table in a
Glauber M Dantas created FLINK-35392:
Summary: SQL Lookup Join on external database failing when using
'FOR SYSTEM_TIME AS OF' statement
Key: FLINK-35392
URL: https://issues.apache.org/jira/browse/FLINK-35392
[
https://issues.apache.org/jira/browse/FLINK-35382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847262#comment-17847262
]
Ryan Skraba commented on FLINK-35382:
-
* 1.20 Default (Java 8) / Test (module: tests)
[
https://issues.apache.org/jira/browse/FLINK-35380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847261#comment-17847261
]
Ryan Skraba commented on FLINK-35380:
-
* 1.20 Default (Java 8) / Test (module: tests)
[
https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847260#comment-17847260
]
Ryan Skraba commented on FLINK-35342:
-
I didn't succeed in reproducing the error locally...
[
https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847259#comment-17847259
]
Ryan Skraba commented on FLINK-34273:
-
* 1.20 test_cron_adaptive_scheduler table
[
https://issues.apache.org/jira/browse/FLINK-35391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LvYanquan updated FLINK-35391:
--
Description: Apache Paimon has [released
0.8|https://paimon.apache.org/releases/release-0.8/]
zhuzhurk commented on code in PR #24782:
URL: https://github.com/apache/flink/pull/24782#discussion_r1604843080
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/event/FsBatchFlushOutputStream.java:
##
@@ -107,9 +114,6 @@ public void flush() throws IOException {
LvYanquan created FLINK-35391:
-
Summary: Bump dependency of Paimon Pipeline connector to 0.8.0
Key: FLINK-35391
URL: https://issues.apache.org/jira/browse/FLINK-35391
Project: Flink
Issue Type:
lvyanquan commented on code in PR #3323:
URL: https://github.com/apache/flink-cdc/pull/3323#discussion_r1604846544
##
[
https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-20539.
-
Resolution: Fixed
> Type mismatch when using ROW in computed column
>
ljz2051 commented on code in PR #24768:
URL: https://github.com/apache/flink/pull/24768#discussion_r1604803348
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackend.java:
##
@@ -147,15 +160,30 @@ public S
[
https://issues.apache.org/jira/browse/FLINK-20539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847244#comment-17847244
]
Sergey Nuyanzin commented on FLINK-20539:
-
merged to 1.18:
snuyanzin merged PR #23772:
URL: https://github.com/apache/flink/pull/23772
--
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 PR #23772:
URL: https://github.com/apache/flink/pull/23772#issuecomment-2117351667
Thanks for the PR and for the quick rebase @xuyangzhong
--
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-33461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33461:
---
Summary: Support streaming related semantics for the new JDBC source (was:
Support streaming
[
https://issues.apache.org/jira/browse/FLINK-24298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847231#comment-17847231
]
Ahmed Hamdy commented on FLINK-24298:
-
[~snuyanzin] Could you assign this to myself and possibly
[ https://issues.apache.org/jira/browse/FLINK-24298 ]
Ahmed Hamdy deleted comment on FLINK-24298:
-
was (Author: JIRAUSER280246):
[~martijnvisser] I am happy to work on this, to complete migration of sinks
using deprecated {{SinkFunction}}.
Zakelly commented on PR #24806:
URL: https://github.com/apache/flink/pull/24806#issuecomment-2117278200
@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.
vahmed-hamdy commented on code in PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#discussion_r1604736511
##
flink-connector-rabbitmq/src/main/java/org/apache/flink/connector/rabbitmq/common/RabbitMQConnectionConfig.java:
##
@@ -0,0 +1,465 @@
+package
vahmed-hamdy commented on code in PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#discussion_r1604735515
##
flink-connector-rabbitmq/src/main/java/org/apache/flink/connector/rabbitmq/sink/RabbitMQSinkWriter.java:
##
@@ -0,0 +1,260 @@
+package
vahmed-hamdy commented on code in PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#discussion_r1604725820
##
flink-connector-rabbitmq/src/main/java/org/apache/flink/connector/rabbitmq/common/RabbitMQConnectionSetupException.java:
##
@@ -0,0 +1,13 @@
vahmed-hamdy commented on code in PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#discussion_r1604717135
##
flink-connector-rabbitmq/src/main/java/org/apache/flink/connector/rabbitmq/common/RabbitMQConnectionConfig.java:
##
@@ -0,0 +1,465 @@
+package
czy006 opened a new pull request, #3332:
URL: https://github.com/apache/flink-cdc/pull/3332
Fix [FLINK-35173](https://issues.apache.org/jira/browse/FLINK-35173)
MysqlDebeziumTimeConverter miss timezone convert to timestamp.
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-35269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh resolved FLINK-35269.
-
Assignee: Aleksandr Pilipenko
Resolution: Fixed
> Fix logging level for errors in
[
https://issues.apache.org/jira/browse/FLINK-35269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847213#comment-17847213
]
Hong Liang Teoh commented on FLINK-35269:
-
merged commit
[
https://issues.apache.org/jira/browse/FLINK-35269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-35269:
Fix Version/s: aws-connector-4.3.0
> Fix logging level for errors in AWS connector sinks
PatrickRen merged PR #743:
URL: https://github.com/apache/flink-web/pull/743
--
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:
hlteoh37 merged PR #139:
URL: https://github.com/apache/flink-connector-aws/pull/139
--
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-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847211#comment-17847211
]
Hang Ruan commented on FLINK-35296:
---
Hi, [~清月] .
What is the configuration of this mysql table and
z3d1k commented on code in PR #139:
URL:
https://github.com/apache/flink-connector-aws/pull/139#discussion_r1604612066
##
flink-connector-aws/flink-connector-aws-kinesis-firehose/src/main/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkWriter.java:
##
@@
flinkbot commented on PR #24807:
URL: https://github.com/apache/flink/pull/24807#issuecomment-2117100787
## CI report:
* c8ff5e79b0a2671cc978b02238eb6f83f4bfa19b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32088:
---
Labels: pull-request-available (was: )
> Re-uploading in state file-merging for space
Zakelly opened a new pull request, #24807:
URL: https://github.com/apache/flink/pull/24807
## This PR is on top of #24806 , Will rebase once that's merged
## What is the purpose of the change
As we know, the checkpoint file merging will introduce space amplification.
This PR
段志民 created FLINK-35390:
---
Summary: Error reporting in SQL Server connection table structure
table in Flink CDC-3.0 version
Key: FLINK-35390
URL: https://issues.apache.org/jira/browse/FLINK-35390
Project: Flink
Hangxiang Yu created FLINK-35389:
Summary: Implement List Async State API for ForStStateBackend
Key: FLINK-35389
URL: https://issues.apache.org/jira/browse/FLINK-35389
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-35049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-35049:
-
Summary: Implement Map Async State API for ForStStateBackend (was:
Implement List/Map Async
masteryhx commented on code in PR #24768:
URL: https://github.com/apache/flink/pull/24768#discussion_r1604579199
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackend.java:
##
@@ -147,15 +160,30 @@ public S
PatrickRen opened a new pull request, #743:
URL: https://github.com/apache/flink-web/pull/743
This pull request adds Flink CDC 3.1.0 download links to the Flink website.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
xuyangzhong commented on PR #23772:
URL: https://github.com/apache/flink/pull/23772#issuecomment-2117057696
@snuyanzin Done! Thanks for driving 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
pnowojski commented on PR #24784:
URL: https://github.com/apache/flink/pull/24784#issuecomment-2117031802
Also please note that azure is failing on some compilation issue. Probably
some check style violation.
--
This is an automated message from the Apache Git Service.
To respond to the
pnowojski commented on code in PR #24784:
URL: https://github.com/apache/flink/pull/24784#discussion_r1604531639
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/recovery/RescalingStreamTaskNetworkInput.java:
##
@@ -232,7 +232,9 @@ public Predicate>
[
https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847199#comment-17847199
]
RocMarshal commented on FLINK-20628:
Thanks [~chalixar] for taking over it ! (y)
> Port RabbitMQ
PatrickRen merged PR #739:
URL: https://github.com/apache/flink-web/pull/739
--
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-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-32828.
--
Fix Version/s: 2.0.0
1.18.2
1.20.0
[
https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847197#comment-17847197
]
Yechao Chen commented on FLINK-35296:
-
our version is 3.0.1
log:
{code:java}
2024-05-17
pnowojski merged PR #24802:
URL: https://github.com/apache/flink/pull/24802
--
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:
pnowojski merged PR #24801:
URL: https://github.com/apache/flink/pull/24801
--
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:
pnowojski commented on PR #89:
URL: https://github.com/apache/flink-benchmarks/pull/89#issuecomment-2116980220
Thanks for fixing 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 above to go to the specific
flinkbot commented on PR #24806:
URL: https://github.com/apache/flink/pull/24806#issuecomment-2116975542
## CI report:
* 32645c6c59a013c3a49d4665fc23b1322caa4e9f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35379:
---
Labels: pull-request-available (was: )
> File merging manager is not properly notified
Zakelly opened a new pull request, #24806:
URL: https://github.com/apache/flink/pull/24806
## What is the purpose of the change
This PR fix several issues with file merging mechanism, see `Brief change
log`.
## Brief change log
Fix following issues:
- Checkpoint
PatrickRen commented on code in PR #739:
URL: https://github.com/apache/flink-web/pull/739#discussion_r1604504279
##
docs/content/posts/2024-MM-DD-release-cdc-3.1.0.md:
##
@@ -0,0 +1,67 @@
+---
+title: "Apache Flink CDC 3.1.0 Release Announcement"
+date:
Pedro Mázala created FLINK-35388:
Summary: Flink 1.18.1 get stuck after creating highly available
job result storage directory
Key: FLINK-35388
URL: https://issues.apache.org/jira/browse/FLINK-35388
[
https://issues.apache.org/jira/browse/FLINK-35358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847191#comment-17847191
]
Rasmus Thygesen commented on FLINK-35358:
-
Right, but the same idea with just searching the
[
https://issues.apache.org/jira/browse/FLINK-34615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-34615.
-
Fix Version/s: 1.20.0
Resolution: Fixed
> Move ExternalizedCheckpointCleanup to
[
https://issues.apache.org/jira/browse/FLINK-34615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847190#comment-17847190
]
Zakelly Lan commented on FLINK-34615:
-
Merged into master via
Zakelly commented on PR #24461:
URL: https://github.com/apache/flink/pull/24461#issuecomment-2116919484
I modified the commit message and remove those 'cherry-picked from x'.
Already merged into master.
--
This is an automated message from the Apache Git Service.
To respond to the
Zakelly closed pull request #24461: [FLINK-34615]Split
`ExternalizedCheckpointCleanup` out of `Checkpoint…
URL: https://github.com/apache/flink/pull/24461
--
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
JunRuiLee commented on PR #24782:
URL: https://github.com/apache/flink/pull/24782#issuecomment-2116901812
Thanks @zhuzhurk for review, I've updated this pr accordingly. PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
JunRuiLee commented on code in PR #24782:
URL: https://github.com/apache/flink/pull/24782#discussion_r1604440216
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/event/FileSystemJobEventStore.java:
##
@@ -0,0 +1,365 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-35376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847168#comment-17847168
]
Biao Geng commented on FLINK-35376:
---
hi [~18380428...@163.com], in the implementation of the
spoon-lz commented on PR #24461:
URL: https://github.com/apache/flink/pull/24461#issuecomment-2116868581
@Zakelly Flink-ci has passed
--
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
ljz2051 commented on PR #24768:
URL: https://github.com/apache/flink/pull/24768#issuecomment-2116858619
> I think we'd better note the `shutdown` contract down into the
description/Javadoc of `StateExecutor`. The `StateExecutor` is managed by
`KeyedStateBackend` and the `AEC` or operators
PatrickRen merged PR #3331:
URL: https://github.com/apache/flink-cdc/pull/3331
--
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:
76 matches
Mail list logo
