[GitHub] storm pull request #1714: STORM-2125 Use Calcite's implementation of Rex Com...

2016-09-26 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1714#discussion_r80416617 --- Diff: external/sql/storm-sql-core/src/test/org/apache/storm/sql/compiler/backends/standalone/TestPlanCompiler.java --- @@ -71,9 +71,9 @@ public

[GitHub] storm pull request #1714: STORM-2125 Use Calcite's implementation of Rex Com...

2016-09-26 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1714#discussion_r80418615 --- Diff: external/sql/storm-sql-runtime/src/jvm/org/apache/calcite/interpreter/StormDataContext.java --- @@ -0,0 +1,79 @@ +/** + * Licensed

[GitHub] storm pull request #1714: STORM-2125 Use Calcite's implementation of Rex Com...

2016-09-26 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1714#discussion_r80414692 --- Diff: external/sql/storm-sql-core/src/test/org/apache/storm/sql/TestStormSql.java --- @@ -174,26 +173,42 @@ public void testExternalDataSource

[GitHub] storm pull request #1714: STORM-2125 Use Calcite's implementation of Rex Com...

2016-09-26 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1714#discussion_r80425683 --- Diff: pom.xml --- @@ -264,7 +264,7 @@ 4.11 2.5.1 2.1.7 -1.4.0-incubating +1.9.0

[GitHub] storm pull request #1714: STORM-2125 Use Calcite's implementation of Rex Com...

2016-09-26 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1714#discussion_r80415245 --- Diff: external/sql/storm-sql-core/src/test/org/apache/storm/sql/TestStormSql.java --- @@ -174,26 +173,42 @@ public void testExternalDataSource

[GitHub] storm pull request #1714: STORM-2125 Use Calcite's implementation of Rex Com...

2016-09-26 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1714#discussion_r80414653 --- Diff: external/sql/storm-sql-core/src/test/org/apache/storm/sql/TestStormSql.java --- @@ -174,26 +173,42 @@ public void testExternalDataSource

[GitHub] storm pull request #1714: STORM-2125 Use Calcite's implementation of Rex Com...

2016-09-26 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1714#discussion_r80416478 --- Diff: external/sql/storm-sql-core/src/test/org/apache/storm/sql/compiler/TestCompilerUtils.java --- @@ -153,6 +158,29 @@ public static

[GitHub] storm pull request #1682: STORM-2089 Replace Consumer of ISqlTridentDataSour...

2016-09-26 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1682#discussion_r80413517 --- Diff: external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/ISqlTridentDataSource.java --- @@ -17,14 +17,62 @@ */ package

[GitHub] storm issue #1706: [STORM-2118] A few fixes for storm-sql standalone mode

2016-09-23 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1706 @HeartSaVioR addressed comments. --- 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

[GitHub] storm pull request #1706: [STORM-2118] A few fixes for storm-sql standalone ...

2016-09-22 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1706#discussion_r80185268 --- Diff: external/sql/storm-sql-runtime/src/test/org/apache/storm/sql/TestUtils.java --- @@ -60,6 +62,25 @@ public static String result(String

[GitHub] storm pull request #1706: [STORM-2118] A few fixes for storm-sql standalone ...

2016-09-22 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1706#discussion_r80183483 --- Diff: external/sql/storm-sql-runtime/src/test/org/apache/storm/sql/TestUtils.java --- @@ -60,6 +62,25 @@ public static String result(String

[GitHub] storm pull request #1706: [STORM-2118] A few fixes for storm-sql standalone ...

2016-09-22 Thread arunmahadevan
GitHub user arunmahadevan opened a pull request: https://github.com/apache/storm/pull/1706 [STORM-2118] A few fixes for storm-sql standalone mode 1. Cast the result, accumulator and value types correctly 2. Support aggregate functions with more than one argument You can merge

[GitHub] storm issue #1656: STORM-2057 Support JOIN statement in Storm SQL

2016-09-11 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1656 +1 --- 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

