Fix crypto function input schema

jiangpengcheng · jiangpengcheng · commit be53b3b1fada · 2026-05-29T20:45:54.000+08:00
diff --git a/.ci/tests/integration/cases/crypto-function/manifests.yaml b/.ci/tests/integration/cases/crypto-function/manifests.yaml
@@ -16,6 +16,7 @@ spec:
     typeClassName: java.lang.String
     sourceSpecs:
       "persistent://public/default/java-function-crypto-input-topic":
+        schemaType: java.lang.String
         cryptoConfig:
           cryptoKeyReaderClassName: "org.apache.pulsar.functions.api.examples.RawFileKeyReader"
           cryptoKeyReaderConfig:
diff --git a/config/samples/compute_v1alpha1_function_crypto.yaml b/config/samples/compute_v1alpha1_function_crypto.yaml
@@ -17,6 +17,7 @@ spec:
     typeClassName: java.lang.String
     sourceSpecs:
       "persistent://public/default/java-function-crypto-input-topic":
+        schemaType: java.lang.String
         cryptoConfig:
           cryptoKeyReaderClassName: "org.apache.pulsar.functions.api.examples.RawFileKeyReader"
           cryptoKeyReaderConfig:
