From 02fc4b2af1805ec6e52114aa799d027ea8154fca Mon Sep 17 00:00:00 2001 From: yyin Date: Wed, 4 Feb 2026 14:53:18 +0800 Subject: [PATCH] Change discover schema action order for input in TaCoKitGuessSchema --- .../component/runtime/di/schema/TaCoKitGuessSchema.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/component-studio/component-runtime-di/src/main/java/org/talend/sdk/component/runtime/di/schema/TaCoKitGuessSchema.java b/component-studio/component-runtime-di/src/main/java/org/talend/sdk/component/runtime/di/schema/TaCoKitGuessSchema.java index 052bf35d09d16..173f07d187ff9 100644 --- a/component-studio/component-runtime-di/src/main/java/org/talend/sdk/component/runtime/di/schema/TaCoKitGuessSchema.java +++ b/component-studio/component-runtime-di/src/main/java/org/talend/sdk/component/runtime/di/schema/TaCoKitGuessSchema.java @@ -422,21 +422,22 @@ public boolean guessSchemaThroughAction(final Schema schema) { ServiceMeta.ActionMeta actionRef; if (action == null || action.isEmpty()) { // dataset name should be the same as DiscoverSchema action name so let's try to guess from the component + //First find DiscoverSchemaExtended action name actionRef = findFirstComponentDataSetName() .flatMap(datasetName -> services .stream() .flatMap(s -> s.getActions().stream()) - .filter(a -> a.getFamily().equals(family) && a.getType().equals(SCHEMA_TYPE)) + .filter(a -> a.getFamily().equals(family) && a.getType().equals(SCHEMA_EXTENDED_TYPE)) .filter(a -> a.getAction().equals(datasetName)) .findFirst()) .orElse(null); if (actionRef == null) { - // let's try DiscoverSchemaExtended action name + // second find DiscoverSchema action name actionRef = findFirstComponentDataSetName() .flatMap(datasetName -> services .stream() .flatMap(s -> s.getActions().stream()) - .filter(a -> a.getFamily().equals(family) && a.getType().equals(SCHEMA_EXTENDED_TYPE)) + .filter(a -> a.getFamily().equals(family) && a.getType().equals(SCHEMA_TYPE)) .filter(a -> a.getAction().equals(datasetName)) .findFirst()) .orElse(null);