From b38062d139d7596352a6968631c6b089668a5336 Mon Sep 17 00:00:00 2001 From: YANGDB Date: Wed, 25 Oct 2023 23:37:16 -0700 Subject: [PATCH] remove test which is no longer correct Signed-off-by: YANGDB --- .../SparkSqlFunctionTableScanOperatorTest.java | 17 ----------------- 1 file changed, 17 deletions(-) diff --git a/spark/src/test/java/org/opensearch/sql/spark/functions/SparkSqlFunctionTableScanOperatorTest.java b/spark/src/test/java/org/opensearch/sql/spark/functions/SparkSqlFunctionTableScanOperatorTest.java index 188cd695a3..78fa52c6a1 100644 --- a/spark/src/test/java/org/opensearch/sql/spark/functions/SparkSqlFunctionTableScanOperatorTest.java +++ b/spark/src/test/java/org/opensearch/sql/spark/functions/SparkSqlFunctionTableScanOperatorTest.java @@ -141,23 +141,6 @@ void testQueryResponseAllTypes() { Assertions.assertFalse(sparkSqlFunctionTableScanOperator.hasNext()); } - @Test - @SneakyThrows - void testQueryResponseInvalidDataType() { - SparkQueryRequest sparkQueryRequest = new SparkQueryRequest(); - sparkQueryRequest.setSql(QUERY); - - SparkSqlFunctionTableScanOperator sparkSqlFunctionTableScanOperator = - new SparkSqlFunctionTableScanOperator(sparkClient, sparkQueryRequest); - - when(sparkClient.sql(any())).thenReturn(new JSONObject(getJson("invalid_data_type.json"))); - - RuntimeException exception = - Assertions.assertThrows( - RuntimeException.class, () -> sparkSqlFunctionTableScanOperator.open()); - Assertions.assertEquals("Result contains invalid data type", exception.getMessage()); - } - @Test @SneakyThrows void testQuerySchema() {