|
|
[209]
|
[215]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:38
|
2026/09/03 16:13:38
|
2026/09/03 16:13:38
|
171 ms
|
175 ms
|
write_operation {
input {
common {
plan_id: 94
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-07.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
00f8c9d7-c11a-411f-b7be-c0be0e2f29b0
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_00f8c9d7-c11a-411f-b7be-c0be0e2f29b0
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[169][170]
|
[175][176]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:07
|
2026/09/03 16:13:33
|
2026/09/03 16:13:33
|
25 seconds 362 ms
|
25 seconds 366 ms
|
write_operation {
input {
common {
plan_id: 16
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-12.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
035259f2-8534-4df9-9603-193cb3db6fe8
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_035259f2-8534-4df9-9603-193cb3db6fe8
|
|
|
|
|
[186]
|
[192]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:35
|
2026/09/03 16:13:35
|
2026/09/03 16:13:35
|
81 ms
|
86 ms
|
write_operation {
input {
common {
plan_id: 48
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-05.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
038056f6-65ae-4842-828e-83013290f29d
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_038056f6-65ae-4842-828e-83013290f29d
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'passenger_count' and 'passenger_count'
|
|
|
[242]
|
[248]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:08
|
2026/09/03 16:14:08
|
2026/09/03 16:14:08
|
79 ms
|
82 ms
|
write_operation {
input {
common {
plan_id: 158
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-11.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
04c2c4d4-48cd-41f1-911a-34f31a74a4dd
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_04c2c4d4-48cd-41f1-911a-34f31a74a4dd
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[173]
|
[179]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:33
|
2026/09/03 16:13:33
|
2026/09/03 16:13:33
|
93 ms
|
98 ms
|
write_operation {
input {
common {
plan_id: 22
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-12.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
070b7388-8ec5-4d50-b7fa-defa8b2fc8d7
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_070b7388-8ec5-4d50-b7fa-defa8b2fc8d7
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[70]
|
[70]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:55
|
2026/09/03 15:55:55
|
2026/09/03 15:55:55
|
103 ms
|
108 ms
|
sql_command {
input {
common {
plan_id: 71
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-10.parquet`\n "
}
}
}
|
CLOSED
|
07292414-b820-462e-b17d-cdeb39d1bfac
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_07292414-b820-462e-b17d-cdeb39d1bfac
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[122]
|
[130][131]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:06
|
|
|
8 weeks 3 days 3 hours
|
8 weeks 3 days 3 hours
|
write_operation {
input {
common {
plan_id: 141
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-02.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
RUNNING
|
0736c6a9-8500-4c2b-a735-a0089e70f6bc
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_0736c6a9-8500-4c2b-a735-a0089e70f6bc
|
|
|
|
|
[81]
|
[81]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:56
|
2026/09/03 15:55:56
|
2026/09/03 15:55:56
|
102 ms
|
108 ms
|
sql_command {
input {
common {
plan_id: 82
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-05.parquet`\n "
}
}
}
|
CLOSED
|
08247687-c8b5-4a36-bc65-7818df1a7d86
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_08247687-c8b5-4a36-bc65-7818df1a7d86
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[214]
|
[220]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:38
|
2026/09/03 16:13:38
|
2026/09/03 16:13:39
|
91 ms
|
98 ms
|
write_operation {
input {
common {
plan_id: 104
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-08.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
0cc0f910-7a61-4785-aaf6-54f3223e0dab
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_0cc0f910-7a61-4785-aaf6-54f3223e0dab
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[155][156][157]
|
[161][162][163]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:26
|
2026/09/03 16:10:39
|
2026/09/03 16:17:54
|
12 seconds 670 ms
|
7 minutes 27 seconds
|
write_operation {
input {
common {
plan_id: 189
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-05.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
CLOSED
|
0d73ec80-efc3-457f-b7a0-ecf03792de7e
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_0d73ec80-efc3-457f-b7a0-ecf03792de7e
|
|
|
|
|
[138]
|
[147][148]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:09
|
2026/09/03 16:10:09
|
2026/09/03 16:10:09
|
560 ms
|
567 ms
|
write_operation {
input {
common {
plan_id: 167
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-04.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
CLOSED
|
0e0ae871-5c31-43fe-bfcd-3145d557e602
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_0e0ae871-5c31-43fe-bfcd-3145d557e602
|
|
|
|
|
[225]
|
[231]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:06
|
2026/09/03 16:14:06
|
2026/09/03 16:14:06
|
86 ms
|
90 ms
|
write_operation {
input {
common {
plan_id: 124
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-10.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
0ee9b11f-8e57-463c-86a9-723e65186262
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_0ee9b11f-8e57-463c-86a9-723e65186262
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[227]
|
[233]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:07
|
2026/09/03 16:14:07
|
2026/09/03 16:14:07
|
102 ms
|
106 ms
|
write_operation {
input {
common {
plan_id: 128
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-01.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
0f6391dc-4186-438a-a313-ba7c32f0b0e6
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_0f6391dc-4186-438a-a313-ba7c32f0b0e6
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[193]
|
[199]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:36
|
2026/09/03 16:13:36
|
2026/09/03 16:13:36
|
136 ms
|
141 ms
|
write_operation {
input {
common {
plan_id: 62
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-09.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
11505f12-b6ea-4784-8780-c85845c387a8
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_11505f12-b6ea-4784-8780-c85845c387a8
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[250]
|
[256]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:09
|
2026/09/03 16:14:09
|
2026/09/03 16:14:09
|
158 ms
|
162 ms
|
write_operation {
input {
common {
plan_id: 174
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-06.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
12b1ae76-d166-4c27-9c07-8187996ee91e
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_12b1ae76-d166-4c27-9c07-8187996ee91e
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'passenger_count' and 'passenger_count'
|
|
|
[256]
|
[262]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:10
|
2026/09/03 16:14:10
|
2026/09/03 16:14:10
|
143 ms
|
146 ms
|
write_operation {
input {
common {
plan_id: 186
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-02.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
131986c8-8cfc-4db3-a6cc-6201942f62e0
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_131986c8-8cfc-4db3-a6cc-6201942f62e0
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[126]
|
[134][135]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:07
|
2026/09/03 16:10:07
|
2026/09/03 16:10:07
|
333 ms
|
334 ms
|
write_operation {
input {
common {
plan_id: 147
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-07.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
CLOSED
|
14b3700d-9902-44c3-8c7b-7d1ab2be7dac
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_14b3700d-9902-44c3-8c7b-7d1ab2be7dac
|
|
|
|
|
[207]
|
[213]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:38
|
2026/09/03 16:13:38
|
2026/09/03 16:13:38
|
127 ms
|
131 ms
|
write_operation {
input {
common {
plan_id: 90
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-03.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
14c8aa2c-e9b7-4654-8609-907121af310f
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_14c8aa2c-e9b7-4654-8609-907121af310f
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'passenger_count' and 'passenger_count'
|
|
|
[104][105]
|
[111]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:04:22
|
2026/09/03 16:04:23
|
2026/09/03 16:04:23
|
1 second 293 ms
|
1 second 306 ms
|
common {
plan_id: 116
}
aggregate {
input {
common {
plan_id: 115
}
read {
data_source {
format: "delta"
schema: ""
paths: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips"
}
}
}
group_type: GROUP_TYPE_GROUPBY
aggregate_expressions {
unresolved_function {
function_name: "count"
arguments {
literal {
integer: 1
}
}
}
}
}
|
CLOSED
|
1534209b-e69e-4668-879a-4f7b18f0c8ed
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_1534209b-e69e-4668-879a-4f7b18f0c8ed
|
|
|
|
|
[211]
|
[217]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:38
|
2026/09/03 16:13:38
|
2026/09/03 16:13:38
|
95 ms
|
99 ms
|
write_operation {
input {
common {
plan_id: 98
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-05.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
15644fc0-5219-436f-978a-262f2851cff8
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_15644fc0-5219-436f-978a-262f2851cff8
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[195]
|
[201]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:36
|
2026/09/03 16:13:36
|
2026/09/03 16:13:36
|
107 ms
|
111 ms
|
write_operation {
input {
common {
plan_id: 66
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-12.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
1842e87c-6411-4588-a7cc-b4a675f5ab04
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_1842e87c-6411-4588-a7cc-b4a675f5ab04
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[212]
|
[218]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:38
|
2026/09/03 16:13:38
|
2026/09/03 16:13:38
|
97 ms
|
100 ms
|
write_operation {
input {
common {
plan_id: 100
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-03.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
193c6253-94c4-4d1c-b0b0-d48c996d246e
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_193c6253-94c4-4d1c-b0b0-d48c996d246e
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[181]
|
[187]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:34
|
2026/09/03 16:13:34
|
2026/09/03 16:13:34
|
116 ms
|
121 ms
|
write_operation {
input {
common {
plan_id: 38
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-07.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
19df5b34-f378-494e-81db-e3371ab2c257
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_19df5b34-f378-494e-81db-e3371ab2c257
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[149][150]
|
[155][156]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:10
|
2026/09/03 16:10:17
|
2026/09/03 16:10:17
|
7 seconds 162 ms
|
7 seconds 163 ms
|
write_operation {
input {
common {
plan_id: 183
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-12.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
CLOSED
|
19e2d57c-1fb5-4d37-a377-c4460bc08d30
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_19e2d57c-1fb5-4d37-a377-c4460bc08d30
|
|
|
|
|
[196]
|
[202]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:36
|
2026/09/03 16:13:36
|
2026/09/03 16:13:36
|
87 ms
|
94 ms
|
write_operation {
input {
common {
plan_id: 68
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-08.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
1a81ea2a-525d-4e8d-9b12-741b7aa7c3f9
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_1a81ea2a-525d-4e8d-9b12-741b7aa7c3f9
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[218]
|
[224]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:39
|
2026/09/03 16:13:39
|
2026/09/03 16:13:39
|
86 ms
|
91 ms
|
write_operation {
input {
common {
plan_id: 112
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-05.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
1b892df8-440a-4e11-8f2a-a8e9f5a0d381
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_1b892df8-440a-4e11-8f2a-a8e9f5a0d381
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[64]
|
[64]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:54
|
2026/09/03 15:55:54
|
2026/09/03 15:55:54
|
134 ms
|
141 ms
|
sql_command {
input {
common {
plan_id: 65
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-02.parquet`\n "
}
}
}
|
CLOSED
|
1e92a838-5a6e-43a9-acb6-29c21ec6736e
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_1e92a838-5a6e-43a9-acb6-29c21ec6736e
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[206]
|
[212]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:37
|
2026/09/03 16:13:38
|
2026/09/03 16:13:38
|
116 ms
|
121 ms
|
write_operation {
input {
common {
plan_id: 88
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-02.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
1f032c4e-d4a8-4748-b54f-a53e0013de78
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_1f032c4e-d4a8-4748-b54f-a53e0013de78
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[219][220]
|
[225][226]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:39
|
2026/09/03 16:14:06
|
2026/09/03 16:14:06
|
26 seconds 854 ms
|
26 seconds 857 ms
|
write_operation {
input {
common {
plan_id: 114
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-07.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
21211c3d-a004-4101-a1bb-488c89fddc2f
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_21211c3d-a004-4101-a1bb-488c89fddc2f
|
|
|
|
|
[94]
|
[94]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:58
|
2026/09/03 15:55:58
|
2026/09/03 15:55:58
|
183 ms
|
190 ms
|
sql_command {
input {
common {
plan_id: 95
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-02.parquet`\n "
}
}
}
|
CLOSED
|
2150884e-0543-40e8-9b8e-e5bb1316f685
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_2150884e-0543-40e8-9b8e-e5bb1316f685
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
|
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:59:02
|
2026/09/03 15:59:02
|
2026/09/03 15:59:02
|
11 ms
|
24 ms
|
common {
plan_id: 107
}
limit {
input {
common {
plan_id: 106
}
local_relation {
data: "\377\377\377\377@\000\000\000[truncated(size=152)]"
}
}
limit: 1000
}
|
CLOSED
|
21f9f48f-f295-462d-88d7-9aec4bdd3753
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_21f9f48f-f295-462d-88d7-9aec4bdd3753
|
|
|
|
|
[114]
|
[119][120]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:05
|
2026/09/03 16:10:06
|
2026/09/03 16:10:06
|
322 ms
|
322 ms
|
write_operation {
input {
common {
plan_id: 127
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-05.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
CLOSED
|
24da78ab-53f3-47e8-b928-e057f6c960f7
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_24da78ab-53f3-47e8-b928-e057f6c960f7
|
|
|
|
|
[130]
|
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:07
|
|
|
8 weeks 3 days 3 hours
|
8 weeks 3 days 3 hours
|
write_operation {
input {
common {
plan_id: 153
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-12.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
RUNNING
|
2630ec1c-1b31-4c50-a65b-55f5decbd2fc
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_2630ec1c-1b31-4c50-a65b-55f5decbd2fc
|
|
|
|
|
|
[103]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:00:22
|
2026/09/03 16:00:22
|
2026/09/03 16:00:22
|
25 ms
|
30 ms
|
sql_command {
input {
common {
plan_id: 109
}
sql {
query: "\ncreate table spark_catalog.yellow_taxi.trips(\n VendorID long,\n tpep_pickup_datetime timestamp,\n tpep_dropoff_datetime timestamp,\n passenger_count long,\n trip_distance double,\n RatecodeID long,\n store_and_fwd_flag string,\n PULocationID long,\n DOLocationID long,\n payment_type long,\n fare_amount double,\n extra double,\n mta_tax double,\n tip_amount double,\n tolls_amount double,\n improvement_surcharge double,\n total_amount double,\n congestion_surcharge double,\n airport_fee double,\n load_timestamp timestamp,\n year int,\n month int,\n day int\n)\nusing delta\npartitioned by (year,month)\nlocation \'/home/jovyan/spark-warehouse/yellow_taxi.db/trips\'\n"
}
}
}
|
CLOSED
|
269f6447-c3d5-480a-826a-f446bdec940f
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_269f6447-c3d5-480a-826a-f446bdec940f
|
|
TABLE_OR_VIEW_ALREADY_EXISTS
+details
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
|
|
|
[215]
|
[221]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:39
|
2026/09/03 16:13:39
|
2026/09/03 16:13:39
|
106 ms
|
110 ms
|
write_operation {
input {
common {
plan_id: 106
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-04.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
29dbea9c-4898-40e0-8360-9ebb3400571e
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_29dbea9c-4898-40e0-8360-9ebb3400571e
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'passenger_count' and 'passenger_count'
|
|
|
[230]
|
[236]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:07
|
2026/09/03 16:14:07
|
2026/09/03 16:14:07
|
134 ms
|
137 ms
|
write_operation {
input {
common {
plan_id: 134
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-09.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
2b2caa6f-19ec-4b1d-a859-3e6126e4c68b
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_2b2caa6f-19ec-4b1d-a859-3e6126e4c68b
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[192]
|
[198]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:35
|
2026/09/03 16:13:36
|
2026/09/03 16:13:36
|
279 ms
|
284 ms
|
write_operation {
input {
common {
plan_id: 60
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-04.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
2c86dd1a-1570-4f98-9e2e-9b81a80d2006
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_2c86dd1a-1570-4f98-9e2e-9b81a80d2006
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[240]
|
[246]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:08
|
2026/09/03 16:14:08
|
2026/09/03 16:14:08
|
91 ms
|
94 ms
|
write_operation {
input {
common {
plan_id: 154
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-07.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
2cd0c3f1-7085-448d-af0e-31d580b5d84f
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_2cd0c3f1-7085-448d-af0e-31d580b5d84f
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[241]
|
[247]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:08
|
2026/09/03 16:14:08
|
2026/09/03 16:14:08
|
82 ms
|
85 ms
|
write_operation {
input {
common {
plan_id: 156
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-07.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
2d69db4e-6414-4518-b9f7-a4f2a54548ab
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_2d69db4e-6414-4518-b9f7-a4f2a54548ab
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[62]
|
[62]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:54
|
2026/09/03 15:55:54
|
2026/09/03 15:55:54
|
113 ms
|
122 ms
|
sql_command {
input {
common {
plan_id: 63
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-09.parquet`\n "
}
}
}
|
CLOSED
|
2df7501f-cf45-447d-8e5b-5abb0eb1e7dc
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_2df7501f-cf45-447d-8e5b-5abb0eb1e7dc
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[137][139]
|
[145][146]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:09
|
|
|
8 weeks 3 days 3 hours
|
8 weeks 3 days 3 hours
|
write_operation {
input {
common {
plan_id: 165
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-05.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
RUNNING
|
2f228dd1-be15-416d-be3d-8dc0abcdbd80
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_2f228dd1-be15-416d-be3d-8dc0abcdbd80
|
|
|
|
|
|
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:56:10
|
2026/09/03 15:56:10
|
2026/09/03 15:56:10
|
357 ms
|
378 ms
|
common {
plan_id: 101
}
limit {
input {
common {
plan_id: 100
}
local_relation {
data: "\377\377\377\377@\000\000\000[truncated(size=152)]"
}
}
limit: 1000
}
|
CLOSED
|
2fb37124-09dd-46af-a3ea-7f3ff3899f9a
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_2fb37124-09dd-46af-a3ea-7f3ff3899f9a
|
|
|
|
|
[80]
|
[80]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:56
|
2026/09/03 15:55:56
|
2026/09/03 15:55:56
|
133 ms
|
147 ms
|
sql_command {
input {
common {
plan_id: 81
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-11.parquet`\n "
}
}
}
|
CLOSED
|
300aa833-632d-41e2-b4d0-2915f9f05b5a
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_300aa833-632d-41e2-b4d0-2915f9f05b5a
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[85]
|
[85]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:57
|
2026/09/03 15:55:57
|
2026/09/03 15:55:57
|
199 ms
|
203 ms
|
sql_command {
input {
common {
plan_id: 86
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-02.parquet`\n "
}
}
}
|
CLOSED
|
300ea7b2-0a1f-4e0b-aefa-ca3b63ffbc78
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_300ea7b2-0a1f-4e0b-aefa-ca3b63ffbc78
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[113]
|
[118]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:05
|
|
|
8 weeks 3 days 3 hours
|
8 weeks 3 days 3 hours
|
write_operation {
input {
common {
plan_id: 125
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-08.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
RUNNING
|
30c3a325-39ef-4d92-aeb2-0c3cb47450ee
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_30c3a325-39ef-4d92-aeb2-0c3cb47450ee
|
|
|
|
|
[200]
|
[206]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:37
|
2026/09/03 16:13:37
|
2026/09/03 16:13:37
|
92 ms
|
98 ms
|
write_operation {
input {
common {
plan_id: 76
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-01.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
31428a5a-88f9-453a-b45c-c7644ee6ce7e
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_31428a5a-88f9-453a-b45c-c7644ee6ce7e
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[183]
|
[189]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:34
|
2026/09/03 16:13:35
|
2026/09/03 16:13:35
|
105 ms
|
111 ms
|
write_operation {
input {
common {
plan_id: 42
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-06.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
320e82c2-abf9-41e7-831c-5b4e4e6469f9
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_320e82c2-abf9-41e7-831c-5b4e4e6469f9
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
|
[98]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:56:09
|
2026/09/03 15:56:10
|
2026/09/03 15:56:10
|
216 ms
|
235 ms
|
sql_command {
input {
common {
plan_id: 99
}
sql {
query: "create schema if not exists spark_catalog.yellow_taxi"
}
}
}
|
CLOSED
|
3322b461-013d-4354-aa6f-30d2254e748c
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_3322b461-013d-4354-aa6f-30d2254e748c
|
|
|
|
|
[117][119]
|
[125][126]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:06
|
2026/09/03 16:10:06
|
2026/09/03 16:10:06
|
390 ms
|
390 ms
|
write_operation {
input {
common {
plan_id: 133
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-12.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
CLOSED
|
3353fded-646f-4e2b-94ee-ddf45ec66e18
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_3353fded-646f-4e2b-94ee-ddf45ec66e18
|
|
|
|
|
[185]
|
[191]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:35
|
2026/09/03 16:13:35
|
2026/09/03 16:13:35
|
83 ms
|
88 ms
|
write_operation {
input {
common {
plan_id: 46
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-12.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
3a121330-0197-4c65-82ea-66cd99480a68
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_3a121330-0197-4c65-82ea-66cd99480a68
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[190]
|
[196]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:35
|
2026/09/03 16:13:35
|
2026/09/03 16:13:35
|
79 ms
|
82 ms
|
write_operation {
input {
common {
plan_id: 56
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-05.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
3a1b4a58-3756-4684-a865-1c18f8afce94
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_3a1b4a58-3756-4684-a865-1c18f8afce94
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[143]
|
[149]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:09
|
|
|
8 weeks 3 days 3 hours
|
8 weeks 3 days 3 hours
|
write_operation {
input {
common {
plan_id: 175
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-04.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
RUNNING
|
3bb4164c-8dcf-4a51-bc6d-b9c29174b839
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_3bb4164c-8dcf-4a51-bc6d-b9c29174b839
|
|
|
|
|
[210]
|
[216]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:38
|
2026/09/03 16:13:38
|
2026/09/03 16:13:38
|
141 ms
|
145 ms
|
write_operation {
input {
common {
plan_id: 96
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-09.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
3c9481a0-0f2d-428a-9746-fcd72062da9f
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_3c9481a0-0f2d-428a-9746-fcd72062da9f
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[67]
|
[67]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:54
|
2026/09/03 15:55:55
|
2026/09/03 15:55:55
|
119 ms
|
127 ms
|
sql_command {
input {
common {
plan_id: 68
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-11.parquet`\n "
}
}
}
|
CLOSED
|
3eadc714-e301-4dca-9d15-ca05eb9c2b8a
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_3eadc714-e301-4dca-9d15-ca05eb9c2b8a
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[147]
|
[154]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:10
|
|
|
8 weeks 3 days 3 hours
|
8 weeks 3 days 3 hours
|
write_operation {
input {
common {
plan_id: 181
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-09.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
RUNNING
|
3f39aeed-ff3c-4900-8789-60d0940d1a76
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_3f39aeed-ff3c-4900-8789-60d0940d1a76
|
|
|
|
|
[243]
|
[249]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:08
|
2026/09/03 16:14:08
|
2026/09/03 16:14:08
|
85 ms
|
88 ms
|
write_operation {
input {
common {
plan_id: 160
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-05.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
425e9ce3-23ef-448b-be7a-da8b0336f908
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_425e9ce3-23ef-448b-be7a-da8b0336f908
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[175]
|
[181]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:33
|
2026/09/03 16:13:33
|
2026/09/03 16:13:33
|
110 ms
|
118 ms
|
write_operation {
input {
common {
plan_id: 26
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-06.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
43c883ae-8661-4fae-9072-fff947596643
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_43c883ae-8661-4fae-9072-fff947596643
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[197]
|
[203]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:36
|
2026/09/03 16:13:36
|
2026/09/03 16:13:36
|
99 ms
|
105 ms
|
write_operation {
input {
common {
plan_id: 70
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-12.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
43d0c529-3218-4ae3-a405-0e00f1eb6600
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_43d0c529-3218-4ae3-a405-0e00f1eb6600
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[187]
|
[193]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:35
|
2026/09/03 16:13:35
|
2026/09/03 16:13:35
|
87 ms
|
93 ms
|
write_operation {
input {
common {
plan_id: 50
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-04.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
453243e3-12f6-43ff-b295-28633ad30539
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_453243e3-12f6-43ff-b295-28633ad30539
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[141]
|
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:09
|
2026/09/03 16:10:09
|
2026/09/03 16:10:09
|
156 ms
|
156 ms
|
write_operation {
input {
common {
plan_id: 171
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-08.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
CLOSED
|
46569e48-f731-4f2a-85b8-f216c5e2460e
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_46569e48-f731-4f2a-85b8-f216c5e2460e
|
|
|
|
|
[108][109]
|
[114][115]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:00
|
2026/09/03 16:10:04
|
2026/09/03 16:10:04
|
4 seconds 83 ms
|
4 seconds 85 ms
|
write_operation {
input {
common {
plan_id: 119
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-11.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
CLOSED
|
4834ae02-5360-4c58-8f85-4f9f8f34dae7
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_4834ae02-5360-4c58-8f85-4f9f8f34dae7
|
|
|
|
|
[131]
|
[138][139]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:08
|
|
|
8 weeks 3 days 3 hours
|
8 weeks 3 days 3 hours
|
write_operation {
input {
common {
plan_id: 155
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-07.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
RUNNING
|
4909aecf-283f-47b5-8b1a-eaca18732b21
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_4909aecf-283f-47b5-8b1a-eaca18732b21
|
|
|
|
|
[163]
|
[169]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:12:39
|
2026/09/03 16:12:39
|
2026/09/03 16:12:39
|
100 ms
|
103 ms
|
write_operation {
input {
common {
plan_id: 6
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-10.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
49321596-692d-4bbb-9aa6-ac0b49869aae
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_49321596-692d-4bbb-9aa6-ac0b49869aae
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[248]
|
[254]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:09
|
2026/09/03 16:14:09
|
2026/09/03 16:14:09
|
75 ms
|
78 ms
|
write_operation {
input {
common {
plan_id: 170
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-08.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
49bf026a-31fb-4e3b-a127-7952a0a67f41
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_49bf026a-31fb-4e3b-a127-7952a0a67f41
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[164][165]
|
[170][171]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:12:39
|
2026/09/03 16:13:06
|
2026/09/03 16:13:06
|
27 seconds 620 ms
|
27 seconds 625 ms
|
write_operation {
input {
common {
plan_id: 8
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-08.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
4a0e6fa4-11f8-45c5-9138-12142a2c4d93
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_4a0e6fa4-11f8-45c5-9138-12142a2c4d93
|
|
|
|
|
[145][148]
|
[152][153]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:10
|
|
|
8 weeks 3 days 3 hours
|
8 weeks 3 days 3 hours
|
write_operation {
input {
common {
plan_id: 179
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-09.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
RUNNING
|
4a4d2cea-6df1-4258-81eb-757d681d47f8
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_4a4d2cea-6df1-4258-81eb-757d681d47f8
|
|
|
|
|
[251]
|
[257]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:09
|
2026/09/03 16:14:10
|
2026/09/03 16:14:10
|
93 ms
|
97 ms
|
write_operation {
input {
common {
plan_id: 176
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-09.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
4aa96cc8-eac5-47dd-a15d-7d6ec84e4631
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_4aa96cc8-eac5-47dd-a15d-7d6ec84e4631
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
|
[101]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:59:02
|
2026/09/03 15:59:02
|
2026/09/03 15:59:02
|
109 ms
|
118 ms
|
sql_command {
input {
common {
plan_id: 105
}
sql {
query: "\ncreate table if not exists spark_catalog.yellow_taxi.trips(\n VendorID long,\n tpep_pickup_datetime timestamp,\n tpep_dropoff_datetime timestamp,\n passenger_count long,\n trip_distance double,\n RatecodeID long,\n store_and_fwd_flag string,\n PULocationID long,\n DOLocationID long,\n payment_type long,\n fare_amount double,\n extra double,\n mta_tax double,\n tip_amount double,\n tolls_amount double,\n improvement_surcharge double,\n total_amount double,\n congestion_surcharge double,\n airport_fee double,\n load_timestamp timestamp,\n year int,\n month int,\n day int\n)\nusing delta\npartitioned by (year,month)\nlocation \'/home/jovyan/spark-warehouse/yellow_taxi.db/trips\'\n"
}
}
}
|
CLOSED
|
4e3e69c5-e8a8-4c00-a30a-7571f47e1126
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_4e3e69c5-e8a8-4c00-a30a-7571f47e1126
|
|
|
|
|
[146]
|
[150][151]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:10
|
|
|
8 weeks 3 days 3 hours
|
8 weeks 3 days 3 hours
|
write_operation {
input {
common {
plan_id: 177
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-04.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
RUNNING
|
4f641188-f012-4bf6-bce6-417e8736f9c1
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_4f641188-f012-4bf6-bce6-417e8736f9c1
|
|
|
|
|
[93]
|
[93]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:58
|
2026/09/03 15:55:58
|
2026/09/03 15:55:58
|
105 ms
|
125 ms
|
sql_command {
input {
common {
plan_id: 94
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-04.parquet`\n "
}
}
}
|
CLOSED
|
4f6df773-6d3f-428e-9bfc-d72f445d2d47
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_4f6df773-6d3f-428e-9bfc-d72f445d2d47
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[198]
|
[204]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:36
|
2026/09/03 16:13:36
|
2026/09/03 16:13:36
|
93 ms
|
98 ms
|
write_operation {
input {
common {
plan_id: 72
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-05.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
4fae2a35-37ef-4ee1-a1b5-ff7757bf2cff
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_4fae2a35-37ef-4ee1-a1b5-ff7757bf2cff
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[90]
|
[90]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:58
|
2026/09/03 15:55:58
|
2026/09/03 15:55:58
|
101 ms
|
106 ms
|
sql_command {
input {
common {
plan_id: 91
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-04.parquet`\n "
}
}
}
|
CLOSED
|
50a40a08-5b4b-450b-ac7d-e821cbbf4955
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_50a40a08-5b4b-450b-ac7d-e821cbbf4955
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[213]
|
[219]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:38
|
2026/09/03 16:13:38
|
2026/09/03 16:13:38
|
98 ms
|
102 ms
|
write_operation {
input {
common {
plan_id: 102
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-04.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
50badd40-73b6-413c-bf7f-913fa37c99a1
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_50badd40-73b6-413c-bf7f-913fa37c99a1
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[232]
|
[238]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:07
|
2026/09/03 16:14:07
|
2026/09/03 16:14:07
|
110 ms
|
161 ms
|
write_operation {
input {
common {
plan_id: 138
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-10.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
52a96a13-df5e-4a95-af5a-163a6252c863
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_52a96a13-df5e-4a95-af5a-163a6252c863
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[83]
|
[83]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:57
|
2026/09/03 15:55:57
|
2026/09/03 15:55:57
|
111 ms
|
117 ms
|
sql_command {
input {
common {
plan_id: 84
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-02.parquet`\n "
}
}
}
|
CLOSED
|
52a9dfb4-11be-42bb-8c91-43f0c9bbb04b
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_52a9dfb4-11be-42bb-8c91-43f0c9bbb04b
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[142]
|
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:09
|
|
|
8 weeks 3 days 3 hours
|
8 weeks 3 days 3 hours
|
write_operation {
input {
common {
plan_id: 173
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-05.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
RUNNING
|
531ff59e-678b-4e2c-8bde-a0f5c5f9248b
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_531ff59e-678b-4e2c-8bde-a0f5c5f9248b
|
|
|
|
|
[79]
|
[79]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:56
|
2026/09/03 15:55:56
|
2026/09/03 15:55:56
|
112 ms
|
118 ms
|
sql_command {
input {
common {
plan_id: 80
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2024-07.parquet`\n "
}
}
}
|
CLOSED
|
562cc198-1aba-4541-973d-7c1250cf4270
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_562cc198-1aba-4541-973d-7c1250cf4270
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[231]
|
[237]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:07
|
2026/09/03 16:14:07
|
2026/09/03 16:14:07
|
88 ms
|
91 ms
|
write_operation {
input {
common {
plan_id: 136
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-06.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
57ae2e76-b04c-45fc-bed4-787052fe1f0b
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_57ae2e76-b04c-45fc-bed4-787052fe1f0b
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[77]
|
[77]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:56
|
2026/09/03 15:55:56
|
2026/09/03 15:55:56
|
137 ms
|
141 ms
|
sql_command {
input {
common {
plan_id: 78
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-11.parquet`\n "
}
}
}
|
CLOSED
|
57bf1364-3172-4342-98f8-e94aa788a939
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_57bf1364-3172-4342-98f8-e94aa788a939
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[223]
|
[229]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:06
|
2026/09/03 16:14:06
|
2026/09/03 16:14:06
|
156 ms
|
160 ms
|
write_operation {
input {
common {
plan_id: 120
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-11.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
581465f6-3066-4298-b9b9-5ec1adcbc575
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_581465f6-3066-4298-b9b9-5ec1adcbc575
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[179]
|
[185]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:34
|
2026/09/03 16:13:34
|
2026/09/03 16:13:34
|
250 ms
|
255 ms
|
write_operation {
input {
common {
plan_id: 34
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-08.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
58782597-3c4f-4429-82f1-d7be3d74c34e
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_58782597-3c4f-4429-82f1-d7be3d74c34e
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[88]
|
[88]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:57
|
2026/09/03 15:55:57
|
2026/09/03 15:55:57
|
113 ms
|
121 ms
|
sql_command {
input {
common {
plan_id: 89
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-06.parquet`\n "
}
}
}
|
CLOSED
|
5b82384b-d3f7-41dc-ae98-91690da5f528
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_5b82384b-d3f7-41dc-ae98-91690da5f528
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[100][101][97][98][99]
|
[105][106][107][108][109]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:03:17
|
2026/09/03 16:03:44
|
2026/09/03 16:03:44
|
26 seconds 948 ms
|
26 seconds 976 ms
|
common {
plan_id: 112
}
limit {
input {
common {
plan_id: 111
}
read {
data_source {
format: "delta"
schema: ""
paths: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips"
}
}
}
limit: 1000
}
|
CLOSED
|
5c4d2c10-fdcb-48fb-b90d-06cbd97c3009
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_5c4d2c10-fdcb-48fb-b90d-06cbd97c3009
|
|
|
|
|
[61]
|
[61]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:54
|
2026/09/03 15:55:54
|
2026/09/03 15:55:54
|
120 ms
|
127 ms
|
sql_command {
input {
common {
plan_id: 62
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-11.parquet`\n "
}
}
}
|
CLOSED
|
5d5b0d8c-a3a4-4b14-9ec4-126ac9ef9b6c
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_5d5b0d8c-a3a4-4b14-9ec4-126ac9ef9b6c
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[132]
|
[140]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:08
|
2026/09/03 16:10:08
|
2026/09/03 16:10:08
|
198 ms
|
199 ms
|
write_operation {
input {
common {
plan_id: 157
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2021-07.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
CLOSED
|
5d5f4566-bcab-49ad-b1f3-d0255fe910bc
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_5d5f4566-bcab-49ad-b1f3-d0255fe910bc
|
|
|
|
|
[217]
|
[223]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:39
|
2026/09/03 16:13:39
|
2026/09/03 16:13:39
|
89 ms
|
93 ms
|
write_operation {
input {
common {
plan_id: 110
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2025-06.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
5fac896b-bc68-4d5c-bcc2-abfc406e750f
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_5fac896b-bc68-4d5c-bcc2-abfc406e750f
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[68]
|
[68]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:55
|
2026/09/03 15:55:55
|
2026/09/03 15:55:55
|
125 ms
|
130 ms
|
sql_command {
input {
common {
plan_id: 69
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-09.parquet`\n "
}
}
}
|
CLOSED
|
63857746-50c6-4e6f-b0a0-3726dd1a630a
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_63857746-50c6-4e6f-b0a0-3726dd1a630a
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[76]
|
[76]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 15:55:56
|
2026/09/03 15:55:56
|
2026/09/03 15:55:56
|
191 ms
|
200 ms
|
sql_command {
input {
common {
plan_id: 77
}
sql {
query: "insert into yellow_taxi.trips\n select \n try_cast(VendorID as long),\n try_cast(tpep_pickup_datetime as timestamp),\n try_cast(tpep_dropoff_datetime as timestamp),\n try_cast(passenger_count as long),\n try_cast(trip_distance as double),\n try_cast(RatecodeID as long),\n try_cast(store_and_fwd_flag as string),\n try_cast(PULocationID as long),\n try_cast(DOLocationID as long),\n try_cast(payment_type as long),\n try_cast(fare_amount as double),\n try_cast(extra as double),\n try_cast(mta_tax as double),\n try_cast(tip_amount as double),\n try_cast(tolls_amount as double),\n try_cast(improvement_surcharge as double),\n try_cast(total_amount as double),\n try_cast(congestion_surcharge as double),\n try_cast(airport_fee as double),\n current_timestamp,\n coalesce(year(tpep_pickup_datetime),2026),\n coalesce(month(tpep_pickup_datetime),9),\n coalesce(day(tpep_pickup_datetime),3)\n from\n parquet.`/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-10.parquet`\n "
}
}
}
|
CLOSED
|
666d7732-56bb-4a3f-9910-563a42d240b6
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_666d7732-56bb-4a3f-9910-563a42d240b6
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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...
|
|
|
[115]
|
[121][122]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:05
|
2026/09/03 16:10:06
|
2026/09/03 16:10:06
|
289 ms
|
289 ms
|
write_operation {
input {
common {
plan_id: 129
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-07.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
CLOSED
|
6780f38f-c162-42bf-98a5-81e0579a82ee
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_6780f38f-c162-42bf-98a5-81e0579a82ee
|
|
|
|
|
[245]
|
[251]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:09
|
2026/09/03 16:14:09
|
2026/09/03 16:14:09
|
230 ms
|
236 ms
|
write_operation {
input {
common {
plan_id: 164
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-02.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
68456b2c-116e-405c-9494-0c45481a30f9
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_68456b2c-116e-405c-9494-0c45481a30f9
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[204]
|
[210]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:37
|
2026/09/03 16:13:37
|
2026/09/03 16:13:37
|
143 ms
|
148 ms
|
write_operation {
input {
common {
plan_id: 84
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-03.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
6bc41597-674a-4fee-9ab3-55277c54abe3
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_6bc41597-674a-4fee-9ab3-55277c54abe3
|
|
DELTA_FAILED_TO_MERGE_FIELDS
+details
INTERNAL: [DELTA_FAILED_TO_MERGE_FIELDS] Failed to merge fields 'VendorID' and 'VendorID'
|
|
|
[118]
|
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:06
|
|
|
8 weeks 3 days 3 hours
|
8 weeks 3 days 3 hours
|
write_operation {
input {
common {
plan_id: 135
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-01.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
RUNNING
|
7023641f-3361-4da3-9af4-ecef5cacf90a
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_7023641f-3361-4da3-9af4-ecef5cacf90a
|
|
|
|
|
|
[104]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:00:30
|
2026/09/03 16:00:30
|
2026/09/03 16:00:30
|
11 ms
|
14 ms
|
sql_command {
input {
common {
plan_id: 110
}
sql {
query: "describe details spark_catalog.yellow_taxi.trips"
}
}
}
|
CLOSED
|
729b26e6-c29d-4972-9c76-e77b5ade0a53
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_729b26e6-c29d-4972-9c76-e77b5ade0a53
|
|
TABLE_OR_VIEW_NOT_FOUND
+details
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
|
|
|
[158][159][160]
|
[164][165][166]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:12:07
|
2026/09/03 16:12:38
|
2026/09/03 16:12:38
|
31 seconds 764 ms
|
31 seconds 769 ms
|
write_operation {
input {
common {
plan_id: 0
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2018-10.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
72c531e6-b91e-430c-a90f-107332e492cb
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_72c531e6-b91e-430c-a90f-107332e492cb
|
|
|
|
|
[199]
|
[205]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:36
|
2026/09/03 16:13:36
|
2026/09/03 16:13:37
|
113 ms
|
117 ms
|
write_operation {
input {
common {
plan_id: 74
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-01.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
7338ba55-d94b-45e1-998b-8100ac497b10
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_7338ba55-d94b-45e1-998b-8100ac497b10
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[127]
|
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:07
|
2026/09/03 16:10:07
|
|
127 ms
|
8 weeks 3 days 3 hours
|
write_operation {
input {
common {
plan_id: 149
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-11.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
CANCELED
|
7865d33d-b14d-45dd-80a0-07c104be9353
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_7865d33d-b14d-45dd-80a0-07c104be9353
|
|
|
|
|
[125]
|
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:07
|
|
|
8 weeks 3 days 3 hours
|
8 weeks 3 days 3 hours
|
write_operation {
input {
common {
plan_id: 145
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2022-08.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
RUNNING
|
79715b50-a0c6-4e7e-989e-0d369605fa7e
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_79715b50-a0c6-4e7e-989e-0d369605fa7e
|
|
|
|
|
[184]
|
[190]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:13:35
|
2026/09/03 16:13:35
|
2026/09/03 16:13:35
|
143 ms
|
150 ms
|
write_operation {
input {
common {
plan_id: 44
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2020-12.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
7a5df2e0-b57e-470b-94e5-badc2b56aa44
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_7a5df2e0-b57e-470b-94e5-badc2b56aa44
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[252]
|
[258]
|
50cf85d5-ae27-4707-b30c-2f106b0fbf42
|
2026/09/03 16:14:10
|
2026/09/03 16:14:10
|
2026/09/03 16:14:10
|
88 ms
|
93 ms
|
write_operation {
input {
common {
plan_id: 178
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2019-04.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw_ingest"
mode: SAVE_MODE_APPEND
}
|
CLOSED
|
7a710e17-02ae-4a00-94f4-26950f47b03f
|
SparkConnect_OperationTag_User__Session_50cf85d5-ae27-4707-b30c-2f106b0fbf42_Operation_7a710e17-02ae-4a00-94f4-26950f47b03f
|
|
DELTA_METADATA_MISMATCH
+details
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 ...
|
|
|
[128][129]
|
[136][137]
|
29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0
|
2026/09/03 16:10:07
|
|
|
8 weeks 3 days 3 hours
|
8 weeks 3 days 3 hours
|
write_operation {
input {
common {
plan_id: 151
}
read {
data_source {
format: "parquet"
schema: ""
paths: "/home/jovyan/data/yellow-taxi/yellow_tripdata_2023-08.parquet"
}
}
}
source: "delta"
path: "/home/jovyan/spark-warehouse/yellow_taxi.db/trips_raw"
}
|
RUNNING
|
7addeaeb-55db-4d99-a6af-39b0ebebf3da
|
SparkConnect_OperationTag_User__Session_29cbf5ee-3bc4-44da-a6fe-5b90efeec9f0_Operation_7addeaeb-55db-4d99-a6af-39b0ebebf3da
|
|
|