This is an automated email from the ASF dual-hosted git repository.
gian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new 9f8982a9a6 fix(druid-indexing): failed to get shardSpec for interval
issue (#12573)
9f8982a9a6 is described below
commit 9f8982a9a6b6d1b49ce00d9930b730f40c14260c
Author: Herb Brewer <[email protected]>
AuthorDate: Sat Aug 6 08:57:36 2022 +0800
fix(druid-indexing): failed to get shardSpec for interval issue (#12573)
---
.../org/apache/druid/indexing/common/task/InputSourceProcessor.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/indexing-service/src/main/java/org/apache/druid/indexing/common/task/InputSourceProcessor.java
b/indexing-service/src/main/java/org/apache/druid/indexing/common/task/InputSourceProcessor.java
index 63ebba8daf..e91f5d5fb0 100644
---
a/indexing-service/src/main/java/org/apache/druid/indexing/common/task/InputSourceProcessor.java
+++
b/indexing-service/src/main/java/org/apache/druid/indexing/common/task/InputSourceProcessor.java
@@ -39,6 +39,7 @@ import
org.apache.druid.segment.realtime.appenderator.AppenderatorDriverAddResul
import org.apache.druid.segment.realtime.appenderator.BatchAppenderatorDriver;
import
org.apache.druid.segment.realtime.appenderator.SegmentsAndCommitMetadata;
import org.joda.time.Interval;
+import org.joda.time.chrono.ISOChronology;
import javax.annotation.Nullable;
import java.io.File;
@@ -101,7 +102,7 @@ public class InputSourceProcessor
// IndexTaskInputRowIteratorBuilder.absentBucketIntervalConsumer()
ensures the interval will be present here
Optional<Interval> optInterval =
granularitySpec.bucketInterval(inputRow.getTimestamp());
@SuppressWarnings("OptionalGetWithoutIsPresent")
- final Interval interval = optInterval.get();
+ final Interval interval =
optInterval.get().withChronology(ISOChronology.getInstanceUTC());
final String sequenceName =
sequenceNameFunction.getSequenceName(interval, inputRow);
final AppenderatorDriverAddResult addResult = driver.add(inputRow,
sequenceName);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
