[flink] 01/02: [hotfix] Remove unused methods in StreamGraph

[pnowojski]

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

pnowojski pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 21f66c0fde54c631c9c96bdb581c678c554fb8f1
Author: Piotr Nowojski <piotr.nowoj...@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 b6646f5f901..f85a9e933d5 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
@@ -799,18 +799,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;
     }