This is an automated email from the ASF dual-hosted git repository.
jihoonson pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git
The following commit(s) were added to refs/heads/master by this push:
new f410c28 Always convert start metadata to start (#7332)
f410c28 is described below
commit f410c28af68f258bac9d7fd33899a21e7ddf4605
Author: Jihoon Son <[email protected]>
AuthorDate: Fri Mar 22 21:12:15 2019 -0700
Always convert start metadata to start (#7332)
---
.../org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java
b/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java
index 16f320e..51e33db 100644
---
a/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java
+++
b/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java
@@ -886,7 +886,7 @@ public class IndexerSQLMetadataStorageCoordinator
implements IndexerMetadataStor
// Even though kafka/kinesis indexing services use different
sequenceNumber types for representing
// start and end sequenceNumbers, the below conversion is fine because
the new start sequenceNumbers are supposed
// to be same with end sequenceNumbers of the last commit.
- startMetadataMatchesExisting =
startMetadata.matches(oldCommitMetadataFromDb.asStartMetadata());
+ startMetadataMatchesExisting =
startMetadata.asStartMetadata().matches(oldCommitMetadataFromDb.asStartMetadata());
}
if (!startMetadataMatchesExisting) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
