Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
81 commits
Select commit Hold shift + click to select a range
58a35bf
Deprecate EntryExistsException in Druid 27 and remove in Druid 28 (#1…
kfaraz Jul 8, 2023
c3f84f9
Suppress CVEs (#14291)
tejaswini-imply Jul 10, 2023
66cac08
Refactor HllSketchBuildAggregatorFactory (#14544)
imply-cheddar Jul 10, 2023
30a91be
Add log statements for tmpStorageBytes in MSQ (#14449)
adarshsanjeev Jul 11, 2023
8087aa2
Adding the null check in combine and fold in doublesSketch (#14568)
pranavbhole Jul 11, 2023
5ce5363
Fix planning bug while using sort merge frame processor (#14450)
LakshSingla Jul 11, 2023
c91148c
Bump tough-cookie from 4.0.0 to 4.1.3 in /web-console (#14557)
dependabot[bot] Jul 11, 2023
a764ed7
Update Jupyter notebook tutorial instructions for ARM devices (#14459)
demo-kratia Jul 11, 2023
0ca3ba0
Add service/heartbeat metric into statsd-reporter (#14564)
YongGang Jul 11, 2023
854ef98
Minor doc fixes. (#14565)
abhishekrb19 Jul 11, 2023
d76903f
Tasks API documentation refactor (#14492)
demo-kratia Jul 11, 2023
7142b0c
Enable result level cache for GroupByStrategyV2 on broker (#11595)
hqx871 Jul 12, 2023
cc8b210
AggregatorFactory: Use guessAggregatorHeapFootprint when factorizeWit…
gianm Jul 12, 2023
3711c0d
Reduce heap footprint of GenericIndexed. (#14563)
gianm Jul 12, 2023
3ff5148
Add ZooKeeper connection state alerts and metrics. (#14333)
gianm Jul 12, 2023
89aee6c
Fixing an issue in sequential merge (#14574)
cryptoe Jul 12, 2023
d21c54f
Cross reference backpressure info (#14508)
cristian-popa Jul 12, 2023
12ce187
Update slack text (#14578)
ektravel Jul 12, 2023
65e1b27
Fix a resource leak with Window processing (#14573)
imply-cheddar Jul 12, 2023
0dcb19f
Add Continuous Profiling to Unit Tests (#14506)
rash67 Jul 13, 2023
7650a71
Add window query test files from Drill (#14561)
imply-cheddar Jul 13, 2023
450ecd6
More efficient generation of ImmutableWorkerHolder from WorkerHolder.…
gianm Jul 13, 2023
f4ee58e
Add `aggregatorMergeStrategy` property in SegmentMetadata queries (#1…
abhishekrb19 Jul 13, 2023
589aac8
Make errorCode of InsertTimeOutOfBoundsFault consistent with others (…
zachjsh Jul 13, 2023
c1c7dff
Using DruidExceptions in MSQ (changes related to the Broker) (#14534)
LakshSingla Jul 13, 2023
95ca430
Change default handoffConditionTimeout to 15 minutes. (#14539)
gianm Jul 13, 2023
214f7c3
Expose leader dimension in service/heartbeat metric into statsd-repor…
YongGang Jul 17, 2023
d5f6749
Web console: catchup to all the backend changes (#14540)
vogievetsky Jul 17, 2023
1f6507d
Remove the deprecated `InsertCannotOrderByDescending` MSQ fault (#14588)
abhishekrb19 Jul 17, 2023
ab051d9
Add test for ReservoirSegmentSampler (#14591)
kfaraz Jul 17, 2023
0e3ce0a
Improve shields with suitable logos (#14575)
asdf2014 Jul 17, 2023
6425ef4
Web console: fix service view filtering on other bugs (#14597)
vogievetsky Jul 17, 2023
6becd81
Web console: better schema discovery copy (#14601)
vogievetsky Jul 18, 2023
03d6d39
Extension to read and ingest iceberg data files (#14329)
a2l007 Jul 18, 2023
0412f40
Prepare master branch for next release, 28.0.0 (#14595)
AmatyaAvadhanula Jul 18, 2023
aef221f
Allow multiple consoleAppender to be used in peon logging (#14521)
maytasm Jul 18, 2023
88dc330
Docs: Changes for coordinator improvements done in #13197 (#14590)
kfaraz Jul 18, 2023
993d8a9
Bump up version in iceberg pom (#14605)
kfaraz Jul 18, 2023
cab93fb
Docs: Minor change missed in #14590 (#14604)
kfaraz Jul 18, 2023
0a8262e
make sure execution mode is set (#14606)
vogievetsky Jul 18, 2023
913416c
add equality, null, and range filter (#14542)
clintropolis Jul 18, 2023
f4d0ea7
Add support for earliest `aggregatorMergeStrategy` (#14598)
abhishekrb19 Jul 18, 2023
ae168c4
Adding null fix for rows and col stats information. (#14617)
cryptoe Jul 19, 2023
68fd221
remove extractionFn from equality, null, and range filters (#14612)
clintropolis Jul 19, 2023
1f4ee5e
Docs: Change default value of "maxRowsInMemory" in tuningConfig (#14618)
Jaehui-Lee Jul 19, 2023
f7348d7
add support for smartSegmentLoading (#14610)
vogievetsky Jul 19, 2023
bac5ef3
Add ingest/input/bytes metric and Kafka consumer metrics. (#14582)
gianm Jul 20, 2023
01e9a39
fix boolean segment filters (#14622)
vogievetsky Jul 20, 2023
c2e6758
Simplify bounds/range vs selectors/equality logic in SQL planning. (#…
gianm Jul 20, 2023
024ce40
reduce heap footprint of ingesting auto typed columns by pushing comp…
clintropolis Jul 20, 2023
1ddbaa8
Reserve threads for non-query requests without using laning (#14576)
abhishekagarwal87 Jul 20, 2023
77e0c16
Sql statement api error messaging fixes. (#14629)
cryptoe Jul 20, 2023
2956536
Web console: make typing fun again (#14632)
vogievetsky Jul 20, 2023
f5784e6
Web console: add explore view (#14602)
vogievetsky Jul 21, 2023
efb3281
Clean up the core API required for Iceberg extension (#14614)
abhishekagarwal87 Jul 21, 2023
54f29fe
Use PreparedBatch while deleting segments (#14639)
jasonk000 Jul 23, 2023
536e491
Suppress ambari metrics CVEs (#14645)
AmatyaAvadhanula Jul 24, 2023
607f511
Improve logging in CoordinatorBasedSegmentHandoffNotifier (#14640)
aho135 Jul 24, 2023
28914bb
Fix issue with long data source names (#14620)
Jul 24, 2023
f742bb7
Get task location should be stored on the lifecycle object (#14649)
Jul 25, 2023
2f9619a
Use OverlordClient for all Overlord RPCs. (#14581)
gianm Jul 25, 2023
6566bda
Suppress CVEs (#14648)
AmatyaAvadhanula Jul 25, 2023
6b229f5
new environment vars for external druid and kafka + jupyter template …
sergioferragut Jul 25, 2023
2dc3e94
Service status API documentation refactor (#14528)
demo-kratia Jul 26, 2023
4804630
Clean up Kinesis doc (#14529)
ektravel Jul 26, 2023
52fbc69
Fix the bug in string last vector aggregation (#14655)
abhishekagarwal87 Jul 26, 2023
6a42a24
Fix a comment in the Calcite UT testExactCountDistinctWithFilter (#14…
adarshsanjeev Jul 26, 2023
b2a07c5
Bump word-wrap from 1.2.3 to 1.2.4 in /web-console (#14613)
dependabot[bot] Jul 26, 2023
e99bab2
Bump org.xerial.snappy:snappy-java from 1.1.10.1 to 1.1.10.3 (#14641)
dependabot[bot] Jul 26, 2023
d69edb7
Docs: Fix some typos. (#14663)
slfan1989 Jul 26, 2023
915cea7
Bump decode-uri-component from 0.2.0 to 0.2.2 in /web-console (#13481)
dependabot[bot] Jul 26, 2023
add9796
Bump qs from 6.5.2 to 6.5.3 in /website (#13510)
dependabot[bot] Jul 26, 2023
4a68f8a
Fix maxCompletedTasks parameter in OverlordClientImpl. (#14667)
gianm Jul 26, 2023
dd204e5
Refresh the OS Druid web console screenshots (#14397)
demo-kratia Jul 26, 2023
7634ac8
Quick fix for SegmentLoadDropHandler bug (#14670)
kfaraz Jul 27, 2023
9b88b78
Fix race condition in KubernetesTaskRunner when task is added to the …
YongGang Jul 27, 2023
0b9e4af
Clean up some of the descriptions (#14661)
ektravel Jul 27, 2023
482def7
Supervisor API documentation refactor (#14579)
demo-kratia Jul 27, 2023
986a271
Merge core CoordinatorClient with MSQ CoordinatorServiceClient. (#14652)
gianm Jul 27, 2023
ee9cfc7
Tasks API documentation spacing update (#14633)
demo-kratia Jul 27, 2023
f5b2cb5
fix spelling conflict
demo-kratia Jul 27, 2023
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
The diff you're trying to view is too large. We only load the first 3000 changed files.
44 changes: 44 additions & 0 deletions .github/scripts/setup_test_profiling_env.sh
Original file line number Diff line number Diff line change
@@ -0,0 +1,44 @@
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

#!/bin/bash

set -e

JAR_INPUT_FILE="jfr-profiler-1.0.0.jar"
JAR_OUTPUT_FILE="jfr-profiler.jar"
ENV_VAR="JFR_PROFILER_ARG_LINE"

if [ "$#" -ne 5 ]; then
echo "usage: $0 <jdk_version> <run_id> <run_number> <run_attempt> <module>"
fi

if [[ "$1" == "17" ]];
then
curl https://static.imply.io/cp/$JAR_INPUT_FILE -s -o $JAR_OUTPUT_FILE

echo $ENV_VAR=-javaagent:"$PWD"/$JAR_OUTPUT_FILE \
-Djfr.profiler.http.username=druid-ci \
-Djfr.profiler.http.password=w3Fb6PW8LIo849mViEkbgA== \
-Djfr.profiler.tags.project=druid \
-Djfr.profiler.tags.run_id=$2 \
-Djfr.profiler.tags.run_number=$3 \
-Djfr.profiler.tags.run_attempt=$4 \
-Djfr.profiler.tags.module=$5
else
echo $ENV_VAR=\"\"
fi


3 changes: 2 additions & 1 deletion .github/scripts/unit_tests_script.sh
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,8 @@ unset _JAVA_OPTIONS

# Set MAVEN_OPTS for Surefire launcher.
MAVEN_OPTS='-Xmx2500m' ${MVN} test -pl ${MAVEN_PROJECTS} \
${MAVEN_SKIP} -Ddruid.generic.useDefaultValueForNull=${DRUID_USE_DEFAULT_VALUE_FOR_NULL}
${MAVEN_SKIP} -Ddruid.generic.useDefaultValueForNull=${DRUID_USE_DEFAULT_VALUE_FOR_NULL} \
-DjfrProfilerArgLine="${JFR_PROFILER_ARG_LINE}"
sh -c "dmesg | egrep -i '(oom|out of memory|kill process|killed).*' -C 1 || exit 0"
free -m
${MVN} -pl ${MAVEN_PROJECTS} jacoco:report || { echo "coverage_failure=false" >> "$GITHUB_ENV" && false; }
Expand Down
10 changes: 7 additions & 3 deletions .github/workflows/cron-job-its.yml
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ on:

jobs:
build:
if: github.event_name == 'schedule'
if: (github.event_name == 'schedule' && github.repository == 'apache/druid')
name: build (jdk8)
runs-on: ubuntu-latest
steps:
Expand Down Expand Up @@ -107,10 +107,12 @@ jobs:
group: other

security_vulnerabilities:
if: github.repository == 'apache/druid'
name: security vulnerabilities
strategy:
fail-fast: false
matrix:
HADOOP_PROFILE: [ '', '-Phadoop3' ]
HADOOP_PROFILE: [ '', '-Phadoop2' ]
runs-on: ubuntu-latest
steps:
- name: Checkout branch
Expand All @@ -123,9 +125,11 @@ jobs:
distribution: 'zulu'
cache: maven

- name: maven build # needed to rebuild incase of maven snapshot resolution fails
run: mvn clean install dependency:go-offline -P dist -P skip-static-checks,skip-tests -Dmaven.javadoc.skip=true -Dcyclonedx.skip=true -Dweb.console.skip=true

- name: security vulnerabilities check
env:
MVN: mvn --no-snapshot-updates
HADOOP_PROFILE: ${{ matrix.HADOOP_PROFILE }}
run: |
mvn dependency-check:purge dependency-check:check ${HADOOP_PROFILE} || { echo "
Expand Down
5 changes: 5 additions & 0 deletions .github/workflows/reusable-unit-tests.yml
Original file line number Diff line number Diff line change
Expand Up @@ -86,6 +86,11 @@ jobs:
echo "DRUID_USE_DEFAULT_VALUE_FOR_NULL=true" >> $GITHUB_ENV
fi

- name: test profiling
run: |
./.github/scripts/setup_test_profiling_env.sh ${{ inputs.jdk }} ${{ github.run_id }} \
${{ github.run_number }} ${{ github.run_attempt }} ${{ inputs.module }} >> $GITHUB_ENV

- name: fetch base branch for test coverage
if: ${{ github.base_ref != '' }}
run: |
Expand Down
4 changes: 2 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -17,8 +17,8 @@
~ under the License.
-->

[![Coverage Status](https://img.shields.io/codecov/c/gh/apache/druid)](https://codecov.io/gh/apache/druid)
[![Docker](https://img.shields.io/badge/container-docker-blue.svg)](https://hub.docker.com/r/apache/druid)
[![Coverage Status](https://img.shields.io/codecov/c/gh/apache/druid?logo=codecov)](https://codecov.io/gh/apache/druid)
[![Docker](https://img.shields.io/badge/container-docker-blue.svg?logo=docker)](https://hub.docker.com/r/apache/druid)
[![Helm](https://img.shields.io/badge/helm-druid-5F90AB?logo=helm)](https://github.com/apache/druid/blob/master/helm/druid/README.md)
<!--- Following badges are disabled until they can be fixed: -->
<!--- [![Inspections Status](https://img.shields.io/teamcity/http/teamcity.jetbrains.com/s/OpenSourceProjects_Druid_Inspections.svg?label=TeamCity%20inspections)](https://teamcity.jetbrains.com/viewType.html?buildTypeId=OpenSourceProjects_Druid_Inspections) -->
Expand Down
2 changes: 1 addition & 1 deletion benchmarks/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@
<parent>
<groupId>org.apache.druid</groupId>
<artifactId>druid</artifactId>
<version>27.0.0-SNAPSHOT</version>
<version>28.0.0-SNAPSHOT</version>
</parent>

<dependencies>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,12 +26,12 @@
import org.apache.druid.collections.bitmap.RoaringBitmapFactory;
import org.apache.druid.common.config.NullHandling;
import org.apache.druid.java.util.common.StringUtils;
import org.apache.druid.segment.column.BitmapColumnIndex;
import org.apache.druid.segment.column.IndexedUtf8ValueSetIndex;
import org.apache.druid.segment.column.StringValueSetIndex;
import org.apache.druid.segment.data.BitmapSerdeFactory;
import org.apache.druid.segment.data.GenericIndexed;
import org.apache.druid.segment.data.RoaringBitmapSerdeFactory;
import org.apache.druid.segment.index.BitmapColumnIndex;
import org.apache.druid.segment.index.IndexedUtf8ValueIndexes;
import org.apache.druid.segment.index.semantic.StringValueSetIndexes;
import org.apache.druid.segment.serde.StringUtf8ColumnIndexSupplier;
import org.openjdk.jmh.annotations.Benchmark;
import org.openjdk.jmh.annotations.BenchmarkMode;
Expand Down Expand Up @@ -72,7 +72,7 @@ public class DictionaryEncodedStringIndexSupplierBenchmark
public static class BenchmarkState
{
@Nullable
private IndexedUtf8ValueSetIndex<?> stringValueSetIndex;
private IndexedUtf8ValueIndexes<?> stringValueSetIndex;
private final TreeSet<ByteBuffer> values = new TreeSet<>();
private static final int START_INT = 10_000_000;

Expand Down Expand Up @@ -112,7 +112,7 @@ public void setup()
);
StringUtf8ColumnIndexSupplier<?> indexSupplier =
new StringUtf8ColumnIndexSupplier<>(bitmapFactory, dictionaryUtf8::singleThreaded, bitmaps, null);
stringValueSetIndex = (IndexedUtf8ValueSetIndex<?>) indexSupplier.as(StringValueSetIndex.class);
stringValueSetIndex = (IndexedUtf8ValueIndexes<?>) indexSupplier.as(StringValueSetIndexes.class);
List<Integer> filterValues = new ArrayList<>();
List<Integer> nonFilterValues = new ArrayList<>();
for (int i = 0; i < dictionarySize; i++) {
Expand Down
2 changes: 1 addition & 1 deletion cloud/aws-common/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@
<parent>
<groupId>org.apache.druid</groupId>
<artifactId>druid</artifactId>
<version>27.0.0-SNAPSHOT</version>
<version>28.0.0-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>

Expand Down
2 changes: 1 addition & 1 deletion cloud/gcp-common/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@
<parent>
<groupId>org.apache.druid</groupId>
<artifactId>druid</artifactId>
<version>27.0.0-SNAPSHOT</version>
<version>28.0.0-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>

Expand Down
10 changes: 5 additions & 5 deletions distribution/docker/docker-compose.yml
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ services:
- ZOO_MY_ID=1

coordinator:
image: apache/druid:27.0.0
image: apache/druid:28.0.0
container_name: coordinator
volumes:
- druid_shared:/opt/shared
Expand All @@ -67,7 +67,7 @@ services:
- environment

broker:
image: apache/druid:27.0.0
image: apache/druid:28.0.0
container_name: broker
volumes:
- broker_var:/opt/druid/var
Expand All @@ -83,7 +83,7 @@ services:
- environment

historical:
image: apache/druid:27.0.0
image: apache/druid:28.0.0
container_name: historical
volumes:
- druid_shared:/opt/shared
Expand All @@ -100,7 +100,7 @@ services:
- environment

middlemanager:
image: apache/druid:27.0.0
image: apache/druid:28.0.0
container_name: middlemanager
volumes:
- druid_shared:/opt/shared
Expand All @@ -118,7 +118,7 @@ services:
- environment

router:
image: apache/druid:27.0.0
image: apache/druid:28.0.0
container_name: router
volumes:
- router_var:/opt/druid/var
Expand Down
4 changes: 3 additions & 1 deletion distribution/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@
<parent>
<artifactId>druid</artifactId>
<groupId>org.apache.druid</groupId>
<version>27.0.0-SNAPSHOT</version>
<version>28.0.0-SNAPSHOT</version>
</parent>

<dependencies>
Expand Down Expand Up @@ -633,6 +633,8 @@
<argument>org.apache.druid.extensions.contrib:aliyun-oss-extensions</argument>
<argument>-c</argument>
<argument>org.apache.druid.extensions.contrib:opentelemetry-emitter</argument>
<argument>-c</argument>
<argument>org.apache.druid.extensions:druid-iceberg-extensions</argument>
</arguments>
</configuration>
</execution>
Expand Down
Loading