[GitHub] samza pull request #660: SAMZA-1832: Fix race condition between StreamProces...
Github user bharathkk closed the pull request at: https://github.com/apache/samza/pull/660 ---
[GitHub] samza pull request #673: SAMZA-1832: Fix race condition between StreamProces...
GitHub user bharathkk opened a pull request: https://github.com/apache/samza/pull/673 SAMZA-1832: Fix race condition between StreamProcessor and SamzaContainerListener You can merge this pull request into a Git repository by running: $ git pull https://github.com/bharathkk/samza samza-1832-alternative Alternatively you can review and apply these changes as the patch at: https://github.com/apache/samza/pull/673.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #673 commit 035b6f0211f25741f2b928fb2bccf4d1eb1c3605 Author: bharathkk Date: 2018-09-28T05:13:24Z Fix race condition between SamzaContainerListener and StreamProcessor ---
Review Request 68867: Update hell0-samza with latest code
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/68867/ --- Review request for samza and Prateek Maheshwari. Repository: samza-hello-samza Description --- Update hell0-samza with latest code Diffs - build.gradle 9d1f5433afc548ee19b00c0e0e2e73e7963d25ef src/main/config/pageview-adclick-joiner.properties eba7b0b6efc86869dbdf9402ae069550ed4c1723 src/main/config/pageview-filter.properties 331ee1a1f1315c13aa955353795853eca792d669 src/main/config/pageview-profile-table-joiner.properties 7cec6013e744042295568cef17928321abf95b35 src/main/config/pageview-sessionizer.properties 420cdde0d2d82f22daafc49b7428040a7dcd1eef src/main/config/stock-price-table-joiner.properties f9bd684ed3601ba887b48c87c070f31c8b137f8e src/main/config/tumbling-pageview-counter.properties b58dbe9a951a1ec1978a745efdd43e0f9fe87483 src/main/config/wikipedia-application-local-runner.properties b770f1317dfd61b33122c71127ba8163135a26e5 src/main/config/wikipedia-application.properties 841fcc5a3ca6b5e52c82e717fb7baa1e380d134f src/main/java/samza/examples/azure/AzureApplication.java 9f565fe47373c5bb054cfcc1ccc00e54111d786e src/main/java/samza/examples/azure/AzureZKLocalApplication.java 3d4f8b05cd1405070448c7598afa2712bb2db13d src/main/java/samza/examples/cookbook/PageViewAdClickJoiner.java f6c3810ad59532563994ff344952490369c87350 src/main/java/samza/examples/cookbook/PageViewFilterApp.java a2accfdd8fee6033133e77e74fa8c6fd8de186c5 src/main/java/samza/examples/cookbook/PageViewProfileTableJoiner.java 86deb614cc7bf9720df86e9d9f49bb4613ce1384 src/main/java/samza/examples/cookbook/PageViewSessionizerApp.java 2bcd9f5b8f8e14e451451a12b627e189ad673288 src/main/java/samza/examples/cookbook/StockPriceTableJoiner.java cb735d284f82b67f01f797c2ede2c130b80eb047 src/main/java/samza/examples/cookbook/TumblingPageViewCounterApp.java acf1411af7d951081ad988c92822fde2b140608d src/main/java/samza/examples/wikipedia/application/WikipediaApplication.java 032608f4f1f2525c0d5598ea80b84ed4d40f6f7e src/main/java/samza/examples/wikipedia/application/WikipediaZkLocalApplication.java 51dd28f69b146962b2853d2426e153e13a6ab1e6 src/main/java/samza/examples/wikipedia/model/WikipediaParser.java 93479626afa0fb9f8a230fa755e8f30fdbc57563 src/main/java/samza/examples/wikipedia/system/WikipediaInputDescriptor.java PRE-CREATION src/main/java/samza/examples/wikipedia/system/WikipediaSystemDescriptor.java PRE-CREATION Diff: https://reviews.apache.org/r/68867/diff/1/ Testing --- Only tested the high-level wikipedia example for now. I will keep testing the rest of it in the next few days. Commit the change for now to unblock others to test. Thanks, Xinyu Liu
[GitHub] samza pull request #672: SAMZA-1714: Creating shared context factory for sha...
GitHub user cameronlee314 opened a pull request: https://github.com/apache/samza/pull/672 SAMZA-1714: Creating shared context factory for shared context objects This includes changes in https://github.com/apache/samza/pull/626. You can merge this pull request into a Git repository by running: $ git pull https://github.com/cameronlee314/samza shared_context_impl Alternatively you can review and apply these changes as the patch at: https://github.com/apache/samza/pull/672.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #672 commit b6c1588f39e0ad9ccff609c3f6bdb174a7109055 Author: Cameron Lee Date: 2018-09-07T18:10:26Z SAMZA-1858: Public APIs for shared context commit e4cc56d5f66049c7b7d2a2624d35ebe278920fda Author: Cameron Lee Date: 2018-09-07T18:40:38Z fixing ContextImpl and adding tests commit 6359c8a8268fc1819eec2457e887f36c0e6766fc Author: Cameron Lee Date: 2018-09-07T19:32:28Z fixing ApplicationDescriptor link in javadoc and using consistent style for instance var names commit 71122137503717d19861cdee67ffbb36b7350313 Author: Cameron Lee Date: 2018-09-07T22:01:30Z adding SamzaContextImpl and SamzaContainerContext commit fc8b68b606f7c6b5494282fbaae07bdb269dc6ac Author: Cameron Lee Date: 2018-09-07T22:23:26Z using SamzaContainerContext instead of SamzaContext for ApplicationDefinedContainerContextFactory commit 22af79c94f75820a36bdec99000e3f543f8569fb Author: Cameron Lee Date: 2018-09-08T00:45:47Z removing underscores from instance vars for tests commit 9a2e5bd2fbfd15ee6b25589e227ee554b4f9915b Author: Cameron Lee Date: 2018-09-10T21:13:20Z wip: needs unit tests commit 2f349847d88be1e2d541caa72b989757fb237464 Author: Cameron Lee Date: 2018-09-12T00:53:04Z Merge branch 'master' into shared_context_apis commit 31de93d030921a5c1a0895e7eac23f3b0ac61fd3 Author: Cameron Lee Date: 2018-09-12T22:00:26Z wip: still need to move task and container model commit 67c3608d00fb70aa7124c0c671ba281e4dbc5a57 Author: Cameron Lee Date: 2018-09-18T00:25:18Z SAMZA-1880: Rename non-metrics classes which use Timer in their name commit db4fad6debe101f5103537f7c942011505ea2829 Author: Cameron Lee Date: 2018-09-18T00:46:18Z minor style check update commit b63e032c2cbb8e1eadbc7bd6acb30bd431272d54 Author: Cameron Lee Date: 2018-09-18T20:44:29Z simplify terminology: rename Scheduling to Scheduled, rename KeyScheduler to Scheduler commit 970830c491ef90fd675d5cdd8a6134c3950c4b34 Author: Cameron Lee Date: 2018-09-19T20:19:57Z Merge branch 'master' into rename_timer commit 2af9244509da79c35b3b33c18b6b07d2786aae22 Author: Cameron Lee Date: 2018-09-19T20:21:38Z Merge branch 'rename_timer' into shared_context_apis commit 7c774f3c929857e406be3e92f31d11dc2fd603c3 Author: Cameron Lee Date: 2018-09-19T21:33:18Z add models to contexts, merge with refactorings commit 80b01be16fb0998d0dcdd108339c1f905b0e1b2a Author: Cameron Lee Date: 2018-09-19T21:53:50Z Merge branch 'shared_context_apis' into shared_context_impl commit 002148f679cacfb9cce9ff6f10c09b6e3489b18a Author: Cameron Lee Date: 2018-09-20T21:40:17Z update CallbackScheduler doc commit 2406c76e4d0203b60a366eea9d3f163d06154811 Author: Cameron Lee Date: 2018-09-21T00:23:48Z merge with timer renaming; updating tests with new API commit aa0c19b03102bd3750482f5f90f4b6bbb1e69f92 Author: Cameron Lee Date: 2018-09-25T17:15:10Z wip commit 36aa4a4a1fb1584609a937a6391260284e59792f Author: Cameron Lee Date: 2018-09-26T21:07:50Z update docs, add null checks commit ff2a863dcacd06f98436f4d3b2ea9d9d593628c9 Author: Cameron Lee Date: 2018-09-26T21:17:41Z Merge branch 'master' into shared_context_apis commit 5aaaf1f4bc1c87478b98a47c7424986143e38a07 Author: Cameron Lee Date: 2018-09-26T23:04:26Z removing wildcard imports, merge with timer renaming commit da5fa79d0bf5acd07f7051b26e4a0bf9d6187676 Author: Cameron Lee Date: 2018-09-26T23:25:55Z Merge branch 'shared_context_apis' into shared_context_impl commit 906412a6390198b3b0a49147dedf56c2877450da Author: Cameron Lee Date: 2018-09-28T00:05:47Z deleting old classes, updating test imports, fixing compile issues after merge ---
[GitHub] samza pull request #671: Basic configurations
GitHub user dxichen opened a pull request: https://github.com/apache/samza/pull/671 Basic configurations @prateekm @vjagadish Please let me know if there are configs that should/should not be there or there are descriptions that you would like me to change. Screenshots:  https://user-images.githubusercontent.com/29577458/46179677-2f922500-c271-11e8-95a2-b7117c392aa4.png;>      https://user-images.githubusercontent.com/29577458/46179684-302abb80-c271-11e8-822f-5142e9faf494.png;>    https://user-images.githubusercontent.com/29577458/46179688-30c35200-c271-11e8-810d-d014f63fb02d.png;> You can merge this pull request into a Git repository by running: $ git pull https://github.com/dxichen/samza config-doc-revamp Alternatively you can review and apply these changes as the patch at: https://github.com/apache/samza/pull/671.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #671 commit 2e4f4e20390f11b302d5b9ba2d7ffc349f8d01f3 Author: Daniel Chen Date: 2018-09-27T23:14:03Z Basic configurations ---
[GitHub] samza pull request #670: SAMZA-1920: Standalone user guide.
GitHub user shanthoosh opened a pull request: https://github.com/apache/samza/pull/670 SAMZA-1920: Standalone user guide. You can merge this pull request into a Git repository by running: $ git pull https://github.com/shanthoosh/samza getting_started_with_standalone Alternatively you can review and apply these changes as the patch at: https://github.com/apache/samza/pull/670.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #670 commit e40bed581ea482c767d7aee9b3906e7d1b5975de Author: Shanthoosh Venkataraman Date: 2018-09-27T18:34:15Z Initial version of getting started with standalone. ---
[GitHub] samza pull request #669: SAMZA-1918: Convert Kafka connector doc to `.md`
GitHub user dnishimura opened a pull request: https://github.com/apache/samza/pull/669 SAMZA-1918: Convert Kafka connector doc to `.md` @vjagadish1989 please review.  You can merge this pull request into a Git repository by running: $ git pull https://github.com/dnishimura/samza samza-1918-kafka-connector-doc Alternatively you can review and apply these changes as the patch at: https://github.com/apache/samza/pull/669.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #669 commit 49f7f8c370347e7c54287c35700c5cca62c9e9a2 Author: Daniel Nishimura Date: 2018-09-27T17:43:06Z Convert Kafka connector doc to ---
[GitHub] samza pull request #668: SAMZA-1919; Add KafkaSystemDescriptor constructor t...
GitHub user lindong28 opened a pull request: https://github.com/apache/samza/pull/668 SAMZA-1919; Add KafkaSystemDescriptor constructor to allow arbitrary factory class Currently KafkaSystemDescriptor is hardcoded to use org.apache.samza.system.kafka.KafkaSystemFactory as the system factory for instantiating producer/consumer/admin. Users may want to use most methods in KafkaSystemDescriptor but with a different factory class. We can meet such use-case by adding a constructor that allows user to specify the factory class name. You can merge this pull request into a Git repository by running: $ git pull https://github.com/lindong28/samza SAMZA-1919 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/samza/pull/668.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #668 commit 5431fc9f79c9d99479939a5a179616ac279ddd79 Author: Dong Lin Date: 2018-09-27T16:59:50Z SAMZA-1919; Add KafkaSystemDescriptor constructor to allow arbitrary factory class ---
[GitHub] samza pull request #667: Updated doc for Kinesis Connector
GitHub user atoomula opened a pull request: https://github.com/apache/samza/pull/667 Updated doc for Kinesis Connector You can merge this pull request into a Git repository by running: $ git pull https://github.com/atoomula/samza kinesisdocs Alternatively you can review and apply these changes as the patch at: https://github.com/apache/samza/pull/667.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #667 commit e98ffc797a0196cb81638008f16d11fb73eae37b Author: Aditya Toomula Date: 2018-09-27T16:43:27Z Added docs for Kinesis Connector ---
[GitHub] samza pull request #657: SAMZA-1905: Added case study for eBay, Optimizely, ...
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/657 ---
[GitHub] samza pull request #659: Revised monitoring doc
Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/659 ---
