This is an automated email from the ASF dual-hosted git repository. riemer pushed a commit to branch rel/0.95.0 in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit e8e5087a27a7786e92add2a4257ba6aac606c374 Author: yanfeng1992 <[email protected]> AuthorDate: Tue May 21 03:18:11 2024 +0800 guessSchema need to decrypt adapterDescription (#2841) Signed-off-by: huangyanfeng <[email protected]> --- .../streampipes/connect/management/management/GuessManagement.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/GuessManagement.java b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/GuessManagement.java index 97ce035dae..3e1f546907 100644 --- a/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/GuessManagement.java +++ b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/GuessManagement.java @@ -28,6 +28,7 @@ import org.apache.streampipes.model.connect.adapter.AdapterDescription; import org.apache.streampipes.model.connect.guess.AdapterEventPreview; import org.apache.streampipes.model.connect.guess.GuessSchema; import org.apache.streampipes.model.monitoring.SpLogMessage; +import org.apache.streampipes.resource.management.secret.SecretProvider; import org.apache.streampipes.serializers.json.JacksonSerializer; import com.fasterxml.jackson.core.JsonProcessingException; @@ -54,6 +55,7 @@ public class GuessManagement { public GuessSchema guessSchema(AdapterDescription adapterDescription) throws ParseException, WorkerAdapterException, NoServiceEndpointsAvailableException, IOException { var workerUrl = getWorkerUrl(adapterDescription.getAppId()); + SecretProvider.getDecryptionService().apply(adapterDescription); var description = objectMapper.writeValueAsString(adapterDescription); LOG.info("Guess schema at: " + workerUrl);