[GitHub] storm pull request #1656: STORM-2057 Support JOIN statement in Storm SQL

2016-09-07 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1656#discussion_r77945289 --- Diff: storm-core/src/jvm/org/apache/storm/trident/TridentTopology.java --- @@ -277,6 +277,35 @@ public Stream join(List streams, List joinFields

[GitHub] storm issue #1643: STORM-2050 [storm-sql] Support User Defined Aggregate Fun...

2016-08-25 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1643 +1 looks good --- 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

[GitHub] storm issue #1635: STORM-1434 Support the GROUP BY clause in StormSQL

2016-08-24 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1635 @HeartSaVioR I have gone through your recent changes and it looks good. In the logical plan you have posted, there are multiple processors just for the project (before the aggregation

[GitHub] storm pull request #1645: [STORM-2042] Nimbus client connections not closed ...

2016-08-23 Thread arunmahadevan
GitHub user arunmahadevan opened a pull request: https://github.com/apache/storm/pull/1645 [STORM-2042] Nimbus client connections not closed properly causing connection leaks Backport https://github.com/apache/storm/pull/1630 to 0.10.x branch You can merge this pull request

[GitHub] storm pull request #1635: STORM-1434 Support the GROUP BY clause in StormSQL

2016-08-23 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1635#discussion_r75836816 --- Diff: external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/CountBy.java --- @@ -0,0 +1,52

[GitHub] storm pull request #1635: STORM-1434 Support the GROUP BY clause in StormSQL

2016-08-23 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1635#discussion_r75835366 --- Diff: external/sql/storm-sql-core/src/jvm/org/apache/storm/sql/compiler/backends/trident/TridentPostOrderRelNodeVisitor.java --- @@ -0,0 +1,155

[GitHub] storm issue #1635: STORM-1434 Support the GROUP BY clause in StormSQL

2016-08-23 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1635 @HeartSaVioR I have gone through the changes and left a few comments. Like the idea of using Janino for compiling which results in cleaner code. --- If your project is set up for it, you can

[GitHub] storm pull request #1635: STORM-1434 Support the GROUP BY clause in StormSQL

2016-08-23 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1635#discussion_r75833225 --- Diff: external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/CountBy.java --- @@ -0,0 +1,52

[GitHub] storm pull request #1635: STORM-1434 Support the GROUP BY clause in StormSQL

2016-08-23 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1635#discussion_r75828818 --- Diff: external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/CountBy.java --- @@ -0,0 +1,52

[GitHub] storm pull request #1635: STORM-1434 Support the GROUP BY clause in StormSQL

2016-08-23 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1635#discussion_r75827034 --- Diff: external/sql/storm-sql-core/src/jvm/org/apache/storm/sql/compiler/backends/trident/TridentLogicalPlanCompiler.java --- @@ -0,0 +1,344

[GitHub] storm pull request #1635: STORM-1434 Support the GROUP BY clause in StormSQL

2016-08-23 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1635#discussion_r75823827 --- Diff: external/sql/storm-sql-core/src/jvm/org/apache/storm/sql/compiler/backends/trident/TridentPostOrderRelNodeVisitor.java --- @@ -0,0 +1,155

[GitHub] storm pull request #1635: STORM-1434 Support the GROUP BY clause in StormSQL

2016-08-23 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1635#discussion_r75822913 --- Diff: external/sql/storm-sql-core/src/jvm/org/apache/storm/sql/StormSqlImpl.java --- @@ -137,18 +137,12 @@ public void submit

[GitHub] storm pull request #1636: [STORM-2047] Add note to add logviewer hosts to br...

2016-08-20 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1636#discussion_r75576234 --- Diff: docs/SECURITY.md --- @@ -81,7 +81,9 @@ curl -i --negotiate -u:anyUser -b ~/cookiejar.txt -c ~/cookiejar.txt http://s 1. Firefox

[GitHub] storm pull request #1636: [STORM-2047] Add note to add logviewer hosts to br...

2016-08-18 Thread arunmahadevan
GitHub user arunmahadevan opened a pull request: https://github.com/apache/storm/pull/1636 [STORM-2047] Add note to add logviewer hosts to browser whitelist You can merge this pull request into a Git repository by running: $ git pull https://github.com/arunmahadevan/storm

[GitHub] storm issue #1631: [STORM-2042] Nimbus client connections not closed properl...

2016-08-18 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1631 @harshach this is the port of https://github.com/apache/storm/pull/1630 into master. Can you review and merge this well ? --- If your project is set up for it, you can reply to this email

[GitHub] storm pull request #1631: [STORM-2042] Nimbus client connections not closed ...

2016-08-17 Thread arunmahadevan
GitHub user arunmahadevan opened a pull request: https://github.com/apache/storm/pull/1631 [STORM-2042] Nimbus client connections not closed properly causing connection leaks https://github.com/apache/storm/pull/1630 ported to master branch. You can merge this pull request

[GitHub] storm pull request #1583: STORM-1979: Storm Druid Connector implementation.

2016-07-27 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1583#discussion_r72387042 --- Diff: external/storm-druid/src/main/java/org/apache/storm/druid/trident/DruidBeamState.java --- @@ -0,0 +1,73 @@ +/* + * Licensed

[GitHub] storm pull request #1577: [STORM-1987] Fix TridentKafkaWordCount arg handlin...

2016-07-19 Thread arunmahadevan
GitHub user arunmahadevan opened a pull request: https://github.com/apache/storm/pull/1577 [STORM-1987] Fix TridentKafkaWordCount arg handling in distributed mode You can merge this pull request into a Git repository by running: $ git pull https://github.com/arunmahadevan

[GitHub] storm issue #1527: [STORM-1932] Change Duration's value data type

2016-07-15 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1527 Either you can use `@isNumber` or add a `@isLong` validator to decorate the millisecond values, its not already available. --- If your project is set up for it, you can reply to this email

[GitHub] storm pull request #1527: [STORM-1932] Change Duration's value data type

2016-07-15 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1527#discussion_r70955540 --- Diff: storm-core/src/jvm/org/apache/storm/topology/base/BaseWindowedBolt.java --- @@ -66,10 +66,14 @@ public String toString() { * Holds

[GitHub] storm pull request #1527: [STORM-1932] Change Duration's value data type

2016-07-15 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1527#discussion_r70955173 --- Diff: storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java --- @@ -76,7 +76,7 @@ public WindowedBoltExecutor(IWindowedBolt bolt

[GitHub] storm pull request #1568: [STORM-1964] Unexpected behavior when using count ...

2016-07-15 Thread arunmahadevan
GitHub user arunmahadevan opened a pull request: https://github.com/apache/storm/pull/1568 [STORM-1964] Unexpected behavior when using count window together with timestamp extraction Do not use timestamp to determine the event count in WatermarkCountEvictionPolicy when count

[GitHub] storm pull request #1563: [STORM-1968] Storm logviewer does not work for nim...

2016-07-13 Thread arunmahadevan
GitHub user arunmahadevan opened a pull request: https://github.com/apache/storm/pull/1563 [STORM-1968] Storm logviewer does not work for nimbus.log in secure cluster logviewer invokes "get-log-user-group-whitelist" which tries to get the worker metadata file by invokin

[GitHub] storm issue #1557: STORM-1960. Add CORS support to STORM UI Rest api

2016-07-13 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1557 +1 --- 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

[GitHub] storm pull request #1557: STORM-1960. Add CORS support to STORM UI Rest api

2016-07-13 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1557#discussion_r70657632 --- Diff: storm-core/src/clj/org/apache/storm/ui/helpers.clj --- @@ -221,10 +221,7 @@ (defnk json-response [data callback :serialize-fn

[GitHub] storm issue #1552: STORM-1960. Add CORS support to STORM UI Rest api.

2016-07-12 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1552 @harshach May be for now we can document in the REST api doc and expose configs in future if needed. --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] storm issue #1413: [STORM-1833] Simple equi-join in storm-sql standalone mod...

