fapaul commented on a change in pull request #17580:
URL: https://github.com/apache/flink/pull/17580#discussion_r740024899
##########
File path:
flink-clients/src/test/java/org/apache/flink/client/ExecutionEnvironmentTest.java
##########
@@ -91,9 +106,42 @@ public void testUserDefinedJobNameWithConfigure() {
testJobName(jobName, env);
}
+ @Test
+ public void testConfigureFileSystem() throws Exception {
+ final Configuration config = new Configuration();
+ EXPECTED_CONFIGURATION.forEach(config::setString);
+ final StreamExecutionEnvironment environment = new
LocalStreamEnvironment(config);
+ environment.getCheckpointConfig().setCheckpointStorage("testConfig:/"
+ tmp.newFolder());
+ environment.enableCheckpointing(100);
+ environment.fromElements(1, 2, 3, 4).map((MapFunction<Integer,
Integer>) value -> value);
Review comment:
It is not about the cast but rather the execution, without inserting the
mapper the job is not executable.
--
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]
