Fix jave test.

.github/workflows/ubuntu_building.yml

@@ -50,8 +50,8 @@ jobs:
     - name: Streaming python test
       run: sh -c "bash streaming/buildtest.sh --test_categories=streaming_python"
 
-#    - name: Streaming java test
-#      run: sh -c "bash streaming/buildtest.sh --test_categories=streaming_java"
+    - name: Streaming java test
+      run: sh -c "bash streaming/buildtest.sh --test_categories=streaming_java"
 
     - name: Streaming cpp test
       run: sh -c "bash streaming/buildtest.sh --test_categories=streaming_cpp"

streaming/java/BUILD.bazel

@@ -53,8 +53,8 @@ define_java_module(
         "@maven//:org_apache_logging_log4j_log4j_slf4j_impl",
         "@maven//:org_slf4j_slf4j_api",
         "@maven//:org_testng_testng",
-        "@ray_streaming_maven//:io_ray_ray_api",
-        "@ray_streaming_maven//:io_ray_ray_runtime",
+        "@com_github_ray_project_ray//:io_ray_ray_api",
+        "@com_github_ray_project_ray//:io_ray_ray_runtime",
         "@ray_streaming_maven//:com_google_guava_guava",
         "@ray_streaming_maven//:com_esotericsoftware_kryo",
         "@ray_streaming_maven//:com_esotericsoftware_minlog_minlog",
@@ -119,8 +119,8 @@ define_java_module(
         "@maven//:org_apache_logging_log4j_log4j_core",
         "@maven//:org_apache_logging_log4j_log4j_slf4j_impl",
         "@maven//:org_slf4j_slf4j_api",
-        "@ray_streaming_maven//:io_ray_ray_api",
-        "@ray_streaming_maven//:io_ray_ray_runtime",
+        "@com_github_ray_project_ray//:io_ray_ray_api",
+        "@com_github_ray_project_ray//:io_ray_ray_runtime",
         "@ray_streaming_maven//:com_google_guava_guava",
         "@ray_streaming_maven//:com_google_code_findbugs_jsr305",
         "@ray_streaming_maven//:com_google_code_gson_gson",
@@ -155,8 +155,8 @@ define_java_module(
         ":io_ray_ray_streaming-runtime",
         "@maven//:org_slf4j_slf4j_api",
         "@maven//:org_testng_testng",
-        "@ray_streaming_maven//:io_ray_ray_api",
-        "@ray_streaming_maven//:io_ray_ray_runtime",
+        "@com_github_ray_project_ray//:io_ray_ray_api",
+        "@com_github_ray_project_ray//:io_ray_ray_runtime",
         "@ray_streaming_maven//:com_google_guava_guava",
         "@ray_streaming_maven//:de_ruedigermoeller_fst",
         "@ray_streaming_maven//:org_apache_commons_commons_lang3",
@@ -176,8 +176,8 @@ define_java_module(
         "@maven//:org_apache_logging_log4j_log4j_slf4j_impl",
         "@maven//:org_msgpack_msgpack_core",
         "@maven//:org_slf4j_slf4j_api",
-        "@ray_streaming_maven//:io_ray_ray_api",
-        "@ray_streaming_maven//:io_ray_ray_runtime",
+        "@com_github_ray_project_ray//:io_ray_ray_api",
+        "@com_github_ray_project_ray//:io_ray_ray_runtime",
         "@ray_streaming_maven//:com_google_guava_guava",
         "@ray_streaming_maven//:org_apache_commons_commons_lang3",
         "@ray_streaming_maven//:commons_io_commons_io",

streaming/java/streaming-runtime/src/test/java/io/ray/streaming/runtime/demo/HybridStreamTest.java

@@ -43,7 +43,7 @@ public boolean filter(Object value) throws Exception {
     }
   }
 
-  @Test(timeOut = 60000, enabled = false)
+  @Test(timeOut = 60000)
   public void testHybridDataStream() throws Exception {
     String sinkFileName = "/tmp/testHybridDataStream.txt";
     Files.deleteIfExists(Paths.get(sinkFileName));

streaming/java/streaming-runtime/src/test/java/io/ray/streaming/runtime/demo/UnionStreamTest.java

@@ -24,7 +24,7 @@ public UnionStreamTest() {
     super(true);
   }
 
-  @Test(timeOut = 60000, enabled = false)
+  @Test(timeOut = 60000)
   public void testUnionStream() throws Exception {
     String sinkFileName = "/tmp/testUnionStream.txt";
     Files.deleteIfExists(Paths.get(sinkFileName));

streaming/java/streaming-runtime/src/test/java/io/ray/streaming/runtime/streamingqueue/StreamingQueueTest.java

@@ -31,6 +31,7 @@
 import org.testng.annotations.BeforeMethod;
 import org.testng.annotations.Test;
 
+@Test(enabled = false)
 public class StreamingQueueTest extends RayEnvBaseTest implements Serializable {
 
   private static Logger LOGGER = LoggerFactory.getLogger(StreamingQueueTest.class);
@@ -71,7 +72,7 @@ void afterMethod(Method method) {
     System.clearProperty("ray.head-args.1");
   }
 
-  @Test(timeOut = 300000, enabled = false)
+  @Test(timeOut = 300000)
   public void testReaderWriter() {
     ActorHandle<WriterWorker> writerActor = Ray.actor(WriterWorker::new, "writer").remote();
     ActorHandle<ReaderWorker> readerActor = Ray.actor(ReaderWorker::new, "reader").remote();
@@ -81,7 +82,6 @@ public void testReaderWriter() {
     LOGGER.info(
         "call getName on readerActor: {}", readerActor.task(ReaderWorker::getName).remote().get());
 
-    // LOGGER.info(writerActor.task(WriterWorker::testCallReader, readerActor).remote().get());
     List<String> outputQueueList = new ArrayList<>();
     List<String> inputQueueList = new ArrayList<>();
     int queueNum = 2;

streaming/java/streaming-runtime/src/test/java/io/ray/streaming/runtime/transfer/ChannelIdTest.java

@@ -7,6 +7,7 @@
 import io.ray.streaming.runtime.transfer.channel.ChannelId;
 import org.testng.annotations.Test;
 
+@Test(enabled = false)
 public class ChannelIdTest extends RayEnvBaseTest {
 
   static {