This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new e2bdfdd492 guessSchema need to decrypt adapterDescription (#2841)
e2bdfdd492 is described below
commit e2bdfdd4929d6b34ac7e4447a1d9c8394592b6c4
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 14b5ccf1c1..b6dfbce037 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
@@ -31,6 +31,7 @@ import
org.apache.streampipes.model.connect.guess.AdapterEventPreview;
import org.apache.streampipes.model.connect.guess.GuessSchema;
import org.apache.streampipes.model.extensions.svcdiscovery.SpServiceTag;
import org.apache.streampipes.model.monitoring.SpLogMessage;
+import org.apache.streampipes.resource.management.secret.SecretProvider;
import org.apache.streampipes.serializers.json.JacksonSerializer;
import org.apache.streampipes.svcdiscovery.api.model.SpServiceUrlProvider;
@@ -58,6 +59,7 @@ public class GuessManagement {
public GuessSchema guessSchema(AdapterDescription adapterDescription)
throws ParseException, WorkerAdapterException,
NoServiceEndpointsAvailableException, IOException {
+ SecretProvider.getDecryptionService().apply(adapterDescription);
var workerUrl = getWorkerUrl(
adapterDescription.getAppId(),
adapterDescription.getDeploymentConfiguration().getDesiredServiceTags()
