jffwang
/
hetu-core
0
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

!651 openLooKeng-1.1.0 is upward Incompatible when runing a cross region query 

Merge pull request !651 from luren/cross-region-compatible
This commit is contained in:
i-robot 2021-03-05 14:09:07 +08:00 committed by Gitee
parent dfe46c1ee2 f997460374
commit ef17b839ee
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hetu-datacenter/src/main/java/io/hetu/core/plugin/datacenter/pagesource/DataCenterPageSourceProvider.java
View File

@ -50,7 +50,6 @@ public class DataCenterPageSourceProvider
{
private static final int STRING_CAPACITY = 16;
private static final String ENABLE_CROSS_REGION_DYNAMIC_FILTER = "cross_region_dynamic_filter_enabled";
private static final String OPTIMIZE_DYNAMIC_FILTER_GENERATION = "optimize_dynamic_filter_generation";
private static final String EXCHANGE_COMPRESSION = "exchange_compression";
private final DataCenterConfig config;
@ -129,9 +128,8 @@ public class DataCenterPageSourceProvider
Map<String, String> properties = new HashMap<>();
// Only set the session if there is any dynamic filter for this page source
if (dynamicFilterSupplier != null) {
if (dynamicFilterSupplier != null && dynamicFilterSupplier.isPresent()) {
properties.put(ENABLE_CROSS_REGION_DYNAMIC_FILTER, "true");
properties.put(OPTIMIZE_DYNAMIC_FILTER_GENERATION, "false"); // close removeUnsupportedDynamicFilter optimizer
}
if (config.isCompressionEnabled()) {
properties.put(EXCHANGE_COMPRESSION, "true");