Fix streaming py test for 1.0 APIs (#10520)

2026-07-02 00:28:45 +08:00 · 2020-09-03 14:15:09 +08:00
parent ea95e6f7cc
commit 2f03bb5100
4 changed files with 7 additions and 7 deletions
@@ -65,7 +65,7 @@ if __name__ == "__main__":
    args = parser.parse_args()
    titles_file = str(args.titles_file)

-    ray.init(load_code_from_local=True, include_java=True)
+    ray.init(_load_code_from_local=True, _include_java=True)

    ctx = StreamingContext.Builder() \
        .option(Config.CHANNEL_TYPE, Config.NATIVE_CHANNEL) \