PipelineX 引擎,多BE节点环境下,由于fragment内部 local exchange的拆分,local shuffle 数据分发出现错乱,导致SQL结果错误。

Viewed 29
CREATE TABLE test1
   ( id VARCHAR(20), 
    c1 int
   )
ENGINE=OLAP
DUPLICATE KEY( id )
COMMENT "OLAP" 
DISTRIBUTED BY HASH( id ) BUCKETS  auto
PROPERTIES (
    "replication_num" = "1" 
);

insert into test1 values ('a',1);

SELECT c1 FROM test1 GROUP BY c1 HAVING  EXISTS(SELECT 1)   
INTERSECT  
SELECT c1 FROM test1;
1 Answers

错误的结果显示是啥呀?