Skip to content

Commit

Permalink
[INLONG-7706][Manager] Fix error
Browse files Browse the repository at this point in the history
  • Loading branch information
fuweng11 committed Mar 29, 2023
1 parent 4b3434d commit f2f08bc
Showing 1 changed file with 1 addition and 5 deletions.
Expand Up @@ -49,8 +49,6 @@ public Map<String, String> getStreamTypeConvertMap(String sourceType) throws Exc
Map<String, String> typeMap = new HashMap<>();
list.forEach(s -> {
typeMap.put(s.get(SOUCE_TYPE), s.get(TARGET_TYPE));
System.out.println(s.get(SOUCE_TYPE));
System.out.println(s.get(TARGET_TYPE));
});
return typeMap;
}
Expand All @@ -63,9 +61,7 @@ public Map<String, String> getSinkTypeConvertMap(String sinkType) throws Excepti
Map<String, Map<String, String>> map = yaml.load(new FileInputStream(path));
List<Map<String, String>> list = (List<Map<String, String>>) map.get(sinkType);
list.forEach(s -> {
typeMap.put(s.get("sourceType"), s.get("targetType"));
System.out.println(s.get("sourceType"));
System.out.println(s.get("targetType"));
typeMap.put(s.get(SOUCE_TYPE), s.get(TARGET_TYPE));
});
return typeMap;
}
Expand Down

0 comments on commit f2f08bc

Please sign in to comment.