fix(TCOMP-2710): send notice that schema is empty

Talend · Jun 25, 2024 · 507f8bc · 507f8bc
1 parent b9e8d63
commit 507f8bc
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/...ntime-di/src/main/java/org/talend/sdk/component/runtime/di/schema/TaCoKitGuessSchema.java b/...ntime-di/src/main/java/org/talend/sdk/component/runtime/di/schema/TaCoKitGuessSchema.java
@@ -19,6 +19,7 @@
 import static java.util.Optional.ofNullable;
 import static java.util.stream.Collectors.toList;
 import static java.util.stream.Collectors.toMap;
+import static org.talend.sdk.component.api.exception.DiscoverSchemaException.HandleErrorWith.EXCEPTION;
 import static org.talend.sdk.component.api.exception.DiscoverSchemaException.HandleErrorWith.EXECUTE_LIFECYCLE;
 import static org.talend.sdk.component.api.record.SchemaProperty.IS_KEY;
 import static org.talend.sdk.component.api.record.SchemaProperty.PATTERN;
@@ -167,8 +168,7 @@ private DiscoverSchemaException transformException(final Exception e) {
         } else if (e instanceof ComponentException) {
             discoverSchemaException = new DiscoverSchemaException((ComponentException) e);
         } else {
-            discoverSchemaException = new DiscoverSchemaException(e.getMessage(), e.getStackTrace(),
-                    DiscoverSchemaException.HandleErrorWith.EXCEPTION);
+            discoverSchemaException = new DiscoverSchemaException(e.getMessage(), e.getStackTrace(), EXCEPTION);
         }
         return discoverSchemaException;
     }
@@ -243,7 +243,12 @@ private void executeDiscoverSchemaExtendedAction(final Schema schema, final Stri
         final Object schemaResult =
                 actionRef.getInvoker().apply(buildActionConfig(actionRef, configuration, schema, branch));
         if (schemaResult instanceof Schema) {
-            fromSchema(Schema.class.cast(schemaResult));
+            final Schema result = (Schema) schemaResult;
+            if (result.getEntries().isEmpty()) {
+                throw new DiscoverSchemaException(ERROR_NO_AVAILABLE_SCHEMA_FOUND, EXCEPTION);
+            } else {
+                fromSchema(Schema.class.cast(schemaResult));
+            }
         }
     }