Hi,

When trying to use a ComplexKeyGenerator with 0.5.1 I get the following
error:
"Exception in thread "main" java.io.IOException: Could not load key
generator class org.apache.hudi.ComplexKeyGenerator"

https://gist.github.com/fo3310001/5a998b73a95f734b2852fc1c8689dd62


The command I am using is passing the hudi-utilities-bundle:

 spark-submit --class
org.apache.hudi.utilities.deltastreamer.HoodieDeltaStreamer  --packages
org.apache.spark:spark-avro_2.11:2.4.4  --master yarn --deploy-mode client
 /usr/lib/hudi/hudi-utilities-bundle_2.11-0.5.1-incubating.jar (...)

Any pointers would be appreciated.

Thank you!

Reply via email to