48403 tests run, 42 skipped, 24 failed.
Annotations
github-actions / Unit Test Result
CharsetNameTest.testDefaultCollationMySQL57
java.lang.AssertionError
at com.alibaba.polardbx.common.charset.CharsetNameTest.testDefaultCollationMySQL57(CharsetNameTest.java:181)
Raw output
java.lang.AssertionError
at com.alibaba.polardbx.common.charset.CharsetNameTest.testDefaultCollationMySQL57(CharsetNameTest.java:181)
github-actions / Unit Test Result
ColumnarManagerTest.testPurgeWithMultiVersionSchema
expected:<ERR-CODE: [[TDDL]-12005][ERR_COLUMNAR...> but was:<ERR-CODE: [[PXC]-12005][ERR_COLUMNAR...>
Raw output
org.junit.ComparisonFailure: expected:<ERR-CODE: [[TDDL]-12005][ERR_COLUMNAR...> but was:<ERR-CODE: [[PXC]-12005][ERR_COLUMNAR...>
at com.alibaba.polardbx.executor.gms.ColumnarManagerTest.testPurgeWithMultiVersionSchema(ColumnarManagerTest.java:243)
github-actions / Unit Test Result
LogicalShowCreateTablesForPartitionDatabaseHandlerTest.showWithMySqlIndentTest
ERR-CODE: [PXC-9001][ERR_GMS_GENERIC] acquire meta db error.
Raw output
com.alibaba.polardbx.common.exception.TddlRuntimeException: ERR-CODE: [PXC-9001][ERR_GMS_GENERIC] acquire meta db error.
at com.alibaba.polardbx.executor.handler.LogicalShowCreateTablesForPartitionDatabaseHandlerTest.showWithMySqlIndentTest(LogicalShowCreateTablesForPartitionDatabaseHandlerTest.java:105)
github-actions / Unit Test Result
LogicalShowCreateTablesForShardingDatabaseHandlerTest.showWithMySqlIndentTest
ERR-CODE: [PXC-9001][ERR_GMS_GENERIC] acquire meta db error.
Raw output
com.alibaba.polardbx.common.exception.TddlRuntimeException: ERR-CODE: [PXC-9001][ERR_GMS_GENERIC] acquire meta db error.
at com.alibaba.polardbx.executor.handler.LogicalShowCreateTablesForShardingDatabaseHandlerTest.showWithMySqlIndentTest(LogicalShowCreateTablesForShardingDatabaseHandlerTest.java:101)
github-actions / Unit Test Result
AntiJoinRFTest.testSql[AntiJoinRFTest.yml:0]
Failed to create table
Raw output
java.lang.RuntimeException: Failed to create table
at com.alibaba.polardbx.executor.mpp.operator.AntiJoinRFTest.<init>(AntiJoinRFTest.java:17)
Caused by: com.alibaba.polardbx.common.exception.TddlRuntimeException: ERR-CODE: [PXC-4601][ERR_EXECUTOR] Failed to create partition tables on db[optest] with mode='drds'
at com.alibaba.polardbx.executor.mpp.operator.AntiJoinRFTest.<init>(AntiJoinRFTest.java:17)
github-actions / Unit Test Result
ParallelHashJoinFactoryTest.test[ParallelHashJoinFactoryTest.yml:0]
Failed to create table
Raw output
java.lang.RuntimeException: Failed to create table
at com.alibaba.polardbx.executor.mpp.operator.ParallelHashJoinFactoryTest.<init>(ParallelHashJoinFactoryTest.java:14)
Caused by: com.alibaba.polardbx.common.exception.TddlRuntimeException: ERR-CODE: [PXC-4601][ERR_EXECUTOR] Failed to create partition tables on db[optest] with mode='drds'
at com.alibaba.polardbx.executor.mpp.operator.ParallelHashJoinFactoryTest.<init>(ParallelHashJoinFactoryTest.java:14)
github-actions / Unit Test Result
ParallelHashJoinFactoryTest.testSql[ParallelHashJoinFactoryTest.yml:0]
Failed to create table
Raw output
java.lang.RuntimeException: Failed to create table
at com.alibaba.polardbx.executor.mpp.operator.ParallelHashJoinFactoryTest.<init>(ParallelHashJoinFactoryTest.java:14)
Caused by: com.alibaba.polardbx.common.exception.TddlRuntimeException: ERR-CODE: [PXC-4601][ERR_EXECUTOR] Failed to create partition tables on db[optest] with mode='drds'
at com.alibaba.polardbx.executor.mpp.operator.ParallelHashJoinFactoryTest.<init>(ParallelHashJoinFactoryTest.java:14)
github-actions / Unit Test Result
ReversedAntiJoinRFTest.test[ReversedAntiJoinRFTest.yml:0]
Failed to create table
Raw output
java.lang.RuntimeException: Failed to create table
at com.alibaba.polardbx.executor.mpp.operator.ReversedAntiJoinRFTest.<init>(ReversedAntiJoinRFTest.java:21)
Caused by: com.alibaba.polardbx.common.exception.TddlRuntimeException: ERR-CODE: [PXC-4601][ERR_EXECUTOR] Failed to create partition tables on db[optest] with mode='drds'
at com.alibaba.polardbx.executor.mpp.operator.ReversedAntiJoinRFTest.<init>(ReversedAntiJoinRFTest.java:21)
github-actions / Unit Test Result
ReversedAntiJoinRFTest.testSql[ReversedAntiJoinRFTest.yml:0]
Failed to create table
Raw output
java.lang.RuntimeException: Failed to create table
at com.alibaba.polardbx.executor.mpp.operator.ReversedAntiJoinRFTest.<init>(ReversedAntiJoinRFTest.java:21)
Caused by: com.alibaba.polardbx.common.exception.TddlRuntimeException: ERR-CODE: [PXC-4601][ERR_EXECUTOR] Failed to create partition tables on db[optest] with mode='drds'
at com.alibaba.polardbx.executor.mpp.operator.ReversedAntiJoinRFTest.<init>(ReversedAntiJoinRFTest.java:21)
github-actions / Unit Test Result
RebalanceDdlPlanManagerTest.testOnExecuting
java.lang.NullPointerException
at com.alibaba.polardbx.executor.partitionmanagement.rebalance.RebalanceDdlPlanManagerTest.testOnExecuting(RebalanceDdlPlanManagerTest.java:73)
Raw output
java.lang.NullPointerException
at com.alibaba.polardbx.executor.partitionmanagement.rebalance.RebalanceDdlPlanManagerTest.testOnExecuting(RebalanceDdlPlanManagerTest.java:73)
github-actions / Unit Test Result
RebalanceDdlPlanManagerTest.testOnPauseOnNonMaintenanceWindow
java.lang.NullPointerException
at com.alibaba.polardbx.executor.partitionmanagement.rebalance.RebalanceDdlPlanManagerTest.testOnPauseOnNonMaintenanceWindow(RebalanceDdlPlanManagerTest.java:103)
Raw output
java.lang.NullPointerException
at com.alibaba.polardbx.executor.partitionmanagement.rebalance.RebalanceDdlPlanManagerTest.testOnPauseOnNonMaintenanceWindow(RebalanceDdlPlanManagerTest.java:103)
github-actions / Unit Test Result
RebalanceDdlPlanManagerTest.testOnInit
java.lang.NullPointerException
at com.alibaba.polardbx.executor.partitionmanagement.rebalance.RebalanceDdlPlanManagerTest.testOnInit(RebalanceDdlPlanManagerTest.java:54)
Raw output
java.lang.NullPointerException
at com.alibaba.polardbx.executor.partitionmanagement.rebalance.RebalanceDdlPlanManagerTest.testOnInit(RebalanceDdlPlanManagerTest.java:54)
github-actions / Unit Test Result
SkewColumnBuildTest.testSql[0]
Failed to create table
Raw output
java.lang.RuntimeException: Failed to create table
at com.alibaba.polardbx.executor.statistics.SkewColumnBuildTest.<init>(SkewColumnBuildTest.java:21)
Caused by: java.lang.NullPointerException
at com.alibaba.polardbx.executor.statistics.SkewColumnBuildTest.<init>(SkewColumnBuildTest.java:21)
github-actions / Unit Test Result
PushDownReplaceTest.testPushDownReplace
: Global Secondary Index 'gsi_t' already exists
Raw output
org.apache.calcite.runtime.CalciteContextException: : Global Secondary Index 'gsi_t' already exists
at com.alibaba.polardbx.optimizer.core.rel.PushDownReplaceTest.testPushDownReplace(PushDownReplaceTest.java:48)
Caused by: org.apache.calcite.sql.validate.SqlValidatorException: Global Secondary Index 'gsi_t' already exists
at com.alibaba.polardbx.optimizer.core.rel.PushDownReplaceTest.testPushDownReplace(PushDownReplaceTest.java:48)
github-actions / Unit Test Result
LimitTest.testSql[LimitTest.yml:2]
targetSql =
SELECT foo.id AS foo_id, foo.bar AS foo_bar, foo.`range` AS foo_range FROM alchemy_foo as foo ORDER BY foo.bar LIMIT -1, 18446744073709551615;
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by get rex -1
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by get rex -1
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Raw output
org.junit.internal.ArrayComparisonFailure:
targetSql =
SELECT foo.id AS foo_id, foo.bar AS foo_bar, foo.`range` AS foo_range FROM alchemy_foo as foo ORDER BY foo.bar LIMIT -1, 18446744073709551615;
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by get rex -1
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by get rex -1
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Caused by: org.junit.ComparisonFailure:
expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
github-actions / Unit Test Result
LimitTest.testSql[LimitTest.yml:3]
targetSql =
SELECT foo.id AS foo_id, foo.bar AS foo_bar, foo.`range` AS foo_range FROM alchemy_foo as foo ORDER BY foo.bar LIMIT 18446744073709551615, -1;
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by get rex -1
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by get rex -1
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Raw output
org.junit.internal.ArrayComparisonFailure:
targetSql =
SELECT foo.id AS foo_id, foo.bar AS foo_bar, foo.`range` AS foo_range FROM alchemy_foo as foo ORDER BY foo.bar LIMIT 18446744073709551615, -1;
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by get rex -1
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by get rex -1
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Caused by: org.junit.ComparisonFailure:
expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
github-actions / Unit Test Result
LimitTest.testSql[LimitTest.yml:4]
targetSql =
SELECT foo.id AS foo_id, foo.bar AS foo_bar, foo.`range` AS foo_range FROM alchemy_foo as foo ORDER BY foo.bar LIMIT -1, 10;
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by get rex -1
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by get rex -1
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Raw output
org.junit.internal.ArrayComparisonFailure:
targetSql =
SELECT foo.id AS foo_id, foo.bar AS foo_bar, foo.`range` AS foo_range FROM alchemy_foo as foo ORDER BY foo.bar LIMIT -1, 10;
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by get rex -1
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by get rex -1
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Caused by: org.junit.ComparisonFailure:
expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
github-actions / Unit Test Result
LimitTest.testSql[LimitTest.yml:5]
targetSql =
SELECT foo.id AS foo_id, foo.bar AS foo_bar, foo.`range` AS foo_range FROM alchemy_foo as foo ORDER BY foo.bar LIMIT 10, -1;
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by get rex -1
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by get rex -1
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Raw output
org.junit.internal.ArrayComparisonFailure:
targetSql =
SELECT foo.id AS foo_id, foo.bar AS foo_bar, foo.`range` AS foo_range FROM alchemy_foo as foo ORDER BY foo.bar LIMIT 10, -1;
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by get rex -1
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by get rex -1
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Caused by: org.junit.ComparisonFailure:
expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
github-actions / Unit Test Result
LimitTest.testSql[LimitTest.yml:6]
targetSql =
SELECT foo.id AS foo_id, foo.bar AS foo_bar, foo.`range` AS foo_range FROM alchemy_foo as foo ORDER BY foo.bar LIMIT 10, -11;
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by get rex -11
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by get rex -11
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Raw output
org.junit.internal.ArrayComparisonFailure:
targetSql =
SELECT foo.id AS foo_id, foo.bar AS foo_bar, foo.`range` AS foo_range FROM alchemy_foo as foo ORDER BY foo.bar LIMIT 10, -11;
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by get rex -11
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by get rex -11
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Caused by: org.junit.ComparisonFailure:
expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
github-actions / Unit Test Result
LimitTest.testSql[LimitTest.yml:7]
targetSql =
SELECT foo.id AS foo_id, foo.bar AS foo_bar, foo.`range` AS foo_range FROM alchemy_foo as foo ORDER BY foo.bar LIMIT 10, -18446744073709551615;
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by get rex -18446744073709551615
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by get rex -18446744073709551615
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Raw output
org.junit.internal.ArrayComparisonFailure:
targetSql =
SELECT foo.id AS foo_id, foo.bar AS foo_bar, foo.`range` AS foo_range FROM alchemy_foo as foo ORDER BY foo.bar LIMIT 10, -18446744073709551615;
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by get rex -18446744073709551615
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by get rex -18446744073709551615
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Caused by: org.junit.ComparisonFailure:
expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
github-actions / Unit Test Result
SimpleDmlTest.testSql[SimpleDmlTest.insert.yml:14]
targetSql =
insert into test_hash_tb(id, name, name) values(1, 'a', 'a');
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by column 'name' specified twice.
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by column 'name' specified twice.
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Raw output
org.junit.internal.ArrayComparisonFailure:
targetSql =
insert into test_hash_tb(id, name, name) values(1, 'a', 'a');
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by column 'name' specified twice.
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by column 'name' specified twice.
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Caused by: org.junit.ComparisonFailure:
expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
github-actions / Unit Test Result
SimpleDmlTest.testSql[SimpleDmlTest.insert.yml:15]
targetSql =
insert into test_hash_tb(id, name, name) values(1, 'a', 'a'), (2, 'b', 'b');
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by column 'name' specified twice.
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by column 'name' specified twice.
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Raw output
org.junit.internal.ArrayComparisonFailure:
targetSql =
insert into test_hash_tb(id, name, name) values(1, 'a', 'a'), (2, 'b', 'b');
realPlanVal =
err-code: [pxc-4501][err_optimizer] optimize error by column 'name' specified twice.
targetPlanVal =
err-code: [tddl-4501][err_optimizer] optimize error by column 'name' specified twice.
: arrays first differed at element [0]; expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
Caused by: org.junit.ComparisonFailure:
expected:<...
plan:
err-code: [[tddl]-4501][err_optimizer...> but was:<...
plan:
err-code: [[pxc]-4501][err_optimizer...>
github-actions / Unit Test Result
ConstantFoldRuleTest.testSql[ConstantFoldRuleTest.yml:7]
targetSql =
select l_partkey, now(),sysdate(),curdate(),curtime(),utc_date(), utc_time(), utc_timestamp(),
date('2008-09-10 07:15:30.123456'),
time('2008-09-10 07:15:30.123456'),
year('2008-09-10 07:15:30.123456'),
quarter('2008-09-10 07:15:30.123456'),
month('2008-09-10 07:15:30.123456'),
week('2008-09-10 07:15:30.123456'),
day('2008-09-10 07:15:30.123456'),
hour('2008-09-10 07:15:30.123456'),
minute('2008-09-10 07:15:30.123456'),
second('2008-09-10 07:15:30.123456'),
microsecond('2008-09-10 07:15:30.123456'),
dayofweek('2008-09-10 07:15:30.123456'),
dayofyear('2008-09-10 07:15:30.123456'),
weekofyear('2008-09-10 07:15:30.123456'),
weekday('2008-09-10 07:15:30.123456'),
yearweek('2008-09-10 07:15:30.123456'),
dayname('2008-09-10 07:15:30.123456'),
monthname('2008-09-10 07:15:30.123456'),
last_day('2008-09-10 07:15:30.123456'),
date_add('2008-09-10 07:15:30.123456', interval 1 minute),
date_sub('2008-09-10 07:15:30.123456',interval '1 1:1:1' day_second),
timediff('2008-09-10 07:15:30.123456','2008-09-09 07:15:30.123456'),
datediff('2008-09-10 07:15:30.123456','2008-09-09 07:15:30.123456'),
to_days('2008-09-10 07:15:30.123456'),
from_days(733627),
1+2 +(CAST( -11 AS DECIMAL))
from lineitem;
realPlanVal =
com.alibaba.polardbx.optimizer.core.datatype.intervaltype cannot be cast to java.lang.number
targetPlanVal =
project(l_partkey="l_partkey", now()="now()", sysdate()="sysdate()", curdate()="curdate()", curtime()="curtime()", utc_date()="utc_date()", utc_time()="utc_time()", utc_timestamp()="utc_timestamp()", date('2008-09-10 07:15:30.123456')="date('2008-09-10 07:15:30.123456')", time('2008-09-10 07:15:30.123456')="time('2008-09-10 07:15:30.123456')", year('2008-09-10 07:15:30.123456')="2008", quarter('2008-09-10 07:15:30.123456')="3", month('2008-09-10 07:15:30.123456')="9", week('2008-09-10 07:15:30.123456')="36", day('2008-09-10 07:15:30.123456')="10", hour('2008-09-10 07:15:30.123456')="7", minute('2008-09-10 07:15:30.123456')="15", second('2008-09-10 07:15:30.123456')="30", microsecond('2008-09-10 07:15:30.123456')="123456", dayofweek('2008-09-10 07:15:30.123456')="4", dayofyear('2008-09-10 07:15:30.123456')="254", weekofyear('2008-09-10 07:15:30.123456')="37", weekday('2008-09-10 07:15:30.123456')="2", yearweek('2008-09-10 07:15:30.123456')="200836", dayname('2008-09-10 07:15:30.123456')="dayname('2008-09-10 07:15:30.123456')", monthname('2008-09-10 07:15:30.123456')="monthname('2008-09-10 07:15:30.123456')", last_day('2008-09-10 07:15:30.123456')="last_day('2008-09-10 07:15:30.123456')", date_add('2008-09-10 07:15:30.123456', interval 1 minute)="date_add('2008-09-10 07:15:30.123456', interval_primary(1, minute))", date_sub('2008-09-10 07:15:30.123456', interval '1 1:1:1' day_second)="date_sub('2008-09-10 07:15:30.123456', interval_primary('1 1:1:1', day_second))", timediff('2008-09-10 07:15:30.123456', '2008-09-09 07:15:30.123456')="timediff('2008-09-10 07:15:30.123456', '2008-09-09 07:15:30.123456')", datediff('2008-09-10 07:15:30.123456', '2008-09-09 07:15:30.123456')="1", to_days('2008-09-10 07:15:30.123456')="733660", from_days(733627)="from_days(733627)", 1 + 2 + cast(-11 as decimal)="3 + cast(-11)")
logicalview(tables="[0000-0003].lineitem_[00-15]", shardcount=16, sql="select `l_orderkey`, `l_partkey`, `l_suppkey`, `l_linenumber`, `l_quantity`, `l_extendedprice`, `l_discount`, `l_tax`, `l_returnflag`, `l_linestatus`, `l_shipdate`, `l_commitdate`, `l_receiptdate`, `l_shipinstruct`, `l_shipmode`, `l_comment` from `lineitem` as `lineitem`")
: arrays first differed at element [0]; expected:<... lineitem;
plan:
[project(l_partkey="l_partkey", now()="now()", sysdate()="sysdate()", curdate()="curdate()", curtime()="curtime()", utc_date()="utc_date()", utc_time()="utc_time()", utc_timestamp()="utc_timestamp()", date('2008-09-10 07:15:30.123456')="date('2008-09-10 07:15:30.123456')", time('2008-09-10 07:15:30.123456')="time('2008-09-10 07:15:30.123456')", year('2008-09-10 07:15:30.123456')="2008", quarter('2008-09-10 07:15:30.123456')="3", month('2008-09-10 07:15:30.123456')="9", week('2008-09-10 07:15:30.123456')="36", day('2008-09-10 07:15:30.123456')="10", hour('2008-09-10 07:15:30.123456')="7", minute('2008-09-10 07:15:30.123456')="15", second('2008-09-10 07:15:30.123456')="30", microsecond('2008-09-10 07:15:30.123456')="123456", dayofweek('2008-09-10 07:15:30.123456')="4", dayofyear('2008-09-10 07:15:30.123456')="254", weekofyear('2008-09-10 07:15:30.123456')="37", weekday('2008-09-10 07:15:30.123456')="2", yearweek('2008-09-10 07:15:30.123456')="200836", dayname('2008-09-10 07:15:30.123456')="dayname('2008-09-10 07:15:30.123456')", monthname('2008-09-10 07:15:30.123456')="monthname('2008-09-10 07:15:30.123456')", last_day('2008-09-10 07:15:30.123456')="last_day('2008-09-10 07:15:30.123456')", date_add('2008-09-10 07:15:30.123456', interval 1 minute)="date_add('2008-09-10 07:15:30.123456', interval_primary(1, minute))", date_sub('2008-09-10 07:15:30.123456', interval '1 1:1:1' day_second)="date_sub('2008-09-10 07:15:30.123456', interval_primary('1 1:1:1', day_second))", timediff('2008-09-10 07:15:30.123456', '2008-09-09 07:15:30.123456')="timediff('2008-09-10 07:15:30.123456', '2008-09-09 07:15:30.123456')", datediff('2008-09-10 07:15:30.123456', '2008-09-09 07:15:30.123456')="1", to_days('2008-09-10 07:15:30.123456')="733660", from_days(733627)="from_days(733627)", 1 + 2 + cast(-11 as decimal)="3 + cast(-11)")
logicalview(tables="[0000-0003].lineitem_[00-15]", shardcount=16, sql="select `l_orderkey`, `l_partkey`, `l_suppkey`, `l_linenumber`, `l_quantity`, `l_extendedprice`, `l_discount`, `l_tax`, `l_returnflag`, `l_linestatus`, `l_shipdate`, `l_commitdate`, `l_receiptdate`, `l_shipinstruct`, `l_shipmode`, `l_comment` from `lineitem` as `lineitem`")]> but was:<... lineitem;
plan:
[com.alibaba.polardbx.optimizer.core.datatype.intervaltype cannot be cast to java.lang.number]>
Raw output
org.junit.internal.ArrayComparisonFailure:
targetSql =
select l_partkey, now(),sysdate(),curdate(),curtime(),utc_date(), utc_time(), utc_timestamp(),
date('2008-09-10 07:15:30.123456'),
time('2008-09-10 07:15:30.123456'),
year('2008-09-10 07:15:30.123456'),
quarter('2008-09-10 07:15:30.123456'),
month('2008-09-10 07:15:30.123456'),
week('2008-09-10 07:15:30.123456'),
day('2008-09-10 07:15:30.123456'),
hour('2008-09-10 07:15:30.123456'),
minute('2008-09-10 07:15:30.123456'),
second('2008-09-10 07:15:30.123456'),
microsecond('2008-09-10 07:15:30.123456'),
dayofweek('2008-09-10 07:15:30.123456'),
dayofyear('2008-09-10 07:15:30.123456'),
weekofyear('2008-09-10 07:15:30.123456'),
weekday('2008-09-10 07:15:30.123456'),
yearweek('2008-09-10 07:15:30.123456'),
dayname('2008-09-10 07:15:30.123456'),
monthname('2008-09-10 07:15:30.123456'),
last_day('2008-09-10 07:15:30.123456'),
date_add('2008-09-10 07:15:30.123456', interval 1 minute),
date_sub('2008-09-10 07:15:30.123456',interval '1 1:1:1' day_second),
timediff('2008-09-10 07:15:30.123456','2008-09-09 07:15:30.123456'),
datediff('2008-09-10 07:15:30.123456','2008-09-09 07:15:30.123456'),
to_days('2008-09-10 07:15:30.123456'),
from_days(733627),
1+2 +(CAST( -11 AS DECIMAL))
from lineitem;
realPlanVal =
com.alibaba.polardbx.optimizer.core.datatype.intervaltype cannot be cast to java.lang.number
targetPlanVal =
project(l_partkey="l_partkey", now()="now()", sysdate()="sysdate()", curdate()="curdate()", curtime()="curtime()", utc_date()="utc_date()", utc_time()="utc_time()", utc_timestamp()="utc_timestamp()", date('2008-09-10 07:15:30.123456')="date('2008-09-10 07:15:30.123456')", time('2008-09-10 07:15:30.123456')="time('2008-09-10 07:15:30.123456')", year('2008-09-10 07:15:30.123456')="2008", quarter('2008-09-10 07:15:30.123456')="3", month('2008-09-10 07:15:30.123456')="9", week('2008-09-10 07:15:30.123456')="36", day('2008-09-10 07:15:30.123456')="10", hour('2008-09-10 07:15:30.123456')="7", minute('2008-09-10 07:15:30.123456')="15", second('2008-09-10 07:15:30.123456')="30", microsecond('2008-09-10 07:15:30.123456')="123456", dayofweek('2008-09-10 07:15:30.123456')="4", dayofyear('2008-09-10 07:15:30.123456')="254", weekofyear('2008-09-10 07:15:30.123456')="37", weekday('2008-09-10 07:15:30.123456')="2", yearweek('2008-09-10 07:15:30.123456')="200836", dayname('2008-09-10 07:15:30.123456')="dayname('2008-09-10 07:15:30.123456')", monthname('2008-09-10 07:15:30.123456')="monthname('2008-09-10 07:15:30.123456')", last_day('2008-09-10 07:15:30.123456')="last_day('2008-09-10 07:15:30.123456')", date_add('2008-09-10 07:15:30.123456', interval 1 minute)="date_add('2008-09-10 07:15:30.123456', interval_primary(1, minute))", date_sub('2008-09-10 07:15:30.123456', interval '1 1:1:1' day_second)="date_sub('2008-09-10 07:15:30.123456', interval_primary('1 1:1:1', day_second))", timediff('2008-09-10 07:15:30.123456', '2008-09-09 07:15:30.123456')="timediff('2008-09-10 07:15:30.123456', '2008-09-09 07:15:30.123456')", datediff('2008-09-10 07:15:30.123456', '2008-09-09 07:15:30.123456')="1", to_days('2008-09-10 07:15:30.123456')="733660", from_days(733627)="from_days(733627)", 1 + 2 + cast(-11 as decimal)="3 + cast(-11)")
logicalview(tables="[0000-0003].lineitem_[00-15]", shardcount=16, sql="select `l_orderkey`, `l_partkey`, `l_suppkey`, `l_linenumber`, `l_quantity`, `l_extendedprice`, `l_discount`, `l_tax`, `l_returnflag`, `l_linestatus`, `l_shipdate`, `l_commitdate`, `l_receiptdate`, `l_shipinstruct`, `l_shipmode`, `l_comment` from `lineitem` as `lineitem`")
: arrays first differed at element [0]; expected:<... lineitem;
plan:
[project(l_partkey="l_partkey", now()="now()", sysdate()="sysdate()", curdate()="curdate()", curtime()="curtime()", utc_date()="utc_date()", utc_time()="utc_time()", utc_timestamp()="utc_timestamp()", date('2008-09-10 07:15:30.123456')="date('2008-09-10 07:15:30.123456')", time('2008-09-10 07:15:30.123456')="time('2008-09-10 07:15:30.123456')", year('2008-09-10 07:15:30.123456')="2008", quarter('2008-09-10 07:15:30.123456')="3", month('2008-09-10 07:15:30.123456')="9", week('2008-09-10 07:15:30.123456')="36", day('2008-09-10 07:15:30.123456')="10", hour('2008-09-10 07:15:30.123456')="7", minute('2008-09-10 07:15:30.123456')="15", second('2008-09-10 07:15:30.123456')="30", microsecond('2008-09-10 07:15:30.123456')="123456", dayofweek('2008-09-10 07:15:30.123456')="4", dayofyear('2008-09-10 07:15:30.123456')="254", weekofyear('2008-09-10 07:15:30.123456')="37", weekday('2008-09-10 07:15:30.123456')="2", yearweek('2008-09-10 07:15:30.123456')="200836", dayname('2008-09-10 07:15:30.123456')="dayname('2008-09-10 07:15:30.123456')", monthname('2008-09-10 07:15:30.123456')="monthname('2008-09-10 07:15:30.123456')", last_day('2008-09-10 07:15:30.123456')="last_day('2008-09-10 07:15:30.123456')", date_add('2008-09-10 07:15:30.123456', interval 1 minute)="date_add('2008-09-10 07:15:30.123456', interval_primary(1, minute))", date_sub('2008-09-10 07:15:30.123456', interval '1 1:1:1' day_second)="date_sub('2008-09-10 07:15:30.123456', interval_primary('1 1:1:1', day_second))", timediff('2008-09-10 07:15:30.123456', '2008-09-09 07:15:30.123456')="timediff('2008-09-10 07:15:30.123456', '2008-09-09 07:15:30.123456')", datediff('2008-09-10 07:15:30.123456', '2008-09-09 07:15:30.123456')="1", to_days('2008-09-10 07:15:30.123456')="733660", from_days(733627)="from_days(733627)", 1 + 2 + cast(-11 as decimal)="3 + cast(-11)")
logicalview(tables="[0000-0003].lineitem_[00-15]", shardcount=16, sql="select `l_orderkey`, `l_partkey`, `l_suppkey`, `l_linenumber`, `l_quantity`, `l_extendedprice`, `l_discount`, `l_tax`, `l_returnflag`, `l_linestatus`, `l_shipdate`, `l_commitdate`, `l_receiptdate`, `l_shipinstruct`, `l_shipmode`, `l_comment` from `lineitem` as `lineitem`")]> but was:<... lineitem;
plan:
[com.alibaba.polardbx.optimizer.core.datatype.intervaltype cannot be cast to java.lang.number]>
Caused by: org.junit.ComparisonFailure:
expected:<... lineitem;
plan:
[project(l_partkey="l_partkey", now()="now()", sysdate()="sysdate()", curdate()="curdate()", curtime()="curtime()", utc_date()="utc_date()", utc_time()="utc_time()", utc_timestamp()="utc_timestamp()", date('2008-09-10 07:15:30.123456')="date('2008-09-10 07:15:30.123456')", time('2008-09-10 07:15:30.123456')="time('2008-09-10 07:15:30.123456')", year('2008-09-10 07:15:30.123456')="2008", quarter('2008-09-10 07:15:30.123456')="3", month('2008-09-10 07:15:30.123456')="9", week('2008-09-10 07:15:30.123456')="36", day('2008-09-10 07:15:30.123456')="10", hour('2008-09-10 07:15:30.123456')="7", minute('2008-09-10 07:15:30.123456')="15", second('2008-09-10 07:15:30.123456')="30", microsecond('2008-09-10 07:15:30.123456')="123456", dayofweek('2008-09-10 07:15:30.123456')="4", dayofyear('2008-09-10 07:15:30.123456')="254", weekofyear('2008-09-10 07:15:30.123456')="37", weekday('2008-09-10 07:15:30.123456')="2", yearweek('2008-09-10 07:15:30.123456')="200836", dayname('2008-09-10 07:15:30.123456')="dayname('2008-09-10 07:15:30.123456')", monthname('2008-09-10 07:15:30.123456')="monthname('2008-09-10 07:15:30.123456')", last_day('2008-09-10 07:15:30.123456')="last_day('2008-09-10 07:15:30.123456')", date_add('2008-09-10 07:15:30.123456', interval 1 minute)="date_add('2008-09-10 07:15:30.123456', interval_primary(1, minute))", date_sub('2008-09-10 07:15:30.123456', interval '1 1:1:1' day_second)="date_sub('2008-09-10 07:15:30.123456', interval_primary('1 1:1:1', day_second))", timediff('2008-09-10 07:15:30.123456', '2008-09-09 07:15:30.123456')="timediff('2008-09-10 07:15:30.123456', '2008-09-09 07:15:30.123456')", datediff('2008-09-10 07:15:30.123456', '2008-09-09 07:15:30.123456')="1", to_days('2008-09-10 07:15:30.123456')="733660", from_days(733627)="from_days(733627)", 1 + 2 + cast(-11 as decimal)="3 + cast(-11)")
logicalview(tables="[0000-0003].lineitem_[00-15]", shardcount=16, sql="select `l_orderkey`, `l_partkey`, `l_suppkey`, `l_linenumber`, `l_quantity`, `l_extendedprice`, `l_discount`, `l_tax`, `l_returnflag`, `l_linestatus`, `l_shipdate`, `l_commitdate`, `l_receiptdate`, `l_shipinstruct`, `l_shipmode`, `l_comment` from `lineitem` as `lineitem`")]> but was:<... lineitem;
plan:
[com.alibaba.polardbx.optimizer.core.datatype.intervaltype cannot be cast to java.lang.number]>
github-actions / Unit Test Result
DerivedSubQueryPlanTest.testSql[DerivedSubQueryPlanTest.testPushOptToDerivedNonCorrSubQuery.yml:7]
targetSql =
SELECT
ord.*,
orde.*
FROM
(
SELECT
*
FROM
(
(
SELECT
*
FROM
or_order oro
LEFT JOIN
(
SELECT
COUNT( 1 ) butoon_Type,
TRANS_NO out_trans_no
FROM
OR_OUT_STOCK
GROUP BY
out_trans_no ) oros
ON
oro.TRANS_NO = oros.out_trans_no
WHERE
oro.platform_code IN ( 'ELE',
'MT',
'BD',
'JDDJ' )
AND oro.create_time >= NOW( ) - INTERVAL 24 HOUR )
UNION
(
SELECT
*
FROM
or_order oro
LEFT JOIN
(
SELECT
COUNT( 1 ) butoon_Type,
TRANS_NO out_trans_no
FROM
OR_OUT_STOCK
GROUP BY
out_trans_no ) oros
ON
oro.TRANS_NO = oros.out_trans_no
WHERE
oro.platform_code IN ( 'ELE',
'MT',
'BD',
'JDDJ' )
AND oro.create_time < NOW( ) - INTERVAL 24 HOUR
AND oro.STATUS IN ("101",
"102",
"103",
"106",
"107",
"108",
"401") ) ) orders
ORDER BY
orders.create_time DESC LIMIT 0,5 ) ord,
or_order_item orde
WHERE
ord.order_no = orde.order_no;
realPlanVal =
err-code: [pxc-4006][err_table_not_exist] table 'or_order' doesn't exist.
targetPlanVal =
bkajoin(condition="order_no = order_no", type="inner")
topn(sort="create_time desc", offset=0, fetch=5)
hashagg(group="order_no,trans_no,platform_code,platform_name,shop_code,shop_name,allot_shop_code,allot_shop_name,channel_type,type,business_type,business_date,create_type,is_copy,order_time,expect_arrival_time,status,trans_status,package_fee,package_number,platform_user_id,is_fetch,o2o_dist_mode,consignee_name,consignee_telephone,salesman_mobile,salesman_type,consignee_postcode,consignee_province_code,consignee_province_name,consignee_city_code,consignee_city_name,consignee_area_code,consignee_area_name,consignee_address,express_company,logistics_no,total_amount,adjust_amount,freight_amount,discount_amount,payment_amount,payment_type,used_integral,payment_time,buyer_remark,seller_remark,is_need_invoice,invoice_type,invoice_header,invoice_content,invoice_taxer_id,product_weight,platform_commision,distributor_commision,product_volume,is_retain_order,retain_order_time,is_locked,locker,shop_income,return_flag,group_code,is_group_leader,sourcing_model,create_by,create_time,last_update_by,last_update_time,delivery_status,tip,platform_shop_code,lock_stock_type,receive_model,salesman_commision,reminder_flag,salesman_second_commision,butoon_type,out_trans_no")
unionall(concurrent=true)
hashjoin(condition="trans_no = out_trans_no", type="left")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_order", shardcount=4, sql="select `order_no`, `trans_no`, `platform_code`, `platform_name`, `shop_code`, `shop_name`, `allot_shop_code`, `allot_shop_name`, `channel_type`, `type`, `business_type`, `business_date`, `create_type`, `is_copy`, `order_time`, `expect_arrival_time`, `status`, `trans_status`, `package_fee`, `package_number`, `platform_user_id`, `is_fetch`, `o2o_dist_mode`, `consignee_name`, `consignee_telephone`, `salesman_mobile`, `salesman_type`, `consignee_postcode`, `consignee_province_code`, `consignee_province_name`, `consignee_city_code`, `consignee_city_name`, `consignee_area_code`, `consignee_area_name`, `consignee_address`, `express_company`, `logistics_no`, `total_amount`, `adjust_amount`, `freight_amount`, `discount_amount`, `payment_amount`, `payment_type`, `used_integral`, `payment_time`, `buyer_remark`, `seller_remark`, `is_need_invoice`, `invoice_type`, `invoice_header`, `invoice_content`, `invoice_taxer_id`, `product_weight`, `platform_commision`, `distributor_commision`, `product_volume`, `is_retain_order`, `retain_order_time`, `is_locked`, `locker`, `shop_income`, `return_flag`, `group_code`, `is_group_leader`, `sourcing_model`, `create_by`, `create_time`, `last_update_by`, `last_update_time`, `delivery_status`, `tip`, `platform_shop_code`, `lock_stock_type`, `receive_model`, `salesman_commision`, `reminder_flag`, `salesman_second_commision` from `or_order` as `or_order` where ((`platform_code` in('ele', 'mt', 'bd', 'jddj')) and (`create_time` >= date_sub(now(), interval 24 hour)))")
project(butoon_type="butoon_type", out_trans_no="trans_no")
hashagg(group="trans_no", butoon_type="sum(butoon_type)")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_out_stock", shardcount=4, sql="select `trans_no`, count(*) as `butoon_type` from `or_out_stock` as `or_out_stock` group by `trans_no`")
hashjoin(condition="trans_no = out_trans_no", type="left")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_order", shardcount=4, sql="select `order_no`, `trans_no`, `platform_code`, `platform_name`, `shop_code`, `shop_name`, `allot_shop_code`, `allot_shop_name`, `channel_type`, `type`, `business_type`, `business_date`, `create_type`, `is_copy`, `order_time`, `expect_arrival_time`, `status`, `trans_status`, `package_fee`, `package_number`, `platform_user_id`, `is_fetch`, `o2o_dist_mode`, `consignee_name`, `consignee_telephone`, `salesman_mobile`, `salesman_type`, `consignee_postcode`, `consignee_province_code`, `consignee_province_name`, `consignee_city_code`, `consignee_city_name`, `consignee_area_code`, `consignee_area_name`, `consignee_address`, `express_company`, `logistics_no`, `total_amount`, `adjust_amount`, `freight_amount`, `discount_amount`, `payment_amount`, `payment_type`, `used_integral`, `payment_time`, `buyer_remark`, `seller_remark`, `is_need_invoice`, `invoice_type`, `invoice_header`, `invoice_content`, `invoice_taxer_id`, `product_weight`, `platform_commision`, `distributor_commision`, `product_volume`, `is_retain_order`, `retain_order_time`, `is_locked`, `locker`, `shop_income`, `return_flag`, `group_code`, `is_group_leader`, `sourcing_model`, `create_by`, `create_time`, `last_update_by`, `last_update_time`, `delivery_status`, `tip`, `platform_shop_code`, `lock_stock_type`, `receive_model`, `salesman_commision`, `reminder_flag`, `salesman_second_commision` from `or_order` as `or_order` where ((`platform_code` in('ele', 'mt', 'bd', 'jddj')) and (`status` in('101', '102', '103', '106', '107', '108', '401')) and (`create_time` < date_sub(now(), interval 24 hour)))")
project(butoon_type="butoon_type", out_trans_no="trans_no")
hashagg(group="trans_no", butoon_type="sum(butoon_type)")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_out_stock", shardcount=4, sql="select `trans_no`, count(*) as `butoon_type` from `or_out_stock` as `or_out_stock` group by `trans_no`")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_order_item", shardcount=4, sql="select `id`, `order_no`, `sub_order_no`, `bag_code`, `product_code`, `product_name`, `one_category_code`, `one_category_name`, `two_category_code`, `two_category_name`, `three_category_code`, `three_category_name`, `product_brand_code`, `product_brand_name`, `product_barcode`, `product_sku`, `product_price`, `product_spec`, `platform_product_sku`, `product_meter_unit`, `platform_product_code`, `platform_product_name`, `platform_product_url`, `buy_number`, `out_stock_number`, `product_weight`, `product_volume`, `discount_amount`, `share_amount`, `payable_amount`, `coupon_duct_amount`, `paid_amount`, `is_split`, `group_product_code`, `group_product_name`, `integral_share`, `is_out_stock`, `is_gift`, `activity_name`, `activity_id`, `platform_commision_point`, `platform_commision`, `distributor_commision`, `salesman_commision`, `return_type`, `factory_cost`, `is_cancel`, `erp_order_item_id`, `create_by`, `create_time`, `last_update_by`, `last_update_time`, `platform_product_index`, `salesman_second_commision` from `or_order_item` as `or_order_item` where (`order_no` in (...))")
: arrays first differed at element [0]; expected:<....order_no;
plan:
[bkajoin(condition="order_no = order_no", type="inner")
topn(sort="create_time desc", offset=0, fetch=5)
hashagg(group="order_no,trans_no,platform_code,platform_name,shop_code,shop_name,allot_shop_code,allot_shop_name,channel_type,type,business_type,business_date,create_type,is_copy,order_time,expect_arrival_time,status,trans_status,package_fee,package_number,platform_user_id,is_fetch,o2o_dist_mode,consignee_name,consignee_telephone,salesman_mobile,salesman_type,consignee_postcode,consignee_province_code,consignee_province_name,consignee_city_code,consignee_city_name,consignee_area_code,consignee_area_name,consignee_address,express_company,logistics_no,total_amount,adjust_amount,freight_amount,discount_amount,payment_amount,payment_type,used_integral,payment_time,buyer_remark,seller_remark,is_need_invoice,invoice_type,invoice_header,invoice_content,invoice_taxer_id,product_weight,platform_commision,distributor_commision,product_volume,is_retain_order,retain_order_time,is_locked,locker,shop_income,return_flag,group_code,is_group_leader,sourcing_model,create_by,create_time,last_update_by,last_update_time,delivery_status,tip,platform_shop_code,lock_stock_type,receive_model,salesman_commision,reminder_flag,salesman_second_commision,butoon_type,out_trans_no")
unionall(concurrent=true)
hashjoin(condition="trans_no = out_trans_no", type="left")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_order", shardcount=4, sql="select `order_no`, `trans_no`, `platform_code`, `platform_name`, `shop_code`, `shop_name`, `allot_shop_code`, `allot_shop_name`, `channel_type`, `type`, `business_type`, `business_date`, `create_type`, `is_copy`, `order_time`, `expect_arrival_time`, `status`, `trans_status`, `package_fee`, `package_number`, `platform_user_id`, `is_fetch`, `o2o_dist_mode`, `consignee_name`, `consignee_telephone`, `salesman_mobile`, `salesman_type`, `consignee_postcode`, `consignee_province_code`, `consignee_province_name`, `consignee_city_code`, `consignee_city_name`, `consignee_area_code`, `consignee_area_name`, `consignee_address`, `express_company`, `logistics_no`, `total_amount`, `adjust_amount`, `freight_amount`, `discount_amount`, `payment_amount`, `payment_type`, `used_integral`, `payment_time`, `buyer_remark`, `seller_remark`, `is_need_invoice`, `invoice_type`, `invoice_header`, `invoice_content`, `invoice_taxer_id`, `product_weight`, `platform_commision`, `distributor_commision`, `product_volume`, `is_retain_order`, `retain_order_time`, `is_locked`, `locker`, `shop_income`, `return_flag`, `group_code`, `is_group_leader`, `sourcing_model`, `create_by`, `create_time`, `last_update_by`, `last_update_time`, `delivery_status`, `tip`, `platform_shop_code`, `lock_stock_type`, `receive_model`, `salesman_commision`, `reminder_flag`, `salesman_second_commision` from `or_order` as `or_order` where ((`platform_code` in('ele', 'mt', 'bd', 'jddj')) and (`create_time` >= date_sub(now(), interval 24 hour)))")
project(butoon_type="butoon_type", out_trans_no="trans_no")
hashagg(group="trans_no", butoon_type="sum(butoon_type)")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_out_stock", shardcount=4, sql="select `trans_no`, count(*) as `butoon_type` from `or_out_stock` as `or_out_stock` group by `trans_no`")
hashjoin(condition="trans_no = out_trans_no", type="left")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_order", shardcount=4, sql="select `order_no`, `trans_no`, `platform_code`, `platform_name`, `shop_code`, `shop_name`, `allot_shop_code`, `allot_shop_name`, `channel_type`, `type`, `business_type`, `business_date`, `create_type`, `is_copy`, `order_time`, `expect_arrival_time`, `status`, `trans_status`, `package_fee`, `package_number`, `platform_user_id`, `is_fetch`, `o2o_dist_mode`, `consignee_name`, `consignee_telephone`, `salesman_mobile`, `salesman_type`, `consignee_postcode`, `consignee_province_code`, `consignee_province_name`, `consignee_city_code`, `consignee_city_name`, `consignee_area_code`, `consignee_area_name`, `consignee_address`, `express_company`, `logistics_no`, `total_amount`, `adjust_amount`, `freight_amount`, `discount_amount`, `payment_amount`, `payment_type`, `used_integral`, `payment_time`, `buyer_remark`, `seller_remark`, `is_need_invoice`, `invoice_type`, `invoice_header`, `invoice_content`, `invoice_taxer_id`, `product_weight`, `platform_commision`, `distributor_commision`, `product_volume`, `is_retain_order`, `retain_order_time`, `is_locked`, `locker`, `shop_income`, `return_flag`, `group_code`, `is_group_leader`, `sourcing_model`, `create_by`, `create_time`, `last_update_by`, `last_update_time`, `delivery_status`, `tip`, `platform_shop_code`, `lock_stock_type`, `receive_model`, `salesman_commision`, `reminder_flag`, `salesman_second_commision` from `or_order` as `or_order` where ((`platform_code` in('ele', 'mt', 'bd', 'jddj')) and (`status` in('101', '102', '103', '106', '107', '108', '401')) and (`create_time` < date_sub(now(), interval 24 hour)))")
project(butoon_type="butoon_type", out_trans_no="trans_no")
hashagg(group="trans_no", butoon_type="sum(butoon_type)")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_out_stock", shardcount=4, sql="select `trans_no`, count(*) as `butoon_type` from `or_out_stock` as `or_out_stock` group by `trans_no`")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_order_item", shardcount=4, sql="select `id`, `order_no`, `sub_order_no`, `bag_code`, `product_code`, `product_name`, `one_category_code`, `one_category_name`, `two_category_code`, `two_category_name`, `three_category_code`, `three_category_name`, `product_brand_code`, `product_brand_name`, `product_barcode`, `product_sku`, `product_price`, `product_spec`, `platform_product_sku`, `product_meter_unit`, `platform_product_code`, `platform_product_name`, `platform_product_url`, `buy_number`, `out_stock_number`, `product_weight`, `product_volume`, `discount_amount`, `share_amount`, `payable_amount`, `coupon_duct_amount`, `paid_amount`, `is_split`, `group_product_code`, `group_product_name`, `integral_share`, `is_out_stock`, `is_gift`, `activity_name`, `activity_id`, `platform_commision_point`, `platform_commision`, `distributor_commision`, `salesman_commision`, `return_type`, `factory_cost`, `is_cancel`, `erp_order_item_id`, `create_by`, `create_time`, `last_update_by`, `last_update_time`, `platform_product_index`, `salesman_second_commision` from `or_order_item` as `or_order_item` where (`order_no` in (...))")]> but was:<....order_no;
plan:
[err-code: [pxc-4006][err_table_not_exist] table 'or_order' doesn't exist.]>
Raw output
org.junit.internal.ArrayComparisonFailure:
targetSql =
SELECT
ord.*,
orde.*
FROM
(
SELECT
*
FROM
(
(
SELECT
*
FROM
or_order oro
LEFT JOIN
(
SELECT
COUNT( 1 ) butoon_Type,
TRANS_NO out_trans_no
FROM
OR_OUT_STOCK
GROUP BY
out_trans_no ) oros
ON
oro.TRANS_NO = oros.out_trans_no
WHERE
oro.platform_code IN ( 'ELE',
'MT',
'BD',
'JDDJ' )
AND oro.create_time >= NOW( ) - INTERVAL 24 HOUR )
UNION
(
SELECT
*
FROM
or_order oro
LEFT JOIN
(
SELECT
COUNT( 1 ) butoon_Type,
TRANS_NO out_trans_no
FROM
OR_OUT_STOCK
GROUP BY
out_trans_no ) oros
ON
oro.TRANS_NO = oros.out_trans_no
WHERE
oro.platform_code IN ( 'ELE',
'MT',
'BD',
'JDDJ' )
AND oro.create_time < NOW( ) - INTERVAL 24 HOUR
AND oro.STATUS IN ("101",
"102",
"103",
"106",
"107",
"108",
"401") ) ) orders
ORDER BY
orders.create_time DESC LIMIT 0,5 ) ord,
or_order_item orde
WHERE
ord.order_no = orde.order_no;
realPlanVal =
err-code: [pxc-4006][err_table_not_exist] table 'or_order' doesn't exist.
targetPlanVal =
bkajoin(condition="order_no = order_no", type="inner")
topn(sort="create_time desc", offset=0, fetch=5)
hashagg(group="order_no,trans_no,platform_code,platform_name,shop_code,shop_name,allot_shop_code,allot_shop_name,channel_type,type,business_type,business_date,create_type,is_copy,order_time,expect_arrival_time,status,trans_status,package_fee,package_number,platform_user_id,is_fetch,o2o_dist_mode,consignee_name,consignee_telephone,salesman_mobile,salesman_type,consignee_postcode,consignee_province_code,consignee_province_name,consignee_city_code,consignee_city_name,consignee_area_code,consignee_area_name,consignee_address,express_company,logistics_no,total_amount,adjust_amount,freight_amount,discount_amount,payment_amount,payment_type,used_integral,payment_time,buyer_remark,seller_remark,is_need_invoice,invoice_type,invoice_header,invoice_content,invoice_taxer_id,product_weight,platform_commision,distributor_commision,product_volume,is_retain_order,retain_order_time,is_locked,locker,shop_income,return_flag,group_code,is_group_leader,sourcing_model,create_by,create_time,last_update_by,last_update_time,delivery_status,tip,platform_shop_code,lock_stock_type,receive_model,salesman_commision,reminder_flag,salesman_second_commision,butoon_type,out_trans_no")
unionall(concurrent=true)
hashjoin(condition="trans_no = out_trans_no", type="left")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_order", shardcount=4, sql="select `order_no`, `trans_no`, `platform_code`, `platform_name`, `shop_code`, `shop_name`, `allot_shop_code`, `allot_shop_name`, `channel_type`, `type`, `business_type`, `business_date`, `create_type`, `is_copy`, `order_time`, `expect_arrival_time`, `status`, `trans_status`, `package_fee`, `package_number`, `platform_user_id`, `is_fetch`, `o2o_dist_mode`, `consignee_name`, `consignee_telephone`, `salesman_mobile`, `salesman_type`, `consignee_postcode`, `consignee_province_code`, `consignee_province_name`, `consignee_city_code`, `consignee_city_name`, `consignee_area_code`, `consignee_area_name`, `consignee_address`, `express_company`, `logistics_no`, `total_amount`, `adjust_amount`, `freight_amount`, `discount_amount`, `payment_amount`, `payment_type`, `used_integral`, `payment_time`, `buyer_remark`, `seller_remark`, `is_need_invoice`, `invoice_type`, `invoice_header`, `invoice_content`, `invoice_taxer_id`, `product_weight`, `platform_commision`, `distributor_commision`, `product_volume`, `is_retain_order`, `retain_order_time`, `is_locked`, `locker`, `shop_income`, `return_flag`, `group_code`, `is_group_leader`, `sourcing_model`, `create_by`, `create_time`, `last_update_by`, `last_update_time`, `delivery_status`, `tip`, `platform_shop_code`, `lock_stock_type`, `receive_model`, `salesman_commision`, `reminder_flag`, `salesman_second_commision` from `or_order` as `or_order` where ((`platform_code` in('ele', 'mt', 'bd', 'jddj')) and (`create_time` >= date_sub(now(), interval 24 hour)))")
project(butoon_type="butoon_type", out_trans_no="trans_no")
hashagg(group="trans_no", butoon_type="sum(butoon_type)")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_out_stock", shardcount=4, sql="select `trans_no`, count(*) as `butoon_type` from `or_out_stock` as `or_out_stock` group by `trans_no`")
hashjoin(condition="trans_no = out_trans_no", type="left")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_order", shardcount=4, sql="select `order_no`, `trans_no`, `platform_code`, `platform_name`, `shop_code`, `shop_name`, `allot_shop_code`, `allot_shop_name`, `channel_type`, `type`, `business_type`, `business_date`, `create_type`, `is_copy`, `order_time`, `expect_arrival_time`, `status`, `trans_status`, `package_fee`, `package_number`, `platform_user_id`, `is_fetch`, `o2o_dist_mode`, `consignee_name`, `consignee_telephone`, `salesman_mobile`, `salesman_type`, `consignee_postcode`, `consignee_province_code`, `consignee_province_name`, `consignee_city_code`, `consignee_city_name`, `consignee_area_code`, `consignee_area_name`, `consignee_address`, `express_company`, `logistics_no`, `total_amount`, `adjust_amount`, `freight_amount`, `discount_amount`, `payment_amount`, `payment_type`, `used_integral`, `payment_time`, `buyer_remark`, `seller_remark`, `is_need_invoice`, `invoice_type`, `invoice_header`, `invoice_content`, `invoice_taxer_id`, `product_weight`, `platform_commision`, `distributor_commision`, `product_volume`, `is_retain_order`, `retain_order_time`, `is_locked`, `locker`, `shop_income`, `return_flag`, `group_code`, `is_group_leader`, `sourcing_model`, `create_by`, `create_time`, `last_update_by`, `last_update_time`, `delivery_status`, `tip`, `platform_shop_code`, `lock_stock_type`, `receive_model`, `salesman_commision`, `reminder_flag`, `salesman_second_commision` from `or_order` as `or_order` where ((`platform_code` in('ele', 'mt', 'bd', 'jddj')) and (`status` in('101', '102', '103', '106', '107', '108', '401')) and (`create_time` < date_sub(now(), interval 24 hour)))")
project(butoon_type="butoon_type", out_trans_no="trans_no")
hashagg(group="trans_no", butoon_type="sum(butoon_type)")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_out_stock", shardcount=4, sql="select `trans_no`, count(*) as `butoon_type` from `or_out_stock` as `or_out_stock` group by `trans_no`")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_order_item", shardcount=4, sql="select `id`, `order_no`, `sub_order_no`, `bag_code`, `product_code`, `product_name`, `one_category_code`, `one_category_name`, `two_category_code`, `two_category_name`, `three_category_code`, `three_category_name`, `product_brand_code`, `product_brand_name`, `product_barcode`, `product_sku`, `product_price`, `product_spec`, `platform_product_sku`, `product_meter_unit`, `platform_product_code`, `platform_product_name`, `platform_product_url`, `buy_number`, `out_stock_number`, `product_weight`, `product_volume`, `discount_amount`, `share_amount`, `payable_amount`, `coupon_duct_amount`, `paid_amount`, `is_split`, `group_product_code`, `group_product_name`, `integral_share`, `is_out_stock`, `is_gift`, `activity_name`, `activity_id`, `platform_commision_point`, `platform_commision`, `distributor_commision`, `salesman_commision`, `return_type`, `factory_cost`, `is_cancel`, `erp_order_item_id`, `create_by`, `create_time`, `last_update_by`, `last_update_time`, `platform_product_index`, `salesman_second_commision` from `or_order_item` as `or_order_item` where (`order_no` in (...))")
: arrays first differed at element [0]; expected:<....order_no;
plan:
[bkajoin(condition="order_no = order_no", type="inner")
topn(sort="create_time desc", offset=0, fetch=5)
hashagg(group="order_no,trans_no,platform_code,platform_name,shop_code,shop_name,allot_shop_code,allot_shop_name,channel_type,type,business_type,business_date,create_type,is_copy,order_time,expect_arrival_time,status,trans_status,package_fee,package_number,platform_user_id,is_fetch,o2o_dist_mode,consignee_name,consignee_telephone,salesman_mobile,salesman_type,consignee_postcode,consignee_province_code,consignee_province_name,consignee_city_code,consignee_city_name,consignee_area_code,consignee_area_name,consignee_address,express_company,logistics_no,total_amount,adjust_amount,freight_amount,discount_amount,payment_amount,payment_type,used_integral,payment_time,buyer_remark,seller_remark,is_need_invoice,invoice_type,invoice_header,invoice_content,invoice_taxer_id,product_weight,platform_commision,distributor_commision,product_volume,is_retain_order,retain_order_time,is_locked,locker,shop_income,return_flag,group_code,is_group_leader,sourcing_model,create_by,create_time,last_update_by,last_update_time,delivery_status,tip,platform_shop_code,lock_stock_type,receive_model,salesman_commision,reminder_flag,salesman_second_commision,butoon_type,out_trans_no")
unionall(concurrent=true)
hashjoin(condition="trans_no = out_trans_no", type="left")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_order", shardcount=4, sql="select `order_no`, `trans_no`, `platform_code`, `platform_name`, `shop_code`, `shop_name`, `allot_shop_code`, `allot_shop_name`, `channel_type`, `type`, `business_type`, `business_date`, `create_type`, `is_copy`, `order_time`, `expect_arrival_time`, `status`, `trans_status`, `package_fee`, `package_number`, `platform_user_id`, `is_fetch`, `o2o_dist_mode`, `consignee_name`, `consignee_telephone`, `salesman_mobile`, `salesman_type`, `consignee_postcode`, `consignee_province_code`, `consignee_province_name`, `consignee_city_code`, `consignee_city_name`, `consignee_area_code`, `consignee_area_name`, `consignee_address`, `express_company`, `logistics_no`, `total_amount`, `adjust_amount`, `freight_amount`, `discount_amount`, `payment_amount`, `payment_type`, `used_integral`, `payment_time`, `buyer_remark`, `seller_remark`, `is_need_invoice`, `invoice_type`, `invoice_header`, `invoice_content`, `invoice_taxer_id`, `product_weight`, `platform_commision`, `distributor_commision`, `product_volume`, `is_retain_order`, `retain_order_time`, `is_locked`, `locker`, `shop_income`, `return_flag`, `group_code`, `is_group_leader`, `sourcing_model`, `create_by`, `create_time`, `last_update_by`, `last_update_time`, `delivery_status`, `tip`, `platform_shop_code`, `lock_stock_type`, `receive_model`, `salesman_commision`, `reminder_flag`, `salesman_second_commision` from `or_order` as `or_order` where ((`platform_code` in('ele', 'mt', 'bd', 'jddj')) and (`create_time` >= date_sub(now(), interval 24 hour)))")
project(butoon_type="butoon_type", out_trans_no="trans_no")
hashagg(group="trans_no", butoon_type="sum(butoon_type)")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_out_stock", shardcount=4, sql="select `trans_no`, count(*) as `butoon_type` from `or_out_stock` as `or_out_stock` group by `trans_no`")
hashjoin(condition="trans_no = out_trans_no", type="left")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_order", shardcount=4, sql="select `order_no`, `trans_no`, `platform_code`, `platform_name`, `shop_code`, `shop_name`, `allot_shop_code`, `allot_shop_name`, `channel_type`, `type`, `business_type`, `business_date`, `create_type`, `is_copy`, `order_time`, `expect_arrival_time`, `status`, `trans_status`, `package_fee`, `package_number`, `platform_user_id`, `is_fetch`, `o2o_dist_mode`, `consignee_name`, `consignee_telephone`, `salesman_mobile`, `salesman_type`, `consignee_postcode`, `consignee_province_code`, `consignee_province_name`, `consignee_city_code`, `consignee_city_name`, `consignee_area_code`, `consignee_area_name`, `consignee_address`, `express_company`, `logistics_no`, `total_amount`, `adjust_amount`, `freight_amount`, `discount_amount`, `payment_amount`, `payment_type`, `used_integral`, `payment_time`, `buyer_remark`, `seller_remark`, `is_need_invoice`, `invoice_type`, `invoice_header`, `invoice_content`, `invoice_taxer_id`, `product_weight`, `platform_commision`, `distributor_commision`, `product_volume`, `is_retain_order`, `retain_order_time`, `is_locked`, `locker`, `shop_income`, `return_flag`, `group_code`, `is_group_leader`, `sourcing_model`, `create_by`, `create_time`, `last_update_by`, `last_update_time`, `delivery_status`, `tip`, `platform_shop_code`, `lock_stock_type`, `receive_model`, `salesman_commision`, `reminder_flag`, `salesman_second_commision` from `or_order` as `or_order` where ((`platform_code` in('ele', 'mt', 'bd', 'jddj')) and (`status` in('101', '102', '103', '106', '107', '108', '401')) and (`create_time` < date_sub(now(), interval 24 hour)))")
project(butoon_type="butoon_type", out_trans_no="trans_no")
hashagg(group="trans_no", butoon_type="sum(butoon_type)")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_out_stock", shardcount=4, sql="select `trans_no`, count(*) as `butoon_type` from `or_out_stock` as `or_out_stock` group by `trans_no`")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_order_item", shardcount=4, sql="select `id`, `order_no`, `sub_order_no`, `bag_code`, `product_code`, `product_name`, `one_category_code`, `one_category_name`, `two_category_code`, `two_category_name`, `three_category_code`, `three_category_name`, `product_brand_code`, `product_brand_name`, `product_barcode`, `product_sku`, `product_price`, `product_spec`, `platform_product_sku`, `product_meter_unit`, `platform_product_code`, `platform_product_name`, `platform_product_url`, `buy_number`, `out_stock_number`, `product_weight`, `product_volume`, `discount_amount`, `share_amount`, `payable_amount`, `coupon_duct_amount`, `paid_amount`, `is_split`, `group_product_code`, `group_product_name`, `integral_share`, `is_out_stock`, `is_gift`, `activity_name`, `activity_id`, `platform_commision_point`, `platform_commision`, `distributor_commision`, `salesman_commision`, `return_type`, `factory_cost`, `is_cancel`, `erp_order_item_id`, `create_by`, `create_time`, `last_update_by`, `last_update_time`, `platform_product_index`, `salesman_second_commision` from `or_order_item` as `or_order_item` where (`order_no` in (...))")]> but was:<....order_no;
plan:
[err-code: [pxc-4006][err_table_not_exist] table 'or_order' doesn't exist.]>
Caused by: org.junit.ComparisonFailure:
expected:<....order_no;
plan:
[bkajoin(condition="order_no = order_no", type="inner")
topn(sort="create_time desc", offset=0, fetch=5)
hashagg(group="order_no,trans_no,platform_code,platform_name,shop_code,shop_name,allot_shop_code,allot_shop_name,channel_type,type,business_type,business_date,create_type,is_copy,order_time,expect_arrival_time,status,trans_status,package_fee,package_number,platform_user_id,is_fetch,o2o_dist_mode,consignee_name,consignee_telephone,salesman_mobile,salesman_type,consignee_postcode,consignee_province_code,consignee_province_name,consignee_city_code,consignee_city_name,consignee_area_code,consignee_area_name,consignee_address,express_company,logistics_no,total_amount,adjust_amount,freight_amount,discount_amount,payment_amount,payment_type,used_integral,payment_time,buyer_remark,seller_remark,is_need_invoice,invoice_type,invoice_header,invoice_content,invoice_taxer_id,product_weight,platform_commision,distributor_commision,product_volume,is_retain_order,retain_order_time,is_locked,locker,shop_income,return_flag,group_code,is_group_leader,sourcing_model,create_by,create_time,last_update_by,last_update_time,delivery_status,tip,platform_shop_code,lock_stock_type,receive_model,salesman_commision,reminder_flag,salesman_second_commision,butoon_type,out_trans_no")
unionall(concurrent=true)
hashjoin(condition="trans_no = out_trans_no", type="left")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_order", shardcount=4, sql="select `order_no`, `trans_no`, `platform_code`, `platform_name`, `shop_code`, `shop_name`, `allot_shop_code`, `allot_shop_name`, `channel_type`, `type`, `business_type`, `business_date`, `create_type`, `is_copy`, `order_time`, `expect_arrival_time`, `status`, `trans_status`, `package_fee`, `package_number`, `platform_user_id`, `is_fetch`, `o2o_dist_mode`, `consignee_name`, `consignee_telephone`, `salesman_mobile`, `salesman_type`, `consignee_postcode`, `consignee_province_code`, `consignee_province_name`, `consignee_city_code`, `consignee_city_name`, `consignee_area_code`, `consignee_area_name`, `consignee_address`, `express_company`, `logistics_no`, `total_amount`, `adjust_amount`, `freight_amount`, `discount_amount`, `payment_amount`, `payment_type`, `used_integral`, `payment_time`, `buyer_remark`, `seller_remark`, `is_need_invoice`, `invoice_type`, `invoice_header`, `invoice_content`, `invoice_taxer_id`, `product_weight`, `platform_commision`, `distributor_commision`, `product_volume`, `is_retain_order`, `retain_order_time`, `is_locked`, `locker`, `shop_income`, `return_flag`, `group_code`, `is_group_leader`, `sourcing_model`, `create_by`, `create_time`, `last_update_by`, `last_update_time`, `delivery_status`, `tip`, `platform_shop_code`, `lock_stock_type`, `receive_model`, `salesman_commision`, `reminder_flag`, `salesman_second_commision` from `or_order` as `or_order` where ((`platform_code` in('ele', 'mt', 'bd', 'jddj')) and (`create_time` >= date_sub(now(), interval 24 hour)))")
project(butoon_type="butoon_type", out_trans_no="trans_no")
hashagg(group="trans_no", butoon_type="sum(butoon_type)")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_out_stock", shardcount=4, sql="select `trans_no`, count(*) as `butoon_type` from `or_out_stock` as `or_out_stock` group by `trans_no`")
hashjoin(condition="trans_no = out_trans_no", type="left")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_order", shardcount=4, sql="select `order_no`, `trans_no`, `platform_code`, `platform_name`, `shop_code`, `shop_name`, `allot_shop_code`, `allot_shop_name`, `channel_type`, `type`, `business_type`, `business_date`, `create_type`, `is_copy`, `order_time`, `expect_arrival_time`, `status`, `trans_status`, `package_fee`, `package_number`, `platform_user_id`, `is_fetch`, `o2o_dist_mode`, `consignee_name`, `consignee_telephone`, `salesman_mobile`, `salesman_type`, `consignee_postcode`, `consignee_province_code`, `consignee_province_name`, `consignee_city_code`, `consignee_city_name`, `consignee_area_code`, `consignee_area_name`, `consignee_address`, `express_company`, `logistics_no`, `total_amount`, `adjust_amount`, `freight_amount`, `discount_amount`, `payment_amount`, `payment_type`, `used_integral`, `payment_time`, `buyer_remark`, `seller_remark`, `is_need_invoice`, `invoice_type`, `invoice_header`, `invoice_content`, `invoice_taxer_id`, `product_weight`, `platform_commision`, `distributor_commision`, `product_volume`, `is_retain_order`, `retain_order_time`, `is_locked`, `locker`, `shop_income`, `return_flag`, `group_code`, `is_group_leader`, `sourcing_model`, `create_by`, `create_time`, `last_update_by`, `last_update_time`, `delivery_status`, `tip`, `platform_shop_code`, `lock_stock_type`, `receive_model`, `salesman_commision`, `reminder_flag`, `salesman_second_commision` from `or_order` as `or_order` where ((`platform_code` in('ele', 'mt', 'bd', 'jddj')) and (`status` in('101', '102', '103', '106', '107', '108', '401')) and (`create_time` < date_sub(now(), interval 24 hour)))")
project(butoon_type="butoon_type", out_trans_no="trans_no")
hashagg(group="trans_no", butoon_type="sum(butoon_type)")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_out_stock", shardcount=4, sql="select `trans_no`, count(*) as `butoon_type` from `or_out_stock` as `or_out_stock` group by `trans_no`")
gather(concurrent=true)
logicalview(tables="[0000-0003].or_order_item", shardcount=4, sql="select `id`, `order_no`, `sub_order_no`, `bag_code`, `product_code`, `product_name`, `one_category_code`, `one_category_name`, `two_category_code`, `two_category_name`, `three_category_code`, `three_category_name`, `product_brand_code`, `product_brand_name`, `product_barcode`, `product_sku`, `product_price`, `product_spec`, `platform_product_sku`, `product_meter_unit`, `platform_product_code`, `platform_product_name`, `platform_product_url`, `buy_number`, `out_stock_number`, `product_weight`, `product_volume`, `discount_amount`, `share_amount`, `payable_amount`, `coupon_duct_amount`, `paid_amount`, `is_split`, `group_product_code`, `group_product_name`, `integral_share`, `is_out_stock`, `is_gift`, `activity_name`, `activity_id`, `platform_commision_point`, `platform_commision`, `distributor_commision`, `salesman_commision`, `return_type`, `factory_cost`, `is_cancel`, `erp_order_item_id`, `create_by`, `create_time`, `last_update_by`, `last_update_time`, `platform_product_index`, `salesman_second_commision` from `or_order_item` as `or_order_item` where (`order_no` in (...))")]> but was:<....order_no;
plan:
[err-code: [pxc-4006][err_table_not_exist] table 'or_order' doesn't exist.]>