Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Runstreaming job failed with error in bench.log like "org.apache.spark.SparkException: Error getting partition metadata for 'identity'. Does the topic exist?" #744

Open
jianblog opened this issue Jun 21, 2024 · 0 comments

Comments

@jianblog
Copy link

i followed the step:

  1. run genSeedDataset.sh
  2. 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?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant