[GitHub] samza pull request #432: Initial implementation of remote table provider

2018-02-22 Thread pdu-mn1
GitHub user pdu-mn1 opened a pull request: https://github.com/apache/samza/pull/432 Initial implementation of remote table provider Please see commit messages for detailed descriptions. You can merge this pull request into a Git repository by running: $ git pull https://github.

[GitHub] samza pull request #431: Staging directory name has to be formatted in confi...

2018-02-22 Thread Zedmor
GitHub user Zedmor opened a pull request: https://github.com/apache/samza/pull/431 Staging directory name has to be formatted in config When we instantiate a HDFS config staging directory we missing a formatter for getStagingDirectory so systems.hdfs-system-name.stagingDirectory doe

[GitHub] samza pull request #430: SAMZA-1595: Fix scalacCompileOptions format to buil...

2018-02-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/430 ---

[GitHub] samza pull request #430: SAMZA-1595: Fix scalacCompileOptions format to buil...

2018-02-22 Thread shanthoosh
GitHub user shanthoosh opened a pull request: https://github.com/apache/samza/pull/430 SAMZA-1595: Fix scalacCompileOptions format to build with zinc scala compiler. Zinc scala compiler(part of gradle version >= 3.0) expects the scala compilation arguments as a list(where each comp

[GitHub] samza pull request #427: SAMZA-1594: Remove ScalaCompileOptions to make samz...

2018-02-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/427 ---

[GitHub] samza pull request #429: Added rate limiter interface and embedded implement...

2018-02-22 Thread weisong44
GitHub user weisong44 opened a pull request: https://github.com/apache/samza/pull/429 Added rate limiter interface and embedded implementation Added rate limiter interface and embedded implementation - EmbeddedRateLimiter - EmbeddedTaggedRateLimiter You can merge this pull

[GitHub] samza pull request #428: Json file reader

2018-02-22 Thread Zedmor
Github user Zedmor closed the pull request at: https://github.com/apache/samza/pull/428 ---

[GitHub] samza pull request #428: Json file reader

2018-02-22 Thread Zedmor
GitHub user Zedmor opened a pull request: https://github.com/apache/samza/pull/428 Json file reader 1. Gradle.build changes 2. Staging directory fix for properties 3. Initial offset fix to set it to 0:0 if missing 4. Text file reader You can merge this pull request into

[GitHub] samza pull request #427: SAMZA-1594: Fix ScalaCompileOptions errors with hig...

2018-02-22 Thread shanthoosh
GitHub user shanthoosh opened a pull request: https://github.com/apache/samza/pull/427 SAMZA-1594: Fix ScalaCompileOptions errors with higher gradle version. When samza repository is built with the gradle version greater than 3.0, we notice the following build failure. No s

[GitHub] samza pull request #426: SAMZA-1593: Upgrade gradle nexus plugin.

2018-02-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/426 ---

[GitHub] samza pull request #426: SAMZA-1593: Upgrade gradle nexus plugin.

2018-02-22 Thread shanthoosh
GitHub user shanthoosh opened a pull request: https://github.com/apache/samza/pull/426 SAMZA-1593: Upgrade gradle nexus plugin. Current nexus plugin which samza repository is using is not compatible with the gradle versions greater than 3.0. For doing the ligradle migration

[GitHub] samza pull request #425: Add stream-table join support for samza sql

2018-02-22 Thread atoomula
GitHub user atoomula opened a pull request: https://github.com/apache/samza/pull/425 Add stream-table join support for samza sql You can merge this pull request into a Git repository by running: $ git pull https://github.com/atoomula/samza join Alternatively you can review an

Re: [VOTE] SEP-11: Host affinity in standalone.

2018-02-22 Thread Yi Pan
Hi, Santhoosh, Overall looks good to me now. There are still some minor issues / errors in the design doc - in YARN, are you sure that we persist the JobModel to coordinator stream? I checked the code and didn't find that. The JobModel was simply generated and served from the memory in the JobCoor