[jira] [Created] (FLINK-31357) A record is deleted before being inserted, it will be deleted

2023-03-07 Thread Fangliang Liu (Jira)
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

[jira] [Updated] (FLINK-31354) NettyClientServerSslTest.testValidSslConnectionAdvanced timed out

2023-03-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31354: -- Description:

[jira] [Updated] (FLINK-31356) Serialize garbled characters at checkpoint

2023-03-07 Thread John (Jira)
[ 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  

[jira] [Updated] (FLINK-31356) Serialize garbled characters at checkpoint

2023-03-07 Thread John (Jira)
[ 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  

[jira] [Created] (FLINK-31356) Serialize garbled characters at checkpoint

2023-03-07 Thread John (Jira)
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

[GitHub] [flink] jiangxin369 commented on a diff in pull request #22034: [FLINK-31240][table] Reduce the overhead of conversion between DataStream and Table

2023-03-07 Thread via GitHub
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

[GitHub] [flink] jiangxin369 commented on a diff in pull request #22034: [FLINK-31240][table] Reduce the overhead of conversion between DataStream and Table

2023-03-07 Thread via GitHub
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

[GitHub] [flink] echauchot commented on pull request #21636: [FLINK-30113] Implement state compression for broadcast and regular operator states

2023-03-07 Thread via GitHub
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 > >

[GitHub] [flink] TanYuxin-tyx commented on pull request #22112: [FLINK-31346][runtime] IO scheduler does not throw TimeoutException if numRequestedBuffers is greater than 0

2023-03-07 Thread via GitHub
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

[jira] [Updated] (FLINK-31341) OutOfMemoryError in Kafka e2e tests

2023-03-07 Thread Matthias Pohl (Jira)
[ 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 >

[GitHub] [flink] reswqa commented on pull request #22112: [FLINK-31346][runtime] IO scheduler does not throw TimeoutException if numRequestedBuffers is greater than 0

2023-03-07 Thread via GitHub
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

[jira] [Updated] (FLINK-31342) SQLClientSchemaRegistryITCase timed out when starting the test container

2023-03-07 Thread Matthias Pohl (Jira)
[ 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

[GitHub] [flink] reswqa commented on a diff in pull request #22112: [FLINK-31346][runtime] IO scheduler does not throw TimeoutException if numRequestedBuffers is greater than 0

2023-03-07 Thread via GitHub
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

[jira] [Commented] (FLINK-31339) PlannerScalaFreeITCase.testImperativeUdaf

2023-03-07 Thread Matthias Pohl (Jira)
[ 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? >

[jira] [Commented] (FLINK-31355) CommonDataStreamTests.test_execute_and_collect failed

2023-03-07 Thread Matthias Pohl (Jira)
[ 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? >

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22112: [FLINK-31346][runtime] IO scheduler does not throw TimeoutException if numRequestedBuffers is greater than 0

2023-03-07 Thread via GitHub
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

[jira] [Assigned] (FLINK-31354) NettyClientServerSslTest.testValidSslConnectionAdvanced timed out

2023-03-07 Thread Matthias Pohl (Jira)
[ 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

[GitHub] [flink] reswqa commented on a diff in pull request #22084: [FLINK-31293][runtime] LocalBufferPool request overdraft buffer only when no available buffer and pool size is reached

2023-03-07 Thread via GitHub
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) {

[GitHub] [flink] reswqa commented on pull request #22084: [FLINK-31293][runtime] LocalBufferPool request overdraft buffer only when no available buffer and pool size is reached

2023-03-07 Thread via GitHub
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

[GitHub] [flink] reswqa commented on a diff in pull request #22084: [FLINK-31293][runtime] LocalBufferPool request overdraft buffer only when no available buffer and pool size is reached

2023-03-07 Thread via GitHub
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() {

[GitHub] [flink] reswqa commented on a diff in pull request #22084: [FLINK-31293][runtime] LocalBufferPool request overdraft buffer only when no available buffer and pool size is reached

2023-03-07 Thread via GitHub
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() {

<    1   2   3