[jira] [Created] (SAMZA-1227) LocalStoreMonitor should emit metrics for total job state and active job state

Prateek Maheshwari created SAMZA-1227: - Summary: LocalStoreMonitor should emit metrics for total job state and active job state Key: SAMZA-1227 URL: https://issues.apache.org/jira/browse/SAMZA-1227

[jira] [Created] (SAMZA-1230) Document localized resource config

Fred Ji created SAMZA-1230: -- Summary: Document localized resource config Key: SAMZA-1230 URL: https://issues.apache.org/jira/browse/SAMZA-1230 Project: Samza Issue Type: Bug Reporter:

[jira] [Updated] (SAMZA-1228) StreamProcessor should stop JmxServer

[ https://issues.apache.org/jira/browse/SAMZA-1228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navina Ramesh updated SAMZA-1228: - Fix Version/s: 0.13.0 > StreamProcessor should stop JmxServer >

[jira] [Created] (SAMZA-1228) StreamProcessor should stop JmxServer

Navina Ramesh created SAMZA-1228: Summary: StreamProcessor should stop JmxServer Key: SAMZA-1228 URL: https://issues.apache.org/jira/browse/SAMZA-1228 Project: Samza Issue Type: Bug

[jira] [Created] (SAMZA-1229) Disk space monitor should only count data in use by the container

Prateek Maheshwari created SAMZA-1229: - Summary: Disk space monitor should only count data in use by the container Key: SAMZA-1229 URL: https://issues.apache.org/jira/browse/SAMZA-1229 Project:

[jira] [Commented] (SAMZA-1229) Disk space monitor should only count data in use by the container

[ https://issues.apache.org/jira/browse/SAMZA-1229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977641#comment-15977641 ] ASF GitHub Bot commented on SAMZA-1229: --- GitHub user prateekm opened a pull request:

[jira] [Commented] (SAMZA-1224) Revert job coordinator factory config to the old format

[ https://issues.apache.org/jira/browse/SAMZA-1224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977321#comment-15977321 ] Navina Ramesh commented on SAMZA-1224: -- [~fredji] We haven't released any samza version with this

[jira] [Updated] (SAMZA-1220) Add thread name to SamzaContainer shutdown hook and prevent shutdown deadlock

[ https://issues.apache.org/jira/browse/SAMZA-1220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1220: Description: [~jagadish1...@gmail.com] and I were recently looking at a thread dump for a SamzaContainer

samza-hello-samza git commit: SAMZA-1225: Add demo examples for programming with the fluent API

Repository: samza-hello-samza Updated Branches: refs/heads/latest 4d20c2bde -> c87ed565f SAMZA-1225: Add demo examples for programming with the fluent API Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo Commit:

[jira] [Updated] (SAMZA-1144) Deprecate yarn.package.path and change package localizer to use the universal resource localization config

[ https://issues.apache.org/jira/browse/SAMZA-1144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fred Ji updated SAMZA-1144: --- Fix Version/s: (was: 0.13.0) 0.14.0 > Deprecate yarn.package.path and change package

[jira] [Created] (SAMZA-1231) Put warning for deprecating yarn.package.path

Fred Ji created SAMZA-1231: -- Summary: Put warning for deprecating yarn.package.path Key: SAMZA-1231 URL: https://issues.apache.org/jira/browse/SAMZA-1231 Project: Samza Issue Type: Task

[jira] [Commented] (SAMZA-1222) Clean up LocalApplicationRunner

[ https://issues.apache.org/jira/browse/SAMZA-1222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977741#comment-15977741 ] ASF GitHub Bot commented on SAMZA-1222: --- GitHub user xinyuiscool opened a pull request:

[jira] [Updated] (SAMZA-1222) Clean up LocalApplicationRunner

[ https://issues.apache.org/jira/browse/SAMZA-1222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1222: - Description: Clean up the LocalApplicationRunner based on the feedback in

[jira] [Resolved] (SAMZA-868) support elasticsearch version 2.x

[ https://issues.apache.org/jira/browse/SAMZA-868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-868. Resolution: Fixed > support elasticsearch version 2.x >

[jira] [Commented] (SAMZA-868) support elasticsearch version 2.x

[ https://issues.apache.org/jira/browse/SAMZA-868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15976307#comment-15976307 ] Yi Pan (Data Infrastructure) commented on SAMZA-868: merged and submitted. Thanks! >

[jira] [Updated] (SAMZA-868) support elasticsearch version 2.x

[ https://issues.apache.org/jira/browse/SAMZA-868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-868: --- Fix Version/s: 0.13.0 > support elasticsearch version 2.x >

samza git commit: SAMZA-868: support elasticsearch version 2.x

Repository: samza Updated Branches: refs/heads/master de8cffdfa -> e753c8de3 SAMZA-868: support elasticsearch version 2.x Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/e753c8de Tree:

[jira] [Assigned] (SAMZA-868) support elasticsearch version 2.x

[ https://issues.apache.org/jira/browse/SAMZA-868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-868: -- Assignee: Jiri Humpolicek (was: Yi Pan (Data Infrastructure))

[jira] [Assigned] (SAMZA-868) support elasticsearch version 2.x

[ https://issues.apache.org/jira/browse/SAMZA-868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-868: -- Assignee: Yi Pan (Data Infrastructure) > support elasticsearch

[jira] [Assigned] (SAMZA-1165) ZK cleanup

[ https://issues.apache.org/jira/browse/SAMZA-1165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari reassigned SAMZA-1165: - Assignee: Boris Shkolnik > ZK cleanup > -- > > Key:

[jira] [Assigned] (SAMZA-1150) Handling Error propagation between ZkJobCoordinator & DebounceTimer

[ https://issues.apache.org/jira/browse/SAMZA-1150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari reassigned SAMZA-1150: - Assignee: Navina Ramesh > Handling Error propagation between ZkJobCoordinator &

[jira] [Resolved] (SAMZA-1098) Update samza-hello latest branch to use Samza 0.13.0-SNAPSHOT version

[ https://issues.apache.org/jira/browse/SAMZA-1098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1098. --- Resolution: Fixed Looks like this is already fixed. > Update samza-hello latest

[jira] [Resolved] (SAMZA-1163) Samza 0.12 build with scala 2.10

[ https://issues.apache.org/jira/browse/SAMZA-1163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1163. --- Resolution: Fixed > Samza 0.12 build with scala 2.10 >

[jira] [Resolved] (SAMZA-1157) When throwable is caught in serialization/deserialzation, Samza should propagate the throwable via exception, instead of suppressing

[ https://issues.apache.org/jira/browse/SAMZA-1157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1157. --- Resolution: Fixed > When throwable is caught in serialization/deserialzation, Samza

[jira] [Resolved] (SAMZA-1205) Disable Flaky test : TestJmxServer#serverStartsUp

[ https://issues.apache.org/jira/browse/SAMZA-1205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1205. --- Resolution: Fixed > Disable Flaky test : TestJmxServer#serverStartsUp >

[jira] [Updated] (SAMZA-1218) Support StreamTaskFactory and AsyncStreamTaskFactory in LocalApplicationRunner

[ https://issues.apache.org/jira/browse/SAMZA-1218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1218: -- Summary: Support StreamTaskFactory and AsyncStreamTaskFactory in LocalApplicationRunner

[jira] [Updated] (SAMZA-1218) Support taskFactory in local application runner.

[ https://issues.apache.org/jira/browse/SAMZA-1218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1218: -- Fix Version/s: (was: 0.13.0) 0.14.0 > Support taskFactory in

[jira] [Updated] (SAMZA-1056) Provide Operator implementations access to KeyValueStorageEngines

[ https://issues.apache.org/jira/browse/SAMZA-1056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1056: -- Fix Version/s: (was: 0.13.0) 0.14.0 > Provide Operator

[jira] [Updated] (SAMZA-1184) Improvements to Merge Script

[ https://issues.apache.org/jira/browse/SAMZA-1184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1184: -- Fix Version/s: (was: 0.13.0) 0.14.0 > Improvements to Merge

[jira] [Updated] (SAMZA-1221) Simplify MessageStreamImpl and OperatorSpec graphs and traversals

[ https://issues.apache.org/jira/browse/SAMZA-1221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1221: -- Fix Version/s: (was: 0.13.0) 0.14.0 > Simplify MessageStreamImpl

[jira] [Updated] (SAMZA-1072) Make scalaVersion configurable through ENV variable in samza-test json files

[ https://issues.apache.org/jira/browse/SAMZA-1072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1072: -- Fix Version/s: (was: 0.13.0) 0.14.0 > Make scalaVersion

[jira] [Commented] (SAMZA-1226) Relax the type parameters in user functions in fluent API

[ https://issues.apache.org/jira/browse/SAMZA-1226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15976228#comment-15976228 ] ASF GitHub Bot commented on SAMZA-1226: --- GitHub user nickpan47 opened a pull request: