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 `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: 
[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: [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_ALREADY_EXISTS] Cannot create table or view `yellow_taxi`.`trips` because it already exists.
Choose a different name, drop or replace the existing object, or add the IF NOT EXISTS clause to tolerate pre-existing objects. SQLSTATE: 42P07

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: [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#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#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...

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#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#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: [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: [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#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: [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#3067L as bigint) AS VendorID#3088L, try_cast(tpep_pickup_datetime#3068 as timestamp) AS tpep_pickup_datetime#3089, try_cast(tpep_dropoff_datetime#3069 as timestamp) AS tpep_dropoff_datetime#3090, try_cast(passenger_count#3070 as bigint) AS passenger_count#3091L, try_cast(trip_distance#3071 as double) AS trip_distance#3092, try_cast(RatecodeID#3072 as bigint) AS RatecodeID#3093L, try_cast(store_and_fwd_flag#3073 as string) AS store_and_fwd_flag#3094, try_cast(PULocationID#3074L as bigint) AS PULocationID#3095L, try_cast(DOLocationID#3075L as bigint) AS DOLocationID#3096L, try_cast(payment_type#3076L as bigint) AS payment_type#3097L, try_cast(fare_amount#3077 as double) AS fare_amount#3098, try_cast(extra#3078 as double) AS extra#3099, try_cast(mta_tax#3079 as double) AS mta_tax#3100, try_cast(tip_amount#3080 as double) AS tip_amount#3101, try_cast(tolls_amount#3081 as double) AS tolls_amount#3102, try_cast(improvement_surcharge#3082 as double) AS improvement_surcharge#3103, try_cast(total_amount#3083 as double) AS total_amount#3104, try_cast(congestion_surcharge#3084 as double) AS congestion_surcharge#3105, try_cast(airport_fee#3085 as double) AS airport_fee#3106, current_timestamp() AS current_timestamp()#3087, coalesce(year(cast(tpep_pickup_datetime#3068 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3107, coalesce(month(cast(tpep_pickup_datetime#3068 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3108, 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#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#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#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: [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: [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: [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#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: [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#3464 as bigint) AS VendorID#3485L, try_cast(tpep_pickup_datetime#3465 as timestamp) AS tpep_pickup_datetime#3486, try_cast(tpep_dropoff_datetime#3466 as timestamp) AS tpep_dropoff_datetime#3487, try_cast(passenger_count#3467L as bigint) AS passenger_count#3488L, try_cast(trip_distance#3468 as double) AS trip_distance#3489, try_cast(RatecodeID#3469L as bigint) AS RatecodeID#3490L, try_cast(store_and_fwd_flag#3470 as string) AS store_and_fwd_flag#3491, try_cast(PULocationID#3471 as bigint) AS PULocationID#3492L, try_cast(DOLocationID#3472 as bigint) AS DOLocationID#3493L, try_cast(payment_type#3473L as bigint) AS payment_type#3494L, try_cast(fare_amount#3474 as double) AS fare_amount#3495, try_cast(extra#3475 as double) AS extra#3496, try_cast(mta_tax#3476 as double) AS mta_tax#3497, try_cast(tip_amount#3477 as double) AS tip_amount#3498, try_cast(tolls_amount#3478 as double) AS tolls_amount#3499, try_cast(improvement_surcharge#3479 as double) AS improvement_surcharge#3500, try_cast(total_amount#3480 as double) AS total_amount#3501, try_cast(congestion_surcharge#3481 as double) AS congestion_surcharge#3502, try_cast(airport_fee#3482 as double) AS airport_fee#3503, current_timestamp() AS current_timestamp()#3484, coalesce(year(cast(tpep_pickup_datetime#3465 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3504, coalesce(month(cast(tpep_pickup_datetime#3465 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3505, 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#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: [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#3552L as bigint) AS VendorID#3573L, try_cast(tpep_pickup_datetime#3553 as timestamp) AS tpep_pickup_datetime#3574, try_cast(tpep_dropoff_datetime#3554 as timestamp) AS tpep_dropoff_datetime#3575, try_cast(passenger_count#3555 as bigint) AS passenger_count#3576L, try_cast(trip_distance#3556 as double) AS trip_distance#3577, try_cast(RatecodeID#3557 as bigint) AS RatecodeID#3578L, try_cast(store_and_fwd_flag#3558 as string) AS store_and_fwd_flag#3579, try_cast(PULocationID#3559L as bigint) AS PULocationID#3580L, try_cast(DOLocationID#3560L as bigint) AS DOLocationID#3581L, try_cast(payment_type#3561L as bigint) AS payment_type#3582L, try_cast(fare_amount#3562 as double) AS fare_amount#3583, try_cast(extra#3563 as double) AS extra#3584, try_cast(mta_tax#3564 as double) AS mta_tax#3585, try_cast(tip_amount#3565 as double) AS tip_amount#3586, try_cast(tolls_amount#3566 as double) AS tolls_amount#3587, try_cast(improvement_surcharge#3567 as double) AS improvement_surcharge#3588, try_cast(total_amount#3568 as double) AS total_amount#3589, try_cast(congestion_surcharge#3569 as double) AS congestion_surcharge#3590, try_cast(airport_fee#3570 as double) AS airport_fee#3591, current_timestamp() AS current_timestamp()#3572, coalesce(year(cast(tpep_pickup_datetime#3553 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3592, coalesce(month(cast(tpep_pickup_datetime#3553 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3593, 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#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#3640L as bigint) AS VendorID#3661L, try_cast(tpep_pickup_datetime#3641 as timestamp) AS tpep_pickup_datetime#3662, try_cast(tpep_dropoff_datetime#3642 as timestamp) AS tpep_dropoff_datetime#3663, try_cast(passenger_count#3643 as bigint) AS passenger_count#3664L, try_cast(trip_distance#3644 as double) AS trip_distance#3665, try_cast(RatecodeID#3645 as bigint) AS RatecodeID#3666L, try_cast(store_and_fwd_flag#3646 as string) AS store_and_fwd_flag#3667, try_cast(PULocationID#3647L as bigint) AS PULocationID#3668L, try_cast(DOLocationID#3648L as bigint) AS DOLocationID#3669L, try_cast(payment_type#3649L as bigint) AS payment_type#3670L, try_cast(fare_amount#3650 as double) AS fare_amount#3671, try_cast(extra#3651 as double) AS extra#3672, try_cast(mta_tax#3652 as double) AS mta_tax#3673, try_cast(tip_amount#3653 as double) AS tip_amount#3674, try_cast(tolls_amount#3654 as double) AS tolls_amount#3675, try_cast(improvement_surcharge#3655 as double) AS improvement_surcharge#3676, try_cast(total_amount#3656 as double) AS total_amount#3677, try_cast(congestion_surcharge#3657 as double) AS congestion_surcharge#3678, try_cast(airport_fee#3658 as double) AS airport_fee#3679, current_timestamp() AS current_timestamp()#3660, coalesce(year(cast(tpep_pickup_datetime#3641 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3680, coalesce(month(cast(tpep_pickup_datetime#3641 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3681, 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: [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#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#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#3860L as bigint) AS VendorID#3881L, try_cast(tpep_pickup_datetime#3861 as timestamp) AS tpep_pickup_datetime#3882, try_cast(tpep_dropoff_datetime#3862 as timestamp) AS tpep_dropoff_datetime#3883, try_cast(passenger_count#3863L as bigint) AS passenger_count#3884L, try_cast(trip_distance#3864 as double) AS trip_distance#3885, try_cast(RatecodeID#3865L as bigint) AS RatecodeID#3886L, try_cast(store_and_fwd_flag#3866 as string) AS store_and_fwd_flag#3887, try_cast(PULocationID#3867L as bigint) AS PULocationID#3888L, try_cast(DOLocationID#3868L as bigint) AS DOLocationID#3889L, try_cast(payment_type#3869L as bigint) AS payment_type#3890L, try_cast(fare_amount#3870 as double) AS fare_amount#3891, try_cast(extra#3871 as double) AS extra#3892, try_cast(mta_tax#3872 as double) AS mta_tax#3893, try_cast(tip_amount#3873 as double) AS tip_amount#3894, try_cast(tolls_amount#3874 as double) AS tolls_amount#3895, try_cast(improvement_surcharge#3875 as double) AS improvement_surcharge#3896, try_cast(total_amount#3876 as double) AS total_amount#3897, try_cast(congestion_surcharge#3877 as double) AS congestion_surcharge#3898, try_cast(airport_fee#3878 as double) AS airport_fee#3899, current_timestamp() AS current_timestamp()#3880, coalesce(year(cast(tpep_pickup_datetime#3861 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3900, coalesce(month(cast(tpep_pickup_datetime#3861 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3901, 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#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: [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#3948L as bigint) AS VendorID#3969L, try_cast(tpep_pickup_datetime#3949 as timestamp) AS tpep_pickup_datetime#3970, try_cast(tpep_dropoff_datetime#3950 as timestamp) AS tpep_dropoff_datetime#3971, try_cast(passenger_count#3951 as bigint) AS passenger_count#3972L, try_cast(trip_distance#3952 as double) AS trip_distance#3973, try_cast(RatecodeID#3953 as bigint) AS RatecodeID#3974L, try_cast(store_and_fwd_flag#3954 as string) AS store_and_fwd_flag#3975, try_cast(PULocationID#3955L as bigint) AS PULocationID#3976L, try_cast(DOLocationID#3956L as bigint) AS DOLocationID#3977L, try_cast(payment_type#3957L as bigint) AS payment_type#3978L, try_cast(fare_amount#3958 as double) AS fare_amount#3979, try_cast(extra#3959 as double) AS extra#3980, try_cast(mta_tax#3960 as double) AS mta_tax#3981, try_cast(tip_amount#3961 as double) AS tip_amount#3982, try_cast(tolls_amount#3962 as double) AS tolls_amount#3983, try_cast(improvement_surcharge#3963 as double) AS improvement_surcharge#3984, try_cast(total_amount#3964 as double) AS total_amount#3985, try_cast(congestion_surcharge#3965 as double) AS congestion_surcharge#3986, try_cast(airport_fee#3966 as double) AS airport_fee#3987, current_timestamp() AS current_timestamp()#3968, coalesce(year(cast(tpep_pickup_datetime#3949 as date)), 2026) AS coalesce(year(tpep_pickup_datetime), 2026)#3988, coalesce(month(cast(tpep_pickup_datetime#3949 as date)), 9) AS coalesce(month(tpep_pickup_datetime), 9)#3989, 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#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: [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: [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#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: [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: [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: [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_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: [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: [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: [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: [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'