Skip to content

Migrate several indexing and compaction integration tests to embedded-tests #18207

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 38 commits into
base: master
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
38 commits
Select commit Hold shift + click to select a range
400de14
Add EmbeddedIndexParallelTaskTest to migrate ITPerfectRollupParallelI…
kfaraz Jul 4, 2025
38c87ef
Use deepstore for intermediary storage
kfaraz Jul 4, 2025
52b2e71
Remove old tests
kfaraz Jul 4, 2025
c43205c
Remove 2 unused ITs
kfaraz Jul 4, 2025
91f092e
Fix deps
kfaraz Jul 4, 2025
5c3a2de
Minor cleanup
kfaraz Jul 4, 2025
b0e1026
Fix dependencies
kfaraz Jul 5, 2025
081e1e2
Merge branch 'master' of github.com:apache/druid into add_embedded_pe…
kfaraz Jul 5, 2025
6279630
Convert ITAutoCompactionTest to EmbeddedAutoCompactionTest
kfaraz Jul 8, 2025
6eeacc8
Merge branch 'master' of github.com:apache/druid into add_embedded_pe…
kfaraz Jul 8, 2025
792d54f
Merge branch 'add_embedded_perfect_rollup_test' of github.com:kfaraz/…
kfaraz Jul 8, 2025
0b98f64
Fix pom
kfaraz Jul 8, 2025
60200d8
Add necessary extensions to embedded cluster test
kfaraz Jul 8, 2025
f2f2d3a
Do not use deprecated APIs
kfaraz Jul 8, 2025
1c1959f
Remove upgrade TestNGGroup
kfaraz Jul 8, 2025
7ee8b38
Address failures
kfaraz Jul 8, 2025
7004592
Add embedded test for concurrent append and replace
kfaraz Jul 8, 2025
bf465e5
Fix deps and tests
kfaraz Jul 8, 2025
0a9572b
Merge branch 'master' of github.com:apache/druid into add_embedded_pe…
kfaraz Jul 8, 2025
0caf10e
Enable test that validates fix for concurrent append
kfaraz Jul 8, 2025
f4d0017
Fix test name
kfaraz Jul 8, 2025
5a85eb0
Merge branch 'master' of github.com:apache/druid into add_embedded_pe…
kfaraz Jul 11, 2025
3bc246d
wip: temp changes
kfaraz Jul 11, 2025
2aae4b7
Convert TaskPayload to TaskBuilder
kfaraz Jul 11, 2025
ce69567
Rename data files
kfaraz Jul 11, 2025
b126ad3
Add EmbeddedCompactionSparseColumnTest
kfaraz Jul 12, 2025
3470f93
Clean up TaskBuilder
kfaraz Jul 13, 2025
bc18de8
Add test for BrokerClient.submitNativeQuery
kfaraz Jul 13, 2025
272c2b7
Remove unused files
kfaraz Jul 13, 2025
8e35b81
Rename the file to simplify the patch
kfaraz Jul 13, 2025
41dc765
Move back the file
kfaraz Jul 13, 2025
d59f4e7
Add centralized schema variant of test
kfaraz Jul 13, 2025
25e4f00
Completely remove `compaction` IT group
kfaraz Jul 13, 2025
97f4430
Rename some tests to follow a simpler nomenclature
kfaraz Jul 14, 2025
fe3258b
Merge branch 'master' of github.com:apache/druid into add_embedded_pe…
kfaraz Jul 14, 2025
69a5a28
Fix tests
kfaraz Jul 14, 2025
9a3e25e
Fix pom
kfaraz Jul 14, 2025
5d960b1
Remove duplicate dependency
kfaraz Jul 14, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions .github/workflows/cron-job-its.yml
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ jobs:
strategy:
fail-fast: false
matrix:
testing_group: [batch-index, input-format, input-source, perfect-rollup-parallel-batch-index, kafka-index, kafka-index-slow, kafka-transactional-index, kafka-transactional-index-slow, kafka-data-format, ldap-security, realtime-index, append-ingestion, compaction]
testing_group: [batch-index, input-format, input-source, kafka-index, kafka-index-slow, kafka-transactional-index, kafka-transactional-index-slow, kafka-data-format, ldap-security, realtime-index, append-ingestion]
uses: ./.github/workflows/reusable-standard-its.yml
needs: build
with:
Expand All @@ -74,7 +74,7 @@ jobs:
strategy:
fail-fast: false
matrix:
testing_group: [ input-source, perfect-rollup-parallel-batch-index, kafka-index, kafka-transactional-index, kafka-index-slow, kafka-transactional-index-slow, kafka-data-format, append-ingestion, compaction ]
testing_group: [ input-source, kafka-index, kafka-transactional-index, kafka-index-slow, kafka-transactional-index-slow, kafka-data-format, append-ingestion ]
uses: ./.github/workflows/reusable-standard-its.yml
needs: build
with:
Expand Down Expand Up @@ -109,7 +109,7 @@ jobs:
with:
build_jdk: 17
runtime_jdk: 17
testing_groups: -DexcludedGroups=batch-index,input-format,input-source,perfect-rollup-parallel-batch-index,kafka-index,query,query-retry,query-error,realtime-index,security,ldap-security,s3-deep-storage,gcs-deep-storage,azure-deep-storage,hdfs-deep-storage,s3-ingestion,kinesis-index,kinesis-data-format,kafka-transactional-index,kafka-index-slow,kafka-transactional-index-slow,kafka-data-format,hadoop-s3-to-s3-deep-storage,hadoop-s3-to-hdfs-deep-storage,hadoop-azure-to-azure-deep-storage,hadoop-azure-to-hdfs-deep-storage,hadoop-gcs-to-gcs-deep-storage,hadoop-gcs-to-hdfs-deep-storage,aliyun-oss-deep-storage,append-ingestion,compaction,high-availability,upgrade,shuffle-deep-store,custom-coordinator-duties
testing_groups: -DexcludedGroups=batch-index,input-format,input-source,kafka-index,query,query-retry,query-error,realtime-index,security,ldap-security,s3-deep-storage,gcs-deep-storage,azure-deep-storage,hdfs-deep-storage,s3-ingestion,kinesis-index,kinesis-data-format,kafka-transactional-index,kafka-index-slow,kafka-transactional-index-slow,kafka-data-format,hadoop-s3-to-s3-deep-storage,hadoop-s3-to-hdfs-deep-storage,hadoop-azure-to-azure-deep-storage,hadoop-azure-to-hdfs-deep-storage,hadoop-gcs-to-gcs-deep-storage,hadoop-gcs-to-hdfs-deep-storage,aliyun-oss-deep-storage,append-ingestion,high-availability,custom-coordinator-duties
use_indexer: ${{ matrix.indexer }}
group: other

