You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by jo...@apache.org on 2019/03/27 01:28:54 UTC
[incubator-druid] branch 0.14.0-incubating updated: Always convert
start metadata to start (#7332) (#7346)
This is an automated email from the ASF dual-hosted git repository.
jonwei pushed a commit to branch 0.14.0-incubating
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git
The following commit(s) were added to refs/heads/0.14.0-incubating by this push:
new 4e31dcb Always convert start metadata to start (#7332) (#7346)
4e31dcb is described below
commit 4e31dcb8c04fab53ff99cc57e5adb291cf1083e0
Author: Jonathan Wei <jo...@users.noreply.github.com>
AuthorDate: Tue Mar 26 18:28:48 2019 -0700
Always convert start metadata to start (#7332) (#7346)
---
.../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 22f602a..fa0df2d 100644
--- a/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java
+++ b/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java
@@ -887,7 +887,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: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org