lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Correct TestKafkaSource class and comment (#3451)

Browse Source
This commit is contained in:
vinoyang
2021-08-12 09:11:00 +08:00
committed by GitHub
parent b3e430f24b
commit dc3cbb28e7
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestKafkaSource.java → hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestJsonKafkaSource.java
View File

@@ -56,9 +56,9 @@ import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.mockito.Mockito.mock; import static org.mockito.Mockito.mock;
/** /**
* Tests against {@link AvroKafkaSource}. * Tests against {@link JsonKafkaSource}.
*/ */
public class TestKafkaSource extends UtilitiesTestBase { public class TestJsonKafkaSource extends UtilitiesTestBase {
private static String TEST_TOPIC_NAME = "hoodie_test"; private static String TEST_TOPIC_NAME = "hoodie_test";