houqp commented on issue #623:
URL: 
https://github.com/apache/arrow-datafusion/issues/623#issuecomment-869057635


   With #629, I am able to get the integration tests to pass for 1, 3, 5, 6. 
Looking at a different error with query 7 at the moment:
   
   ```
   Running benchmark with query 7:                                              
                                 
    select                                                                      
                                                                                
                                                               
       supp_nation,                                                             
                                                                                
                                                               
       cust_nation,                                                             
                                 
       l_year,                                                                  
                                 
       sum(volume) as revenue                                                   
                                 
   from                                                                         
                                 
       (                                                                        
                                 
           select                                                               
                                 
               n1.n_name as supp_nation,                                        
                                                                                
                                                               
               n2.n_name as cust_nation,                                        
                                                                                
                                                               
               extract(year from l_shipdate) as l_year,                         
                                                                                
                                                               
               l_extendedprice * (1 - l_discount) as volume                     
                                                                                
                                                               
           from                                                                 
                                                                                
                                                               
               supplier,                                                        
                                 
               lineitem,                                                        
                                                                                
                                                               
               orders,                                                          
                                 
               customer,                                                        
                                 
               nation n1,                                                       
                                 
               nation n2                                                        
                                 
           where                                                                
                                 
                   s_suppkey = l_suppkey                                        
                                 
             and o_orderkey = l_orderkey                                        
                                 
             and c_custkey = o_custkey                                          
                                 
             and s_nationkey = n1.n_nationkey                                   
                                 
             and c_nationkey = n2.n_nationkey                                   
                                 
             and (                                                              
                                 
                   (n1.n_name = 'FRANCE' and n2.n_name = 'GERMANY')             
                                                                                
                                                               
                   or (n1.n_name = 'GERMANY' and n2.n_name = 'FRANCE')          
                                 
               )                                                                
                                 
             and l_shipdate between date '1995-01-01' and date '1996-12-31'     
                                 
       ) as shipping                                                            
                                 
   group by                                                                     
                                 
       supp_nation,                                                             
                                 
       cust_nation,                                                             
                                 
       l_year                                                                   
                                 
   order by                                                                     
                                                                                
                                                               
       supp_nation,                                                             
                                 
       cust_nation,                                                             
                                 
       l_year;                                                                  
                                                                                
                                                               
   [2021-06-26T20:16:57Z INFO  ballista::context] Connecting to Ballista 
scheduler at http://ballista-scheduler:50050                                    
                                                                      
   Error: Plan("Execution(\"General(\\\"logical_plan::to_proto() unsupported 
scalar function DatePart\\\")\")")  
   
   ```


-- 
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