2016-07-07 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1413 @harshach @haohui could you please take a look ? --- 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

[GitHub] storm issue #1527: [STORM-1932] Change Duration's value data type

2016-07-05 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1527 @darionyaphet You need to make more changes, 1. you should use `longValue()` instead of the `intValue()` in the `initWindowManager` where the values are read from storm conf. 2

[GitHub] storm pull request #1527: [STORM-1932] Change Duration's value data type

2016-07-05 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1527#discussion_r69672789 --- Diff: storm-core/src/jvm/org/apache/storm/windowing/CountEvictionPolicy.java --- @@ -26,10 +26,10 @@ * @param the type of event tracked

[GitHub] storm pull request #1527: [STORM-1932] Change Duration's value data type

2016-07-05 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1527#discussion_r69672262 --- Diff: storm-core/src/jvm/org/apache/storm/topology/base/BaseWindowedBolt.java --- @@ -66,10 +66,14 @@ public String toString() { * Holds

[GitHub] storm pull request #1527: [STORM-1932] Change Duration's value data type

2016-07-05 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1527#discussion_r69671675 --- Diff: storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java --- @@ -76,7 +76,7 @@ public WindowedBoltExecutor(IWindowedBolt bolt

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

2016-07-03 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r69395742 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -60,22 +64,23 @@ public RedisKeyValueState

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

