You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2022/07/07 08:14:46 UTC
[flink] 01/02: [hotfix] Remove unused methods in StreamGraph
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 2656f95cbaf574ca09f40c5271684f5cb1e9a0c2
Author: Piotr Nowojski <pi...@gmail.com>
AuthorDate: Mon Jul 4 17:44:45 2022 +0200
[hotfix] Remove unused methods in StreamGraph
---
.../org/apache/flink/streaming/api/graph/StreamGraph.java | 12 ------------
.../org/apache/flink/streaming/api/graph/StreamNode.java | 4 ----
2 files changed, 16 deletions(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
index 7f06c6182be..da721ce8b7f 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
@@ -811,18 +811,6 @@ public class StreamGraph implements Pipeline {
vertex.setSerializerOut(out);
}
- public void setSerializersFrom(Integer from, Integer to) {
- StreamNode fromVertex = getStreamNode(from);
- StreamNode toVertex = getStreamNode(to);
-
- toVertex.setSerializersIn(fromVertex.getTypeSerializerOut());
- toVertex.setSerializerOut(fromVertex.getTypeSerializerIn(0));
- }
-
- public <OUT> void setOutType(Integer vertexID, TypeInformation<OUT> outType) {
- getStreamNode(vertexID).setSerializerOut(outType.createSerializer(executionConfig));
- }
-
public void setInputFormat(Integer vertexID, InputFormat<?, ?> inputFormat) {
getStreamNode(vertexID).setInputFormat(inputFormat);
}
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java
index cac1cd5c97e..4e400b8485f 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java
@@ -272,10 +272,6 @@ public class StreamNode {
return typeSerializersIn;
}
- public TypeSerializer<?> getTypeSerializerIn(int index) {
- return typeSerializersIn[index];
- }
-
public TypeSerializer<?> getTypeSerializerOut() {
return typeSerializerOut;
}