- 30 1月, 2021 1 次提交
-
-
由 Gian Merlino 提交于
* Vectorized theta sketch aggregator. Also a refactoring of BufferAggregator and VectorAggregator such that they share a common interface, BaseBufferAggregator. This allows implementing both in the same file with an abstract + dual subclass structure. * Rework implementation to use composition instead of inheritance. * Rework things to enable working properly for both complex types and regular types. Involved finally moving makeVectorProcessor from DimensionHandlerUtils into ColumnProcessors and harmonizing the two things. * Add missing method. * Style and name changes. * Fix issues from inspections. * Fix style issue.
-
- 29 1月, 2021 5 次提交
-
-
由 Agustin Gonzalez 提交于
* Prevent interval materialization for UniformGranularitySpec inside the overlord * Change API of bucketIntervals in GranularitySpec to return an Iterable<Interval> * Javadoc update, respect inputIntervals contract * Eliminate dependency on wrappedspec (i.e. ArbitraryGranularity) in UniformGranularitySpec * Added one boundary condition test to UniformGranularityTest and fixed Travis forbidden method errors in IntervalsByGranularity * Fix Travis style & other checks * Refactor TreeSet to facilitate re-use in UniformGranularitySpec * Make sure intervals are unique when there is no segment granularity * Style/bugspot fixes... * More travis checks * Add condensedIntervals method to GranularitySpec and pass it as needed to the lock method * Style & PR feedback * Fixed failing test * Fixed bug in IntervalsByGranularity iterator that it would return repeated elements (see added unit tests that were broken before this change) * Refactor so that we can get the condensed buckets without materializing the intervals * Get rid of GranularitySpec::condensedInputIntervals ... not needed * Travis failures fixes * Travis checkstyle fix * Edited/added javadoc comments and a method name (code review feedback) * Fixed jacoco coverage by moving class and adding more coverage * Avoid materializing the condensed intervals when locking * Deal with overlapping intervals * Remove code and use library code instead * Refactor intervals by granularity using the FluentIterable, add sanity checks * Change !hasNext() to inputIntervals().isEmpty() * Remove redundant lambda * Use materialized intervals here since this is outside the overlord (for performance) * Name refactor to reflect the fact that bucket intervals are sorted. * Style fixes * Removed redundant method and have condensedIntervalIterator throw IAE when element is null for consistency with other methods in this class (as well that null interval when condensing does not make sense) * Remove forbidden api * Move helper class inside common base class to reduce public space pollution
-
由 Suneet Saldanha 提交于
-
由 Abhishek Agarwal 提交于
* Fix cardinality estimation * Add unit test * code coverage * fix typo
-
由 Vadim Ogievetsky 提交于
* Remove first / last suggestions * remove commened out code
-
由 Clint Wylie 提交于
* expressions: adding bitwise expressions * double handling and vectorization * move conversion to Evals * revert unintended changes * less magic, split convert functions, fix parser for funny exponent doubles * fix spelling exceptions list * more spelling * fix grammar, add more test, fix docs * fix docs Co-authored-by: NMax Kaplan <max@maxkaplan.me>
-
- 27 1月, 2021 3 次提交
-
-
由 Maytas Monsereenusorn 提交于
Fix byte calculation for maxBytesInMemory to take into account of Sink/Hydrant Object overhead (#10740) * Fix byte calculation for maxBytesInMemory to take into account of Sink/Hydrant Object overhead * Fix byte calculation for maxBytesInMemory to take into account of Sink/Hydrant Object overhead * Fix byte calculation for maxBytesInMemory to take into account of Sink/Hydrant Object overhead * Fix byte calculation for maxBytesInMemory to take into account of Sink/Hydrant Object overhead * fix checkstyle * Fix byte calculation for maxBytesInMemory to take into account of Sink/Hydrant Object overhead * Fix byte calculation for maxBytesInMemory to take into account of Sink/Hydrant Object overhead * fix test * fix test * add log * Fix byte calculation for maxBytesInMemory to take into account of Sink/Hydrant Object overhead * address comments * fix checkstyle * fix checkstyle * add config to skip overhead memory calculation * add test for the skipBytesInMemoryOverheadCheck config * add docs * fix checkstyle * fix checkstyle * fix spelling * address comments * fix travis * address comments
-
由 Suneet Saldanha 提交于
* Run integration tests in a second stage * maybe run the integration tests * better * drop sudo
-
由 Suneet Saldanha 提交于
* Bump http-proxy from 1.18.0 to 1.18.1 in /web-console (#7) Bumps [http-proxy](https://github.com/http-party/node-http-proxy) from 1.18.0 to 1.18.1. - [Release notes](https://github.com/http-party/node-http-proxy/releases) - [Changelog](https://github.com/http-party/node-http-proxy/blob/master/CHANGELOG.md) - [Commits](https://github.com/http-party/node-http-proxy/compare/1.18.0...1.18.1) Signed-off-by: Ndependabot[bot] <support@github.com> Co-authored-by: Ndependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * Bump elliptic from 6.5.1 to 6.5.3 in /web-console (#6) Bumps [elliptic](https://github.com/indutny/elliptic) from 6.5.1 to 6.5.3. - [Release notes](https://github.com/indutny/elliptic/releases) - [Commits](https://github.com/indutny/elliptic/compare/v6.5.1...v6.5.3) Signed-off-by: Ndependabot[bot] <support@github.com> Co-authored-by: Ndependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * Bump dot-prop from 4.2.0 to 4.2.1 in /web-console (#5) Bumps [dot-prop](https://github.com/sindresorhus/dot-prop) from 4.2.0 to 4.2.1. - [Release notes](https://github.com/sindresorhus/dot-prop/releases) - [Commits](https://github.com/sindresorhus/dot-prop/compare/v4.2.0...v4.2.1) Signed-off-by: Ndependabot[bot] <support@github.com> Co-authored-by: Ndependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * Bump bl from 1.2.2 to 1.2.3 in /website (#4) Bumps [bl](https://github.com/rvagg/bl) from 1.2.2 to 1.2.3. - [Release notes](https://github.com/rvagg/bl/releases) - [Commits](https://github.com/rvagg/bl/compare/v1.2.2...v1.2.3) Signed-off-by: Ndependabot[bot] <support@github.com> Co-authored-by: Ndependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * Bump prismjs from 1.20.0 to 1.23.0 in /website (#3) Bumps [prismjs](https://github.com/PrismJS/prism) from 1.20.0 to 1.23.0. - [Release notes](https://github.com/PrismJS/prism/releases) - [Changelog](https://github.com/PrismJS/prism/blob/master/CHANGELOG.md) - [Commits](https://github.com/PrismJS/prism/compare/v1.20.0...v1.23.0) Signed-off-by: Ndependabot[bot] <support@github.com> Co-authored-by: Ndependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Ndependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
-
- 25 1月, 2021 2 次提交
-
-
由 Himadri Singh 提交于
* AWS Web Identity Support required for AWS IRSA * Update kinesis-ingestion.md * disabling coverage tests https://github.com/apache/druid/pull/10541#issuecomment-737558213 * exclude coverage * Update licenses.yaml
-
由 Vadim Ogievetsky 提交于
-
- 23 1月, 2021 4 次提交
-
-
由 Charles Smith 提交于
-
由 Clint Wylie 提交于
-
由 zhangyue19921010 提交于
Co-authored-by: Nyuezhang <yuezhang@freewheel.tv>
-
由 zhangyue19921010 提交于
[Bug Fix] Broker will not wait for its SQL metadata view to fully initialize before starting up, even though set awaitInitializationOnStart true (#10779) * enhance the logic of Start up DruidSchema immediately if there are no segments. * add UT to test DruidSchema init Co-authored-by: Nyuezhang <yuezhang@freewheel.tv>
-
- 21 1月, 2021 1 次提交
-
-
由 Gian Merlino 提交于
* Retain order of AND, OR filter children. If we retain the order, it enables short-circuiting. People can put a more selective filter earlier in the list and lower the chance that later filters will need to be evaluated. Short-circuiting was working before #9608, which switched to unordered sets to solve a different problem. This patch tries to solve that problem a different way. This patch moves filter simplification logic from "optimize" to "toFilter", because that allows the code to be shared with Filters.and and Filters.or. The simplification has become more complicated and so it's useful to share it. This patch also removes code from CalciteCnfHelper that is no longer necessary because Filters.and and Filters.or are now doing the work. * Fixes for inspections. * Fix tests. * Back to a Set.
-
- 17 1月, 2021 2 次提交
-
-
由 zhangyue19921010 提交于
* ready to test * tested on dev cluster * tested * code review * add UTs * add UTs * ut passed * ut passed * opti imports * done * done * fix checkstyle * modify uts * modify logs * changing the package of SegmentLazyLoadFailCallback.java to org.apache.druid.segment * merge from master * modify import orders * merge from master * merge from master * modify logs * modify docs * modify logs to rerun ci * modify logs to rerun ci * modify logs to rerun ci * modify logs to rerun ci * modify logs to rerun ci * modify logs to rerun ci * modify logs to rerun ci * modify logs to rerun ci Co-authored-by: Nyuezhang <yuezhang@freewheel.tv>
-
由 Gian Merlino 提交于
-
- 16 1月, 2021 2 次提交
-
-
由 Jihoon Son 提交于
-
由 Xavier Léauté 提交于
except success and failure stats, task count metrics should all be gauges, since they represent the current state and not some aggregate counter over time.
-
- 15 1月, 2021 4 次提交
-
-
由 Gian Merlino 提交于
* OrFilter: Properly handle child matchers that return the original mask. This happens when a child matcher is literally true (for example, BooleanVectorValueMatcher). In this case, OrFilter would throw this exception from its call to removeAll while processing the next filter: java.lang.IllegalStateException: 'other' must be a different instance from 'this' Also update the javadocs for VectorValueMatcher to call out that the returned object may be the same as the input mask. * Fix style.
-
由 Gian Merlino 提交于
No existing code relies on being able to call these methods in this way. The new tests exhaustively test all vectors up to size 7, and also test behavior the run-on-self behavior that has been adjusted by this patch.
-
由 Gian Merlino 提交于
-
由 Vadim Ogievetsky 提交于
-
- 14 1月, 2021 5 次提交
-
-
由 kaijianding 提交于
* use actual dataInterval in cache key * fix ut fail * fix segmentMaxTime exclusive
-
由 Jihoon Son 提交于
* Add a config for monitorScheduler type * check interrupted * null check * do not schedule monitor if the previous one is still running * checkstyle * clean up names * change default back to basic * fix test
-
由 Jihoon Son 提交于
* Tidy up query error codes * fix tests * Restore query exception type in JsonParserIterator * address review comments; add a comment explaining the ugly switch * fix test
-
由 Clint Wylie 提交于
* i put my thing down, flip it and reverse it * oops
-
由 Clint Wylie 提交于
re-use expression vector evaluation results for the same offset in expression vector selectors (#10614) * cache expression selector results by associating vector expression bindings to underlying vector offset * better coverage, fix floats * style * stupid bot * stupid me * more test * intellij threw me under the bus when it generated those junit methods * narrow interface instead of passing around offset
-
- 13 1月, 2021 3 次提交
-
-
由 Vadim Ogievetsky 提交于
* fix bigint when it does not exist * add test
-
由 Lucas Capistrant 提交于
* allow the LogUsedSegments duty to be skippped * Fixes for TravisCI coverage checks and documentation spell checking * prameterize DruidCoordinatorTest in order to achieve coverage * update config name to remove duty ref and improve documentation * refine documentation for new config with reviewer advice * add default column to docs for new config * remove legacy code in LogUsedSegments and remove config to disbale duty * fix makeHistoricalMangementDuties now that the returned list is always the same
-
由 Jihoon Son 提交于
* Fix potential deadlock in batch ingestion * fix checkstyle and comment * this is better
-
- 12 1月, 2021 1 次提交
-
-
由 Jihoon Son 提交于
* Add missing unit tests for segment loading in historicals * unused import
-
- 11 1月, 2021 1 次提交
-
-
由 Lucas Capistrant 提交于
* Coordinator Dynamic Config changes to ease upgrading with new config value * change a log to debug level following review * changes based on review feedback * fix checkstyle
-
- 09 1月, 2021 6 次提交
-
-
由 Xavier Léauté 提交于
Today Kafka message support in streaming indexing tasks is limited to message values, and does not provide a way to expose Kafka headers, timestamps, or keys, which may be of interest to more specialized Druid input formats. For instance, Kafka headers may be used to indicate payload format/encoding or additional metadata, and timestamps are often omitted from values in Kafka streams applications, since they are included in the record. This change proposes to introduce KafkaRecordEntity as InputEntity, which would give input formats full access to the underlying Kafka record, including headers, key, timestamps. It would also open access to low-level information such as topic, partition, offset if needed. KafkaEntity is a subclass of ByteEntity for backwards compatibility with existing input formats, and to avoid introducing unnecessary complexity for Kinesis indexing tasks.
-
由 zhangyue19921010 提交于
* done * done * done Co-authored-by: Nyuezhang <yuezhang@freewheel.tv>
-
由 zhangyue19921010 提交于
Co-authored-by: Nyuezhang <yuezhang@freewheel.tv>
-
由 bananaaggle 提交于
* fix web-console show json bug * replace all JSON.stringify Co-authored-by: Nyuanyi <yuanyi@freewheel.tv>
-
由 秦臻 提交于
* javascript filter result convert to java boolean * use type convert replace script convert, and add more unit test Co-authored-by: Nqinzhen <qinzhen@kuaishou.com>
-
由 Abhishek Agarwal 提交于
-