Hey Jacob,
Thanks for taking time to review the SEP.
I agree with you and Navina that the current SEP doesn't provide support to
arbitrary input systems and it doesn't support partition shrink. I think
the scope of this SEP is to support partition expansion for Kafka (the most
widely used input s
+1 (non-binding)
build and tested on Linux (with python 2.7; 2.4 and 3.5 - didn't work)
On Tue, Jun 6, 2017 at 2:49 PM, Jacob Maes wrote:
> +1 (non-binding)
>
> Built and tested on both OSX and RHEL with gradle 2.0 and 2.2 respectively.
>
> Also verified the high level API + YARN host affinity o
+1 (non-binding)
Built and tested on both OSX and RHEL with gradle 2.0 and 2.2 respectively.
Also verified the high level API + YARN host affinity on a test job with 32
containers.
On Tue, Jun 6, 2017 at 9:14 AM, xinyu liu wrote:
> +1 (non-binding).
>
> Downloaded the source tar, built it an
Hi, all,
Thanks for all the inputs! Finally I got some time to go through the
discussion thread and digest most of the points made above. Here is my
personal summary:
Consensus on requirements:
1. ApplicationRunner needs async APIs.
2. ApplicationRunner can be hidden from user (except mayb
+1 (non-binding).
Downloaded the source tar, built it and run check-all.sh on REHL6 with
gradle 2.8. All passed.
As a side note to Jagadish's comments, the build doesn't work on a higher
gradle version either (gradle 3.5). Seems "-language:implicitConversions
-language:reflectiveCalls" is not a v
