You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by xi...@apache.org on 2020/08/17 22:41:57 UTC
[incubator-pinot] branch
fixing_backward_compatible_offline_table_schema created (now 0c3234f)
This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a change to branch fixing_backward_compatible_offline_table_schema
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
at 0c3234f Fixing backward-compatible issue of schema fetch call
This branch includes the following new commits:
new 0c3234f Fixing backward-compatible issue of schema fetch call
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org
[incubator-pinot] 01/01: Fixing backward-compatible issue of schema
fetch call
Posted by xi...@apache.org.
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 <fx...@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-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org