Expand Down
22 changes: 3 additions & 19 deletions .github/workflows/standard-its.yml
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ jobs:
strategy:
fail-fast: false
matrix:
testing_group: [batch-index, input-format, input-source, perfect-rollup-parallel-batch-index, kafka-index, kafka-index-slow, kafka-transactional-index, kafka-transactional-index-slow, kafka-data-format, ldap-security, realtime-index, append-ingestion, compaction, cds-task-schema-publish-disabled, cds-coordinator-metadata-query-disabled]
testing_group: [batch-index, input-format, input-source, kafka-index, kafka-index-slow, kafka-transactional-index, kafka-transactional-index-slow, kafka-data-format, ldap-security, realtime-index, append-ingestion, cds-task-schema-publish-disabled, cds-coordinator-metadata-query-disabled]
uses: ./.github/workflows/reusable-standard-its.yml
if: ${{ needs.changes.outputs.core == 'true' || needs.changes.outputs.common-extensions == 'true' }}
with:
Expand All @@ -63,7 +63,7 @@ jobs:
strategy:
fail-fast: false
matrix:
testing_group: [input-source, perfect-rollup-parallel-batch-index, kafka-index, append-ingestion, compaction]
testing_group: [input-source, kafka-index, append-ingestion]
uses: ./.github/workflows/reusable-standard-its.yml
if: ${{ needs.changes.outputs.core == 'true' || needs.changes.outputs.common-extensions == 'true' }}
with:
Expand Down Expand Up @@ -102,22 +102,6 @@ jobs:
override_config_path: ./environment-configs/test-groups/prepopulated-data
group: query

