gyfora merged PR #775:
URL: https://github.com/apache/flink-web/pull/775
--
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
[
https://issues.apache.org/jira/browse/FLINK-37413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-37413:
---
Reporter: Piotr Nowojski (was: Xuyang Zhong)
> Introduce append-only RowTimeDeduplicateFunc
martongreber commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1977734299
##
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/KuduSource.java:
##
@@ -0,0 +1,130 @@
+/*
+ * Licensed to the Apache Software
martongreber commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1977733939
##
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/reader/KuduSourceReader.java:
##
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apac
martongreber commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1977732794
##
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/reader/KuduSourceReader.java:
##
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apac
gguptp commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1977837166
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReader.java:
#
gguptp commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1977837807
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReader.java:
#
gguptp commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1977838611
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReader.java:
#
gguptp commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1977840254
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/config/DynamodbStreamsSourceConfigConstants.java:
##
[
https://issues.apache.org/jira/browse/FLINK-37410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-37410:
--
Assignee: Efrat Levitan
> Split-level Watermark Metrics
> ---
martongreber commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1977722483
##
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/config/ContinuousBoundingSettings.java:
##
@@ -0,0 +1,81 @@
+/*
+ * Licensed t
martongreber commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1977721833
##
flink-connector-kudu/pom.xml:
##
@@ -64,11 +69,22 @@ under the License.
flink-table-runtime
+
martongreber commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1977724995
##
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/enumerator/KuduSourceEnumerator.java:
##
@@ -0,0 +1,256 @@
+/*
+ * Licensed to
martongreber commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1977724631
##
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/enumerator/KuduSourceEnumerator.java:
##
@@ -0,0 +1,256 @@
+/*
+ * Licensed to
martongreber commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1977726108
##
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/enumerator/KuduSourceEnumerator.java:
##
@@ -0,0 +1,256 @@
+/*
+ * Licensed to
martongreber commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1977733401
##
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/reader/KuduSourceReader.java:
##
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apac
arielmoraes commented on PR #3507:
URL: https://github.com/apache/flink-cdc/pull/3507#issuecomment-2695015536
Can we reopen this? It's a much required connector.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
arielmoraes commented on PR #3445:
URL: https://github.com/apache/flink-cdc/pull/3445#issuecomment-2695018809
Is there any news on 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 to the specif
[
https://issues.apache.org/jira/browse/FLINK-37387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-37387:
---
Assignee: Sergey Nuyanzin
> License check behaves differently for different jdk ver
[
https://issues.apache.org/jira/browse/FLINK-37387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-37387.
-
Fix Version/s: 2.1.0
2.0.1
Resolution: Fixed
> License check b
nilmadhab commented on PR #26235:
URL: https://github.com/apache/flink/pull/26235#issuecomment-2693854941
> do we still need this PR if another PR was raised an this one is based on
1.16 which is not supported anymore?
Yes this can be closed. Closing now
--
This is an automated mes
nilmadhab closed pull request #26235: Update table_api.md with modern Docker
Compose syntax
URL: https://github.com/apache/flink/pull/26235
--
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 specif
FranMorilloAWS opened a new pull request, #191:
URL: https://github.com/apache/flink-connector-aws/pull/191
## Purpose of the change
*For example: Implements the Table API for the Kinesis Source.*
## Verifying this change
Please make sure both new and modified tes
boring-cyborg[bot] commented on PR #191:
URL:
https://github.com/apache/flink-connector-aws/pull/191#issuecomment-2693884736
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is a
[
https://issues.apache.org/jira/browse/FLINK-37352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37352:
---
Labels: pull-request-available (was: )
> Write full changelog to Paimon Sink.
> ---
lvyanquan commented on PR #3935:
URL: https://github.com/apache/flink-cdc/pull/3935#issuecomment-2694009083
@MOBIN-F PTAL as you are familiar with Paimon connector.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
[
https://issues.apache.org/jira/browse/FLINK-37387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931896#comment-17931896
]
Sergey Nuyanzin commented on FLINK-37387:
-
Merged as
[f1a5add443d38af9975d21cde
snuyanzin commented on code in PR #26236:
URL: https://github.com/apache/flink/pull/26236#discussion_r1977069808
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/SemanticTestBase.java:
##
@@ -135,6 +130,25 @@ void runTests
yuxiqian opened a new pull request, #3934:
URL: https://github.com/apache/flink-cdc/pull/3934
(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, e
yuxiqian closed pull request #3934: a lame attempt to introduce cdc benchmark
URL: https://github.com/apache/flink-cdc/pull/3934
--
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.
hlteoh37 commented on code in PR #188:
URL:
https://github.com/apache/flink-connector-aws/pull/188#discussion_r1977101009
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisShardSplitReaderBase.java:
gyfora commented on PR #25896:
URL: https://github.com/apache/flink/pull/25896#issuecomment-2693784863
@kurtostfeld , it would be good to merge this soon. The most important thing
related to the Avro types in the first step is to not introduce any
regressions.
--
This is an automated me
Matthias Pohl created FLINK-37412:
-
Summary: Add slot allocation strategy to for selecting TMs first
that have already slots assigned
Key: FLINK-37412
URL: https://issues.apache.org/jira/browse/FLINK-37412
snuyanzin merged PR #26240:
URL: https://github.com/apache/flink/pull/26240
--
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.apa
rmoff commented on PR #3771:
URL: https://github.com/apache/flink-cdc/pull/3771#issuecomment-269387
@Sukang1002 I'm not planning to progress this PR further.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-37352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931916#comment-17931916
]
Yanquan Lv commented on FLINK-37352:
I'm willing to take this.
> Write full changel
Sukang1002 commented on PR #3771:
URL: https://github.com/apache/flink-cdc/pull/3771#issuecomment-2693790611
Ok, thank you for your reply, then I will further improve this document.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
lvyanquan commented on code in PR #3916:
URL: https://github.com/apache/flink-cdc/pull/3916#discussion_r1977066005
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-jdbc/src/main/java/org/apache/flink/cdc/connectors/jdbc/catalog/JdbcCatalog.java:
##
Rui Fan created FLINK-37411:
---
Summary: Introduce the rollback mechanism for Autoscaler
Key: FLINK-37411
URL: https://issues.apache.org/jira/browse/FLINK-37411
Project: Flink
Issue Type: New Featur
pnowojski merged PR #26051:
URL: https://github.com/apache/flink/pull/26051
--
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.apa
[
https://issues.apache.org/jira/browse/FLINK-37005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-37005.
--
Fix Version/s: 2.1.0
Release Note:
Newly submitted deduplication "keep first row" SQL que
loserwang1024 commented on PR #156:
URL:
https://github.com/apache/flink-connector-kafka/pull/156#issuecomment-2694108513
> Did you check if documentation (for SQL) reflects that this is a required
property?
https://github.com/user-attachments/assets/3e0aa060-32cc-4f70-9472-7f6b1439f
lvyanquan commented on code in PR #3812:
URL: https://github.com/apache/flink-cdc/pull/3812#discussion_r1976998390
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java:
##
@@ -45,6 +45,12 @@ public class PipelineOptions {
lvyanquan commented on code in PR #3893:
URL: https://github.com/apache/flink-cdc/pull/3893#discussion_r1977159664
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomAlterTablePars
snuyanzin commented on code in PR #26193:
URL: https://github.com/apache/flink/pull/26193#discussion_r1977502632
##
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/FileSinkTest.java:
##
@@ -41,6 +41,6 @@ public void testCreateFileWriterW
snuyanzin commented on code in PR #26193:
URL: https://github.com/apache/flink/pull/26193#discussion_r1977501988
##
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/FileSinkTest.java:
##
@@ -23,11 +23,11 @@
import
org.apache.flink.conne
Piotr Nowojski created FLINK-37413:
--
Summary: Introduce append-only RowTimeDeduplicateFunction with
Async State API
Key: FLINK-37413
URL: https://issues.apache.org/jira/browse/FLINK-37413
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-37413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-37413:
--
Assignee: (was: Xuyang Zhong)
> Introduce append-only RowTimeDeduplicateFunction
[
https://issues.apache.org/jira/browse/FLINK-37413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931962#comment-17931962
]
Piotr Nowojski commented on FLINK-37413:
FLINK-37005 introduced the sync only ve
twalthr merged PR #26236:
URL: https://github.com/apache/flink/pull/26236
--
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
dyccode commented on PR #26195:
URL: https://github.com/apache/flink/pull/26195#issuecomment-2694402812
> Failing CI
@davidradl I'm sorry for not noticing this issue in a timely manner. I have
now resolved it
--
This is an automated message from the Apache Git Service.
To respond t
[
https://issues.apache.org/jira/browse/FLINK-37402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-37402.
Fix Version/s: 2.1.0
Resolution: Fixed
Fixed in master: d5ffb88df4d033b357a72a3def6d45ebc80
snuyanzin commented on PR #26195:
URL: https://github.com/apache/flink/pull/26195#issuecomment-2694417557
we need to have the PR rebased (not merge only)
Currently if you open commit history for this PR there is a merge commit
which is a no go.
Need to rebase first to eliminate it
--
[
https://issues.apache.org/jira/browse/FLINK-37411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931941#comment-17931941
]
Gyula Fora commented on FLINK-37411:
It feels like this rollback mechanism should be
[
https://issues.apache.org/jira/browse/FLINK-36673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-36673.
--
Fix Version/s: kubernetes-operator-1.11.0
Resolution: Fixed
> Operator is not properly handling
[
https://issues.apache.org/jira/browse/FLINK-36673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931954#comment-17931954
]
Gyula Fora commented on FLINK-36673:
[~alnzng] 1.11.0 was released today , it will s
pnowojski commented on PR #26051:
URL: https://github.com/apache/flink/pull/26051#issuecomment-2693914171
Thanks for the reviews. Everything is finally green. Sorry for the delay,
but I had to deal with some other things in the mean time.
--
This is an automated message from the Apache Gi
Zakelly commented on PR #26237:
URL: https://github.com/apache/flink/pull/26237#issuecomment-2694631063
Also, additional two commits to enhance the user experience are attached.
--
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-37410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-37410:
---
Summary: [FLIP-513] Split-level Watermark Metrics (was: Split-level
Watermark Metrics)
> [
[
https://issues.apache.org/jira/browse/FLINK-37412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932121#comment-17932121
]
Liu commented on FLINK-37412:
-
Hello, [~mapohl]. I would like to implement it. Can you assig
kurtostfeld commented on code in PR #25896:
URL: https://github.com/apache/flink/pull/25896#discussion_r1978482869
##
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/utils/AvroKryoSerializerUtils.java:
##
@@ -106,11 +105,55 @@ public void write(Kryo kryo, Ou
kurtostfeld commented on code in PR #25896:
URL: https://github.com/apache/flink/pull/25896#discussion_r1978477882
##
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/utils/AvroKryoSerializerUtils.java:
##
@@ -106,11 +105,55 @@ public void write(Kryo kryo, Ou
gguptp commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1977895665
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/config/DynamodbStreamsSourceConfigConstants.java:
##
gguptp commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1977896339
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReader.java:
#
martongreber commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1977735111
##
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/testutils/KuduSourceITBase.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache S
gguptp commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1977899145
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/DynamoDbStreamsSource.java:
##
@@ -133,13 +135,20 @@
gguptp commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1977896339
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReader.java:
#
[
https://issues.apache.org/jira/browse/FLINK-37407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi reassigned FLINK-37407:
-
Assignee: Gabor Somogyi
> Add meta information to SQL state connector
> ---
[
https://issues.apache.org/jira/browse/FLINK-37043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-37043.
Resolution: Done
> [Umbrella] Test Flink Release 2.0
> -
>
>
ChaomingZhangCN commented on code in PR #3893:
URL: https://github.com/apache/flink-cdc/pull/3893#discussion_r1978748419
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/AlterTableCommentEvent.java:
##
@@ -0,0 +1,89 @@
+/*
+ * Licensed to the Apache Software F
ChaomingZhangCN commented on code in PR #3893:
URL: https://github.com/apache/flink-cdc/pull/3893#discussion_r1978701396
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomAlterTab
[
https://issues.apache.org/jira/browse/FLINK-35810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932160#comment-17932160
]
Weijie Guo commented on FLINK-35810:
Thanks [~yunfengzhou] for the careful investiga
[
https://issues.apache.org/jira/browse/FLINK-37414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37414:
---
Affects Version/s: 1.20.1
> Java heap space OOM in test_cron_azure core
> --
yunfengzhou-hub opened a new pull request, #26241:
URL: https://github.com/apache/flink/pull/26241
## What is the purpose of the change
This PR fixes the bug that AsyncWaitOperator might be triggering
mailboxExecutor.execute() after the mailbox has been quiesced in
AsyncWaitOperatorT
yuxiqian opened a new pull request, #3936:
URL: https://github.com/apache/flink-cdc/pull/3936
As noted in
https://github.com/apache/flink-cdc/actions/runs/13623293435/job/38139886612?pr=3912,
if JVM timezone is randomly set to GMT+0:00, it will be "smartly" converted to
`"GMT"` (w/o offset
ChaomingZhangCN commented on code in PR #3883:
URL: https://github.com/apache/flink-cdc/pull/3883#discussion_r1978689655
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSi
[
https://issues.apache.org/jira/browse/FLINK-37379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-37379:
-
Fix Version/s: 2.0.0
> Lack of state cache load for ForSt after recovery
> -
[
https://issues.apache.org/jira/browse/FLINK-36437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-36437.
--
Resolution: Not A Problem
> Hive connector failed to compile with JDK 11
> ---
[
https://issues.apache.org/jira/browse/FLINK-37414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932159#comment-17932159
]
Weijie Guo commented on FLINK-37414:
Looking at the history, this has existed at lea
[
https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-3154:
Fix Version/s: 2.0.0
> Update Kryo version from 2.24.0 to latest Kryo LTS version
> ---
[
https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-3154:
Priority: Blocker (was: Not a Priority)
> Update Kryo version from 2.24.0 to latest Kryo LTS versi
kurtostfeld commented on code in PR #25896:
URL: https://github.com/apache/flink/pull/25896#discussion_r1978578476
##
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/utils/AvroKryoSerializerUtils.java:
##
@@ -106,11 +105,55 @@ public void write(Kryo kryo, Ou
kurtostfeld commented on PR #25896:
URL: https://github.com/apache/flink/pull/25896#issuecomment-2696147722
@gyfora I've rewritten the Avro GenericRecord Kryo serializer and the Avro
GenericData.Array serializer. Avro is also a serialization library, so the Kryo
serializers just basically w
yunfengzhou-hub opened a new pull request, #26242:
URL: https://github.com/apache/flink/pull/26242
## What is the purpose of the change
This PR fixes the bug that AsyncWaitOperator might be triggering
mailboxExecutor.execute() after the mailbox has been quiesced in
AsyncWaitOperatorT
bvarghese1 commented on code in PR #26230:
URL: https://github.com/apache/flink/pull/26230#discussion_r1978609329
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala:
##
@@ -287,6 +287,39
flinkbot commented on PR #26242:
URL: https://github.com/apache/flink/pull/26242#issuecomment-2696197701
## CI report:
* 28f55fee43f26ebf2473a534bbda2dc638b58e84 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37414:
---
Description:
{code:java}
Mar 03 05:22:14 java.lang.OutOfMemoryError: Java heap space
Mar 03 05:22:
Weijie Guo created FLINK-37414:
--
Summary: Java heap space OOM in test_cron_azure core
Key: FLINK-37414
URL: https://issues.apache.org/jira/browse/FLINK-37414
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-37414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37414:
---
Affects Version/s: 2.0.0
2.1.0
> Java heap space OOM in test_cron_azure core
[
https://issues.apache.org/jira/browse/FLINK-37414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37414:
---
Description:
{code:java}
Mar 03 05:22:14 java.lang.OutOfMemoryError: Java heap space
Mar 03 05:22:
fredia commented on code in PR #26237:
URL: https://github.com/apache/flink/pull/26237#discussion_r1978510149
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/cache/CachedDataOutputStream.java:
##
@@ -64,58 +66,80 @@ public CachedDat
slfan1989 commented on PR #26193:
URL: https://github.com/apache/flink/pull/26193#issuecomment-2696031316
> Please also change commit name and PR description.
> I'm pretty sure you're not going to change to junit5 everywhere in Flink
within this PR,
> in this case current name is wrong
xintongsong opened a new pull request, #777:
URL: https://github.com/apache/flink-web/pull/777
(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,
Zakelly commented on code in PR #26237:
URL: https://github.com/apache/flink/pull/26237#discussion_r1978519401
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/cache/CachedDataOutputStream.java:
##
@@ -64,58 +66,80 @@ public CachedDa
fredia commented on code in PR #26237:
URL: https://github.com/apache/flink/pull/26237#discussion_r1978538199
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/cache/CachedDataOutputStream.java:
##
@@ -64,58 +66,80 @@ public CachedDat
yuxiqian commented on code in PR #3932:
URL: https://github.com/apache/flink-cdc/pull/3932#discussion_r1978539251
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlPipelineRecordEm
fredia commented on PR #26237:
URL: https://github.com/apache/flink/pull/26237#issuecomment-2696072001
Thanks for the update, `ForStFlinkFileSystemTest#testSstFileInCache ` failed
because we reserved the space.
The design and implementation are fine for me.
--
This is an automated mess
hejufang commented on PR #25837:
URL: https://github.com/apache/flink/pull/25837#issuecomment-2696066319
@Zakelly @masteryhx Could you please take a look when you have time?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
gguptp commented on PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#issuecomment-2696094301
@hlteoh37 i have addressed the comments and updated the PR. Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
[
https://issues.apache.org/jira/browse/FLINK-35810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-35810:
--
Assignee: Yunfeng Zhou (was: Weijie Guo)
> OOM in
> AsyncWaitOperatorTest.testProcessingTim
1 - 100 of 114 matches
Mail list logo
