This is an automated email from the ASF dual-hosted git repository.
nju_yaho pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-ballista.git
The following commit(s) were added to refs/heads/main by this push:
new b0d8cc7e Update datafusion dependency to the latest version (#612)
b0d8cc7e is described below
commit b0d8cc7ed48e9f258018407641327de04e0fc2cb
Author: yahoNanJing <[email protected]>
AuthorDate: Mon Jan 30 16:19:27 2023 +0800
Update datafusion dependency to the latest version (#612)
* Update datafusion dependency to the latest version
* Fix python
* Skip ut of test_window_lead due to
https://github.com/apache/arrow-datafusion-python/issues/135
* Fix clippy
---------
Co-authored-by: yangzhong <[email protected]>
---
ballista/scheduler/src/state/execution_graph_dot.rs | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/ballista/scheduler/src/state/execution_graph_dot.rs
b/ballista/scheduler/src/state/execution_graph_dot.rs
index 75171d9d..4edb717a 100644
--- a/ballista/scheduler/src/state/execution_graph_dot.rs
+++ b/ballista/scheduler/src/state/execution_graph_dot.rs
@@ -108,7 +108,7 @@ impl ExecutionGraphDot {
for (reader_node, parent_stage_id) in &meta.readers {
// shuffle write node is always node zero
let parent_shuffle_write_node =
format!("stage_{parent_stage_id}_0");
- links.push(format!("{parent_shuffle_write_node} ->
{reader_node}",));
+ links.push(format!("{parent_shuffle_write_node} ->
{reader_node}"));
}
// keep the order deterministic
links.sort();
