clean up imports

Author: mspruc

wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaTextFileSourceTest.java

@@ -20,19 +20,16 @@
 
 import org.apache.wayang.java.channels.JavaChannelInstance;
 import org.apache.wayang.java.execution.JavaExecutor;
+
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.Assumptions;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 
 import java.net.URL;
-import java.time.Duration;
-import java.time.Instant;
 import java.util.List;
 import java.util.Locale;
-import java.util.stream.Stream;
-
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
 /**
@@ -114,20 +111,20 @@ void testReadRemoteFileHTTP() throws Exception {
     @Test
     void testReadRemoteFileHTTPS() throws Exception {
         try {
-        final String testFileURL = "https://downloads.apache.org/incubator/wayang/1.0.0/RELEASE_NOTES";
+            final String testFileURL = "https://downloads.apache.org/incubator/wayang/1.0.0/RELEASE_NOTES";
 
-        // Prepare the source.
-        final URL inputUrl = new URL(testFileURL);
-        final JavaTextFileSource source = new JavaTextFileSource(inputUrl.toString());
+            // Prepare the source.
+            final URL inputUrl = new URL(testFileURL);
+            final JavaTextFileSource source = new JavaTextFileSource(inputUrl.toString());
 
-        // Execute.
-        final JavaChannelInstance[] inputs = new JavaChannelInstance[] {};
-        final JavaChannelInstance[] outputs = new JavaChannelInstance[] { createStreamChannelInstance() };
-        evaluate(source, inputs, outputs);
+            // Execute.
+            final JavaChannelInstance[] inputs = new JavaChannelInstance[] {};
+            final JavaChannelInstance[] outputs = new JavaChannelInstance[] { createStreamChannelInstance() };
+            evaluate(source, inputs, outputs);
 
-        // Verify the outcome.
-        final List<String> result = outputs[0].<String>provideStream().toList();
-        assertEquals(64, result.size());
+            // Verify the outcome.
+            final List<String> result = outputs[0].<String>provideStream().toList();
+            assertEquals(64, result.size());
         } catch (final Exception e) {
             Assumptions.assumeTrue(false, "Skipping test due to possible network error: " + e.getMessage());
         }