shuiqiangchen commented on a change in pull request #13572: URL: https://github.com/apache/flink/pull/13572#discussion_r503742983
########## File path: flink-python/src/main/java/org/apache/flink/api/common/python/PythonBridgeUtils.java ########## @@ -74,6 +75,20 @@ return unpickledData; } + public static List<?> readPythonObjects(String fileName) throws IOException { Review comment: This util method will also be used in StreamTableEnvironment._from_elements(), have you tested it?Maybe we can keep it here, and create a new method for reading DataStream element objects. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org