e3b5deb7414aee5265840148dd62eb028709999d,streaming/python/tests/test_stream.py,,test_data_stream,#,5

Before Change

def test_data_stream():
    ray.init(_load_code_from_local=True)
    ctx = StreamingContext.Builder().build()
    stream = ctx.from_values(1, 2, 3)
    java_stream = stream.as_java_stream()
    python_stream = java_stream.as_python_stream()

After Change

def test_data_stream():
    ray.init(job_config=ray.job_config.JobConfig(code_search_path=sys.path))
    ctx = StreamingContext.Builder().build()
    stream = ctx.from_values(1, 2, 3)
    java_stream = stream.as_java_stream()
    python_stream = java_stream.as_python_stream()

Instances