[jira] [Updated] (STORM-1961) Come up with streams api for storm core use cases

[ https://issues.apache.org/jira/browse/STORM-1961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan updated STORM-1961: -- Attachment: UnifiedStreamapiforStorm.pdf The high level design and api doc. I have been making

[jira] [Commented] (STORM-2047) In secure setup the log page can't be viewed

[ https://issues.apache.org/jira/browse/STORM-2047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15427634#comment-15427634 ] Arun Mahadevan commented on STORM-2047: --- [~raghavgautam] The storm security doc

[jira] [Updated] (STORM-2042) Nimbus client connections not closed properly causing connection leaks

[ https://issues.apache.org/jira/browse/STORM-2042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan updated STORM-2042: -- Fix Version/s: 1.x 2.0.0 > Nimbus client connections not closed properly

[jira] [Commented] (STORM-1434) Support the GROUP BY clause in StormSQL

[ https://issues.apache.org/jira/browse/STORM-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15422735#comment-15422735 ] Arun Mahadevan commented on STORM-1434: --- [~kabhwan] Trident supports two kinds of aggregates on

[jira] [Created] (STORM-2037) debug operation should be whitelisted in SimpleAclAuthorizer

Arun Mahadevan created STORM-2037: - Summary: debug operation should be whitelisted in SimpleAclAuthorizer Key: STORM-2037 URL: https://issues.apache.org/jira/browse/STORM-2037 Project: Apache Storm

[jira] [Commented] (STORM-2027) Possible Race Condition issue in SlidingWindow

[ https://issues.apache.org/jira/browse/STORM-2027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15412986#comment-15412986 ] Arun Mahadevan commented on STORM-2027: --- [~kabhwan] I havent looked deeper, but it looks like the

[jira] [Created] (STORM-1987) Fix TridentKafkaWordCount arg handling

Arun Mahadevan created STORM-1987: - Summary: Fix TridentKafkaWordCount arg handling Key: STORM-1987 URL: https://issues.apache.org/jira/browse/STORM-1987 Project: Apache Storm Issue Type:

[jira] [Assigned] (STORM-1964) Unexpected behavior when using count window together with timestamp extraction

[ https://issues.apache.org/jira/browse/STORM-1964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan reassigned STORM-1964: - Assignee: Arun Mahadevan > Unexpected behavior when using count window together with

[jira] [Created] (STORM-1968) Storm logviewer does not work for nimbus.log in secure cluster

Arun Mahadevan created STORM-1968: - Summary: Storm logviewer does not work for nimbus.log in secure cluster Key: STORM-1968 URL: https://issues.apache.org/jira/browse/STORM-1968 Project: Apache Storm

[jira] [Resolved] (STORM-1873) Reemit late tuples in windowed mode

[ https://issues.apache.org/jira/browse/STORM-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan resolved STORM-1873. --- Resolution: Fixed Fix Version/s: 1.1.0 2.0.0 > Reemit late tuples

[jira] [Resolved] (STORM-1878) Flux does not handle stateful bolts

[ https://issues.apache.org/jira/browse/STORM-1878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan resolved STORM-1878. --- Resolution: Fixed Fix Version/s: 1.1.0 1.0.2

[jira] [Created] (STORM-1868) Modify TridentKafkaWordCount to run in distributed mode

Arun Mahadevan created STORM-1868: - Summary: Modify TridentKafkaWordCount to run in distributed mode Key: STORM-1868 URL: https://issues.apache.org/jira/browse/STORM-1868 Project: Apache Storm

[jira] [Resolved] (STORM-1859) Late tuples are not acked in windowed mode

[ https://issues.apache.org/jira/browse/STORM-1859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan resolved STORM-1859. --- Resolution: Fixed Fix Version/s: 1.1.0 1.0.2

[jira] [Resolved] (STORM-1850) State Checkpointing documentation update regarding spout state management

[ https://issues.apache.org/jira/browse/STORM-1850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan resolved STORM-1850. --- Resolution: Fixed Fix Version/s: 1.1.0 2.0.0 > State Checkpointing

[jira] [Commented] (STORM-1841) Address a few minor issues in windowing and doc

[ https://issues.apache.org/jira/browse/STORM-1841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15294011#comment-15294011 ] Arun Mahadevan commented on STORM-1841: --- Thanks [~raghavgautam] for finding and reporting this

[jira] [Created] (STORM-1851) Nimbus impersonation authorizer in defaults.yaml causes issues in secure mode

Arun Mahadevan created STORM-1851: - Summary: Nimbus impersonation authorizer in defaults.yaml causes issues in secure mode Key: STORM-1851 URL: https://issues.apache.org/jira/browse/STORM-1851

[jira] [Commented] (STORM-1757) Apache Beam Runner for Storm

[ https://issues.apache.org/jira/browse/STORM-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15287098#comment-15287098 ] Arun Mahadevan commented on STORM-1757: --- > So if I ask all bolts to checkpoint and most succeed but

[jira] [Commented] (STORM-1757) Apache Beam Runner for Storm

[ https://issues.apache.org/jira/browse/STORM-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15286896#comment-15286896 ] Arun Mahadevan commented on STORM-1757: --- The state transition doc tries to explain some of this.

[jira] [Commented] (STORM-1757) Apache Beam Runner for Storm

[ https://issues.apache.org/jira/browse/STORM-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15286881#comment-15286881 ] Arun Mahadevan commented on STORM-1757: --- [~revans2] the current checkpointing supports at-least once

[jira] [Created] (STORM-1841) Address a few minor issues in windowing and doc

Arun Mahadevan created STORM-1841: - Summary: Address a few minor issues in windowing and doc Key: STORM-1841 URL: https://issues.apache.org/jira/browse/STORM-1841 Project: Apache Storm Issue

[jira] [Commented] (STORM-1757) Apache Beam Runner for Storm

[ https://issues.apache.org/jira/browse/STORM-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284767#comment-15284767 ] Arun Mahadevan commented on STORM-1757: --- [~revans2] distributed checkpointing implemented on top of

[jira] [Commented] (STORM-1757) Apache Beam Runner for Storm

[ https://issues.apache.org/jira/browse/STORM-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284266#comment-15284266 ] Arun Mahadevan commented on STORM-1757: --- Multiple active windows what [~satish.duggana] is proposing

[jira] [Created] (STORM-1833) Add simple equi-join support in storm-sql standalone mode

Arun Mahadevan created STORM-1833: - Summary: Add simple equi-join support in storm-sql standalone mode Key: STORM-1833 URL: https://issues.apache.org/jira/browse/STORM-1833 Project: Apache Storm

[jira] [Commented] (STORM-1757) Apache Beam Runner for Storm

[ https://issues.apache.org/jira/browse/STORM-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15282475#comment-15282475 ] Arun Mahadevan commented on STORM-1757: --- Unified storm stream api is ideal but could be a bigger

[jira] [Commented] (STORM-1757) Apache Beam Runner for Storm

[ https://issues.apache.org/jira/browse/STORM-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268155#comment-15268155 ] Arun Mahadevan commented on STORM-1757: --- Would like to collaborate in this effort. > Apache Beam

[jira] [Created] (STORM-1714) StatefulBolts ends up as normal bolts while using TopologyBuilder.setBolt without parallelism

Arun Mahadevan created STORM-1714: - Summary: StatefulBolts ends up as normal bolts while using TopologyBuilder.setBolt without parallelism Key: STORM-1714 URL: https://issues.apache.org/jira/browse/STORM-1714

[jira] [Created] (STORM-1711) Kerberos principals gets mixed up while using storm-hive

Arun Mahadevan created STORM-1711: - Summary: Kerberos principals gets mixed up while using storm-hive Key: STORM-1711 URL: https://issues.apache.org/jira/browse/STORM-1711 Project: Apache Storm

[jira] [Created] (STORM-1709) Add group by support in storm-sql standalone mode

Arun Mahadevan created STORM-1709: - Summary: Add group by support in storm-sql standalone mode Key: STORM-1709 URL: https://issues.apache.org/jira/browse/STORM-1709 Project: Apache Storm

[jira] [Updated] (STORM-1692) HBaseSecurityUtil#login modifies the current UGI causing issues if two instances are running with different credentials

[ https://issues.apache.org/jira/browse/STORM-1692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan updated STORM-1692: -- Summary: HBaseSecurityUtil#login modifies the current UGI causing issues if two instances are

[jira] [Commented] (STORM-1692) org.apache.storm.hbase.security.HBaseSecurityUtil#login uses broken double checked locking.

[ https://issues.apache.org/jira/browse/STORM-1692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15229845#comment-15229845 ] Arun Mahadevan commented on STORM-1692: --- HBaseSecurityUtil uses legacyprovider.login(), which

[jira] [Created] (STORM-1662) Reduce map lookups in send_to_eventlogger

Arun Mahadevan created STORM-1662: - Summary: Reduce map lookups in send_to_eventlogger Key: STORM-1662 URL: https://issues.apache.org/jira/browse/STORM-1662 Project: Apache Storm Issue Type:

[jira] [Created] (STORM-1615) Update state checkpointing doc with bolt's acking contract

Arun Mahadevan created STORM-1615: - Summary: Update state checkpointing doc with bolt's acking contract Key: STORM-1615 URL: https://issues.apache.org/jira/browse/STORM-1615 Project: Apache Storm

[jira] [Updated] (STORM-1608) Fix stateful topology acking behavior

[ https://issues.apache.org/jira/browse/STORM-1608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan updated STORM-1608: -- Summary: Fix stateful topology acking behavior (was: Fix stateful bolt acking behavior) > Fix

[jira] [Created] (STORM-1608) Fix stateful bolt acking behavior

Arun Mahadevan created STORM-1608: - Summary: Fix stateful bolt acking behavior Key: STORM-1608 URL: https://issues.apache.org/jira/browse/STORM-1608 Project: Apache Storm Issue Type: Bug

[jira] [Created] (STORM-1586) ExprCompiler support for UDFs in Storm-sql

Arun Mahadevan created STORM-1586: - Summary: ExprCompiler support for UDFs in Storm-sql Key: STORM-1586 URL: https://issues.apache.org/jira/browse/STORM-1586 Project: Apache Storm Issue

[jira] [Assigned] (STORM-1586) ExprCompiler support for UDFs in Storm-sql

[ https://issues.apache.org/jira/browse/STORM-1586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan reassigned STORM-1586: - Assignee: Arun Mahadevan > ExprCompiler support for UDFs in Storm-sql >

[jira] [Created] (STORM-1585) Add DDL support for UDFs in Storm-sql

Arun Mahadevan created STORM-1585: - Summary: Add DDL support for UDFs in Storm-sql Key: STORM-1585 URL: https://issues.apache.org/jira/browse/STORM-1585 Project: Apache Storm Issue Type:

[jira] [Created] (STORM-1584) Support UDF in storm-sql

Arun Mahadevan created STORM-1584: - Summary: Support UDF in storm-sql Key: STORM-1584 URL: https://issues.apache.org/jira/browse/STORM-1584 Project: Apache Storm Issue Type: Improvement

[jira] [Updated] (STORM-1570) Support nested field lookup in Storm sql

[ https://issues.apache.org/jira/browse/STORM-1570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan updated STORM-1570: -- Summary: Support nested field lookup in Storm sql (was: Support nested field lookup and user

[jira] [Created] (STORM-1576) TopologyBuilder fails with ConcurrentModification in addCheckPointInputs for stateful topologies

Arun Mahadevan created STORM-1576: - Summary: TopologyBuilder fails with ConcurrentModification in addCheckPointInputs for stateful topologies Key: STORM-1576 URL: https://issues.apache.org/jira/browse/STORM-1576

[jira] [Updated] (STORM-1576) TopologyBuilder fails with ConcurrentModification in addCheckPointInputs for stateful topologies

[ https://issues.apache.org/jira/browse/STORM-1576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan updated STORM-1576: -- Affects Version/s: 2.0.0 1.0.0 > TopologyBuilder fails with

[jira] [Created] (STORM-1570) Support nested field lookup and user defined functions in Storm sql

Arun Mahadevan created STORM-1570: - Summary: Support nested field lookup and user defined functions in Storm sql Key: STORM-1570 URL: https://issues.apache.org/jira/browse/STORM-1570 Project: Apache

[jira] [Resolved] (STORM-1566) Worker exits with error o.a.s.d.worker [ERROR] Error on initialization of server mk-worker java.lang.ClassCastException: java.lang.String cannot be cast to java.io.File

[ https://issues.apache.org/jira/browse/STORM-1566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan resolved STORM-1566. --- Resolution: Fixed Fix Version/s: 2.0.0 Thanks [~satish.duggana] merged to master. >

[jira] [Resolved] (STORM-1558) Utils in java breaks component page due to illegal type cast

[ https://issues.apache.org/jira/browse/STORM-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan resolved STORM-1558. --- Resolution: Fixed Thanks [~Cody] merged to master. > Utils in java breaks component page due

[jira] [Commented] (STORM-1540) Topology Debug/Sampling Breaks Trident Topologies

[ https://issues.apache.org/jira/browse/STORM-1540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148380#comment-15148380 ] Arun Mahadevan commented on STORM-1540: --- Actually this issue happens only when the trident tuples

[jira] [Created] (STORM-1552) Fix topology event sampling log directory

Arun Mahadevan created STORM-1552: - Summary: Fix topology event sampling log directory Key: STORM-1552 URL: https://issues.apache.org/jira/browse/STORM-1552 Project: Apache Storm Issue

[jira] [Created] (STORM-1550) Fix storm.cmd to pass url-encoded options

Arun Mahadevan created STORM-1550: - Summary: Fix storm.cmd to pass url-encoded options Key: STORM-1550 URL: https://issues.apache.org/jira/browse/STORM-1550 Project: Apache Storm Issue Type:

[jira] [Commented] (STORM-1532) Fix readCommandLineOpts to parse JSON correctly

[ https://issues.apache.org/jira/browse/STORM-1532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15138858#comment-15138858 ] Arun Mahadevan commented on STORM-1532: --- -c drpc.servers=[\"host1\"] works > Fix

[jira] [Commented] (STORM-1532) Fix readCommandLineOpts to parse JSON correctly

[ https://issues.apache.org/jira/browse/STORM-1532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15138898#comment-15138898 ] Arun Mahadevan commented on STORM-1532: --- Actually this seems to be an issue only with storm.cmd.

[jira] [Created] (STORM-1532) Fix readCommandLineOpts to parse JSON correctly

Arun Mahadevan created STORM-1532: - Summary: Fix readCommandLineOpts to parse JSON correctly Key: STORM-1532 URL: https://issues.apache.org/jira/browse/STORM-1532 Project: Apache Storm Issue

[jira] [Commented] (STORM-1476) Filter -c options from args and add them as part of storm.options

[ https://issues.apache.org/jira/browse/STORM-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15140427#comment-15140427 ] Arun Mahadevan commented on STORM-1476: --- Thanks [~satish.duggana] merged to master and 1.x branch.

[jira] [Resolved] (STORM-1476) Filter -c options from args and add them as part of storm.options

[ https://issues.apache.org/jira/browse/STORM-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan resolved STORM-1476. --- Resolution: Fixed Fix Version/s: 2.0.0 > Filter -c options from args and add them as

[jira] [Created] (STORM-1527) Trident api doc for peek

Arun Mahadevan created STORM-1527: - Summary: Trident api doc for peek Key: STORM-1527 URL: https://issues.apache.org/jira/browse/STORM-1527 Project: Apache Storm Issue Type: Bug

[jira] [Created] (STORM-1517) Add peek api in trident stream

Arun Mahadevan created STORM-1517: - Summary: Add peek api in trident stream Key: STORM-1517 URL: https://issues.apache.org/jira/browse/STORM-1517 Project: Apache Storm Issue Type: Bug

[jira] [Created] (STORM-1513) Update trident api docs

Arun Mahadevan created STORM-1513: - Summary: Update trident api docs Key: STORM-1513 URL: https://issues.apache.org/jira/browse/STORM-1513 Project: Apache Storm Issue Type: Sub-task

[jira] [Updated] (STORM-1505) Add map, flatMap and filter operations in trident api

[ https://issues.apache.org/jira/browse/STORM-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan updated STORM-1505: -- Summary: Add map, flatMap and filter operations in trident api (was: Add map and flatMap

[jira] [Created] (STORM-1505) Add map and flatMap operations in trident api

Arun Mahadevan created STORM-1505: - Summary: Add map and flatMap operations in trident api Key: STORM-1505 URL: https://issues.apache.org/jira/browse/STORM-1505 Project: Apache Storm Issue

[jira] [Created] (STORM-1486) Fix Storm-kafka documentation to reflect changes from STORM-1220

Arun Mahadevan created STORM-1486: - Summary: Fix Storm-kafka documentation to reflect changes from STORM-1220 Key: STORM-1486 URL: https://issues.apache.org/jira/browse/STORM-1486 Project: Apache

[jira] [Commented] (STORM-1478) make bolt's getComponentConfiguration method cleaner/simpler

[ https://issues.apache.org/jira/browse/STORM-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15106600#comment-15106600 ] Arun Mahadevan commented on STORM-1478: --- Thanks [~vesense] merged to master. > make bolt's

[jira] [Resolved] (STORM-1478) make bolt's getComponentConfiguration method cleaner/simpler

[ https://issues.apache.org/jira/browse/STORM-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan resolved STORM-1478. --- Resolution: Fixed Fix Version/s: 2.0.0 > make bolt's getComponentConfiguration method

[jira] [Commented] (STORM-676) Storm Trident support sliding windows

[ https://issues.apache.org/jira/browse/STORM-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15092198#comment-15092198 ] Arun Mahadevan commented on STORM-676: -- [~satish.duggana] do you have any results from prototype that

[jira] [Resolved] (STORM-1411) some fixes for storm-windowing

[ https://issues.apache.org/jira/browse/STORM-1411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan resolved STORM-1411. --- Resolution: Fixed > some fixes for storm-windowing > -- > >

[jira] [Created] (STORM-1416) Add documentation for windowing state store functionality

Arun Mahadevan created STORM-1416: - Summary: Add documentation for windowing state store functionality Key: STORM-1416 URL: https://issues.apache.org/jira/browse/STORM-1416 Project: Apache Storm

[jira] [Resolved] (STORM-1389) unnecessary generatiion of projection tuples again in StateQueryProcessor#finishBatch

[ https://issues.apache.org/jira/browse/STORM-1389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan resolved STORM-1389. --- Resolution: Fixed > unnecessary generatiion of projection tuples again in >

[jira] [Updated] (STORM-1389) unnecessary generatiion of projection tuples again in StateQueryProcessor#finishBatch

[ https://issues.apache.org/jira/browse/STORM-1389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan updated STORM-1389: -- Fix Version/s: 0.11.0 > unnecessary generatiion of projection tuples again in >

[jira] [Updated] (STORM-1389) unnecessary generatiion of projection tuples again in StateQueryProcessor#finishBatch

[ https://issues.apache.org/jira/browse/STORM-1389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan updated STORM-1389: -- Affects Version/s: 0.11.0 > unnecessary generatiion of projection tuples again in >

[jira] [Created] (STORM-1219) Fix HDFS and Hive bolt flush/acking

Arun Mahadevan created STORM-1219: - Summary: Fix HDFS and Hive bolt flush/acking Key: STORM-1219 URL: https://issues.apache.org/jira/browse/STORM-1219 Project: Apache Storm Issue Type: Bug

[jira] [Commented] (STORM-1187) Support for late and out of order events in time based windows

[ https://issues.apache.org/jira/browse/STORM-1187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15011489#comment-15011489 ] Arun Mahadevan commented on STORM-1187: --- At a high level this is captured under "Tuple timestamp and

[jira] [Commented] (STORM-1187) Support for late and out of order events in time based windows

[ https://issues.apache.org/jira/browse/STORM-1187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15012801#comment-15012801 ] Arun Mahadevan commented on STORM-1187: --- The plan is to add support to core first and roll out

[jira] [Commented] (STORM-1187) Support for late and out of order events in time based windows

[ https://issues.apache.org/jira/browse/STORM-1187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15010316#comment-15010316 ] Arun Mahadevan commented on STORM-1187: --- Thanks for the inputs. Yes, the plan to to handle event

[jira] [Created] (STORM-1207) Add flux support for handling windowed bolts

Arun Mahadevan created STORM-1207: - Summary: Add flux support for handling windowed bolts Key: STORM-1207 URL: https://issues.apache.org/jira/browse/STORM-1207 Project: Apache Storm Issue

[jira] [Created] (STORM-1176) Checkpoint window evaluated state and use this to prune duplicate evaluations

Arun Mahadevan created STORM-1176: - Summary: Checkpoint window evaluated state and use this to prune duplicate evaluations Key: STORM-1176 URL: https://issues.apache.org/jira/browse/STORM-1176

[jira] [Created] (STORM-1175) State store for windowing operations

Arun Mahadevan created STORM-1175: - Summary: State store for windowing operations Key: STORM-1175 URL: https://issues.apache.org/jira/browse/STORM-1175 Project: Apache Storm Issue Type:

[jira] [Created] (STORM-1187) Support for late and out of order events in time based windows

Arun Mahadevan created STORM-1187: - Summary: Support for late and out of order events in time based windows Key: STORM-1187 URL: https://issues.apache.org/jira/browse/STORM-1187 Project: Apache Storm

[jira] [Created] (STORM-1167) Add sliding & tumbling window support for core storm

Arun Mahadevan created STORM-1167: - Summary: Add sliding & tumbling window support for core storm Key: STORM-1167 URL: https://issues.apache.org/jira/browse/STORM-1167 Project: Apache Storm

[jira] [Closed] (STORM-1137) loading data into postgresdb

[ https://issues.apache.org/jira/browse/STORM-1137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan closed STORM-1137. - Resolution: Invalid > loading data into postgresdb > > >

[jira] [Commented] (STORM-1137) loading data into postgresdb

[ https://issues.apache.org/jira/browse/STORM-1137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14978355#comment-14978355 ] Arun Mahadevan commented on STORM-1137: --- Multiple Jiras with same message again and again, it

[jira] [Resolved] (STORM-1029) Finalize default sampling pct and fields to log

[ https://issues.apache.org/jira/browse/STORM-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan resolved STORM-1029. --- Resolution: Fixed > Finalize default sampling pct and fields to log >

[jira] [Created] (STORM-1029) Finalize default sampling pct and fields to log

Arun Mahadevan created STORM-1029: - Summary: Finalize default sampling pct and fields to log Key: STORM-1029 URL: https://issues.apache.org/jira/browse/STORM-1029 Project: Apache Storm Issue

[jira] [Resolved] (STORM-1004) Option to specifiy a sampling rate for event inspector

[ https://issues.apache.org/jira/browse/STORM-1004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan resolved STORM-1004. --- Resolution: Fixed > Option to specifiy a sampling rate for event inspector >

[jira] [Commented] (STORM-1024) log4j changes leaving ${sys:storm.log.dir} under STORM_HOME dir

[ https://issues.apache.org/jira/browse/STORM-1024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14727700#comment-14727700 ] Arun Mahadevan commented on STORM-1024: --- [~sriharsha] Please review > log4j changes leaving

[jira] [Commented] (STORM-1024) log4j changes leaving ${sys:storm.log.dir} under STORM_HOME dir

[ https://issues.apache.org/jira/browse/STORM-1024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14727680#comment-14727680 ] Arun Mahadevan commented on STORM-1024: --- It appears that the "-Dstorm.log.dir" arg is not passed to

[jira] [Created] (STORM-1004) Option to specifiy a sampling rate for event inspector

Arun Mahadevan created STORM-1004: - Summary: Option to specifiy a sampling rate for event inspector Key: STORM-1004 URL: https://issues.apache.org/jira/browse/STORM-1004 Project: Apache Storm

[jira] [Created] (STORM-975) Storm-Kafka trident topology example

Arun Mahadevan created STORM-975: Summary: Storm-Kafka trident topology example Key: STORM-975 URL: https://issues.apache.org/jira/browse/STORM-975 Project: Apache Storm Issue Type:

[jira] [Commented] (STORM-954) Toplogy Event Inspector

[ https://issues.apache.org/jira/browse/STORM-954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14640965#comment-14640965 ] Arun Mahadevan commented on STORM-954: -- Putting down high level thoughts below. Have

[jira] [Commented] (STORM-837) HdfsState ignores commits

[ https://issues.apache.org/jira/browse/STORM-837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634566#comment-14634566 ] Arun Mahadevan commented on STORM-837: -- In HdfsState we support a TimedRotation policy

[jira] [Commented] (STORM-837) HdfsState ignores commits

[ https://issues.apache.org/jira/browse/STORM-837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14628608#comment-14628608 ] Arun Mahadevan commented on STORM-837: -- [~revans2] Can we add an option to log the

[jira] [Assigned] (STORM-837) HdfsState ignores commits

[ https://issues.apache.org/jira/browse/STORM-837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan reassigned STORM-837: Assignee: Arun Mahadevan HdfsState ignores commits -