@@ -273,7 +273,6 @@ fn generate_commit_info(
273273    let  commit_info_exprs = [ 
274274        // TODO(zach): we should probably take a timestamp closer to actual commit time? 
275275        Expression :: literal ( timestamp) , 
276-         Expression :: null_literal ( DataType :: LONG ) , 
277276        Expression :: literal ( operation. unwrap_or ( UNKNOWN_OPERATION ) ) , 
278277        // HACK (part 1/2): since we don't have proper map support, we create a literal struct with 
279278        // one null field to create data that serializes as "operationParameters": {} 
@@ -316,6 +315,9 @@ fn generate_commit_info(
316315        . get_mut ( "operationParameters" ) 
317316        . ok_or_else ( || Error :: missing_column ( "operationParameters" ) ) ?
318317        . data_type  = hack_data_type; 
318+     commit_info_data_type
319+         . fields 
320+         . shift_remove ( "inCommitTimestamp" ) ; 
319321    commit_info_field. data_type  = DataType :: Struct ( commit_info_data_type) ; 
320322
321323    let  commit_info_evaluator = engine. get_expression_handler ( ) . get_evaluator ( 
@@ -591,7 +593,6 @@ mod tests {
591593            serde_json:: json!( { 
592594                "commitInfo" :  { 
593595                    "timestamp" :  0 , 
594-                     "inCommitTimestamp" :  0 , 
595596                    "operation" :  "test operation" , 
596597                    "kernelVersion" :  format!( "v{}" ,  env!( "CARGO_PKG_VERSION" ) ) , 
597598                    "operationParameters" :  { } , 
@@ -602,7 +603,6 @@ mod tests {
602603            serde_json:: json!( { 
603604                "commitInfo" :  { 
604605                    "timestamp" :  0 , 
605-                     "inCommitTimestamp" :  0 , 
606606                    "operation" :  "test operation" , 
607607                    "kernelVersion" :  format!( "v{}" ,  env!( "CARGO_PKG_VERSION" ) ) , 
608608                    "operationParameters" :  { } , 
0 commit comments