[incubator-pinot] 01/01: Fixing backward-compatible issue of schema fetch call

[xiangfu]

This is an automated email from the ASF dual-hosted git repository.

xiangfu pushed a commit to branch 
fixing_backward_compatible_offline_table_schema
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git

commit 0c3234f7b6afbc8a1550dcb696c290c6877758da
Author: Xiang Fu <fx19880...@gmail.com>
AuthorDate: Mon Aug 17 15:41:37 2020 -0700

    Fixing backward-compatible issue of schema fetch call
---
 .../java/org/apache/pinot/common/metadata/ZKMetadataProvider.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/pinot-common/src/main/java/org/apache/pinot/common/metadata/ZKMetadataProvider.java
 
b/pinot-common/src/main/java/org/apache/pinot/common/metadata/ZKMetadataProvider.java
index b3f007a..c40ce8b 100644
--- 
a/pinot-common/src/main/java/org/apache/pinot/common/metadata/ZKMetadataProvider.java
+++ 
b/pinot-common/src/main/java/org/apache/pinot/common/metadata/ZKMetadataProvider.java
@@ -279,7 +279,10 @@ public class ZKMetadataProvider {
     }
     // Try to fetch offline schema if realtime schema does not exist
     if (schema == null && (tableType == null || tableType == 
TableType.OFFLINE)) {
-      schema = getSchema(propertyStore, 
TableNameBuilder.OFFLINE.tableNameWithType(tableName));
+      TableConfig offlineTableConfig = getOfflineTableConfig(propertyStore, 
tableName);
+      if (offlineTableConfig != null) {
+        schema = getSchema(propertyStore, 
offlineTableConfig.getValidationConfig().getSchemaName());
+      }
     }
     if (schema != null) {
       LOGGER.warn("Schema name does not match raw table name, schema name: {}, 
raw table name: {}",


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org