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 -> {