-
Notifications
You must be signed in to change notification settings - Fork 9.1k
Fix Checkstyle error, rename a argument #297
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
base: trunk
Are you sure you want to change the base?
Conversation
💔 -1 overall
This message was automatically generated. |
💔 -1 overall
This message was automatically generated. |
💔 -1 overall
This message was automatically generated. |
💔 -1 overall
This message was automatically generated. |
💔 -1 overall
This message was automatically generated. |
💔 -1 overall
This message was automatically generated. |
💔 -1 overall
This message was automatically generated. |
💔 -1 overall
This message was automatically generated. |
💔 -1 overall
This message was automatically generated. |
…batch processing For each run of a batch application, we need to clear the internal streams from the previous run and recreate new ones. This patch introduces the following: 1) bounded flag in StreamSpec 2) app.mode (BATCH/STREAM) in the application config. An application is a batch app iff all the input streams are bounded. 3) app.runId and use it to generate the internal topics for each run. run.id generation is not addressed in this pr. There will be another patch to resolve it for both yarn and standalone. For now, this patch only works for yarn. Author: Xinyu Liu <xiliu@xiliu-ld1.linkedin.biz> Reviewers: Jake Maes <jmakes@apache.org> Closes apache#297 from xinyuiscool/SAMZA-1417
💔 -1 overall
This message was automatically generated. |
No description provided.