2016-07-03 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r69395744 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -161,7 +176,11 @@ public void prepareCommit

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

2016-07-03 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r69395738 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -60,22 +64,23 @@ public RedisKeyValueState

[GitHub] storm issue #1528: STORM-1934 Fix race condition between sync-supervisor and...

2016-06-29 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1528 Thanks @HeartSaVioR. It looks good. +1 --- 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

[GitHub] storm issue #1528: STORM-1934 Fix race condition between sync-supervisor and...

2016-06-29 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1528 @HeartSaVioR thanks for the clarification, it makes sense now. Can you also check rebalance from 2 -> 3 workers ? --- If your project is set up for it, you can reply to this email and h

[GitHub] storm issue #1528: STORM-1934 Fix race condition between sync-supervisor and...

2016-06-29 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1528 @HeartSaVioR The changes looks good. May be you can add some comments in sync-process and mk-synchronize-supervisor on what each is supposed to do. In your comment where you rebalanced

[GitHub] storm issue #1470: STORM-1886 Extend KeyValueState iface with delete

2016-06-27 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1470 @kosii I have gone through the latest changes and left a few comments. The idea of using tombstone looks nice and once the comments are addressed its good to merge. --- If your project

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

2016-06-27 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r68537734 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -161,7 +176,11 @@ public void prepareCommit

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

2016-06-27 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r68537622 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -60,22 +64,23 @@ public RedisKeyValueState

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

2016-06-27 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r68537628 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -60,22 +64,23 @@ public RedisKeyValueState

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

2016-06-27 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r68537606 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -60,22 +64,23 @@ public RedisKeyValueState

[GitHub] storm issue #1488: STORM-1906: Window count/length of zero should be disallo...

2016-06-15 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1488 +1 --- 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

[GitHub] storm issue #1470: STORM-1886 Extend KeyValueState iface with delete

2016-06-13 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1470 @kosii the delete api is useful. Lets also try to see if we could handle the deletes by maintaining an entry within the pendingPrepare itself and avoid the extra hashsets and synchronized

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

2016-06-13 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r66785298 --- Diff: storm-core/src/jvm/org/apache/storm/state/KeyValueState.java --- @@ -45,4 +45,11 @@ * @return the value or defaultValue

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

2016-06-13 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r66785022 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -116,20 +123,30 @@ private void

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

2016-06-13 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r66785037 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -163,15 +190,20 @@ public void prepareCommit

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

