I am facing issue while configuring repartition method attribute for repartition processor using python. What is the right way to set it.
Solved
Repartition Processor Configuration
- Fan
- 4 replies
Best answer by chandrakant_v
to set the repartition method, one need to use the following snippet.
Use the modelType attribute of repartition processor object.
repartition.modelType = "Repartition By Number (Increase or Decrease)"
- StreamSets Employee
- 101 replies
Hello
- Fan
- 4 replies
I’m trying to set repartition method value this way:
repartition.repartition_method = "REPARTITION BY NUMBER (INCREASE OR DECREASE)"
But i’m getting the following error:
Repartition Method -- CREATION_010 - Configuration value 'REPARTITION BY NUMBER (INCREASE OR DECREASE)' is not a valid 'RepartitionTypeValues' enum value: java.lang.IllegalArgumentException: No enum constant com.streamsets.pipeline.spark.transform.repartition.RepartitionTypeValues.REPARTITION BY NUMBER (INCREASE OR DECREASE)
- Headliner
- 258 replies
- Fan
- 4 replies
- Answer
to set the repartition method, one need to use the following snippet.
Use the modelType attribute of repartition processor object.
repartition.modelType = "Repartition By Number (Increase or Decrease)"
- StreamSets Employee
- 101 replies
Thank you for sharing the resolution
Feel free to reach out to us if you have any further issues. :)
Reply
Enter your E-mail address. We'll send you an e-mail with instructions to reset your password.