This is an automated email from the ASF dual-hosted git repository.
karan pushed a change to branch 26.0.0
in repository https://gitbox.apache.org/repos/asf/druid.git
from 0753a23848 Fix race condition in KubernetesTaskRunner between shutdown
and getKnownTasks (#14030) (#14057)
add c4ba97d27e Fixing overlord unable to become a leader when syncing the
lock from metadata store. (#14038)
add 5b85ff7e28 Frames: Ensure nulls are read as default values when
appropriate. (#14020)
add 408d23526f MSQ: Support multiple result columns with the same name.
(#14025)
add 0812606703 msq: add durable storage info (#14035)
new 1b0c17c43a Adding missed s3 retry handling in storage connector.
(#14086)
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/multi-stage-query/reference.md | 48 +++++++-
docs/multi-stage-query/security.md | 15 +++
.../org/apache/druid/msq/exec/ControllerImpl.java | 100 +++++++++------
.../apache/druid/msq/indexing/ColumnMappings.java | 137 +++++++++++++++------
.../msq/indexing/report/MSQResultsReport.java | 69 ++++++++++-
.../apache/druid/msq/sql/MSQTaskQueryMaker.java | 3 -
.../org/apache/druid/msq/sql/MSQTaskSqlEngine.java | 7 +-
.../org/apache/druid/msq/exec/MSQFaultsTest.java | 56 +++++++--
.../org/apache/druid/msq/exec/MSQInsertTest.java | 24 ++++
.../org/apache/druid/msq/exec/MSQSelectTest.java | 68 ++++++++++
.../msq/indexing/report/MSQTaskReportTest.java | 3 +-
.../common/SortMergeJoinFrameProcessorTest.java | 74 +++++------
.../druid/msq/test/ExtractResultsFactory.java | 9 +-
.../org/apache/druid/msq/test/MSQTestBase.java | 59 +++++----
.../storage/s3/output/RetryableS3OutputStream.java | 12 +-
.../druid/indexing/overlord/TaskLockbox.java | 8 +-
.../druid/indexing/overlord/TaskLockboxTest.java | 6 +-
.../druid/testing/utils/MsqTestQueryHelper.java | 5 +-
.../data/input/impl/CombiningInputSource.java | 2 +-
.../druid/frame/field/DoubleFieldReader.java | 3 +-
.../apache/druid/frame/field/FloatFieldReader.java | 3 +-
.../apache/druid/frame/field/LongFieldReader.java | 5 +-
.../apache/druid/frame/field/LongFieldWriter.java | 23 +++-
.../druid/frame/field/StringFieldReader.java | 14 ++-
.../read/columnar/DoubleFrameColumnReader.java | 2 +-
.../read/columnar/FloatFrameColumnReader.java | 2 +-
.../frame/read/columnar/LongFrameColumnReader.java | 2 +-
.../org/apache/druid/utils/CollectionUtils.java | 23 ++++
.../apache/druid/frame/write/FrameWriterTest.java | 34 +++++
.../apache/druid/utils/CollectionUtilsTest.java | 64 +++++++---
.../apache/druid/sql/calcite/CalciteQueryTest.java | 4 +
31 files changed, 672 insertions(+), 212 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
