JingsongLi commented on code in PR #739:
URL: https://github.com/apache/flink-web/pull/739#discussion_r1593424071
##
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:
JingsongLi commented on code in PR #739:
URL: https://github.com/apache/flink-web/pull/739#discussion_r1593423213
##
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:
JingsongLi commented on code in PR #739:
URL: https://github.com/apache/flink-web/pull/739#discussion_r1593422867
##
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:
JingsongLi commented on code in PR #739:
URL: https://github.com/apache/flink-web/pull/739#discussion_r159343
##
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:
yuxiqian commented on code in PR #2968:
URL: https://github.com/apache/flink-cdc/pull/2968#discussion_r1593412252
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/ObjectUtils.java:
##
@@
[
https://issues.apache.org/jira/browse/FLINK-35306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844530#comment-17844530
]
Rui Fan commented on FLINK-35306:
-
Sounds make sense to me, let's follow FLINK-35307.
> Flink cannot
[
https://issues.apache.org/jira/browse/FLINK-35306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-35306:
Component/s: Build System / CI
Tests
> Flink cannot compile with jdk17
>
RocMarshal commented on code in PR #117:
URL:
https://github.com/apache/flink-connector-jdbc/pull/117#discussion_r1593374629
##
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactoryTest.java:
##
@@ -144,7 +146,8 @@ void
flinkbot commented on PR #24762:
URL: https://github.com/apache/flink/pull/24762#issuecomment-2099726058
## CI report:
* 1a7982481df72336b004d2581772a96e3205b0d7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
RocMarshal commented on code in PR #117:
URL:
https://github.com/apache/flink-connector-jdbc/pull/117#discussion_r1593372606
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java:
##
@@ -179,13 +205,34 @@ public
[
https://issues.apache.org/jira/browse/FLINK-32087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-32087:
---
Assignee: Yanfei Lei (was: Rui Xia)
> Space amplification statistics of file merging
>
somelovelanguage commented on PR #41:
URL: https://github.com/apache/flink-playgrounds/pull/41#issuecomment-2099721932
It works! Thank you!
--
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
[
https://issues.apache.org/jira/browse/FLINK-32087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32087:
---
Labels: pull-request-available (was: )
> Space amplification statistics of file merging
>
fredia opened a new pull request, #24762:
URL: https://github.com/apache/flink/pull/24762
## What is the purpose of the change
This PR introduces space amplification statistics of file merging.
## Brief change log
- Add `SpaceStat` class in
Zakelly Lan created FLINK-35307:
---
Summary: Add Compile CI check on jdk17
Key: FLINK-35307
URL: https://issues.apache.org/jira/browse/FLINK-35307
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-35306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844519#comment-17844519
]
Zakelly Lan commented on FLINK-35306:
-
How about also adding compilation CI check on java11/17
>
[
https://issues.apache.org/jira/browse/FLINK-35306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844519#comment-17844519
]
Zakelly Lan edited comment on FLINK-35306 at 5/8/24 4:25 AM:
-
How about also
[
https://issues.apache.org/jira/browse/FLINK-35306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-35306:
Description:
[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=59380=results]
[
https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyuzhi updated FLINK-35192:
--
Attachment: screenshot-4.png
> Kubernetes operator oom
> ---
>
>
chenyuzhi459 opened a new pull request, #825:
URL: https://github.com/apache/flink-kubernetes-operator/pull/825
## What is the purpose of the change
According to
[FLINK-35192](https://issues.apache.org/jira/browse/FLINK-35192), the current
operator image uses glibc as the
flinkbot commented on PR #24761:
URL: https://github.com/apache/flink/pull/24761#issuecomment-2099697858
## CI report:
* 94df53390b48dc820d8147a0eb17f84743f7850d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35306:
---
Labels: pull-request-available (was: )
> Flink cannot compile with jdk17
>
1996fanrui opened a new pull request, #24761:
URL: https://github.com/apache/flink/pull/24761
## What is the purpose of the change
Flink cannot compile with jdk17
Reason: TypeSerializerUpgradeTestBase.UpgradeVerifier updates the
schemaCompatibilityMatcher method name to
[
https://issues.apache.org/jira/browse/FLINK-35306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-35306:
Description:
Reason: TypeSerializerUpgradeTestBase.UpgradeVerifier update the
schemaCompatibilityMatcher
Rui Fan created FLINK-35306:
---
Summary: Flink cannot compile with jdk17
Key: FLINK-35306
URL: https://issues.apache.org/jira/browse/FLINK-35306
Project: Flink
Issue Type: Bug
Affects Versions:
[
https://issues.apache.org/jira/browse/FLINK-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844507#comment-17844507
]
Rui Fan commented on FLINK-34954:
-
Hi [~q.xu] , I wanna check with you did you meet this issue in your
[
https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-35215:
---
Assignee: Rui Fan
> The performance of serializerKryo and serializerKryoWithoutRegistration are
>
Zakelly commented on code in PR #24748:
URL: https://github.com/apache/flink/pull/24748#discussion_r1593310127
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/ParallelEpochManager.java:
##
@@ -0,0 +1,41 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-34666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren closed FLINK-34666.
-
Resolution: Fixed
> Keep assigned splits in order to fix wrong meta group calculation
>
AidenPerce commented on PR #2968:
URL: https://github.com/apache/flink-cdc/pull/2968#issuecomment-2099656171
@yuxiqian may help to merge it please ?
--
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
Jiabao-Sun commented on code in PR #24670:
URL: https://github.com/apache/flink/pull/24670#discussion_r1593325219
##
flink-core/src/test/java/org/apache/flink/util/SerializedValueTest.java:
##
@@ -20,62 +20,57 @@
import org.apache.flink.core.testutils.CommonTestUtils;
[
https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844504#comment-17844504
]
Rui Fan commented on FLINK-35215:
-
Thanks [~kkrugler] for the feedback!
{quote} * I was surprised that
1996fanrui commented on code in PR #24717:
URL: https://github.com/apache/flink/pull/24717#discussion_r1593318508
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/NoFetchingInput.java:
##
@@ -114,18 +117,26 @@ public void readBytes(byte[] bytes, int
1996fanrui commented on code in PR #24717:
URL: https://github.com/apache/flink/pull/24717#discussion_r1593316335
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/NoFetchingInput.java:
##
@@ -114,18 +117,26 @@ public void readBytes(byte[] bytes, int
1996fanrui commented on code in PR #24717:
URL: https://github.com/apache/flink/pull/24717#discussion_r1579104254
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/NoFetchingInput.java:
##
@@ -65,6 +65,10 @@ public boolean canReadLong() throws
[
https://issues.apache.org/jira/browse/FLINK-35143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35143:
--
Fix Version/s: cdc-3.2.0
Affects Version/s: cdc-3.1.0
> Expose newly added tables
[
https://issues.apache.org/jira/browse/FLINK-35129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35129:
--
Fix Version/s: cdc-3.2.0
Affects Version/s: cdc-3.1.0
> Postgres source commits the
[
https://issues.apache.org/jira/browse/FLINK-35067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35067:
--
Fix Version/s: cdc-3.2.0
> Support metadata 'op_type' virtual column for Postgres CDC
[
https://issues.apache.org/jira/browse/FLINK-34688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-34688:
--
Fix Version/s: cdc-3.2.0
(was: cdc-3.1.0)
Affects
[
https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35093:
--
Affects Version/s: cdc-3.1.0
> Postgres source connector support SPECIFIC_OFFSETS start up
[
https://issues.apache.org/jira/browse/FLINK-35067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35067:
--
Affects Version/s: cdc-3.1.0
> Support metadata 'op_type' virtual column for Postgres CDC
[
https://issues.apache.org/jira/browse/FLINK-35121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35121:
--
Fix Version/s: cdc-3.2.0
> CDC pipeline connector should verify requiredOptions and
[
https://issues.apache.org/jira/browse/FLINK-35121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35121:
--
Affects Version/s: cdc-3.1.0
> CDC pipeline connector should verify requiredOptions and
[
https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35093:
--
Fix Version/s: cdc-3.2.0
> Postgres source connector support SPECIFIC_OFFSETS start up mode
[
https://issues.apache.org/jira/browse/FLINK-34666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844495#comment-17844495
]
Hongshun Wang commented on FLINK-34666:
---
Have done it in FLINK-34634, please close it. [~renqs]
[
https://issues.apache.org/jira/browse/FLINK-35281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35281:
---
Labels: pull-request-available (was: )
> FlinkEnvironmentUtils#addJar add each jar only
loserwang1024 commented on PR #3301:
URL: https://github.com/apache/flink-cdc/pull/3301#issuecomment-2099626220
@yuxiqian , @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
loserwang1024 opened a new pull request, #3301:
URL: https://github.com/apache/flink-cdc/pull/3301
Current org.apache.flink.cdc.composer.flink.FlinkEnvironmentUtils#addJar
will be invoked for each source and sink.
```java
public static void addJar(StreamExecutionEnvironment env,
loserwang1024 commented on code in PR #3255:
URL: https://github.com/apache/flink-cdc/pull/3255#discussion_r1593302893
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigurationUtils.java:
##
@@ -130,7 +130,9 @@ static Duration
dianfu commented on code in PR #24756:
URL: https://github.com/apache/flink/pull/24756#discussion_r1593302200
##
flink-python/pyflink/common/types.py:
##
@@ -177,7 +177,10 @@ def of_kind(row_kind: RowKind, *args, **kwargs):
return row
def __contains__(self,
fredia commented on PR #24698:
URL: https://github.com/apache/flink/pull/24698#issuecomment-2099597032
Thanks for the detailed review, rebased to master. Will merge after CI
green.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
Jiabao-Sun commented on code in PR #24670:
URL: https://github.com/apache/flink/pull/24670#discussion_r1593260020
##
flink-core/src/test/java/org/apache/flink/util/LinkedOptionalMapTest.java:
##
@@ -124,42 +118,50 @@ public void mergingToEmpty() {
manoellins opened a new pull request, #79:
URL: https://github.com/apache/flink-training/pull/79
(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
Priya Dhingra created FLINK-35305:
-
Summary: FLIP-438: Amazon SQS Sink Connector
Key: FLINK-35305
URL: https://issues.apache.org/jira/browse/FLINK-35305
Project: Flink
Issue Type: New
manoellins closed pull request #78: Lab 1 - Filter New York only rides
URL: https://github.com/apache/flink-training/pull/78
--
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
manoellins opened a new pull request, #78:
URL: https://github.com/apache/flink-training/pull/78
Logic to filter and return New York only rides
--
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
klam-shop commented on PR #24482:
URL: https://github.com/apache/flink/pull/24482#issuecomment-2099270127
Thanks for working on this Anupam. Any updates on this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-33699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844372#comment-17844372
]
Alexander Filipchik commented on FLINK-33699:
-
hey folks, is anyone actively working on this
antssilva96 commented on code in PR #140:
URL:
https://github.com/apache/flink-connector-aws/pull/140#discussion_r1592721925
##
flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java:
##
@@
Grub3rMS closed pull request #77: Flink module 1
URL: https://github.com/apache/flink-training/pull/77
--
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 closed pull request #24523: [FLINK-25537] [JUnit5 Migration] Module:
flink-core
URL: https://github.com/apache/flink/pull/24523
--
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
flinkbot commented on PR #24760:
URL: https://github.com/apache/flink/pull/24760#issuecomment-2098577523
## CI report:
* 7e2b5f7bc2a6137445c6fbca41fe705d96599932 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liyubin117 commented on PR #24735:
URL: https://github.com/apache/flink/pull/24735#issuecomment-2098565516
@LadyForest Hi, Thanks for your review, I have updated as you said :)
--
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-35193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35193:
---
Labels: pull-request-available (was: )
> Support drop materialized table syntax and
xuyangzhong opened a new pull request, #24760:
URL: https://github.com/apache/flink/pull/24760
## What is the purpose of the change
Support the execution of refresh materialized table.
## Brief change log
- *Add execution in sql gateway*
- *Add operation in
Grub3rMS opened a new pull request, #77:
URL: https://github.com/apache/flink-training/pull/77
(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,
[
https://issues.apache.org/jira/browse/FLINK-35195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu resolved FLINK-35195.
---
Resolution: Fixed
> Support the execution of create materialized table in continuous refresh mode
>
[
https://issues.apache.org/jira/browse/FLINK-35195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844266#comment-17844266
]
dalongliu commented on FLINK-35195:
---
Merged in master: 29736b8c01924b7da03d4bcbfd9c812a8e5a08b4
>
lsyldliu merged PR #24750:
URL: https://github.com/apache/flink/pull/24750
--
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-35299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35299:
---
Labels: pull-request-available (was: )
> FlinkKinesisConsumer does not respect
xintongsong commented on code in PR #24753:
URL: https://github.com/apache/flink/pull/24753#discussion_r1592308269
##
flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/GSFileSystemOptions.java:
##
@@ -80,6 +84,74 @@ public class GSFileSystemOptions {
boring-cyborg[bot] commented on PR #140:
URL:
https://github.com/apache/flink-connector-aws/pull/140#issuecomment-2098181150
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
antssilva96 opened a new pull request, #140:
URL: https://github.com/apache/flink-connector-aws/pull/140
## Purpose of the change
According to the javadoc, the `STREAM_INITIAL_POSITION` property defines
where to start reading Kinesis streams from. However, in the current
eskabetxe commented on code in PR #117:
URL:
https://github.com/apache/flink-connector-jdbc/pull/117#discussion_r1592285942
##
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactoryTest.java:
##
@@ -144,7 +146,8 @@ void
liyubin117 commented on code in PR #24735:
URL: https://github.com/apache/flink/pull/24735#discussion_r1592243049
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -321,6 +322,42 @@ public void createCatalog(String
liyubin117 commented on code in PR #24735:
URL: https://github.com/apache/flink/pull/24735#discussion_r1592242102
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlDdlToOperationConverterTest.java:
##
@@ -102,6 +103,23 @@
/** Test
liyubin117 commented on code in PR #24735:
URL: https://github.com/apache/flink/pull/24735#discussion_r1592237072
##
flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl:
##
@@ -147,6 +147,28 @@ SqlDrop SqlDropCatalog(Span s, boolean replace) :
}
}
[
https://issues.apache.org/jira/browse/FLINK-33462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844238#comment-17844238
]
RocMarshal commented on FLINK-33462:
Hi, [~martijnvisser]
There's a minor item to confirm, should
liyubin117 commented on code in PR #24735:
URL: https://github.com/apache/flink/pull/24735#discussion_r1592191396
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -321,6 +322,42 @@ public void createCatalog(String
[
https://issues.apache.org/jira/browse/FLINK-35161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-35161.
-
Resolution: Fixed
> Implement StateExecutor for ForStStateBackend
>
[
https://issues.apache.org/jira/browse/FLINK-35161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844232#comment-17844232
]
Zakelly Lan commented on FLINK-35161:
-
Merged via ea4112aefa72e9d15525a72157ced3e3da3650ff
>
Zakelly closed pull request #24739: [FLINK-35161][state] Implement
StateExecutor for ForStStateBackend
URL: https://github.com/apache/flink/pull/24739
--
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
Jiabao-Sun commented on code in PR #24670:
URL: https://github.com/apache/flink/pull/24670#discussion_r1592131889
##
flink-core/src/test/java/org/apache/flink/util/CloseableIteratorTest.java:
##
@@ -17,48 +17,48 @@
package org.apache.flink.util;
-import org.junit.Test;
LadyForest commented on code in PR #24735:
URL: https://github.com/apache/flink/pull/24735#discussion_r1591751966
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlDdlToOperationConverterTest.java:
##
@@ -102,6 +103,23 @@
/** Test
yunfengzhou-hub commented on code in PR #24698:
URL: https://github.com/apache/flink/pull/24698#discussion_r1592131320
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncStateException.java:
##
@@ -0,0 +1,40 @@
+/*
+ * Licensed to the Apache Software
melin commented on PR #3245:
URL: https://github.com/apache/flink-cdc/pull/3245#issuecomment-2097893968
/
--
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,
melin closed pull request #3245: [FLINK-35172]DDL statement is added to the
Schema Change Event
URL: https://github.com/apache/flink-cdc/pull/3245
--
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
dawidwys commented on PR #24365:
URL: https://github.com/apache/flink/pull/24365#issuecomment-2097889690
> Now we use splitByWholeSeparatorPreserveAllTokens, when delimiter is
empty, it will return entire string.
Actually it splits by whitespaces:
fredia commented on code in PR #24698:
URL: https://github.com/apache/flink/pull/24698#discussion_r1592128250
##
flink-core/src/main/java/org/apache/flink/core/state/StateFutureImpl.java:
##
@@ -203,12 +251,29 @@ public void callbackFinished() {
}
@Override
-
masteryhx commented on code in PR #24739:
URL: https://github.com/apache/flink/pull/24739#discussion_r1592121657
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStGeneralMultiGetOperation.java:
##
@@ -31,75 +30,50 @@
/**
* The
[
https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844226#comment-17844226
]
Jiabao Sun commented on FLINK-25537:
master: ffa3869c48a68c1dd3126fa949adc6953979711f
> [JUnit5
Jiabao-Sun merged PR #24603:
URL: https://github.com/apache/flink/pull/24603
--
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:
masteryhx commented on code in PR #24740:
URL: https://github.com/apache/flink/pull/24740#discussion_r1592119008
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java:
##
@@ -114,6 +116,10 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-35303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844224#comment-17844224
]
LvYanquan commented on FLINK-35303:
---
Currently, we can add a metadata column from row_kind
[
https://issues.apache.org/jira/browse/FLINK-32080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-32080.
-
Resolution: Fixed
> Restoration of FileMergingSnapshotManager
>
[
https://issues.apache.org/jira/browse/FLINK-32080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844223#comment-17844223
]
Zakelly Lan commented on FLINK-32080:
-
Merged via afe4c79efa15902369d41ef5a6e73d79a2e7d525
>
Zakelly closed pull request #24640: [FLINK-32080][FLIP-306][checkpoint]
Restoration of FileMergingSnapshotManager
URL: https://github.com/apache/flink/pull/24640
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
yux created FLINK-35304:
---
Summary: Mongo ITCase fails due to duplicate records after resuming
Key: FLINK-35304
URL: https://issues.apache.org/jira/browse/FLINK-35304
Project: Flink
Issue Type: Bug
wzorgdrager commented on code in PR #24756:
URL: https://github.com/apache/flink/pull/24756#discussion_r1592097458
##
flink-python/pyflink/common/types.py:
##
@@ -177,7 +177,10 @@ def of_kind(row_kind: RowKind, *args, **kwargs):
return row
def __contains__(self,
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844215#comment-17844215
]
Rui Fan commented on FLINK-35041:
-
I have asked [~Feifan Wang] offline, he will check it this week with
1 - 100 of 126 matches
Mail list logo
