Skip to content

Commit 2f247a9

Browse files
committed
Replace builtin prefix
1 parent 2aefc93 commit 2f247a9

2 files changed

Lines changed: 4 additions & 2 deletions

File tree

mesh-worker-service/src/main/java/io/functionmesh/compute/util/SinksUtil.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -162,8 +162,9 @@ public static V1alpha1Sink createV1alpha1SkinFromSinkConfig(String kind, String
162162
if (connectorsManager == null) {
163163
v1alpha1SinkSpecInput.setTypeClassName("[B");
164164
} else {
165+
String connectorType = archive.replaceFirst("^builtin://", "");
165166
FunctionMeshConnectorDefinition functionMeshConnectorDefinition =
166-
connectorsManager.getConnectorDefinition(sinkConfig.getArchive());
167+
connectorsManager.getConnectorDefinition(connectorType);
167168
if (functionMeshConnectorDefinition == null) {
168169
v1alpha1SinkSpecInput.setTypeClassName("[B");
169170
} else {

mesh-worker-service/src/main/java/io/functionmesh/compute/util/SourcesUtil.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -168,8 +168,9 @@ public static V1alpha1Source createV1alpha1SourceFromSourceConfig(String kind, S
168168
if (connectorsManager == null) {
169169
v1alpha1SourceSpecOutput.setTypeClassName("[B");
170170
} else {
171+
String connectorType = archive.replaceFirst("^builtin://", "");
171172
FunctionMeshConnectorDefinition functionMeshConnectorDefinition =
172-
connectorsManager.getConnectorDefinition(sourceConfig.getArchive());
173+
connectorsManager.getConnectorDefinition(connectorType);
173174
if (functionMeshConnectorDefinition == null) {
174175
v1alpha1SourceSpecOutput.setTypeClassName("[B");
175176
} else {

0 commit comments

Comments
 (0)