Abacn commented on code in PR #23635:
URL: https://github.com/apache/beam/pull/23635#discussion_r997260730
##########
runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkExecutionEnvironments.java:
##########
@@ -73,7 +74,7 @@ public static ExecutionEnvironment
createBatchExecutionEnvironment(FlinkPipeline
static ExecutionEnvironment createBatchExecutionEnvironment(
FlinkPipelineOptions options, List<String> filesToStage, @Nullable
String confDir) {
- LOG.info("Creating a Batch Execution Environment.");
+ LOG.info("Creating a Batch Execution Environment with config {}.",
confDir);
Review Comment:
Most log spams comes from `org.apache.flink.runtime` during flink
minicluster initiating. Tested that if assign confDir to a directory that has
org.apache.flink.runtime WARN logging, it works. However, currently this
parameter is always null (seems like beam not respecting parsed in flinkConfDir)
--
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]
