INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#2891L as bigint) AS VendorID#2912L, try_cast(tpep_pickup_datetime#2892 as timestamp) AS tpep_pickup_datetime#2913, try_cast(tpep_dropoff_datetime#2893 as timestamp) AS tpep_dropoff_datetime#2914, try_cast(passenger_count#2894 as bigint) AS passenger_count#2915L, try_cast(trip_distance#2895 as double) AS trip_distance#2916, try_cast(RatecodeID#2896 as bigint) AS RatecodeID#2917L, try_cast(store_and_fwd_flag#2897 as string) AS store_and_fwd_flag#2918, try_cast(PULocationID#2898L as bigint) AS PULocationID#2919L, try_cast(DOLocationID#2899L as bigint) AS DOLocationID#2920L, try_cast(payment_type#2900L as bigint) AS payment_type#2921L, try_cast(fare_amount#2901 as double) AS fare_amount#2922, try_cast(extra#2902 as double) AS extra#2923, try_cast(mta_tax#2903 as double) AS mta_tax#2924, try_cast(tip_amount#2904 as double) AS tip_amount#2925, try_cast(tolls_amount#2905 as double) AS tolls_amount#2926, try_cast(improvement_surcharge#2906 as double) AS improvement_surcharge#2927, try_cast(total_amount#2907 as double) AS total_amount#2928, try_cast(congestion_surcharge#2908 as double) AS congestion_surcharge#2929, try_cast(airport_fee#2909 as double) AS airport_fee#2930, current_timestamp() AS current_timestamp()#2911, coalesce(year(cast(tpep_pickup_datetime#2892 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#2931, coalesce(month(cast(tpep_pickup_datetime#2892 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#2932, coalesce(day(cast(tpep_pickup_dat...

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'passenger_count' and 'passenger_count'

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#3904L as bigint) AS VendorID#3925L, try_cast(tpep_pickup_datetime#3905 as timestamp) AS tpep_pickup_datetime#3926, try_cast(tpep_dropoff_datetime#3906 as timestamp) AS tpep_dropoff_datetime#3927, try_cast(passenger_count#3907 as bigint) AS passenger_count#3928L, try_cast(trip_distance#3908 as double) AS trip_distance#3929, try_cast(RatecodeID#3909 as bigint) AS RatecodeID#3930L, try_cast(store_and_fwd_flag#3910 as string) AS store_and_fwd_flag#3931, try_cast(PULocationID#3911L as bigint) AS PULocationID#3932L, try_cast(DOLocationID#3912L as bigint) AS DOLocationID#3933L, try_cast(payment_type#3913L as bigint) AS payment_type#3934L, try_cast(fare_amount#3914 as double) AS fare_amount#3935, try_cast(extra#3915 as double) AS extra#3936, try_cast(mta_tax#3916 as double) AS mta_tax#3937, try_cast(tip_amount#3917 as double) AS tip_amount#3938, try_cast(tolls_amount#3918 as double) AS tolls_amount#3939, try_cast(improvement_surcharge#3919 as double) AS improvement_surcharge#3940, try_cast(total_amount#3920 as double) AS total_amount#3941, try_cast(congestion_surcharge#3921 as double) AS congestion_surcharge#3942, try_cast(airport_fee#3922 as double) AS airport_fee#3943, current_timestamp() AS current_timestamp()#3924, coalesce(year(cast(tpep_pickup_datetime#3905 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3944, coalesce(month(cast(tpep_pickup_datetime#3905 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3945, coalesce(day(cast(tpep_pickup_dat...

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#3992 as bigint) AS VendorID#4014L, try_cast(tpep_pickup_datetime#3993 as timestamp) AS tpep_pickup_datetime#4015, try_cast(tpep_dropoff_datetime#3994 as timestamp) AS tpep_dropoff_datetime#4016, try_cast(passenger_count#3995L as bigint) AS passenger_count#4017L, try_cast(trip_distance#3996 as double) AS trip_distance#4018, try_cast(RatecodeID#3997L as bigint) AS RatecodeID#4019L, try_cast(store_and_fwd_flag#3998 as string) AS store_and_fwd_flag#4020, try_cast(PULocationID#3999 as bigint) AS PULocationID#4021L, try_cast(DOLocationID#4000 as bigint) AS DOLocationID#4022L, try_cast(payment_type#4001L as bigint) AS payment_type#4023L, try_cast(fare_amount#4002 as double) AS fare_amount#4024, try_cast(extra#4003 as double) AS extra#4025, try_cast(mta_tax#4004 as double) AS mta_tax#4026, try_cast(tip_amount#4005 as double) AS tip_amount#4027, try_cast(tolls_amount#4006 as double) AS tolls_amount#4028, try_cast(improvement_surcharge#4007 as double) AS improvement_surcharge#4029, try_cast(total_amount#4008 as double) AS total_amount#4030, try_cast(congestion_surcharge#4009 as double) AS congestion_surcharge#4031, try_cast(airport_fee#4010 as double) AS airport_fee#4032, current_timestamp() AS current_timestamp()#4013, coalesce(year(cast(tpep_pickup_datetime#3993 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#4033, coalesce(month(cast(tpep_pickup_datetime#3993 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#4034, coalesce(day(cast(tpep_pickup_date...

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `details` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 9;
'DescribeColumn 'spark_catalog.yellow_taxi.trips, false, [info_name#4336, info_value#4337]
+- 'UnresolvedTableOrView [details], DESCRIBE TABLE, true

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#3155 as bigint) AS VendorID#3176L, try_cast(tpep_pickup_datetime#3156 as timestamp) AS tpep_pickup_datetime#3177, try_cast(tpep_dropoff_datetime#3157 as timestamp) AS tpep_dropoff_datetime#3178, try_cast(passenger_count#3158L as bigint) AS passenger_count#3179L, try_cast(trip_distance#3159 as double) AS trip_distance#3180, try_cast(RatecodeID#3160L as bigint) AS RatecodeID#3181L, try_cast(store_and_fwd_flag#3161 as string) AS store_and_fwd_flag#3182, try_cast(PULocationID#3162 as bigint) AS PULocationID#3183L, try_cast(DOLocationID#3163 as bigint) AS DOLocationID#3184L, try_cast(payment_type#3164L as bigint) AS payment_type#3185L, try_cast(fare_amount#3165 as double) AS fare_amount#3186, try_cast(extra#3166 as double) AS extra#3187, try_cast(mta_tax#3167 as double) AS mta_tax#3188, try_cast(tip_amount#3168 as double) AS tip_amount#3189, try_cast(tolls_amount#3169 as double) AS tolls_amount#3190, try_cast(improvement_surcharge#3170 as double) AS improvement_surcharge#3191, try_cast(total_amount#3171 as double) AS total_amount#3192, try_cast(congestion_surcharge#3172 as double) AS congestion_surcharge#3193, try_cast(airport_fee#3173 as double) AS airport_fee#3194, current_timestamp() AS current_timestamp()#3175, coalesce(year(cast(tpep_pickup_datetime#3156 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3195, coalesce(month(cast(tpep_pickup_datetime#3156 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3196, coalesce(day(cast(tpep_pickup_date...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#4169 as bigint) AS VendorID#4190L, try_cast(tpep_pickup_datetime#4170 as timestamp) AS tpep_pickup_datetime#4191, try_cast(tpep_dropoff_datetime#4171 as timestamp) AS tpep_dropoff_datetime#4192, try_cast(passenger_count#4172L as bigint) AS passenger_count#4193L, try_cast(trip_distance#4173 as double) AS trip_distance#4194, try_cast(RatecodeID#4174L as bigint) AS RatecodeID#4195L, try_cast(store_and_fwd_flag#4175 as string) AS store_and_fwd_flag#4196, try_cast(PULocationID#4176 as bigint) AS PULocationID#4197L, try_cast(DOLocationID#4177 as bigint) AS DOLocationID#4198L, try_cast(payment_type#4178L as bigint) AS payment_type#4199L, try_cast(fare_amount#4179 as double) AS fare_amount#4200, try_cast(extra#4180 as double) AS extra#4201, try_cast(mta_tax#4181 as double) AS mta_tax#4202, try_cast(tip_amount#4182 as double) AS tip_amount#4203, try_cast(tolls_amount#4183 as double) AS tolls_amount#4204, try_cast(improvement_surcharge#4184 as double) AS improvement_surcharge#4205, try_cast(total_amount#4185 as double) AS total_amount#4206, try_cast(congestion_surcharge#4186 as double) AS congestion_surcharge#4207, try_cast(airport_fee#4187 as double) AS airport_fee#4208, current_timestamp() AS current_timestamp()#4189, coalesce(year(cast(tpep_pickup_datetime#4170 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#4209, coalesce(month(cast(tpep_pickup_datetime#4170 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#4210, coalesce(day(cast(tpep_pickup_date...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#3596L as bigint) AS VendorID#3617L, try_cast(tpep_pickup_datetime#3597 as timestamp) AS tpep_pickup_datetime#3618, try_cast(tpep_dropoff_datetime#3598 as timestamp) AS tpep_dropoff_datetime#3619, try_cast(passenger_count#3599L as bigint) AS passenger_count#3620L, try_cast(trip_distance#3600 as double) AS trip_distance#3621, try_cast(RatecodeID#3601L as bigint) AS RatecodeID#3622L, try_cast(store_and_fwd_flag#3602 as string) AS store_and_fwd_flag#3623, try_cast(PULocationID#3603L as bigint) AS PULocationID#3624L, try_cast(DOLocationID#3604L as bigint) AS DOLocationID#3625L, try_cast(payment_type#3605L as bigint) AS payment_type#3626L, try_cast(fare_amount#3606 as double) AS fare_amount#3627, try_cast(extra#3607 as double) AS extra#3628, try_cast(mta_tax#3608 as double) AS mta_tax#3629, try_cast(tip_amount#3609 as double) AS tip_amount#3630, try_cast(tolls_amount#3610 as double) AS tolls_amount#3631, try_cast(improvement_surcharge#3611 as double) AS improvement_surcharge#3632, try_cast(total_amount#3612 as double) AS total_amount#3633, try_cast(congestion_surcharge#3613 as double) AS congestion_surcharge#3634, try_cast(airport_fee#3614 as double) AS airport_fee#3635, current_timestamp() AS current_timestamp()#3616, coalesce(year(cast(tpep_pickup_datetime#3597 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3636, coalesce(month(cast(tpep_pickup_datetime#3597 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3637, coalesce(day(cast(tpep_pickup_d...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#3420L as bigint) AS VendorID#3441L, try_cast(tpep_pickup_datetime#3421 as timestamp) AS tpep_pickup_datetime#3442, try_cast(tpep_dropoff_datetime#3422 as timestamp) AS tpep_dropoff_datetime#3443, try_cast(passenger_count#3423 as bigint) AS passenger_count#3444L, try_cast(trip_distance#3424 as double) AS trip_distance#3445, try_cast(RatecodeID#3425 as bigint) AS RatecodeID#3446L, try_cast(store_and_fwd_flag#3426 as string) AS store_and_fwd_flag#3447, try_cast(PULocationID#3427L as bigint) AS PULocationID#3448L, try_cast(DOLocationID#3428L as bigint) AS DOLocationID#3449L, try_cast(payment_type#3429L as bigint) AS payment_type#3450L, try_cast(fare_amount#3430 as double) AS fare_amount#3451, try_cast(extra#3431 as double) AS extra#3452, try_cast(mta_tax#3432 as double) AS mta_tax#3453, try_cast(tip_amount#3433 as double) AS tip_amount#3454, try_cast(tolls_amount#3434 as double) AS tolls_amount#3455, try_cast(improvement_surcharge#3435 as double) AS improvement_surcharge#3456, try_cast(total_amount#3436 as double) AS total_amount#3457, try_cast(congestion_surcharge#3437 as double) AS congestion_surcharge#3458, try_cast(airport_fee#3438 as double) AS airport_fee#3459, current_timestamp() AS current_timestamp()#3440, coalesce(year(cast(tpep_pickup_datetime#3421 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3460, coalesce(month(cast(tpep_pickup_datetime#3421 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3461, coalesce(day(cast(tpep_pickup_dat...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#2759L as bigint) AS VendorID#2780L, try_cast(tpep_pickup_datetime#2760 as timestamp) AS tpep_pickup_datetime#2781, try_cast(tpep_dropoff_datetime#2761 as timestamp) AS tpep_dropoff_datetime#2782, try_cast(passenger_count#2762 as bigint) AS passenger_count#2783L, try_cast(trip_distance#2763 as double) AS trip_distance#2784, try_cast(RatecodeID#2764 as bigint) AS RatecodeID#2785L, try_cast(store_and_fwd_flag#2765 as string) AS store_and_fwd_flag#2786, try_cast(PULocationID#2766L as bigint) AS PULocationID#2787L, try_cast(DOLocationID#2767L as bigint) AS DOLocationID#2788L, try_cast(payment_type#2768L as bigint) AS payment_type#2789L, try_cast(fare_amount#2769 as double) AS fare_amount#2790, try_cast(extra#2770 as double) AS extra#2791, try_cast(mta_tax#2771 as double) AS mta_tax#2792, try_cast(tip_amount#2772 as double) AS tip_amount#2793, try_cast(tolls_amount#2773 as double) AS tolls_amount#2794, try_cast(improvement_surcharge#2774 as double) AS improvement_surcharge#2795, try_cast(total_amount#2775 as double) AS total_amount#2796, try_cast(congestion_surcharge#2776 as double) AS congestion_surcharge#2797, try_cast(airport_fee#2777 as double) AS airport_fee#2798, current_timestamp() AS current_timestamp()#2779, coalesce(year(cast(tpep_pickup_datetime#2760 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#2799, coalesce(month(cast(tpep_pickup_datetime#2760 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#2800, coalesce(day(cast(tpep_pickup_dat...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#3111L as bigint) AS VendorID#3132L, try_cast(tpep_pickup_datetime#3112 as timestamp) AS tpep_pickup_datetime#3133, try_cast(tpep_dropoff_datetime#3113 as timestamp) AS tpep_dropoff_datetime#3134, try_cast(passenger_count#3114 as bigint) AS passenger_count#3135L, try_cast(trip_distance#3115 as double) AS trip_distance#3136, try_cast(RatecodeID#3116 as bigint) AS RatecodeID#3137L, try_cast(store_and_fwd_flag#3117 as string) AS store_and_fwd_flag#3138, try_cast(PULocationID#3118L as bigint) AS PULocationID#3139L, try_cast(DOLocationID#3119L as bigint) AS DOLocationID#3140L, try_cast(payment_type#3120L as bigint) AS payment_type#3141L, try_cast(fare_amount#3121 as double) AS fare_amount#3142, try_cast(extra#3122 as double) AS extra#3143, try_cast(mta_tax#3123 as double) AS mta_tax#3144, try_cast(tip_amount#3124 as double) AS tip_amount#3145, try_cast(tolls_amount#3125 as double) AS tolls_amount#3146, try_cast(improvement_surcharge#3126 as double) AS improvement_surcharge#3147, try_cast(total_amount#3127 as double) AS total_amount#3148, try_cast(congestion_surcharge#3128 as double) AS congestion_surcharge#3149, try_cast(airport_fee#3129 as double) AS airport_fee#3150, current_timestamp() AS current_timestamp()#3131, coalesce(year(cast(tpep_pickup_datetime#3112 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3151, coalesce(month(cast(tpep_pickup_datetime#3112 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3152, coalesce(day(cast(tpep_pickup_dat...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#2847L as bigint) AS VendorID#2868L, try_cast(tpep_pickup_datetime#2848 as timestamp) AS tpep_pickup_datetime#2869, try_cast(tpep_dropoff_datetime#2849 as timestamp) AS tpep_dropoff_datetime#2870, try_cast(passenger_count#2850 as bigint) AS passenger_count#2871L, try_cast(trip_distance#2851 as double) AS trip_distance#2872, try_cast(RatecodeID#2852 as bigint) AS RatecodeID#2873L, try_cast(store_and_fwd_flag#2853 as string) AS store_and_fwd_flag#2874, try_cast(PULocationID#2854L as bigint) AS PULocationID#2875L, try_cast(DOLocationID#2855L as bigint) AS DOLocationID#2876L, try_cast(payment_type#2856L as bigint) AS payment_type#2877L, try_cast(fare_amount#2857 as double) AS fare_amount#2878, try_cast(extra#2858 as double) AS extra#2879, try_cast(mta_tax#2859 as double) AS mta_tax#2880, try_cast(tip_amount#2860 as double) AS tip_amount#2881, try_cast(tolls_amount#2861 as double) AS tolls_amount#2882, try_cast(improvement_surcharge#2862 as double) AS improvement_surcharge#2883, try_cast(total_amount#2863 as double) AS total_amount#2884, try_cast(congestion_surcharge#2864 as double) AS congestion_surcharge#2885, try_cast(airport_fee#2865 as double) AS airport_fee#2886, current_timestamp() AS current_timestamp()#2867, coalesce(year(cast(tpep_pickup_datetime#2848 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#2887, coalesce(month(cast(tpep_pickup_datetime#2848 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#2888, coalesce(day(cast(tpep_pickup_dat...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#4037L as bigint) AS VendorID#4058L, try_cast(tpep_pickup_datetime#4038 as timestamp) AS tpep_pickup_datetime#4059, try_cast(tpep_dropoff_datetime#4039 as timestamp) AS tpep_dropoff_datetime#4060, try_cast(passenger_count#4040 as bigint) AS passenger_count#4061L, try_cast(trip_distance#4041 as double) AS trip_distance#4062, try_cast(RatecodeID#4042 as bigint) AS RatecodeID#4063L, try_cast(store_and_fwd_flag#4043 as string) AS store_and_fwd_flag#4064, try_cast(PULocationID#4044L as bigint) AS PULocationID#4065L, try_cast(DOLocationID#4045L as bigint) AS DOLocationID#4066L, try_cast(payment_type#4046L as bigint) AS payment_type#4067L, try_cast(fare_amount#4047 as double) AS fare_amount#4068, try_cast(extra#4048 as double) AS extra#4069, try_cast(mta_tax#4049 as double) AS mta_tax#4070, try_cast(tip_amount#4050 as double) AS tip_amount#4071, try_cast(tolls_amount#4051 as double) AS tolls_amount#4072, try_cast(improvement_surcharge#4052 as double) AS improvement_surcharge#4073, try_cast(total_amount#4053 as double) AS total_amount#4074, try_cast(congestion_surcharge#4054 as double) AS congestion_surcharge#4075, try_cast(airport_fee#4055 as double) AS airport_fee#4076, current_timestamp() AS current_timestamp()#4057, coalesce(year(cast(tpep_pickup_datetime#4038 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#4077, coalesce(month(cast(tpep_pickup_datetime#4038 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#4078, coalesce(day(cast(tpep_pickup_dat...

INTERNAL: 
[PARSE_SYNTAX_ERROR] Syntax error at or near '''. SQLSTATE: 42601 (line 29, pos 9)

== SQL ==

create table if not exists spark_catalog.yellow_taxi.trips(
    VendorID long,
    tpep_pickup_datetime timestamp,
    tpep_dropoff_datetime timestamp,
    passenger_count long,
    trip_distance double,
    RatecodeID long,
    store_and_fwd_flag string,
    PULocationID long,
    DOLocationID long,
    payment_type long,
    fare_amount double,
    extra double,
    mta_tax double,
    tip_amount double,
    tolls_amount double,
    improvement_surcharge double,
    total_amount double,
    congestion_surcharge double,
    airport_fee double,
    load_timestamp timestamp,
    year int,
    month int,
    day int
)
using delta
partitioned by (year,month)
location '/home/jovyan/spark-warehouse/yellow_taxi.db/trips
---------^^^

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `spark_catalog`.`yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#4213 as bigint) AS VendorID#4234L, try_cast(tpep_pickup_datetime#4214 as timestamp) AS tpep_pickup_datetime#4235, try_cast(tpep_dropoff_datetime#4215 as timestamp) AS tpep_dropoff_datetime#4236, try_cast(passenger_count#4216L as bigint) AS passenger_count#4237L, try_cast(trip_distance#4217 as double) AS trip_distance#4238, try_cast(RatecodeID#4218L as bigint) AS RatecodeID#4239L, try_cast(store_and_fwd_flag#4219 as string) AS store_and_fwd_flag#4240, try_cast(PULocationID#4220 as bigint) AS PULocationID#4241L, try_cast(DOLocationID#4221 as bigint) AS DOLocationID#4242L, try_cast(payment_type#4222L as bigint) AS payment_type#4243L, try_cast(fare_amount#4223 as double) AS fare_amount#4244, try_cast(extra#4224 as double) AS extra#4245, try_cast(mta_tax#4225 as double) AS mta_tax#4246, try_cast(tip_amount#4226 as double) AS tip_amount#4247, try_cast(tolls_amount#4227 as double) AS tolls_amount#4248, try_cast(improvement_surcharge#4228 as double) AS improvement_surcharge#4249, try_cast(total_amount#4229 as double) AS total_amount#4250, try_cast(congestion_surcharge#4230 as double) AS congestion_surcharge#4251, try_cast(airport_fee#4231 as double) AS airport_fee#4252, current_timestamp() AS current_timestamp()#4233, coalesce(year(cast(tpep_pickup_datetime#4214 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#4253, coalesce(month(cast(tpep_pickup_datetime#4214 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#4254, coalesce(day(cast(tpep_pickup_date...

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#3772L as bigint) AS VendorID#3793L, try_cast(tpep_pickup_datetime#3773 as timestamp) AS tpep_pickup_datetime#3794, try_cast(tpep_dropoff_datetime#3774 as timestamp) AS tpep_dropoff_datetime#3795, try_cast(passenger_count#3775 as bigint) AS passenger_count#3796L, try_cast(trip_distance#3776 as double) AS trip_distance#3797, try_cast(RatecodeID#3777 as bigint) AS RatecodeID#3798L, try_cast(store_and_fwd_flag#3778 as string) AS store_and_fwd_flag#3799, try_cast(PULocationID#3779L as bigint) AS PULocationID#3800L, try_cast(DOLocationID#3780L as bigint) AS DOLocationID#3801L, try_cast(payment_type#3781L as bigint) AS payment_type#3802L, try_cast(fare_amount#3782 as double) AS fare_amount#3803, try_cast(extra#3783 as double) AS extra#3804, try_cast(mta_tax#3784 as double) AS mta_tax#3805, try_cast(tip_amount#3785 as double) AS tip_amount#3806, try_cast(tolls_amount#3786 as double) AS tolls_amount#3807, try_cast(improvement_surcharge#3787 as double) AS improvement_surcharge#3808, try_cast(total_amount#3788 as double) AS total_amount#3809, try_cast(congestion_surcharge#3789 as double) AS congestion_surcharge#3810, try_cast(airport_fee#3790 as double) AS airport_fee#3811, current_timestamp() AS current_timestamp()#3792, coalesce(year(cast(tpep_pickup_datetime#3773 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3812, coalesce(month(cast(tpep_pickup_datetime#3773 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3813, coalesce(day(cast(tpep_pickup_dat...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#3816L as bigint) AS VendorID#3837L, try_cast(tpep_pickup_datetime#3817 as timestamp) AS tpep_pickup_datetime#3838, try_cast(tpep_dropoff_datetime#3818 as timestamp) AS tpep_dropoff_datetime#3839, try_cast(passenger_count#3819 as bigint) AS passenger_count#3840L, try_cast(trip_distance#3820 as double) AS trip_distance#3841, try_cast(RatecodeID#3821 as bigint) AS RatecodeID#3842L, try_cast(store_and_fwd_flag#3822 as string) AS store_and_fwd_flag#3843, try_cast(PULocationID#3823L as bigint) AS PULocationID#3844L, try_cast(DOLocationID#3824L as bigint) AS DOLocationID#3845L, try_cast(payment_type#3825L as bigint) AS payment_type#3846L, try_cast(fare_amount#3826 as double) AS fare_amount#3847, try_cast(extra#3827 as double) AS extra#3848, try_cast(mta_tax#3828 as double) AS mta_tax#3849, try_cast(tip_amount#3829 as double) AS tip_amount#3850, try_cast(tolls_amount#3830 as double) AS tolls_amount#3851, try_cast(improvement_surcharge#3831 as double) AS improvement_surcharge#3852, try_cast(total_amount#3832 as double) AS total_amount#3853, try_cast(congestion_surcharge#3833 as double) AS congestion_surcharge#3854, try_cast(airport_fee#3834 as double) AS airport_fee#3855, current_timestamp() AS current_timestamp()#3836, coalesce(year(cast(tpep_pickup_datetime#3817 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3856, coalesce(month(cast(tpep_pickup_datetime#3817 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3857, coalesce(day(cast(tpep_pickup_dat...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#3023L as bigint) AS VendorID#3044L, try_cast(tpep_pickup_datetime#3024 as timestamp) AS tpep_pickup_datetime#3045, try_cast(tpep_dropoff_datetime#3025 as timestamp) AS tpep_dropoff_datetime#3046, try_cast(passenger_count#3026 as bigint) AS passenger_count#3047L, try_cast(trip_distance#3027 as double) AS trip_distance#3048, try_cast(RatecodeID#3028 as bigint) AS RatecodeID#3049L, try_cast(store_and_fwd_flag#3029 as string) AS store_and_fwd_flag#3050, try_cast(PULocationID#3030L as bigint) AS PULocationID#3051L, try_cast(DOLocationID#3031L as bigint) AS DOLocationID#3052L, try_cast(payment_type#3032L as bigint) AS payment_type#3053L, try_cast(fare_amount#3033 as double) AS fare_amount#3054, try_cast(extra#3034 as double) AS extra#3055, try_cast(mta_tax#3035 as double) AS mta_tax#3056, try_cast(tip_amount#3036 as double) AS tip_amount#3057, try_cast(tolls_amount#3037 as double) AS tolls_amount#3058, try_cast(improvement_surcharge#3038 as double) AS improvement_surcharge#3059, try_cast(total_amount#3039 as double) AS total_amount#3060, try_cast(congestion_surcharge#3040 as double) AS congestion_surcharge#3061, try_cast(airport_fee#3041 as double) AS airport_fee#3062, current_timestamp() AS current_timestamp()#3043, coalesce(year(cast(tpep_pickup_datetime#3024 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3063, coalesce(month(cast(tpep_pickup_datetime#3024 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3064, coalesce(day(cast(tpep_pickup_dat...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#3684L as bigint) AS VendorID#3705L, try_cast(tpep_pickup_datetime#3685 as timestamp) AS tpep_pickup_datetime#3706, try_cast(tpep_dropoff_datetime#3686 as timestamp) AS tpep_dropoff_datetime#3707, try_cast(passenger_count#3687 as bigint) AS passenger_count#3708L, try_cast(trip_distance#3688 as double) AS trip_distance#3709, try_cast(RatecodeID#3689 as bigint) AS RatecodeID#3710L, try_cast(store_and_fwd_flag#3690 as string) AS store_and_fwd_flag#3711, try_cast(PULocationID#3691L as bigint) AS PULocationID#3712L, try_cast(DOLocationID#3692L as bigint) AS DOLocationID#3713L, try_cast(payment_type#3693L as bigint) AS payment_type#3714L, try_cast(fare_amount#3694 as double) AS fare_amount#3715, try_cast(extra#3695 as double) AS extra#3716, try_cast(mta_tax#3696 as double) AS mta_tax#3717, try_cast(tip_amount#3697 as double) AS tip_amount#3718, try_cast(tolls_amount#3698 as double) AS tolls_amount#3719, try_cast(improvement_surcharge#3699 as double) AS improvement_surcharge#3720, try_cast(total_amount#3700 as double) AS total_amount#3721, try_cast(congestion_surcharge#3701 as double) AS congestion_surcharge#3722, try_cast(airport_fee#3702 as double) AS airport_fee#3723, current_timestamp() AS current_timestamp()#3704, coalesce(year(cast(tpep_pickup_datetime#3685 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3724, coalesce(month(cast(tpep_pickup_datetime#3685 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3725, coalesce(day(cast(tpep_pickup_dat...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#3287 as bigint) AS VendorID#3308L, try_cast(tpep_pickup_datetime#3288 as timestamp) AS tpep_pickup_datetime#3309, try_cast(tpep_dropoff_datetime#3289 as timestamp) AS tpep_dropoff_datetime#3310, try_cast(passenger_count#3290L as bigint) AS passenger_count#3311L, try_cast(trip_distance#3291 as double) AS trip_distance#3312, try_cast(RatecodeID#3292L as bigint) AS RatecodeID#3313L, try_cast(store_and_fwd_flag#3293 as string) AS store_and_fwd_flag#3314, try_cast(PULocationID#3294 as bigint) AS PULocationID#3315L, try_cast(DOLocationID#3295 as bigint) AS DOLocationID#3316L, try_cast(payment_type#3296L as bigint) AS payment_type#3317L, try_cast(fare_amount#3297 as double) AS fare_amount#3318, try_cast(extra#3298 as double) AS extra#3319, try_cast(mta_tax#3299 as double) AS mta_tax#3320, try_cast(tip_amount#3300 as double) AS tip_amount#3321, try_cast(tolls_amount#3301 as double) AS tolls_amount#3322, try_cast(improvement_surcharge#3302 as double) AS improvement_surcharge#3323, try_cast(total_amount#3303 as double) AS total_amount#3324, try_cast(congestion_surcharge#3304 as double) AS congestion_surcharge#3325, try_cast(airport_fee#3305 as double) AS airport_fee#3326, current_timestamp() AS current_timestamp()#3307, coalesce(year(cast(tpep_pickup_datetime#3288 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3327, coalesce(month(cast(tpep_pickup_datetime#3288 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3328, coalesce(day(cast(tpep_pickup_date...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [SCHEMA_NOT_FOUND] The schema `spark_catalog`.`yellow_taxi` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a catalog, verify the current_schema() output, or qualify the name with the correct catalog.
To tolerate the error on drop use DROP SCHEMA IF EXISTS. SQLSTATE: 42704

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_CREATE_TABLE_WITH_NON_EMPTY_LOCATION] Cannot create table ('`yellow_taxi`.`trips`'). The associated location ('file:/home/jovyan/spark-warehouse/yellow_taxi.db/trips') is not empty and also not a Delta table.

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#3243 as bigint) AS VendorID#3264L, try_cast(tpep_pickup_datetime#3244 as timestamp) AS tpep_pickup_datetime#3265, try_cast(tpep_dropoff_datetime#3245 as timestamp) AS tpep_dropoff_datetime#3266, try_cast(passenger_count#3246L as bigint) AS passenger_count#3267L, try_cast(trip_distance#3247 as double) AS trip_distance#3268, try_cast(RatecodeID#3248L as bigint) AS RatecodeID#3269L, try_cast(store_and_fwd_flag#3249 as string) AS store_and_fwd_flag#3270, try_cast(PULocationID#3250 as bigint) AS PULocationID#3271L, try_cast(DOLocationID#3251 as bigint) AS DOLocationID#3272L, try_cast(payment_type#3252L as bigint) AS payment_type#3273L, try_cast(fare_amount#3253 as double) AS fare_amount#3274, try_cast(extra#3254 as double) AS extra#3275, try_cast(mta_tax#3255 as double) AS mta_tax#3276, try_cast(tip_amount#3256 as double) AS tip_amount#3277, try_cast(tolls_amount#3257 as double) AS tolls_amount#3278, try_cast(improvement_surcharge#3258 as double) AS improvement_surcharge#3279, try_cast(total_amount#3259 as double) AS total_amount#3280, try_cast(congestion_surcharge#3260 as double) AS congestion_surcharge#3281, try_cast(airport_fee#3261 as double) AS airport_fee#3282, current_timestamp() AS current_timestamp()#3263, coalesce(year(cast(tpep_pickup_datetime#3244 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3283, coalesce(month(cast(tpep_pickup_datetime#3244 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3284, coalesce(day(cast(tpep_pickup_date...

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'passenger_count' and 'passenger_count'

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#2627L as bigint) AS VendorID#2648L, try_cast(tpep_pickup_datetime#2628 as timestamp) AS tpep_pickup_datetime#2649, try_cast(tpep_dropoff_datetime#2629 as timestamp) AS tpep_dropoff_datetime#2650, try_cast(passenger_count#2630 as bigint) AS passenger_count#2651L, try_cast(trip_distance#2631 as double) AS trip_distance#2652, try_cast(RatecodeID#2632 as bigint) AS RatecodeID#2653L, try_cast(store_and_fwd_flag#2633 as string) AS store_and_fwd_flag#2654, try_cast(PULocationID#2634L as bigint) AS PULocationID#2655L, try_cast(DOLocationID#2635L as bigint) AS DOLocationID#2656L, try_cast(payment_type#2636L as bigint) AS payment_type#2657L, try_cast(fare_amount#2637 as double) AS fare_amount#2658, try_cast(extra#2638 as double) AS extra#2659, try_cast(mta_tax#2639 as double) AS mta_tax#2660, try_cast(tip_amount#2640 as double) AS tip_amount#2661, try_cast(tolls_amount#2641 as double) AS tolls_amount#2662, try_cast(improvement_surcharge#2642 as double) AS improvement_surcharge#2663, try_cast(total_amount#2643 as double) AS total_amount#2664, try_cast(congestion_surcharge#2644 as double) AS congestion_surcharge#2665, try_cast(airport_fee#2645 as double) AS airport_fee#2666, current_timestamp() AS current_timestamp()#2647, coalesce(year(cast(tpep_pickup_datetime#2628 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#2667, coalesce(month(cast(tpep_pickup_datetime#2628 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#2668, coalesce(day(cast(tpep_pickup_dat...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#3199 as bigint) AS VendorID#3220L, try_cast(tpep_pickup_datetime#3200 as timestamp) AS tpep_pickup_datetime#3221, try_cast(tpep_dropoff_datetime#3201 as timestamp) AS tpep_dropoff_datetime#3222, try_cast(passenger_count#3202L as bigint) AS passenger_count#3223L, try_cast(trip_distance#3203 as double) AS trip_distance#3224, try_cast(RatecodeID#3204L as bigint) AS RatecodeID#3225L, try_cast(store_and_fwd_flag#3205 as string) AS store_and_fwd_flag#3226, try_cast(PULocationID#3206 as bigint) AS PULocationID#3227L, try_cast(DOLocationID#3207 as bigint) AS DOLocationID#3228L, try_cast(payment_type#3208L as bigint) AS payment_type#3229L, try_cast(fare_amount#3209 as double) AS fare_amount#3230, try_cast(extra#3210 as double) AS extra#3231, try_cast(mta_tax#3211 as double) AS mta_tax#3232, try_cast(tip_amount#3212 as double) AS tip_amount#3233, try_cast(tolls_amount#3213 as double) AS tolls_amount#3234, try_cast(improvement_surcharge#3214 as double) AS improvement_surcharge#3235, try_cast(total_amount#3215 as double) AS total_amount#3236, try_cast(congestion_surcharge#3216 as double) AS congestion_surcharge#3237, try_cast(airport_fee#3217 as double) AS airport_fee#3238, current_timestamp() AS current_timestamp()#3219, coalesce(year(cast(tpep_pickup_datetime#3200 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3239, coalesce(month(cast(tpep_pickup_datetime#3200 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3240, coalesce(day(cast(tpep_pickup_date...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `details` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 9;
'DescribeColumn 'spark_catalog.yellow_taxi.trips, false, [info_name#4363, info_value#4364]
+- 'UnresolvedTableOrView [details], DESCRIBE TABLE, true

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'

INTERNAL: [DELTA_METADATA_MISMATCH] A metadata mismatch was detected when writing to the Delta table.
- A schema mismatch detected when writing to the Delta table (Table ID: 28b4cb71-f282-476d-b38f-4c5b4063764f).
To enable schema migration using DataFrameWriter or DataStreamWriter, please set: '.option("mergeSchema", "true")'.
For other operations, set the session configuration spark.databricks.delta.schema.autoMerge.enabled to "true". See the documentation specific to the operation for details.

Table schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double (nullable = true)
 |-- improvement_surcharge: double (nullable = true)
 |-- total_amount: double (nullable = true)
 |-- congestion_surcharge: void (nullable = true)
 |-- airport_fee: void (nullable = true)


Data schema:
root
 |-- VendorID: long (nullable = true)
 |-- tpep_pickup_datetime: timestamp_ntz (nullable = true)
 |-- tpep_dropoff_datetime: timestamp_ntz (nullable = true)
 |-- passenger_count: double (nullable = true)
 |-- trip_distance: double (nullable = true)
 |-- RatecodeID: double (nullable = true)
 |-- store_and_fwd_flag: string (nullable = true)
 |-- PULocationID: long (nullable = true)
 |-- DOLocationID: long (nullable = true)
 |-- payment_type: long (nullable = true)
 |-- fare_amount: double (nullable = true)
 |-- extra: double (nullable = true)
 |-- mta_tax: double (nullable = true)
 |-- tip_amount: double (nullable = true)
 |-- tolls_amount: double ...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#3331L as bigint) AS VendorID#3352L, try_cast(tpep_pickup_datetime#3332 as timestamp) AS tpep_pickup_datetime#3353, try_cast(tpep_dropoff_datetime#3333 as timestamp) AS tpep_dropoff_datetime#3354, try_cast(passenger_count#3334 as bigint) AS passenger_count#3355L, try_cast(trip_distance#3335 as double) AS trip_distance#3356, try_cast(RatecodeID#3336 as bigint) AS RatecodeID#3357L, try_cast(store_and_fwd_flag#3337 as string) AS store_and_fwd_flag#3358, try_cast(PULocationID#3338L as bigint) AS PULocationID#3359L, try_cast(DOLocationID#3339L as bigint) AS DOLocationID#3360L, try_cast(payment_type#3340L as bigint) AS payment_type#3361L, try_cast(fare_amount#3341 as double) AS fare_amount#3362, try_cast(extra#3342 as double) AS extra#3363, try_cast(mta_tax#3343 as double) AS mta_tax#3364, try_cast(tip_amount#3344 as double) AS tip_amount#3365, try_cast(tolls_amount#3345 as double) AS tolls_amount#3366, try_cast(improvement_surcharge#3346 as double) AS improvement_surcharge#3367, try_cast(total_amount#3347 as double) AS total_amount#3368, try_cast(congestion_surcharge#3348 as double) AS congestion_surcharge#3369, try_cast(airport_fee#3349 as double) AS airport_fee#3370, current_timestamp() AS current_timestamp()#3351, coalesce(year(cast(tpep_pickup_datetime#3332 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3371, coalesce(month(cast(tpep_pickup_datetime#3332 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3372, coalesce(day(cast(tpep_pickup_dat...

INTERNAL: [TABLE_OR_VIEW_NOT_FOUND] The table or view `yellow_taxi`.`trips` cannot be found. Verify the spelling and correctness of the schema and catalog.
If you did not qualify the name with a schema, verify the current_schema() output, or qualify the name with the correct schema and catalog.
To tolerate the error on drop use DROP VIEW IF EXISTS or DROP TABLE IF EXISTS. SQLSTATE: 42P01; line 1 pos 12;
'InsertIntoStatement 'UnresolvedRelation [yellow_taxi, trips], [__required_write_privileges__=INSERT], false, false, false, false
+- Project [try_cast(VendorID#2979L as bigint) AS VendorID#3000L, try_cast(tpep_pickup_datetime#2980 as timestamp) AS tpep_pickup_datetime#3001, try_cast(tpep_dropoff_datetime#2981 as timestamp) AS tpep_dropoff_datetime#3002, try_cast(passenger_count#2982 as bigint) AS passenger_count#3003L, try_cast(trip_distance#2983 as double) AS trip_distance#3004, try_cast(RatecodeID#2984 as bigint) AS RatecodeID#3005L, try_cast(store_and_fwd_flag#2985 as string) AS store_and_fwd_flag#3006, try_cast(PULocationID#2986L as bigint) AS PULocationID#3007L, try_cast(DOLocationID#2987L as bigint) AS DOLocationID#3008L, try_cast(payment_type#2988L as bigint) AS payment_type#3009L, try_cast(fare_amount#2989 as double) AS fare_amount#3010, try_cast(extra#2990 as double) AS extra#3011, try_cast(mta_tax#2991 as double) AS mta_tax#3012, try_cast(tip_amount#2992 as double) AS tip_amount#3013, try_cast(tolls_amount#2993 as double) AS tolls_amount#3014, try_cast(improvement_surcharge#2994 as double) AS improvement_surcharge#3015, try_cast(total_amount#2995 as double) AS total_amount#3016, try_cast(congestion_surcharge#2996 as double) AS congestion_surcharge#3017, try_cast(airport_fee#2997 as double) AS airport_fee#3018, current_timestamp() AS current_timestamp()#2999, coalesce(year(cast(tpep_pickup_datetime#2980 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3019, coalesce(month(cast(tpep_pickup_datetime#2980 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3020, coalesce(day(cast(tpep_pickup_dat...

INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'