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: [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_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_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#3728L as bigint) AS VendorID#3749L, try_cast(tpep_pickup_datetime#3729 as timestamp) AS tpep_pickup_datetime#3750, try_cast(tpep_dropoff_datetime#3730 as timestamp) AS tpep_dropoff_datetime#3751, try_cast(passenger_count#3731L as bigint) AS passenger_count#3752L, try_cast(trip_distance#3732 as double) AS trip_distance#3753, try_cast(RatecodeID#3733L as bigint) AS RatecodeID#3754L, try_cast(store_and_fwd_flag#3734 as string) AS store_and_fwd_flag#3755, try_cast(PULocationID#3735L as bigint) AS PULocationID#3756L, try_cast(DOLocationID#3736L as bigint) AS DOLocationID#3757L, try_cast(payment_type#3737L as bigint) AS payment_type#3758L, try_cast(fare_amount#3738 as double) AS fare_amount#3759, try_cast(extra#3739 as double) AS extra#3760, try_cast(mta_tax#3740 as double) AS mta_tax#3761, try_cast(tip_amount#3741 as double) AS tip_amount#3762, try_cast(tolls_amount#3742 as double) AS tolls_amount#3763, try_cast(improvement_surcharge#3743 as double) AS improvement_surcharge#3764, try_cast(total_amount#3744 as double) AS total_amount#3765, try_cast(congestion_surcharge#3745 as double) AS congestion_surcharge#3766, try_cast(airport_fee#3746 as double) AS airport_fee#3767, current_timestamp() AS current_timestamp()#3748, coalesce(year(cast(tpep_pickup_datetime#3729 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3768, coalesce(month(cast(tpep_pickup_datetime#3729 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3769, 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#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: [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#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: [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: [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#4125L as bigint) AS VendorID#4146L, try_cast(tpep_pickup_datetime#4126 as timestamp) AS tpep_pickup_datetime#4147, try_cast(tpep_dropoff_datetime#4127 as timestamp) AS tpep_dropoff_datetime#4148, try_cast(passenger_count#4128 as bigint) AS passenger_count#4149L, try_cast(trip_distance#4129 as double) AS trip_distance#4150, try_cast(RatecodeID#4130 as bigint) AS RatecodeID#4151L, try_cast(store_and_fwd_flag#4131 as string) AS store_and_fwd_flag#4152, try_cast(PULocationID#4132L as bigint) AS PULocationID#4153L, try_cast(DOLocationID#4133L as bigint) AS DOLocationID#4154L, try_cast(payment_type#4134L as bigint) AS payment_type#4155L, try_cast(fare_amount#4135 as double) AS fare_amount#4156, try_cast(extra#4136 as double) AS extra#4157, try_cast(mta_tax#4137 as double) AS mta_tax#4158, try_cast(tip_amount#4138 as double) AS tip_amount#4159, try_cast(tolls_amount#4139 as double) AS tolls_amount#4160, try_cast(improvement_surcharge#4140 as double) AS improvement_surcharge#4161, try_cast(total_amount#4141 as double) AS total_amount#4162, try_cast(congestion_surcharge#4142 as double) AS congestion_surcharge#4163, try_cast(airport_fee#4143 as double) AS airport_fee#4164, current_timestamp() AS current_timestamp()#4145, coalesce(year(cast(tpep_pickup_datetime#4126 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#4165, coalesce(month(cast(tpep_pickup_datetime#4126 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#4166, 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 '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#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: [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 `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_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: [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_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#3508L as bigint) AS VendorID#3529L, try_cast(tpep_pickup_datetime#3509 as timestamp) AS tpep_pickup_datetime#3530, try_cast(tpep_dropoff_datetime#3510 as timestamp) AS tpep_dropoff_datetime#3531, try_cast(passenger_count#3511 as bigint) AS passenger_count#3532L, try_cast(trip_distance#3512 as double) AS trip_distance#3533, try_cast(RatecodeID#3513 as bigint) AS RatecodeID#3534L, try_cast(store_and_fwd_flag#3514 as string) AS store_and_fwd_flag#3535, try_cast(PULocationID#3515L as bigint) AS PULocationID#3536L, try_cast(DOLocationID#3516L as bigint) AS DOLocationID#3537L, try_cast(payment_type#3517L as bigint) AS payment_type#3538L, try_cast(fare_amount#3518 as double) AS fare_amount#3539, try_cast(extra#3519 as double) AS extra#3540, try_cast(mta_tax#3520 as double) AS mta_tax#3541, try_cast(tip_amount#3521 as double) AS tip_amount#3542, try_cast(tolls_amount#3522 as double) AS tolls_amount#3543, try_cast(improvement_surcharge#3523 as double) AS improvement_surcharge#3544, try_cast(total_amount#3524 as double) AS total_amount#3545, try_cast(congestion_surcharge#3525 as double) AS congestion_surcharge#3546, try_cast(airport_fee#3526 as double) AS airport_fee#3547, current_timestamp() AS current_timestamp()#3528, coalesce(year(cast(tpep_pickup_datetime#3509 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3548, coalesce(month(cast(tpep_pickup_datetime#3509 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3549, 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#2803 as bigint) AS VendorID#2824L, try_cast(tpep_pickup_datetime#2804 as timestamp) AS tpep_pickup_datetime#2825, try_cast(tpep_dropoff_datetime#2805 as timestamp) AS tpep_dropoff_datetime#2826, try_cast(passenger_count#2806L as bigint) AS passenger_count#2827L, try_cast(trip_distance#2807 as double) AS trip_distance#2828, try_cast(RatecodeID#2808L as bigint) AS RatecodeID#2829L, try_cast(store_and_fwd_flag#2809 as string) AS store_and_fwd_flag#2830, try_cast(PULocationID#2810 as bigint) AS PULocationID#2831L, try_cast(DOLocationID#2811 as bigint) AS DOLocationID#2832L, try_cast(payment_type#2812L as bigint) AS payment_type#2833L, try_cast(fare_amount#2813 as double) AS fare_amount#2834, try_cast(extra#2814 as double) AS extra#2835, try_cast(mta_tax#2815 as double) AS mta_tax#2836, try_cast(tip_amount#2816 as double) AS tip_amount#2837, try_cast(tolls_amount#2817 as double) AS tolls_amount#2838, try_cast(improvement_surcharge#2818 as double) AS improvement_surcharge#2839, try_cast(total_amount#2819 as double) AS total_amount#2840, try_cast(congestion_surcharge#2820 as double) AS congestion_surcharge#2841, try_cast(airport_fee#2821 as double) AS airport_fee#2842, current_timestamp() AS current_timestamp()#2823, coalesce(year(cast(tpep_pickup_datetime#2804 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#2843, coalesce(month(cast(tpep_pickup_datetime#2804 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#2844, coalesce(day(cast(tpep_pickup_date...

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#3375 as bigint) AS VendorID#3397L, try_cast(tpep_pickup_datetime#3376 as timestamp) AS tpep_pickup_datetime#3398, try_cast(tpep_dropoff_datetime#3377 as timestamp) AS tpep_dropoff_datetime#3399, try_cast(passenger_count#3378L as bigint) AS passenger_count#3400L, try_cast(trip_distance#3379 as double) AS trip_distance#3401, try_cast(RatecodeID#3380L as bigint) AS RatecodeID#3402L, try_cast(store_and_fwd_flag#3381 as string) AS store_and_fwd_flag#3403, try_cast(PULocationID#3382 as bigint) AS PULocationID#3404L, try_cast(DOLocationID#3383 as bigint) AS DOLocationID#3405L, try_cast(payment_type#3384L as bigint) AS payment_type#3406L, try_cast(fare_amount#3385 as double) AS fare_amount#3407, try_cast(extra#3386 as double) AS extra#3408, try_cast(mta_tax#3387 as double) AS mta_tax#3409, try_cast(tip_amount#3388 as double) AS tip_amount#3410, try_cast(tolls_amount#3389 as double) AS tolls_amount#3411, try_cast(improvement_surcharge#3390 as double) AS improvement_surcharge#3412, try_cast(total_amount#3391 as double) AS total_amount#3413, try_cast(congestion_surcharge#3392 as double) AS congestion_surcharge#3414, try_cast(airport_fee#3393 as double) AS airport_fee#3415, current_timestamp() AS current_timestamp()#3396, coalesce(year(cast(tpep_pickup_datetime#3376 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3416, coalesce(month(cast(tpep_pickup_datetime#3376 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3417, coalesce(day(cast(tpep_pickup_date...

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_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'passenger_count' and 'passenger_count'

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_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#2935L as bigint) AS VendorID#2956L, try_cast(tpep_pickup_datetime#2936 as timestamp) AS tpep_pickup_datetime#2957, try_cast(tpep_dropoff_datetime#2937 as timestamp) AS tpep_dropoff_datetime#2958, try_cast(passenger_count#2938 as bigint) AS passenger_count#2959L, try_cast(trip_distance#2939 as double) AS trip_distance#2960, try_cast(RatecodeID#2940 as bigint) AS RatecodeID#2961L, try_cast(store_and_fwd_flag#2941 as string) AS store_and_fwd_flag#2962, try_cast(PULocationID#2942L as bigint) AS PULocationID#2963L, try_cast(DOLocationID#2943L as bigint) AS DOLocationID#2964L, try_cast(payment_type#2944L as bigint) AS payment_type#2965L, try_cast(fare_amount#2945 as double) AS fare_amount#2966, try_cast(extra#2946 as double) AS extra#2967, try_cast(mta_tax#2947 as double) AS mta_tax#2968, try_cast(tip_amount#2948 as double) AS tip_amount#2969, try_cast(tolls_amount#2949 as double) AS tolls_amount#2970, try_cast(improvement_surcharge#2950 as double) AS improvement_surcharge#2971, try_cast(total_amount#2951 as double) AS total_amount#2972, try_cast(congestion_surcharge#2952 as double) AS congestion_surcharge#2973, try_cast(airport_fee#2953 as double) AS airport_fee#2974, current_timestamp() AS current_timestamp()#2955, coalesce(year(cast(tpep_pickup_datetime#2936 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#2975, coalesce(month(cast(tpep_pickup_datetime#2936 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#2976, 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#2671L as bigint) AS VendorID#2692L, try_cast(tpep_pickup_datetime#2672 as timestamp) AS tpep_pickup_datetime#2693, try_cast(tpep_dropoff_datetime#2673 as timestamp) AS tpep_dropoff_datetime#2694, try_cast(passenger_count#2674 as bigint) AS passenger_count#2695L, try_cast(trip_distance#2675 as double) AS trip_distance#2696, try_cast(RatecodeID#2676 as bigint) AS RatecodeID#2697L, try_cast(store_and_fwd_flag#2677 as string) AS store_and_fwd_flag#2698, try_cast(PULocationID#2678L as bigint) AS PULocationID#2699L, try_cast(DOLocationID#2679L as bigint) AS DOLocationID#2700L, try_cast(payment_type#2680L as bigint) AS payment_type#2701L, try_cast(fare_amount#2681 as double) AS fare_amount#2702, try_cast(extra#2682 as double) AS extra#2703, try_cast(mta_tax#2683 as double) AS mta_tax#2704, try_cast(tip_amount#2684 as double) AS tip_amount#2705, try_cast(tolls_amount#2685 as double) AS tolls_amount#2706, try_cast(improvement_surcharge#2686 as double) AS improvement_surcharge#2707, try_cast(total_amount#2687 as double) AS total_amount#2708, try_cast(congestion_surcharge#2688 as double) AS congestion_surcharge#2709, try_cast(airport_fee#2689 as double) AS airport_fee#2710, current_timestamp() AS current_timestamp()#2691, coalesce(year(cast(tpep_pickup_datetime#2672 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#2711, coalesce(month(cast(tpep_pickup_datetime#2672 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#2712, 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: [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: [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#4081L as bigint) AS VendorID#4102L, try_cast(tpep_pickup_datetime#4082 as timestamp) AS tpep_pickup_datetime#4103, try_cast(tpep_dropoff_datetime#4083 as timestamp) AS tpep_dropoff_datetime#4104, try_cast(passenger_count#4084 as bigint) AS passenger_count#4105L, try_cast(trip_distance#4085 as double) AS trip_distance#4106, try_cast(RatecodeID#4086 as bigint) AS RatecodeID#4107L, try_cast(store_and_fwd_flag#4087 as string) AS store_and_fwd_flag#4108, try_cast(PULocationID#4088L as bigint) AS PULocationID#4109L, try_cast(DOLocationID#4089L as bigint) AS DOLocationID#4110L, try_cast(payment_type#4090L as bigint) AS payment_type#4111L, try_cast(fare_amount#4091 as double) AS fare_amount#4112, try_cast(extra#4092 as double) AS extra#4113, try_cast(mta_tax#4093 as double) AS mta_tax#4114, try_cast(tip_amount#4094 as double) AS tip_amount#4115, try_cast(tolls_amount#4095 as double) AS tolls_amount#4116, try_cast(improvement_surcharge#4096 as double) AS improvement_surcharge#4117, try_cast(total_amount#4097 as double) AS total_amount#4118, try_cast(congestion_surcharge#4098 as double) AS congestion_surcharge#4119, try_cast(airport_fee#4099 as double) AS airport_fee#4120, current_timestamp() AS current_timestamp()#4101, coalesce(year(cast(tpep_pickup_datetime#4082 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#4121, coalesce(month(cast(tpep_pickup_datetime#4082 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#4122, 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#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: [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: [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: [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#2715 as bigint) AS VendorID#2736L, try_cast(tpep_pickup_datetime#2716 as timestamp) AS tpep_pickup_datetime#2737, try_cast(tpep_dropoff_datetime#2717 as timestamp) AS tpep_dropoff_datetime#2738, try_cast(passenger_count#2718L as bigint) AS passenger_count#2739L, try_cast(trip_distance#2719 as double) AS trip_distance#2740, try_cast(RatecodeID#2720L as bigint) AS RatecodeID#2741L, try_cast(store_and_fwd_flag#2721 as string) AS store_and_fwd_flag#2742, try_cast(PULocationID#2722 as bigint) AS PULocationID#2743L, try_cast(DOLocationID#2723 as bigint) AS DOLocationID#2744L, try_cast(payment_type#2724L as bigint) AS payment_type#2745L, try_cast(fare_amount#2725 as double) AS fare_amount#2746, try_cast(extra#2726 as double) AS extra#2747, try_cast(mta_tax#2727 as double) AS mta_tax#2748, try_cast(tip_amount#2728 as double) AS tip_amount#2749, try_cast(tolls_amount#2729 as double) AS tolls_amount#2750, try_cast(improvement_surcharge#2730 as double) AS improvement_surcharge#2751, try_cast(total_amount#2731 as double) AS total_amount#2752, try_cast(congestion_surcharge#2732 as double) AS congestion_surcharge#2753, try_cast(airport_fee#2733 as double) AS airport_fee#2754, current_timestamp() AS current_timestamp()#2735, coalesce(year(cast(tpep_pickup_datetime#2716 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#2755, coalesce(month(cast(tpep_pickup_datetime#2716 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#2756, coalesce(day(cast(tpep_pickup_date...