You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by we...@apache.org on 2022/04/23 07:16:51 UTC
[incubator-seatunnel] branch dev updated: [hotfix][generic] Optimize some generic type code (#1730)
This is an automated email from the ASF dual-hosted git repository.
wenjun pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new ea86e25a [hotfix][generic] Optimize some generic type code (#1730)
ea86e25a is described below
commit ea86e25a33cbb7f7a4a43eef869e8c139baaaa89
Author: 1996fanrui <19...@gmail.com>
AuthorDate: Sat Apr 23 15:16:45 2022 +0800
[hotfix][generic] Optimize some generic type code (#1730)
---
.../java/org/apache/seatunnel/flink/stream/FlinkStreamExecution.java | 2 +-
.../src/main/java/org/apache/seatunnel/flink/transform/Split.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamExecution.java b/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamExecution.java
index 1c2fe8fb..04e55345 100644
--- a/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamExecution.java
+++ b/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamExecution.java
@@ -79,7 +79,7 @@ public class FlinkStreamExecution implements Execution<FlinkStreamSource, FlinkS
}
}
- private void registerResultTable(Plugin plugin, DataStream dataStream) {
+ private void registerResultTable(Plugin<FlinkEnvironment> plugin, DataStream<Row> dataStream) {
Config config = plugin.getConfig();
if (config.hasPath(RESULT_TABLE_NAME)) {
String name = config.getString(RESULT_TABLE_NAME);
diff --git a/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/Split.java b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/Split.java
index c1c95727..3e8ba6dd 100644
--- a/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/Split.java
+++ b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-split/src/main/java/org/apache/seatunnel/flink/transform/Split.java
@@ -94,7 +94,7 @@ public class Split implements FlinkStreamTransform, FlinkBatchTransform {
if (config.hasPath(SEPARATOR)) {
separator = config.getString(SEPARATOR);
}
- TypeInformation[] types = new TypeInformation[fields.size()];
+ TypeInformation<?>[] types = new TypeInformation[fields.size()];
for (int i = 0; i < types.length; i++) {
types[i] = Types.STRING();
}