Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5766#discussion_r177800173
--- Diff:
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroExternalJarProgramITCase.java
---
@@ -44,49 +39,24 @@
private static final String TEST_DATA_FILE = "/testdata.avro";
- @Test
- public void testExternalProgram() {
-
- LocalFlinkMiniCluster testMiniCluster = null;
+ private static final MiniClusterResource miniClusterResource = new
MiniClusterResource(
+ new MiniClusterResource.MiniClusterResourceConfiguration(
+ new Configuration(),
+ 1,
+ 4));
+ @Test
+ public void testExternalProgram() throws Exception {
+ miniClusterResource.setJarFiles(Collections.singleton(new
Path(JAR_FILE)));
--- End diff --
as far as i could tell, no. We actually have to set it in the environment.
---
