chore: merge origin/main

Signed-off-by: Zhenchi <[email protected]>
GreptimeTeam · May 14, 2024 · 0bb5808 · 0bb5808
1 parent 0962afa
commit 0bb5808
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/flow/src/adapter/worker.rs b/src/flow/src/adapter/worker.rs
@@ -226,7 +226,7 @@ impl<'s> Worker<'s> {
                 ctx.insert_global(*source_id, bundle);
             }
 
-            let rendered = ctx.render_plan(plan.plan)?;
+            let rendered = ctx.render_plan(plan)?;
             ctx.render_unbounded_sink(rendered, sink_sender);
         }
         self.task_states.insert(flow_id, cur_task_state);

diff --git a/src/flow/src/compute/render.rs b/src/flow/src/compute/render.rs
@@ -113,11 +113,11 @@ impl<'referred, 'df> Context<'referred, 'df> {
                 reduce_plan,
             } => self.render_reduce(input, key_val_plan, reduce_plan),
             Plan::Join { .. } => NotImplementedSnafu {
-                reason: "Join is still WIP".to_string(),
+                reason: "Join is still WIP",
             }
             .fail(),
             Plan::Union { .. } => NotImplementedSnafu {
-                reason: "Union is still WIP".to_string(),
+                reason: "Union is still WIP",
             }
             .fail(),
         }