This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch dev-2.1.6
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev-2.1.6 by this push:
     new ecb01a12b [Improve] code style improvement
ecb01a12b is described below

commit ecb01a12bbdd696c8517834c46fdc993bf70ef19
Author: benjobs <[email protected]>
AuthorDate: Sun Jan 26 18:20:10 2025 +0800

    [Improve] code style improvement
---
 .../org/apache/streampark/flink/quickstart/connector/MySQLJavaApp.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streampark-flink/streampark-flink-connector-test/src/test/java/org/apache/streampark/flink/quickstart/connector/MySQLJavaApp.java
 
b/streampark-flink/streampark-flink-connector-test/src/test/java/org/apache/streampark/flink/quickstart/connector/MySQLJavaApp.java
index 9c86f1b0e..4248843af 100644
--- 
a/streampark-flink/streampark-flink-connector-test/src/test/java/org/apache/streampark/flink/quickstart/connector/MySQLJavaApp.java
+++ 
b/streampark-flink/streampark-flink-connector-test/src/test/java/org/apache/streampark/flink/quickstart/connector/MySQLJavaApp.java
@@ -38,7 +38,7 @@ public class MySQLJavaApp {
     StreamingContext context = new StreamingContext(envConfig);
 
     // 读取MySQL数据源
-    new JdbcJavaSource<Order>(context, Order.class)
+    new JdbcJavaSource<>(context, Order.class)
         .getDataStream(
             (SQLQueryFunction<Order>)
                 lastOne -> {

Reply via email to