integration-shuffle-deep-store-tests:
needs: changes
strategy:
fail-fast: false
matrix:
indexer: [indexer, middleManager]
uses: ./.github/workflows/reusable-standard-its.yml
if: ${{ needs.changes.outputs.core == 'true' || needs.changes.outputs.common-extensions == 'true' }}
with:
build_jdk: 17
runtime_jdk: 17
testing_groups: -Dgroups=shuffle-deep-store
use_indexer: ${{ matrix.indexer }}
override_config_path: ./environment-configs/test-groups/shuffle-deep-store
group: shuffle deep store

integration-custom-coordinator-duties-tests:
needs: changes
uses: ./.github/workflows/reusable-standard-its.yml
Expand Down Expand Up @@ -197,6 +181,6 @@ jobs:
with:
build_jdk: 17
runtime_jdk: 17
testing_groups: -DexcludedGroups=batch-index,input-format,input-source,perfect-rollup-parallel-batch-index,kafka-index,query,query-retry,query-error,realtime-index,security,ldap-security,s3-deep-storage,gcs-deep-storage,azure-deep-storage,hdfs-deep-storage,s3-ingestion,kinesis-index,kinesis-data-format,kafka-transactional-index,kafka-index-slow,kafka-transactional-index-slow,kafka-data-format,hadoop-s3-to-s3-deep-storage,hadoop-s3-to-hdfs-deep-storage,hadoop-azure-to-azure-deep-storage,hadoop-azure-to-hdfs-deep-storage,hadoop-gcs-to-gcs-deep-storage,hadoop-gcs-to-hdfs-deep-storage,aliyun-oss-deep-storage,append-ingestion,compaction,high-availability,upgrade,shuffle-deep-store,custom-coordinator-duties,centralized-datasource-schema,cds-task-schema-publish-disabled,cds-coordinator-metadata-query-disabled
testing_groups: -DexcludedGroups=batch-index,input-format,input-source,kafka-index,query,query-retry,query-error,realtime-index,security,ldap-security,s3-deep-storage,gcs-deep-storage,azure-deep-storage,hdfs-deep-storage,s3-ingestion,kinesis-index,kinesis-data-format,kafka-transactional-index,kafka-index-slow,kafka-transactional-index-slow,kafka-data-format,hadoop-s3-to-s3-deep-storage,hadoop-s3-to-hdfs-deep-storage,hadoop-azure-to-azure-deep-storage,hadoop-azure-to-hdfs-deep-storage,hadoop-gcs-to-gcs-deep-storage,hadoop-gcs-to-hdfs-deep-storage,aliyun-oss-deep-storage,append-ingestion,high-availability,custom-coordinator-duties,centralized-datasource-schema,cds-task-schema-publish-disabled,cds-coordinator-metadata-query-disabled
use_indexer: ${{ matrix.indexer }}
group: other
23 changes: 23 additions & 0 deletions embedded-tests/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -124,6 +124,12 @@
<version>${project.parent.version}</version>
<type>test-jar</type>
</dependency>
<dependency>
<groupId>org.apache.druid</groupId>
<artifactId>druid-indexing-service</artifactId>
<version>${project.parent.version}</version>
<type>test-jar</type>
</dependency>
<dependency>
<groupId>org.apache.druid.extensions</groupId>
<artifactId>druid-kafka-indexing-service</artifactId>
Expand All @@ -143,6 +149,12 @@
<version>${project.parent.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.druid.extensions</groupId>
<artifactId>druid-datasketches</artifactId>
<version>${project.parent.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.druid</groupId>
<artifactId>druid-aws-common</artifactId>
Expand All @@ -158,6 +170,12 @@
</dependency>

<!-- Non-Druid test dependencies -->
<dependency>
<groupId>org.apache.datasketches</groupId>
<artifactId>datasketches-java</artifactId>
<version>${datasketches.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.scala-lang</groupId>
<artifactId>scala-library</artifactId>
Expand All @@ -178,6 +196,11 @@
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter-api</artifactId>
</dependency>
<dependency>
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter-params</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
Expand Down
Loading
Loading