2016-06-13 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r66785042 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -184,15 +216,17 @@ public void commit(long

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

2016-06-13 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r66785050 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -203,12 +237,14 @@ public void commit

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

2016-06-13 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r66784993 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -104,9 +109,11 @@ private void

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

2016-06-13 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r66784976 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -104,9 +109,11 @@ private void

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

2016-06-13 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r66784961 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -77,7 +81,8 @@ public RedisKeyValueState

[GitHub] storm issue #1453: STORM-1873 Implement alternative behaviour for late tuple...

2016-06-08 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1453 Thanks @kosii merged to master and 1.x-branch. I did not merge to 1.0.x-branch since this adds a new api and as @ptgoetz suggested it can be targeted for 1.1.0 release. --- If your project

[GitHub] storm issue #1453: STORM-1873 Implement alternative behaviour for late tuple...

2016-06-07 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1453 +1 Looks good --- 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

[GitHub] storm issue #1458: STORM-1878: Flux can now handle IStatefulBolts

2016-06-07 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1458 Thanks @sakanaou merged to master, 1.x and 1.0.x branches. --- 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

[GitHub] storm issue #1464: STORM-1884: Prioritize pendingPrepare over pendingCommit

2016-06-07 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1464 +1 --- 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

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-06 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65863969 --- Diff: storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java --- @@ -188,6 +189,10 @@ private void validate(Map stormConf, Count

[GitHub] storm issue #939: [STORM-1175] State store for windowing operations

2016-06-06 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/939 @kosii Thanks for reporting. Yes the keys in `pendingPrepare` should have priority. Typically this case does not happen since when a prepare fails, the txn is rolled-back and retried (i.e

[GitHub] storm issue #1458: STORM-1878: Flux can now handle IStatefulBolts

2016-06-03 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1458 +1 --- 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

[GitHub] storm issue #1437: STORM-1859: Ack late tuples in windowed mode

2016-06-03 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1437 @abhishej This will be part of the next release i.e. 1.0.2. If you want it now, you could clone the 1.0.x branch (or the 1.0.1 tag and cherry-pick the commit). You can build the distribution

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65659063 --- Diff: storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java --- @@ -284,6 +298,10 @@ public void cleanup

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65573427 --- Diff: storm-core/src/jvm/org/apache/storm/topology/base/BaseWindowedBolt.java --- @@ -255,6 +255,22 @@ public BaseWindowedBolt withTimestampField

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65574257 --- Diff: storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java --- @@ -284,6 +298,10 @@ public void cleanup

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65573649 --- Diff: storm-core/src/jvm/org/apache/storm/topology/base/BaseWindowedBolt.java --- @@ -255,6 +255,22 @@ public BaseWindowedBolt withTimestampField

[GitHub] storm issue #1458: STORM-1878: Flux can now handle IStatefulBolts

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1458 @sakanaou Thanks for the patch. Can you also add an example flux topology with an IStatefulBolt similar to to existing ones under https://github.com/apache/storm/tree/master/external

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r6185 --- Diff: storm-core/src/jvm/org/apache/storm/Config.java --- @@ -1872,6 +1872,13 @@ @isString public static final String

[GitHub] storm issue #1453: STORM-1873 Implement alternative behaviour for late tuple...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1453 I have gone through the details and have left some comments. Can you update the [documentation](https://github.com/apache/storm/blob/master/docs/Windowing.md) where it references late tuples

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65500717 --- Diff: storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java --- @@ -268,8 +277,12 @@ public void execute(Tuple input

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65500739 --- Diff: storm-core/src/jvm/org/apache/storm/topology/base/BaseWindowedBolt.java --- @@ -255,6 +255,17 @@ public BaseWindowedBolt withTimestampField

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65500709 --- Diff: storm-core/src/jvm/org/apache/storm/Config.java --- @@ -1872,6 +1872,13 @@ @isString public static final String

[GitHub] storm pull request: STORM-1859: Ack late tuples in windowed mode

2016-05-25 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1437#issuecomment-221622376 Thanks @kosii merged to master, 1.x and 1.0.x branches. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] storm pull request: [STORM-1851] Fix default nimbus impersonation ...

2016-05-24 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1435#issuecomment-221176923 @ptgoetz can you review and merge? --- 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

[GitHub] storm pull request: [STORM-1851] Fix default nimbus impersonation ...

2016-05-23 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1435#issuecomment-221170903 @hmcl updated the docs. --- 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

[GitHub] storm pull request: [STORM-1851] Fix default nimbus impersonation ...

2016-05-23 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1435#issuecomment-221167394 @hmcl the details of setting up impersonation is documented in https://github.com/apache/storm/blob/master/docs/SECURITY.md Maybe I can explicitly mention

[GitHub] storm pull request: STORM-1859: Ack late tuples in windowed mode

2016-05-23 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1437#issuecomment-220928223 +1 --- 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

[GitHub] storm pull request: STORM-1850: State Checkpointing Documentation ...

2016-05-23 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1433#issuecomment-220897907 @HeartSaVioR thanks for noticing. The changes are now merged to master, 1.x-branch and 1.0.x-branch. @omallassi thanks for the patch. You may close

[GitHub] storm pull request: STORM-1850: State Checkpointing Documentation ...

2016-05-23 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1433#issuecomment-220894358 Thanks @omallassi this is merged to master and 1.x-branch. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] storm pull request: Ack late tuples in windowed mode

2016-05-22 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1437#issuecomment-220890249 @kosii Thanks for the patch, it looks good. Can you open a [JIRA](https://issues.apache.org/jira/browse/STORM) and update the PR title to include the JIRA ID

[GitHub] storm pull request: [STORM-1851] Fix default nimbus impersonation ...

2016-05-19 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1435#issuecomment-220376579 @harshach can you take a look ? --- 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

[GitHub] storm pull request: [STORM-1851] Fix default nimbus impersonation ...

2016-05-19 Thread arunmahadevan
GitHub user arunmahadevan opened a pull request: https://github.com/apache/storm/pull/1435 [STORM-1851] Fix default nimbus impersonation authorizer config "nimbus.impersonation.authorizer" is set to "ImpersonationAuthorizer" by default and this causes issu

[GitHub] storm pull request: STORM-1850: State Checkpointing Documentation ...

2016-05-19 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1433#issuecomment-220280889 +1 --- 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

[GitHub] storm pull request: STORM-1841: Address a few minor issues in wind...

2016-05-16 Thread arunmahadevan
GitHub user arunmahadevan opened a pull request: https://github.com/apache/storm/pull/1420 STORM-1841: Address a few minor issues in windowing and doc 1. Do not accept negative values for window length or sliding interval in BaseWindowedBolt 2. Added static factories for Count

[GitHub] storm pull request: [STORM-1833] Simple equi-join in storm-sql sta...

2016-05-13 Thread arunmahadevan
GitHub user arunmahadevan opened a pull request: https://github.com/apache/storm/pull/1413 [STORM-1833] Simple equi-join in storm-sql standalone mode Added support for simple equi-joins with single condition in storm-sql standalone mode. Note: this includes changes from

[GitHub] storm pull request: [STORM-1709] Added group by support in storm s...

2016-05-12 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1336#issuecomment-218702333 @harshach @haohui can you take a look? --- 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

[GitHub] storm pull request: STORM-1733 (0.10.x) Flush stdout and stderr be...

2016-04-28 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1373#issuecomment-215623175 +1 @ptgoetz since you are cutting the 0.10.1 RC, should this wait to merge to 0.10.x branch? --- If your project is set up for it, you can reply

[GitHub] storm pull request: STORM-1733 (0.1.x) Flush stdout and stderr bef...

2016-04-28 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1374#issuecomment-215623115 +1 @ptgoetz since you are cutting the 1.0.1 RC, should this wait to merge to 1.x branch? --- If your project is set up for it, you can reply to this email

[GitHub] storm pull request: STORM-1733 Flush stdout and stderr before call...

2016-04-28 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1360#issuecomment-215622873 Thanks @dsKarthick merged to master. --- 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

<    1   2   3   4   5   6   7   8   >