andygrove opened a new issue, #3319:
URL: https://github.com/apache/arrow-datafusion/issues/3319
**Is your feature request related to a problem or challenge? Please describe
what you are trying to do.**
```
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/avro_to_arrow/arrow_array_reader.rs":435
cur_offset += OffsetSize::from_usize(a.len()).unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/avro_to_arrow/arrow_array_reader.rs":444
let valid_len = cur_offset.to_usize().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/avro_to_arrow/arrow_array_reader.rs":480
.unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/avro_to_arrow/arrow_array_reader.rs":566
.unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/avro_to_arrow/arrow_array_reader.rs":582
.unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/avro_to_arrow/arrow_array_reader.rs":761
panic!("expected struct got {:?}", v);
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/avro_to_arrow/arrow_array_reader.rs":947
_ => unreachable!(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/avro_to_arrow/arrow_array_reader.rs":969
Value::Duration(_d) => unimplemented!(), // shenanigans type
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/avro_to_arrow/arrow_array_reader.rs":971
_ => unreachable!(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/avro_to_arrow/schema.rs":64
AvroSchema::Ref { .. } => todo!("Add support for AvroSchema::Ref"),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/avro_to_arrow/schema.rs":219
DataType::Map(_, _) => unimplemented!("Map support not implemented"),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/catalog/information_schema.rs":118
let catalog = self.catalog_list.catalog(&catalog_name).unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/catalog/information_schema.rs":122
let schema = catalog.schema(&schema_name).unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/catalog/information_schema.rs":124
let table = schema.table(&table_name).unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/catalog/information_schema.rs":155
let catalog = self.catalog_list.catalog(&catalog_name).unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/catalog/information_schema.rs":159
let schema = catalog.schema(&schema_name).unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/catalog/information_schema.rs":161
let table = schema.table(&table_name).unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/catalog/information_schema.rs":182
let catalog = self.catalog_list.catalog(&catalog_name).unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/catalog/information_schema.rs":186
let schema = catalog.schema(&schema_name).unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/catalog/information_schema.rs":188
let table = schema.table(&table_name).unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/catalog/information_schema.rs":306
.unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/catalog/information_schema.rs":308
MemTable::try_new(schema, vec![vec![batch]]).unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/catalog/information_schema.rs":377
.unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/catalog/information_schema.rs":379
MemTable::try_new(schema, vec![vec![batch]]).unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/catalog/information_schema.rs":585
.unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/catalog/information_schema.rs":587
MemTable::try_new(schema, vec![vec![batch]]).unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/datasource/listing/helpers.rs":140
.unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/datasource/listing/helpers.rs":303
.unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/datasource/listing/helpers.rs":308
.unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/datasource/listing/helpers.rs":313
.unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/datasource/listing/helpers.rs":325
ScalarValue::try_from_array(batch.column(col),
row).unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/datasource/listing/table.rs":118
.object_store(&self.table_paths.get(0).unwrap())?;
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/datasource/listing/table.rs":123
.unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/datasource/listing/table.rs":155
.infer_schema(ctx, self.table_paths.get(0).unwrap())
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/datasource/listing/table.rs":335
object_store_url:
self.table_paths.get(0).unwrap().object_store(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/datasource/listing/table.rs":375
.object_store(&self.table_paths.get(0).unwrap())?;
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/datasource/listing/url.rs":102
true => Url::from_file_path(path).unwrap(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/datasource/listing/url.rs":103
false => Url::from_directory_path(path).unwrap(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/datasource/listing/url.rs":178
ObjectStoreUrl::parse(url).unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/datasource/object_store.rs":57
Self::parse("file://").unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/execution/context.rs":495
query_planner.statement_to_plan(statements.pop_front().unwrap())
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/execution/context.rs":1022
unreachable!("TypeId calls write_u64");
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/execution/context.rs":1123
self.set_u64(OPT_BATCH_SIZE, n.try_into().unwrap())
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/execution/context.rs":1186
.unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/execution/context.rs":1394
.unwrap(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/execution/context.rs":1663
props.get(OPT_BATCH_SIZE).unwrap().parse().unwrap(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/execution/context.rs":1666
props.get(TARGET_PARTITIONS).unwrap().parse().unwrap(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/execution/context.rs":1669
props.get(REPARTITION_JOINS).unwrap().parse().unwrap(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/execution/context.rs":1674
.unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/execution/context.rs":1676
.unwrap(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/execution/context.rs":1679
props.get(REPARTITION_WINDOWS).unwrap().parse().unwrap(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/execution/context.rs":1682
props.get(PARQUET_PRUNING).unwrap().parse().unwrap(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/execution/memory_manager.rs":307
panic!(
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/execution/runtime_env.rs":114
RuntimeEnv::new(RuntimeConfig::new()).unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/execution/runtime_env.rs":162
MemoryManagerConfig::try_new_limit(max_memory,
memory_fraction).unwrap(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_optimizer/hash_build_probe_order.rs":83
_ => unreachable!(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_optimizer/pruning.rs":437
let column = columns.iter().next().unwrap().clone();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_optimizer/pruning.rs":706
.unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/aggregates/hash.rs":294
.unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/aggregates/hash.rs":443
group_state.accumulator_set[x].evaluate().unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/aggregates/mod.rs":541
state_index += expr.state_fields().unwrap().len();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/aggregates/row_hash.rs":94
.flat_map(|expr| expr.state_fields().unwrap().into_iter())
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/aggregates/row_hash.rs":309
.unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/aggregates/row_hash.rs":456
results[i].push(acc.evaluate(&state_accessor).unwrap());
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/analyze.rs":98
children.pop().unwrap(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/cross_join.rs":370
right_batch.clone().unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/file_format/parquet.rs":642
.and_then(|c| if c.statistics().is_some()
{Some((c.statistics().unwrap(), c.column_descr()))} else {None})
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/hash_join.rs":644
.unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/hash_join.rs":655
.unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/hash_join.rs":760
.unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/hash_join.rs":765
.unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/hash_join.rs":938
let left_array = $l.as_any().downcast_ref::<$array_type>().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/hash_join.rs":939
let right_array = $r.as_any().downcast_ref::<$array_type>().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/hash_join.rs":1259
compute::take(array.as_ref(), &indices, None).unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/hash_utils.rs":61
let array = array.as_any().downcast_ref::<Decimal128Array>().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/hash_utils.rs":95
let array = $column.as_any().downcast_ref::<$array_type>().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/hash_utils.rs":130
let array = $column.as_any().downcast_ref::<$array_type>().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/hash_utils.rs":167
let array = $column.as_any().downcast_ref::<$array_type>().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/hash_utils.rs":218
let dict_array =
array.as_any().downcast_ref::<DictionaryArray<K>>().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/join_utils.rs":336
OnceFutState::Pending(_) => unreachable!(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/limit.rs":375
RecordBatch::try_new(batch.schema(), limited_columns).unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/limit.rs":420
let input = self.input.as_mut().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/metrics/value.rs":499
panic!(
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/planner.rs":493
_ => unreachable!(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/planner.rs":528
_ => unreachable!(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/planner.rs":927
LogicalPlan::Subquery(_) => todo!(),
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/planner.rs":1027
maybe_plan = plan.unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/repartition.rs":178
let batch = RecordBatch::try_new(batch.schema(),
columns).unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/repartition.rs":372
state.channels.remove(&partition).unwrap().1,
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/sort_merge_join.rs":228
todo!()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/sort_merge_join.rs":366
let current_chunk = self.output_indices.last_mut().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/sort_merge_join.rs":952
combine_batches(&self.output_record_batches,
self.schema.clone())?.unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/sort_merge_join.rs":973
self.batches.front().unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/sort_merge_join.rs":977
self.batches.back().unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/sort_merge_join.rs":981
self.batches.back_mut().unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/sort_merge_join.rs":1050
let left_array =
left_array.as_any().downcast_ref::<$T>().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/sort_merge_join.rs":1051
let right_array =
right_array.as_any().downcast_ref::<$T>().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/sort_merge_join.rs":1056
res = left_value.partial_cmp(right_value).unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/sort_merge_join.rs":1138
left_array.as_any().downcast_ref::<$T>().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/sort_merge_join.rs":1140
right_array.as_any().downcast_ref::<$T>().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/sorts/cursor.rs":204
other.compare(self).unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/sorts/cursor.rs":210
other.compare(self).unwrap() == Ordering::Equal
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/sorts/sort.rs":302
vec![Arc::new(result.unwrap().sorted_batch)],
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/windows/mod.rs":79
.unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/physical_plan/windows/mod.rs":123
.unwrap()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/scheduler/pipeline/execution.rs":84
splice_point = children.into_iter().next().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/scheduler/pipeline/execution.rs":262
unimplemented!()
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/scheduler/plan.rs":124
let group = self.execution_operators.take().unwrap();
"/home/andy/git/apache/arrow-datafusion/datafusion/core/src/scheduler/plan.rs":167
.push((children.into_iter().next().unwrap(), parent))
```
**Describe the solution you'd like**
Use `Result`
**Describe alternatives you've considered**
None
**Additional context**
Generated by https://github.com/andygrove/no-need-to-panic
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
