You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
can be reproduced with example query in error message below.
Issue seems introduced in 468 with new bucket execution. (passed in 467)
Suppressed: java.lang.Exception: SQL: CREATE TABLE test_partition_columns_f1wsd6bhrn WITH (partitioning = ARRAY[
'"r1.f1"',
'bucket(b1, 4)'
]) AS
SELECT
CAST('c1' AS VARCHAR) as c1
, CAST(ROW(1, 2) AS ROW(f1 integer, f2 integer)) as r1
, CAST('2022-01-01 01:01:01' AS TIMESTAMP) as d1
, CAST('2022-01-01 01:01:01' AS TIMESTAMP) as d2
, CAST('2022-01-01 01:01:01' AS TIMESTAMP) as d3
, CAST('2022-01-01 01:01:01' AS TIMESTAMP) as d4
, CAST('b' AS VARCHAR) as b1
, CAST('12345678' AS VARCHAR) as t1
at io.trino.testing.DistributedQueryRunner.executeInternal(DistributedQueryRunner.java:572)
... 11 more
Caused by: java.lang.ClassCastException: class io.trino.spi.block.VariableWidthBlock cannot be cast to class io.trino.spi.block.RowBlock (io.trino.spi.block.VariableWidthBlock and io.trino.spi.block.RowBlock are in unnamed module of loader 'app')
at io.trino.plugin.iceberg.IcebergBucketFunction$HashFunction.getValue(IcebergBucketFunction.java:124)
at io.trino.plugin.iceberg.IcebergBucketFunction$HashFunction.computeHash(IcebergBucketFunction.java:131)
at io.trino.plugin.iceberg.IcebergBucketFunction.getBucket(IcebergBucketFunction.java:74)
at io.trino.operator.BucketPartitionFunction.getPartition(BucketPartitionFunction.java:46)
at io.trino.operator.output.SkewedPartitionFunction.getPartition(SkewedPartitionFunction.java:47)
at io.trino.operator.output.PagePartitioner.partitionPageByRow(PagePartitioner.java:258)
at io.trino.operator.output.PagePartitioner.partitionPage(PagePartitioner.java:146)
at io.trino.operator.output.PartitionedOutputOperator.addInput(PartitionedOutputOperator.java:337)
public Object getValue(Page page, int position)
{
Block block = page.getBlock(dataPath.getFirst());
for (int i = 1; i < dataPath.size(); i++) {
position = block.getUnderlyingValuePosition(position);
block = ((RowBlock) block.getUnderlyingValueBlock()).getFieldBlock(dataPath.get(i));
}
return valueTransform.apply(block, position);
}
The text was updated successfully, but these errors were encountered:
can be reproduced with example query in error message below.
Issue seems introduced in 468 with new bucket execution. (passed in 467)
The text was updated successfully, but these errors were encountered: