Skip to content

Commit

Permalink
remove test which is no longer correct
Browse files Browse the repository at this point in the history
Signed-off-by: YANGDB <[email protected]>
  • Loading branch information
YANG-DB committed Oct 26, 2023
1 parent f415827 commit b38062d
Showing 1 changed file with 0 additions and 17 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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() {
Expand Down

0 comments on commit b38062d

Please sign in to comment.