diff --git a/catalog-rest-service/src/main/resources/json/schema/entity/services/connections/connectionBasicType.json b/catalog-rest-service/src/main/resources/json/schema/entity/services/connections/connectionBasicType.json index 90aaa55b2e7..d969ded3650 100644 --- a/catalog-rest-service/src/main/resources/json/schema/entity/services/connections/connectionBasicType.json +++ b/catalog-rest-service/src/main/resources/json/schema/entity/services/connections/connectionBasicType.json @@ -8,16 +8,16 @@ "javaType": "org.openmetadata.catalog.services.connections.database.ConnectionOptions", "description": "Additional connection options that can be sent to service during the connection.", "type": "object", - "additionalProperties": { - "type": "string" + "patternProperties": { + ".{1,}": { "type": "string" } } }, "connectionArguments": { "javaType": "org.openmetadata.catalog.services.connections.database.ConnectionArguments", "description": "Additional connection arguments such as security or protocol configs that can be sent to service during connection.", "type": "object", - "additionalProperties": { - "type": "string" + "patternProperties": { + ".{1,}": { "type": "string" } } }, "supportsMetadataExtraction": { diff --git a/catalog-rest-service/src/test/java/org/openmetadata/catalog/resources/services/ingestionpipelines/IngestionPipelineResourceTest.java b/catalog-rest-service/src/test/java/org/openmetadata/catalog/resources/services/ingestionpipelines/IngestionPipelineResourceTest.java index 49b3dcc88ad..d83d9c93412 100644 --- a/catalog-rest-service/src/test/java/org/openmetadata/catalog/resources/services/ingestionpipelines/IngestionPipelineResourceTest.java +++ b/catalog-rest-service/src/test/java/org/openmetadata/catalog/resources/services/ingestionpipelines/IngestionPipelineResourceTest.java @@ -492,10 +492,14 @@ public class IngestionPipelineResourceTest extends EntityResourceTest advConfig = new HashMap<>(); + advConfig.put("hive.execution.engine", "tez"); + advConfig.put("tez.queue.name", "tez"); ConnectionArguments connectionArguments = new ConnectionArguments() .withAdditionalProperty("credentials", "/tmp/creds.json") - .withAdditionalProperty("client_email", "ingestion-bot@domain.com"); + .withAdditionalProperty("client_email", "ingestion-bot@domain.com") + .withAdditionalProperty("configuration", advConfig); ConnectionOptions connectionOptions = new ConnectionOptions().withAdditionalProperty("key1", "value1").withAdditionalProperty("key2", "value2"); BigQueryConnection bigQueryConnection =