| Stage Id ▾ | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|
| 22 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 21
}
show_string {
input {
common {
plan_id: 20
}
limit {
input {
common {
plan_id: 19
}
sort {
input {
common {
}
aggregate {
}
}
order {
child {
}
direction: SORT_DIRECTION_DESCENDING
null_ordering: SORT_NULLS_LAST
}
is_global: true
}
}
limit: 20
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "1e03df46-960e-4d65-920d-c0bd8e406fef"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
| 2026/04/27 09:09:25 | 3 s |
200/200
| 212.9 MiB | |||
| 20 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 21
}
show_string {
input {
common {
plan_id: 20
}
limit {
input {
common {
plan_id: 19
}
sort {
input {
common {
}
aggregate {
}
}
order {
child {
}
direction: SORT_DIRECTION_DESCENDING
null_ordering: SORT_NULLS_LAST
}
is_global: true
}
}
limit: 20
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "1e03df46-960e-4d65-920d-c0bd8e406fef"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
| 2026/04/27 09:08:54 | 30 s |
476/476
| 2.2 GiB | 212.9 MiB | ||
| 19 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 15
}
show_string {
input {
common {
plan_id: 14
}
filter {
input {
common {
plan_id: 13
}
read {
named_table {
unparsed_identifier: "iceberg_us.research.base_uniswap_v3_token_transfer_features_all_01"
}
}
}
condition {
unresolved_function {
function_name: "=="
arguments {
unresolved_function {
}
}
arguments {
literal {
}
common {
}
}
}
common {
origin {
python_origin {
}
}
}
}
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "bb82d8fe-41a5-4a5a-8fb8-3de21be5f0f3"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
| 2026/04/27 09:08:10 | 6 s |
7/7
| 49.6 MiB | |||
| 18 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 15
}
show_string {
input {
common {
plan_id: 14
}
filter {
input {
common {
plan_id: 13
}
read {
named_table {
unparsed_identifier: "iceberg_us.research.base_uniswap_v3_token_transfer_features_all_01"
}
}
}
condition {
unresolved_function {
function_name: "=="
arguments {
unresolved_function {
}
}
arguments {
literal {
}
common {
}
}
}
common {
origin {
python_origin {
}
}
}
}
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "bb82d8fe-41a5-4a5a-8fb8-3de21be5f0f3"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
| 2026/04/27 09:08:05 | 5 s |
4/4
| 33.4 MiB | |||
| 17 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 15
}
show_string {
input {
common {
plan_id: 14
}
filter {
input {
common {
plan_id: 13
}
read {
named_table {
unparsed_identifier: "iceberg_us.research.base_uniswap_v3_token_transfer_features_all_01"
}
}
}
condition {
unresolved_function {
function_name: "=="
arguments {
unresolved_function {
}
}
arguments {
literal {
}
common {
}
}
}
common {
origin {
python_origin {
}
}
}
}
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "bb82d8fe-41a5-4a5a-8fb8-3de21be5f0f3"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
| 2026/04/27 09:08:04 | 1 s |
1/1
| 17.2 MiB | |||
| 16 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 12
}
show_string {
input {
common {
plan_id: 11
}
filter {
input {
common {
plan_id: 10
}
read {
named_table {
unparsed_identifier: "iceberg_us.research.one_day_transfer_full_aggr"
}
}
}
condition {
unresolved_function {
function_name: "=="
arguments {
unresolved_function {
}
}
arguments {
literal {
}
common {
}
}
}
common {
origin {
python_origin {
}
}
}
}
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "f6a1a898-1446-46a1-9f72-a309d38029b0"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
| 2026/04/27 09:07:49 | 13 s |
42/42
| 517.3 MiB | |||
| 15 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 12
}
show_string {
input {
common {
plan_id: 11
}
filter {
input {
common {
plan_id: 10
}
read {
named_table {
unparsed_identifier: "iceberg_us.research.one_day_transfer_full_aggr"
}
}
}
condition {
unresolved_function {
function_name: "=="
arguments {
unresolved_function {
}
}
arguments {
literal {
}
common {
}
}
}
common {
origin {
python_origin {
}
}
}
}
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "f6a1a898-1446-46a1-9f72-a309d38029b0"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
| 2026/04/27 09:07:38 | 11 s |
20/20
| 248.5 MiB | |||
| 14 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 12
}
show_string {
input {
common {
plan_id: 11
}
filter {
input {
common {
plan_id: 10
}
read {
named_table {
unparsed_identifier: "iceberg_us.research.one_day_transfer_full_aggr"
}
}
}
condition {
unresolved_function {
function_name: "=="
arguments {
unresolved_function {
}
}
arguments {
literal {
}
common {
}
}
}
common {
origin {
python_origin {
}
}
}
}
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "f6a1a898-1446-46a1-9f72-a309d38029b0"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
| 2026/04/27 09:07:37 | 2 s |
4/4
| 49.8 MiB | |||
| 13 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 12
}
show_string {
input {
common {
plan_id: 11
}
filter {
input {
common {
plan_id: 10
}
read {
named_table {
unparsed_identifier: "iceberg_us.research.one_day_transfer_full_aggr"
}
}
}
condition {
unresolved_function {
function_name: "=="
arguments {
unresolved_function {
}
}
arguments {
literal {
}
common {
}
}
}
common {
origin {
python_origin {
}
}
}
}
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "f6a1a898-1446-46a1-9f72-a309d38029b0"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
| 2026/04/27 09:07:33 | 3 s |
1/1
| 12.4 MiB | |||
| 12 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 9
}
show_string {
input {
common {
plan_id: 8
}
project {
input {
common {
plan_id: 7
}
read {
named_table {
unparsed_identifier: "iceberg_us.base_logs.prod_raw_transfers"
}
}
}
expressions {
unresolved_function {
function_name: "min"
arguments {
unresolved_attribute {
}
common {
}
}
}
}
expressions {
unresolved_function {
function_name: "max"
arguments {
unresolved_attribute {
}
common {
}
}
}
}
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "975457c3-d5f4-4166-883f-9d94fbe15378"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
| 2026/04/27 09:07:27 | 46 ms |
1/1
| 68.0 B | |||
| 10 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 9
}
show_string {
input {
common {
plan_id: 8
}
project {
input {
common {
plan_id: 7
}
read {
named_table {
unparsed_identifier: "iceberg_us.base_logs.prod_raw_transfers"
}
}
}
expressions {
unresolved_function {
function_name: "min"
arguments {
unresolved_attribute {
}
common {
}
}
}
}
expressions {
unresolved_function {
function_name: "max"
arguments {
unresolved_attribute {
}
common {
}
}
}
}
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "975457c3-d5f4-4166-883f-9d94fbe15378"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
| 2026/04/27 09:07:27 | 40 ms |
1/1
| 68.0 B | |||
| 9 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 6
}
show_string {
input {
common {
plan_id: 5
}
aggregate {
input {
common {
plan_id: 4
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "value"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "address"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "n_transfers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "transfer_volume"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
...
| 2026/04/27 09:06:47 | 0.2 s |
1/1
| 399.0 B | |||
| 6 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 6
}
show_string {
input {
common {
plan_id: 5
}
aggregate {
input {
common {
plan_id: 4
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "value"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "address"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "n_transfers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "transfer_volume"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
...
| 2026/04/27 09:06:47 | 0.4 s |
1/1
| 1323.0 B | 399.0 B | ||
| 4 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 6
}
show_string {
input {
common {
plan_id: 5
}
aggregate {
input {
common {
plan_id: 4
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "value"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "address"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "n_transfers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "transfer_volume"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
...
| 2026/04/27 09:06:43 | 3 s |
1/1
| 3.0 MiB | 1323.0 B | ||
| 3 | Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 8
}
catalog {
list_databases {
}
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "7bc419ab-3320-4035-bff0-77ac964f795e"
client_observed_server_side_session_id: "59e154d3-d333-4a5e-95d5-8197b68dd98e"
| 2026/04/27 09:05:14 | 57 ms |
4/4
| ||||
| 2 | Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 6
}
catalog {
list_databases {
}
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "2473580f-9455-4952-894a-4b0cf3d6ba21"
client_observed_server_side_session_id: "59e154d3-d333-4a5e-95d5-8197b68dd98e"
| 2026/04/27 09:05:09 | 38 ms |
4/4
| ||||
| 1 | Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 4
}
catalog {
list_tables {
db_name: "iceberg_us.research"
}
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "3355de98-46bd-415f-8619-54e4888eac93"
client_observed_server_side_session_id: "59e154d3-d333-4a5e-95d5-8197b68dd98e"
| 2026/04/27 09:04:55 | 62 ms |
4/4
| ||||
| 0 | Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 2
}
show_string {
input {
common {
plan_id: 1
}
sql {
query: "SELECT 1"
}
}
num_rows: 20
truncate: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "de735bb7-bd47-441a-9272-d9afd874d1d0"
client_observed_server_side_session_id: "59e154d3-d333-4a5e-95d5-8197b68dd98e"
| 2026/04/27 09:03:52 | 0.6 s |
1/1
|
| Stage Id ▾ | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|
| 21 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 21
}
show_string {
input {
common {
plan_id: 20
}
limit {
input {
common {
plan_id: 19
}
sort {
input {
common {
}
aggregate {
}
}
order {
child {
}
direction: SORT_DIRECTION_DESCENDING
null_ordering: SORT_NULLS_LAST
}
is_global: true
}
}
limit: 20
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "1e03df46-960e-4d65-920d-c0bd8e406fef"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
| Unknown | Unknown |
0/476
| ||||
| 11 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 9
}
show_string {
input {
common {
plan_id: 8
}
project {
input {
common {
plan_id: 7
}
read {
named_table {
unparsed_identifier: "iceberg_us.base_logs.prod_raw_transfers"
}
}
}
expressions {
unresolved_function {
function_name: "min"
arguments {
unresolved_attribute {
}
common {
}
}
}
}
expressions {
unresolved_function {
function_name: "max"
arguments {
unresolved_attribute {
}
common {
}
}
}
}
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "975457c3-d5f4-4166-883f-9d94fbe15378"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
| Unknown | Unknown |
0/1
| ||||
| 8 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 6
}
show_string {
input {
common {
plan_id: 5
}
aggregate {
input {
common {
plan_id: 4
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "value"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "address"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "n_transfers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "transfer_volume"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
...
| Unknown | Unknown |
0/1
| ||||
| 7 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 6
}
show_string {
input {
common {
plan_id: 5
}
aggregate {
input {
common {
plan_id: 4
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "value"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "address"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "n_transfers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "transfer_volume"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
...
| Unknown | Unknown |
0/1
| ||||
| 5 | Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_... session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 6
}
show_string {
input {
common {
plan_id: 5
}
aggregate {
input {
common {
plan_id: 4
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "value"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "address"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "n_transfers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "transfer_volume"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
...
| Unknown | Unknown |
0/1
|