You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2022/10/07 07:00:54 UTC
[flink] 02/04: [FLINK-28474][checkpoint][hotfix] Remove unused code in ChannelStateWriterImplTest
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit c02ceb66c49975d32e5c2ece3b2b9c9b3d207d57
Author: fanrui <19...@gmail.com>
AuthorDate: Sun Jul 17 18:10:14 2022 +0800
[FLINK-28474][checkpoint][hotfix] Remove unused code in ChannelStateWriterImplTest
---
.../flink/runtime/checkpoint/channel/ChannelStateWriterImplTest.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImplTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImplTest.java
index 546c341be32..61c2d80aa33 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImplTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImplTest.java
@@ -96,7 +96,6 @@ public class ChannelStateWriterImplTest {
@Test(expected = IllegalArgumentException.class)
public void testAbortClearsResults() throws Exception {
- NetworkBuffer buffer = getBuffer();
runWithSyncWorker(
(writer, worker) -> {
callStart(writer);
@@ -167,7 +166,7 @@ public class ChannelStateWriterImplTest {
public void testAddDataNotStarted() throws Exception {
unwrappingError(
IllegalArgumentException.class,
- () -> runWithSyncWorker(writer -> callAddInputData(writer)));
+ () -> runWithSyncWorker((Consumer<ChannelStateWriter>) this::callAddInputData));
}
@Test(expected = IllegalArgumentException.class)