Skip to content

Commit 8fa928f

Browse files
committed
try to fix datafusion
1 parent 515ce2c commit 8fa928f

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

Diff for: datafusion/groupby-datafusion.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ def ans_shape(batches):
5151

5252
ctx = df.SessionContext()
5353
if on_disk:
54-
runtime = df.RuntimeConfig().with_temp_file_path(f"{spill_dir}")
54+
runtime = df.RuntimeEnvBuilder().with_temp_file_path(f"{spill_dir}")
5555
config = (df.SessionConfig())
5656
ctx = df.SessionContext(config, runtime)
5757

Diff for: datafusion/join-datafusion.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ def ans_shape(batches):
5454
ctx = df.SessionContext()
5555

5656
if on_disk:
57-
runtime = df.RuntimeConfig().with_temp_file_path(f"{spill_dir}")
57+
runtime = df.RuntimeEnvBuilder().with_temp_file_path(f"{spill_dir}")
5858
config = (df.SessionConfig())
5959
ctx = df.SessionContext(config, runtime)
6060

0 commit comments

Comments
 (0)