DM-13806-Improve Error Handling - Revert back partition key group code
@@ -346,9 +346,6 @@ class DefaultSource(apiClientFactory: (String, Option[String], Option[String]) =
if(fmt.getSchema == null) {
throw new Exception("Schema not found")
}
- if(fmt.getSchema.getPartitionKeyGroup == null && params.partitionFilter == null) {
- throw new Exception("Partition Key Group not found")
- }
log.info(s"Using PartitionKey ${fmt.getPartitionKey}, PartitionKeyGroup ${fmt.getSchema.getPartitionKeyGroup}")
