Re: Test conflicts in JoinTest

2017-12-08 Thread Xingcan Cui
Hi, Finally, the cause is revealed. There's a global (concurrentMap formed) cache in org.apache.calcite.rel.type.RelDataTypeFactoryImpl. The locally used *RelDataType*s will be cached as both the keys and values. For the following two *RelDataType*s, 1. RecordType(BIGINT d, INTEGER e, VARCHAR(655

Test conflicts in JoinTest

2017-12-08 Thread Xingcan Cui
Hi all, Recently I'm trying to add some tests to *org.apache.flink.table.api.stream.table.JoinTest*, but encountered a strange problem. A test case could successfully run in an isolated mode, but failed (threw an *CannotPlanException* in *TableEnvironment.runVolcanoPlanner()*) when ran with anoth