Hi Xiaochuan,
>> Do I need to upgrade Kafka and/or YARN?
*Yarn version:*
- Samza 0.12 supports Yarn 2.6.1 and 2.7.1.
- If you already have 2.6.0 installed (as you have said), I believe you
will be fine. (but I'm not sure)
*Kafka version: *
- Samza 0.12 upgraded the version of Kafka
Hi,
What are the general steps for upgrading Samza from 0.9 to 0.12?
Do I need to upgrade Kafka and/or YARN?
I don't know how Samza was setup initially but we currently have the
following setup:
Samza version: 0.9.1
YARN version: Hadoop 2.6.0-cdh5.4.8
Kafka version: 0.9.0.1
I think installation
Github user asfgit closed the pull request at:
https://github.com/apache/samza/pull/94
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enable
> Seems like they're (usually) going to be used by the framework, are
pretty simple to write, and could probably be written as a common Util
method if we find them repetitive.
Hmm.. To be honest, I didn't see the value of it too. When Xinyu suggested
this change, I assumed it was the newly accept
Hi Navina,
1. Assuming the environment can put the processor ID in the config,
ProcessorIdGenerator#generateProcessorId(Config config) makes sense.
Passing all of Config is rather broad, but I don't think we have an
environment specific subset class for config yet, so should be OK.
2. I don't yet
