-
Notifications
You must be signed in to change notification settings - Fork 306
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
Class static used to pass info between stream steps #12
Comments
Similar problems noticed also in other classes. |
Yeah, to be honest, my first implementation was "quick and dirty", also I am not coding daily anymore - thus, I forgot some best practices about Java coding in last years :-) Thank you so much for these improvements and pull requests. |
I merged your fix. Thank you. I will keep the ticket open as reminder for the other classes. I will refactor the other classes, too. |
@jukkakarvanen |
Kafka_Streams_TensorFlow_Image_Recognition_Example use class static variables to pass information between foreach and mapValues steps.
So I expect rather interesting problems if executed with multiple threads.
I have fix for this, but it is on top of changes related to #11
The text was updated successfully, but these errors were encountered: