You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sj...@apache.org on 2020/09/14 19:47:52 UTC
[flink] branch master updated: [hotfix] Fix checkstyle violations
This is an automated email from the ASF dual-hosted git repository.
sjwiesman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 2a1da16 [hotfix] Fix checkstyle violations
2a1da16 is described below
commit 2a1da1675b083a4b9949d1f2311c0af0d2d2b99d
Author: Seth Wiesman <sj...@gmail.com>
AuthorDate: Mon Sep 14 14:45:01 2020 -0500
[hotfix] Fix checkstyle violations
---
.../flink/table/factories/datagen/types/DataGeneratorMapper.java | 3 +++
.../planner/runtime/stream/table/DataGeneratorConnectorITCase.java | 7 +++++--
2 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/datagen/types/DataGeneratorMapper.java b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/datagen/types/DataGeneratorMapper.java
index 25532cf..8731213 100644
--- a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/datagen/types/DataGeneratorMapper.java
+++ b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/datagen/types/DataGeneratorMapper.java
@@ -56,5 +56,8 @@ public class DataGeneratorMapper<A, B> implements DataGenerator<B> {
return mapper.apply(generator.next());
}
+ /**
+ * A simple serializable function.
+ */
public interface SerializableFunction<A, B> extends Function<A, B>, Serializable {}
}
diff --git a/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/table/DataGeneratorConnectorITCase.java b/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/table/DataGeneratorConnectorITCase.java
index 25be021..b0053f3 100644
--- a/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/table/DataGeneratorConnectorITCase.java
+++ b/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/table/DataGeneratorConnectorITCase.java
@@ -18,16 +18,19 @@
package org.apache.flink.table.planner.runtime.stream.table;
-import org.apache.flink.table.data.RowData;
import org.apache.flink.table.planner.runtime.utils.BatchTestBase;
import org.apache.flink.types.Row;
import org.apache.flink.util.CloseableIterator;
+
import org.junit.Assert;
import org.junit.Test;
import java.util.ArrayList;
import java.util.List;
+/**
+ * IT case for data generator source.
+ */
public class DataGeneratorConnectorITCase extends BatchTestBase {
private static final String TABLE = "CREATE TABLE datagen_t (\n" +
@@ -67,6 +70,6 @@ public class DataGeneratorConnectorITCase extends BatchTestBase {
}
}
- Assert.assertEquals("Unexpected number of results",10, results.size());
+ Assert.assertEquals("Unexpected number of results", 10, results.size());
}
}