Fangliang Liu created FLINK-31357:
-
Summary: A record is deleted before being inserted, it will be
deleted
Key: FLINK-31357
URL: https://issues.apache.org/jira/browse/FLINK-31357
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31354:
--
Description:
[
https://issues.apache.org/jira/browse/FLINK-31356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John updated FLINK-31356:
-
Description:
{panel:title=The last checkpoint of the program was successful}
2023-03-07 08:33:16,085 INFO
[
https://issues.apache.org/jira/browse/FLINK-31356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John updated FLINK-31356:
-
Description:
{panel:title=The last checkpoint of the program was successful}
2023-03-07 08:33:16,085 INFO
John created FLINK-31356:
Summary: Serialize garbled characters at checkpoint
Key: FLINK-31356
URL: https://issues.apache.org/jira/browse/FLINK-31356
Project: Flink
Issue Type: Bug
jiangxin369 commented on code in PR #22034:
URL: https://github.com/apache/flink/pull/22034#discussion_r1127524788
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/DataStreamJavaITCase.java:
##
@@ -377,6 +385,102 @@ public void
jiangxin369 commented on code in PR #22034:
URL: https://github.com/apache/flink/pull/22034#discussion_r1127523251
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/DataStreamJavaITCase.java:
##
@@ -377,6 +385,102 @@ public void
echauchot commented on PR #21636:
URL: https://github.com/apache/flink/pull/21636#issuecomment-1457760168
> What you did for versioning looks sane. I think the problem is with line
>
>
TanYuxin-tyx commented on PR #22112:
URL: https://github.com/apache/flink/pull/22112#issuecomment-1457759198
Now LGTM, thanks @reswqa for fixing the issue.
--
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-31341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31341:
--
Priority: Critical (was: Blocker)
> OutOfMemoryError in Kafka e2e tests
>
reswqa commented on PR #22112:
URL: https://github.com/apache/flink/pull/22112#issuecomment-1457747179
Thanks @TanYuxin-tyx for the review, I have updated this according to your
comments, please take a look again.
--
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-31342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31342:
--
Priority: Critical (was: Blocker)
> SQLClientSchemaRegistryITCase timed out when starting
reswqa commented on code in PR #22112:
URL: https://github.com/apache/flink/pull/22112#discussion_r1127507881
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java:
##
@@ -436,7 +442,17 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-31339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697292#comment-17697292
]
Matthias Pohl commented on FLINK-31339:
---
[~qafro] may you have a look at it?
>
[
https://issues.apache.org/jira/browse/FLINK-31355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697291#comment-17697291
]
Matthias Pohl commented on FLINK-31355:
---
[~hxbks2ks] can you have a look at it?
>
TanYuxin-tyx commented on code in PR #22112:
URL: https://github.com/apache/flink/pull/22112#discussion_r1127307920
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java:
##
@@ -436,7 +442,17 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-31354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-31354:
-
Assignee: Matthias Pohl
> NettyClientServerSslTest.testValidSslConnectionAdvanced
reswqa commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1127499052
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -669,6 +669,13 @@ public void setNumBuffers(int numBuffers) {
reswqa commented on PR #22084:
URL: https://github.com/apache/flink/pull/22084#issuecomment-1457725482
Thanks @1996fanrui for the review and catch the bug, I have updated this
according to your comments, please take a look again.
--
This is an automated message from the Apache Git
reswqa commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1127489392
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java:
##
@@ -242,23 +243,129 @@ public void testRecycleAfterDestroy() {
reswqa commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1127487679
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java:
##
@@ -242,23 +243,129 @@ public void testRecycleAfterDestroy() {
201 - 221 of 221 matches
Mail list logo