diff --git a/server/src/main/java/org/apache/druid/metadata/SQLMetadataConnector.java b/server/src/main/java/org/apache/druid/metadata/SQLMetadataConnector.java index 688409e3cf9b..86c4fb44b7c2 100644 --- a/server/src/main/java/org/apache/druid/metadata/SQLMetadataConnector.java +++ b/server/src/main/java/org/apache/druid/metadata/SQLMetadataConnector.java @@ -217,9 +217,13 @@ public void createPendingSegmentsTable(final String tableName) tableName, getPayloadType(), getQuoteString() ), StringUtils.format( - "CREATE INDEX idx_%1$s_datasource_used_end ON %1$s(dataSource, used, %2$send%2$s)", + "CREATE INDEX idx_%1$s_datasource_end ON %1$s(dataSource, %2$send%2$s)", tableName, getQuoteString() + ), + StringUtils.format( + "CREATE INDEX idx_%1$s_datasource_sequence ON %1$s(dataSource, sequence_name)", + tableName ) ) ); @@ -264,14 +268,11 @@ public void createSegmentTable(final String tableName) + ")", tableName, getPayloadType(), getQuoteString() ), + StringUtils.format("CREATE INDEX idx_%1$s_used ON %1$s(used)", tableName), StringUtils.format( - "CREATE INDEX idx_%1$s_datasource_end ON %1$s(dataSource, %2$send%2$s)", + "CREATE INDEX idx_%1$s_datasource_used_end ON %1$s(dataSource, used, %2$send%2$s)", tableName, getQuoteString() - ), - StringUtils.format( - "CREATE INDEX idx_%1$s_datasource_sequence ON %1$s(dataSource, sequence_name)", - tableName ) ) );