Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@

package org.opensearch.analytics.resilience;

import org.apache.lucene.tests.util.LuceneTestCase;
import org.opensearch.Version;
import org.opensearch.action.admin.indices.create.CreateIndexResponse;
import org.opensearch.analytics.AnalyticsPlugin;
Expand Down Expand Up @@ -44,6 +45,7 @@
* would shut it down for the whole JVM, so topology variants cannot share a class
* with {@code CoordinatorResilienceIT}.
*/
@LuceneTestCase.AwaitsFix(bugUrl = "broken")
public abstract class CoordinatorTopologyTestBase extends OpenSearchIntegTestCase {

protected static final int VALUE = 7;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@
import org.apache.calcite.sql.fun.SqlStdOperatorTable;
import org.apache.calcite.sql.type.SqlTypeName;
import org.apache.calcite.util.ImmutableBitSet;
import org.apache.lucene.tests.util.LuceneTestCase;
import org.opensearch.action.support.PlainActionFuture;
import org.opensearch.analytics.spi.ExchangeSink;
import org.opensearch.analytics.spi.ExchangeSinkContext;
Expand Down Expand Up @@ -85,6 +86,7 @@
*
* @opensearch.internal
*/
@LuceneTestCase.AwaitsFix(bugUrl = "broken")
public class CoordinatorReduceStressIT extends OpenSearchTestCase {

/** Default Substrait input id for the single-input case (matches DatafusionReduceSink.INPUT_ID). */
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@

package org.opensearch.analytics.qa;

import org.apache.lucene.tests.util.LuceneTestCase;
import org.opensearch.client.Request;
import org.opensearch.client.Response;

Expand Down Expand Up @@ -128,6 +129,7 @@ public void testDistinctCountAcrossShards() throws Exception {
}

/** Single-shard {@code take(value, 3)} — bounded array of up to 3 values. */
@LuceneTestCase.AwaitsFix(bugUrl = "broken")
public void testTakeSingleShard() throws Exception {
String index = "coord_reduce_take_single";
createSingleShardParquetBackedIndex(index);
Expand Down Expand Up @@ -160,6 +162,7 @@ public void testTakeSingleShard() throws Exception {
}

/** Cross-shard {@code take(value, 5)} — coordinator unions per-shard arrays and truncates to 5. */
@LuceneTestCase.AwaitsFix(bugUrl = "broken")
public void testTakeAcrossShards() throws Exception {
String index = "coord_reduce_take_multi";
createParquetBackedIndex(index);
Expand Down Expand Up @@ -300,6 +303,7 @@ public void testListSingleShard() throws Exception {
}

/** Cross-shard {@code list(value)} — coordinator concatenates per-shard lists via list_merge UDAF. */
@LuceneTestCase.AwaitsFix(bugUrl = "broken")
public void testListAcrossShards() throws Exception {
String index = "coord_reduce_list_multi";
createParquetBackedIndex(index);
Expand Down Expand Up @@ -377,6 +381,7 @@ public void testValuesSingleShard() throws Exception {
}

/** Cross-shard {@code values(value)} — coordinator concatenates and re-deduplicates via list_merge_distinct UDAF. */
@LuceneTestCase.AwaitsFix(bugUrl = "broken")
public void testValuesAcrossShards() throws Exception {
String index = "coord_reduce_values_multi";
createParquetBackedIndex(index);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@

package org.opensearch.analytics.qa;

import org.apache.lucene.tests.util.LuceneTestCase;
import org.opensearch.client.Request;
import org.opensearch.client.Response;

Expand All @@ -30,6 +31,7 @@
* {@code FilterDelegationHandle} to count calls and exposes the count via REST — a
* bigger surface than this IT warrants, so deferred.
*/
@LuceneTestCase.AwaitsFix(bugUrl = "")
public class FilterDelegationIT extends AnalyticsRestTestCase {

private static final String INDEX_NAME = "filter_delegation_e2e";
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@

package org.opensearch.analytics.qa;

import org.apache.lucene.tests.util.LuceneTestCase;
import org.opensearch.client.Request;
import org.opensearch.client.Response;

Expand Down Expand Up @@ -57,6 +58,7 @@
* {@code OpenSearchTestCase}, so the seed is printed on failure. Re-run with
* {@code ./gradlew :...:integTest -Dtests.seed=HEX} to reproduce.
*/
@LuceneTestCase.AwaitsFix(bugUrl = "")
public class MatchLikeParityIT extends AnalyticsRestTestCase {

private static final String INDEX_NAME = "match_like_parity";
Expand Down
Loading