@@ -38,7 +38,9 @@ void testMetrics_Hadoop2x() throws URISyntaxException, IOException {
3838 // so all the env vars needs to be embedded inside the hadoop-env.sh file
3939 GenericContainer <?> target =
4040 new GenericContainer <>("bmedora/hadoop:2.9-base" )
41- .withCopyToContainer (Transferable .of (readAndPreprocessEnvFile ("hadoop2-env.sh" )), "/hadoop/etc/hadoop/hadoop-env.sh" )
41+ .withCopyToContainer (
42+ Transferable .of (readAndPreprocessEnvFile ("hadoop2-env.sh" )),
43+ "/hadoop/etc/hadoop/hadoop-env.sh" )
4244 .withCreateContainerCmdModifier (cmd -> cmd .withHostName ("test-host" ))
4345 .withStartupTimeout (Duration .ofMinutes (3 ))
4446 .withExposedPorts (50070 )
@@ -57,9 +59,10 @@ private String readAndPreprocessEnvFile(String fileName) throws URISyntaxExcepti
5759
5860 String data ;
5961 try (Stream <String > lines = Files .lines (path )) {
60- data = lines
61- .map (line -> line .replace (ENDPOINT_PLACEHOLDER , otlpEndpoint ))
62- .collect (Collectors .joining ("\n " ));
62+ data =
63+ lines
64+ .map (line -> line .replace (ENDPOINT_PLACEHOLDER , otlpEndpoint ))
65+ .collect (Collectors .joining ("\n " ));
6366 }
6467
6568 return data ;
@@ -76,7 +79,9 @@ void testMetrics_Hadoop3x() throws URISyntaxException, IOException {
7679 GenericContainer <?> target =
7780 new GenericContainer <>("loum/hadoop-pseudo:3.3.6" )
7881 .withExposedPorts (9870 , 9000 )
79- .withCopyToContainer (Transferable .of (readAndPreprocessEnvFile ("hadoop3-env.sh" )), "/opt/hadoop/etc/hadoop/hadoop-env.sh" )
82+ .withCopyToContainer (
83+ Transferable .of (readAndPreprocessEnvFile ("hadoop3-env.sh" )),
84+ "/opt/hadoop/etc/hadoop/hadoop-env.sh" )
8085 .withCreateContainerCmdModifier (cmd -> cmd .withHostName ("test-host" ))
8186 .waitingFor (
8287 Wait .forListeningPorts (9870 , 9000 ).withStartupTimeout (Duration .ofMinutes (3 )));
0 commit comments