You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
ERROR org.apache.pulsar.functions.LocalRunner - Encountered error starting localrunner
java.lang.IllegalArgumentException: Could not validate sink config: Cannot construct instance of org.apache.pulsar.ecosystem.io.lakehouse.SinkConnectorConfig (no Creators, like default constructor, exist): abstract types either need to be mapped to concrete types, have custom deserializer, or contain additional type information
at [Source: UNKNOWN; byte offset: #UNKNOWN]
at org.apache.pulsar.functions.utils.SinkConfigUtils.validateSinkConfig(SinkConfigUtils.java:747) ~[org.apache.pulsar-pulsar-functions-utils-3.0.5.jar:3.0.5]
at org.apache.pulsar.functions.utils.SinkConfigUtils.validateSinkConfig(SinkConfigUtils.java:731) ~[org.apache.pulsar-pulsar-functions-utils-3.0.5.jar:3.0.5]
at org.apache.pulsar.functions.utils.SinkConfigUtils.validateAndExtractDetails(SinkConfigUtils.java:561) ~[org.apache.pulsar-pulsar-functions-utils-3.0.5.jar:3.0.5]
at org.apache.pulsar.functions.LocalRunner.start(LocalRunner.java:423) ~[org.apache.pulsar-pulsar-functions-local-runner-original-3.0.5.jar:3.0.5]
at org.apache.pulsar.functions.LocalRunner.main(LocalRunner.java:221) ~[org.apache.pulsar-pulsar-functions-local-runner-original-3.0.5.jar:3.0.5]
Describe the bug
When attempting to run the pulsar lakehouse sink example(! https://streamnative.io/blog/announcing-delta-lake-sink-connector-apache-pulsar ) locally, an java error occurs:
ERROR org.apache.pulsar.functions.LocalRunner - Encountered error starting localrunner
java.lang.IllegalArgumentException: Could not validate sink config: Cannot construct instance of
org.apache.pulsar.ecosystem.io.lakehouse.SinkConnectorConfig
(no Creators, like default constructor, exist): abstract types either need to be mapped to concrete types, have custom deserializer, or contain additional type informationat [Source: UNKNOWN; byte offset: #UNKNOWN]
at org.apache.pulsar.functions.utils.SinkConfigUtils.validateSinkConfig(SinkConfigUtils.java:747) ~[org.apache.pulsar-pulsar-functions-utils-3.0.5.jar:3.0.5]
at org.apache.pulsar.functions.utils.SinkConfigUtils.validateSinkConfig(SinkConfigUtils.java:731) ~[org.apache.pulsar-pulsar-functions-utils-3.0.5.jar:3.0.5]
at org.apache.pulsar.functions.utils.SinkConfigUtils.validateAndExtractDetails(SinkConfigUtils.java:561) ~[org.apache.pulsar-pulsar-functions-utils-3.0.5.jar:3.0.5]
at org.apache.pulsar.functions.LocalRunner.start(LocalRunner.java:423) ~[org.apache.pulsar-pulsar-functions-local-runner-original-3.0.5.jar:3.0.5]
at org.apache.pulsar.functions.LocalRunner.main(LocalRunner.java:221) ~[org.apache.pulsar-pulsar-functions-local-runner-original-3.0.5.jar:3.0.5]
To Reproduce
After init of the pulsar standalone cluster: run the commands in https://streamnative.io/blog/announcing-delta-lake-sink-connector-apache-pulsar
Actual command:
PULSAR_HOME/bin/pulsar-admin sinks localrun --sink-config-file /tmp/pulsar-functions/connectors/pulsar-delta-lake-sink-config.json
with the settings from the example: with my local cluster settings updated over where needed (tenant / namespace)
Expected behavior
To have the sink create succesfully
Screenshots
Environment
The text was updated successfully, but these errors were encountered: