Skip to content

Commit ecb01a1

Browse files
committed
[Improve] code style improvement
1 parent 1143f64 commit ecb01a1

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

streampark-flink/streampark-flink-connector-test/src/test/java/org/apache/streampark/flink/quickstart/connector/MySQLJavaApp.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public static void main(String[] args) {
3838
StreamingContext context = new StreamingContext(envConfig);
3939

4040
// 读取MySQL数据源
41-
new JdbcJavaSource<Order>(context, Order.class)
41+
new JdbcJavaSource<>(context, Order.class)
4242
.getDataStream(
4343
(SQLQueryFunction<Order>)
4444
lastOne -> {

0 commit comments

Comments
 (0)