This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
The following commit(s) were added to refs/heads/master by this push:
new cd823b7 Refresh schema when reloading segments (#4335)
cd823b7 is described below
commit cd823b7afaef175aeb2b95814710d196fbc283c8
Author: haibow <[email protected]>
AuthorDate: Wed Jun 19 18:43:34 2019 -0700
Refresh schema when reloading segments (#4335)
refresh schema when reloading segments
---
.../apache/pinot/server/starter/helix/HelixInstanceDataManager.java | 6 +-----
1 file changed, 1 insertion(+), 5 deletions(-)
diff --git
a/pinot-server/src/main/java/org/apache/pinot/server/starter/helix/HelixInstanceDataManager.java
b/pinot-server/src/main/java/org/apache/pinot/server/starter/helix/HelixInstanceDataManager.java
index d12645d..62b70fd 100644
---
a/pinot-server/src/main/java/org/apache/pinot/server/starter/helix/HelixInstanceDataManager.java
+++
b/pinot-server/src/main/java/org/apache/pinot/server/starter/helix/HelixInstanceDataManager.java
@@ -179,11 +179,7 @@ public class HelixInstanceDataManager implements
InstanceDataManager {
TableConfig tableConfig =
ZKMetadataProvider.getTableConfig(_propertyStore, tableNameWithType);
Preconditions.checkNotNull(tableConfig);
- Schema schema = null;
- // For OFFLINE table, try to get schema for default columns
- if (TableNameBuilder.OFFLINE.tableHasTypeSuffix(tableNameWithType)) {
- schema = ZKMetadataProvider.getTableSchema(_propertyStore,
tableNameWithType);
- }
+ Schema schema = ZKMetadataProvider.getTableSchema(_propertyStore,
tableNameWithType);
reloadSegment(tableNameWithType, segmentMetadata, tableConfig, schema);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
