paul8263 commented on code in PR #19772:
URL: https://github.com/apache/flink/pull/19772#discussion_r884502437
##########
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java:
##########
@@ -1288,4 +1300,26 @@ private static CustomCommandLine
loadCustomCommandLine(String className, Object.
return constructor.newInstance(params);
}
+
+ /**
+ * Get client timeout from command line via effective configuration.
+ *
+ * @param effectiveConfiguration Flink effective configuration.
+ * @return client timeout with Duration type
+ */
+ private Duration getClientTimeout(Configuration effectiveConfiguration) {
+ logAndSysout("Reading " + ClientOptions.CLIENT_TIMEOUT.key() + " from
cli.");
+ return effectiveConfiguration.get(ClientOptions.CLIENT_TIMEOUT);
+ }
Review Comment:
@Myracle ,
Sorry that I forgot to clear the leftover logs after I refactored the code.
I will do it now.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
