wuchong commented on a change in pull request #15297:
URL: https://github.com/apache/flink/pull/15297#discussion_r598276503
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/experimental/CollectSink.java
##########
@@ -83,7 +83,12 @@ public void open(Configuration parameters) throws Exception {
outputStream = client.getOutputStream();
streamWriter = new DataOutputViewStreamWrapper(outputStream);
} catch (IOException e) {
- throw new IOException("Cannot connect to the client to send back
the stream", e);
+ throw new IOException(
+ "Cannot get back the stream while opening connection to
client at"
Review comment:
Add a space after `at`.
--
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:
[email protected]
