This repository was archived by the owner on Dec 15, 2025. It is now read-only.
This repository was archived by the owner on Dec 15, 2025. It is now read-only.
Runstreaming job failed with error in bench.log like "org.apache.spark.SparkException: Error getting partition metadata for 'identity'. Does the topic exist?" #744
Description
i followed the step:
- run genSeedDataset.sh
- run dataGen.sh
when finished, run run.sh. and got errors. then search the topic in kakfa,only find three topic like this "SPARK_identity_1_5_50_1718960476417
SPARK_identity_1_5_50_1718960899674
SPARK_identity_1_5_50_1718961292132”
Is anywhere i missed or got wrong ? anyone know how the streaming testing in right way?