Ted-Jiang opened a new issue #1937:
URL: https://github.com/apache/arrow-datafusion/issues/1937


   **Describe the bug**
   Start one scheduler one executor in local use datafusion-cli to connect 
`RUST_LOG=INFO cargo run --features=ballista   --bin datafusion-cli  -- --host 
localhost --port 50050`
   ```
   select 1 ;
   [2022-03-07T07:12:41Z INFO  
ballista_core::execution_plans::distributed_query] Connecting to Ballista 
scheduler at http://localhost:50050
   [2022-03-07T07:12:41Z INFO  
ballista_core::execution_plans::distributed_query] Job uc5MHYO is running...
   0 rows in set. Query took 0.226 seconds.
   ```
   ```
   select EXTRACT(year FROM to_timestamp('2020-09-08T12:13:14+00:00'));
   [2022-03-07T07:16:27Z INFO  
ballista_core::execution_plans::distributed_query] Connecting to Ballista 
scheduler at http://localhost:50050
   [2022-03-07T07:16:27Z INFO  
ballista_core::execution_plans::distributed_query] Job frvQ6EA is running...
   0 rows in set. Query took 0.230 seconds.
   ```
   no result show in cli, but i found executor get right plan
   ```
   [2022-03-07T07:17:23Z INFO  ballista_executor::execution_loop] Received task 
Ef30eos/1/0
   [2022-03-07T07:17:23Z INFO  ballista_core::execution_plans::shuffle_writer] 
Writing results to 
/var/folders/dv/lm3yntw54m901255hfqqvdrw39dbdn/T/.tmpXle4nl/Ef30eos/1/0/data.arrow
   [2022-03-07T07:17:23Z INFO  ballista_core::execution_plans::shuffle_writer] 
Executed partition 0 in 0 seconds. Statistics: numBatches=Some(0), 
numRows=Some(0), numBytes=Some(0)
   === [Ef30eos/1/0] Physical plan with metrics ===
   ShuffleWriterExec: None, metrics=[output_rows=0, input_rows=0, 
write_time=924.332µs]
     ProjectionExec: expr=[1 as Int64(1)], metrics=[output_rows=0, 
elapsed_compute=NOT RECORDED, spill_count=0, spilled_bytes=0, mem_used=0]
       EmptyExec: produce_one_row=false, metrics=[]
   
   
   [2022-03-07T07:17:23Z INFO  ballista_executor::execution_loop] Done with 
task Ef30eos/1/0
   [2022-03-07T07:17:23Z INFO  ballista_executor] Task PartitionId { job_id: 
"Ef30eos", stage_id: 1, partition_id: 0 } finished
   [2022-03-07T07:17:23Z INFO  ballista_executor::flight_service] 
FetchPartition reading 
/var/folders/dv/lm3yntw54m901255hfqqvdrw39dbdn/T/.tmpXle4nl/Ef30eos/1/0/data.arrow
   [2022-03-07T07:17:23Z INFO  ballista_executor::flight_service] 
FetchPartition streamed 0 rows
   
   ```
   
   **To Reproduce**
   Steps to reproduce the behavior:
   
   **Expected behavior**
   A clear and concise description of what you expected to happen.
   
   **Additional context**
   Add any other context about the problem here.
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscr...@arrow.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to