[
https://issues.apache.org/jira/browse/STORM-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352412#comment-15352412
]
ASF GitHub Bot commented on STORM-1901:
---
Github user vesense commented on the issue:
Github user vesense commented on the issue:
https://github.com/apache/storm/pull/1521
@dossett BTW, I have a question about `ConfluentAvroSerializer`:
I can't see any unit tests for `ConfluentAvroSerializer`. I wonder how kryo
create the object by using construction `ConfluentAvroS
[
https://issues.apache.org/jira/browse/STORM-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352393#comment-15352393
]
ASF GitHub Bot commented on STORM-1901:
---
Github user vesense commented on the issue:
Github user vesense commented on the issue:
https://github.com/apache/storm/pull/1521
The reason why I define the new interface `DirectAvroSerializer` and move
avro to a sharable module is explained as above.
@harshach This PR is based on STORM-1504, you can take a look at it.
[
https://issues.apache.org/jira/browse/STORM-1932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352307#comment-15352307
]
ASF GitHub Bot commented on STORM-1932:
---
GitHub user darionyaphet opened a pull requ
GitHub user darionyaphet opened a pull request:
https://github.com/apache/storm/pull/1527
[STORM-1932] Change Duration's value data type
[STORM-1932](https://issues.apache.org/jira/browse/STORM-1932)
BaseWindowedBolt Duration value is integer now .
Use long to expr
[
https://issues.apache.org/jira/browse/STORM-1932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
darion yaphet updated STORM-1932:
-
Description: BaseWindowedBolt Duration value is integer now . Use long to
express time interval ma
[
https://issues.apache.org/jira/browse/STORM-1932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
darion yaphet updated STORM-1932:
-
Description: BaseWindowedBolt Duration value is integer . Use long to
express time interval maybe
[
https://issues.apache.org/jira/browse/STORM-1932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
darion yaphet updated STORM-1932:
-
Description: BaseWindowedBolt
> Change Duration's value data type
>
darion yaphet created STORM-1932:
Summary: Change Duration's value data type
Key: STORM-1932
URL: https://issues.apache.org/jira/browse/STORM-1932
Project: Apache Storm
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/STORM-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jungtaek Lim resolved STORM-1924.
-
Resolution: Fixed
Assignee: Sivaguru Kannan
Fix Version/s: 1.1.0
Github user HeartSaVioR commented on the issue:
https://github.com/apache/storm/pull/1512
Merged (cherry-pick) to master, 1.x, 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 not have
[
https://issues.apache.org/jira/browse/STORM-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352191#comment-15352191
]
ASF GitHub Bot commented on STORM-1924:
---
Github user HeartSaVioR commented on the is
Github user HeartSaVioR commented on the issue:
https://github.com/apache/storm/pull/1512
Sorry I need to revert merging this and set commit message to contain
STORM-1924.
Sign-off information is overwritten to me
(eac9641469b79251f5146be4dcf8e52e6914448f), so please feel free to
Github user vesense commented on a diff in the pull request:
https://github.com/apache/storm/pull/1521#discussion_r68685946
--- Diff:
external/storm-kafka/src/jvm/org/apache/storm/kafka/AvroScheme.java ---
@@ -0,0 +1,59 @@
+/**
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/STORM-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352188#comment-15352188
]
ASF GitHub Bot commented on STORM-1901:
---
Github user vesense commented on a diff in
Github user asfgit closed the pull request at:
https://github.com/apache/storm/pull/1512
---
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, or if the feature is enab
Github user HeartSaVioR commented on the issue:
https://github.com/apache/storm/pull/1512
+1 Thanks @csivaguru.
---
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
Github user vesense commented on a diff in the pull request:
https://github.com/apache/storm/pull/1521#discussion_r68683162
--- Diff: external/storm-kafka/README.md ---
@@ -360,6 +361,44 @@ For Trident:
StormSubmitter.submitTopology("kafkaTridentTest", conf,
topology.b
[
https://issues.apache.org/jira/browse/STORM-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352151#comment-15352151
]
ASF GitHub Bot commented on STORM-1901:
---
Github user vesense commented on a diff in
Github user dossett commented on a diff in the pull request:
https://github.com/apache/storm/pull/1521#discussion_r68658648
--- Diff:
external/storm-kafka/src/jvm/org/apache/storm/kafka/AvroScheme.java ---
@@ -0,0 +1,59 @@
+/**
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/STORM-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351852#comment-15351852
]
ASF GitHub Bot commented on STORM-1901:
---
Github user dossett commented on the issue:
[
https://issues.apache.org/jira/browse/STORM-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351846#comment-15351846
]
ASF GitHub Bot commented on STORM-1901:
---
Github user dossett commented on a diff in
Github user dossett commented on the issue:
https://github.com/apache/storm/pull/1521
@harshach My interpretation of the PR is that it moves some Avro speficif
code I added to storm-hdfs into a more sharable module.
@vesense I like the idea of making it easier to read/write av
Github user dossett commented on a diff in the pull request:
https://github.com/apache/storm/pull/1521#discussion_r68657788
--- Diff: external/storm-kafka/README.md ---
@@ -360,6 +361,44 @@ For Trident:
StormSubmitter.submitTopology("kafkaTridentTest", conf,
topology.b
[
https://issues.apache.org/jira/browse/STORM-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351832#comment-15351832
]
ASF GitHub Bot commented on STORM-1901:
---
Github user dossett commented on a diff in
Github user csivaguru commented on the issue:
https://github.com/apache/storm/pull/1512
Can this be merged in? @harshach @HeartSaVioR
---
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 fea
Hi,
In one worker, by default Storm creates one-executor and
one-executor-disruptor threads pair.
In detail, it created __system, __acker, and __bolt or __spout.
I understood __acker and __bolt or __spout, but what is the roles of
__system and __system-disruptor threads?
Another question is a b
[
https://issues.apache.org/jira/browse/STORM-1928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351219#comment-15351219
]
ASF GitHub Bot commented on STORM-1928:
---
GitHub user HeartSaVioR opened a pull reque
GitHub user HeartSaVioR opened a pull request:
https://github.com/apache/storm/pull/1526
STORM-1928 ShellSpout should check heartbeat while ShellSpout is waiting
for subprocess to sync
When nextTuple is not calling at any chances (max spout pending,
backpressure introduced at 1.0.0
[
https://issues.apache.org/jira/browse/STORM-1928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jungtaek Lim updated STORM-1928:
Summary: ShellSpout should check heartbeat while ShellSpout is waiting for
subprocess to sync (was:
[
https://issues.apache.org/jira/browse/STORM-1931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351115#comment-15351115
]
ASF GitHub Bot commented on STORM-1931:
---
GitHub user darionyaphet opened a pull requ
GitHub user darionyaphet opened a pull request:
https://github.com/apache/storm/pull/1525
[STORM-1931] Share mapper and selector in Storm-Kafka
[STORM-1931](https://issues.apache.org/jira/browse/STORM-1931)
Storm Kafka's mapper and selector and Storm Kafka trident's mapper a
darion yaphet created STORM-1931:
Summary: Share mapper and selector in Storm-Kafka
Key: STORM-1931
URL: https://issues.apache.org/jira/browse/STORM-1931
Project: Apache Storm
Issue Type: Imp
Github user obiwabrakenobi commented on the issue:
https://github.com/apache/storm/pull/1096
i'll update the docs @HeartSaVioR
---
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
e
[
https://issues.apache.org/jira/browse/STORM-1919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350669#comment-15350669
]
ASF GitHub Bot commented on STORM-1919:
---
Github user darionyaphet commented on the i
Github user darionyaphet commented on the issue:
https://github.com/apache/storm/pull/1517
@HeartSaVioR Thank you for you Great Work . I have a small question about
`Mapper` extention structure .
---
If your project is set up for it, you can reply to this email and have your
reply ap
[
https://issues.apache.org/jira/browse/STORM-1919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350663#comment-15350663
]
ASF GitHub Bot commented on STORM-1919:
---
Github user darionyaphet commented on a dif
Github user darionyaphet commented on a diff in the pull request:
https://github.com/apache/storm/pull/1517#discussion_r68543199
--- Diff: external/storm-redis/README.md ---
@@ -21,13 +21,16 @@ use it as a maven dependency:
### For normal Bolt
-Storm-redis provi
[
https://issues.apache.org/jira/browse/STORM-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350637#comment-15350637
]
ASF GitHub Bot commented on STORM-1719:
---
GitHub user HeartSaVioR opened a pull reque
GitHub user HeartSaVioR opened a pull request:
https://github.com/apache/storm/pull/1524
STORM-1719 Introduce REST API: Topology metric stats for stream
* Path: /api/v1/topology/:id/metrics
* This API provides detailed metrics for topology
** shows metrics per component, whic
[
https://issues.apache.org/jira/browse/STORM-1311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350630#comment-15350630
]
Jark Wu commented on STORM-1311:
Hi [~darion], this is an origin discussion about REST fr
[
https://issues.apache.org/jira/browse/STORM-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350621#comment-15350621
]
ASF GitHub Bot commented on STORM-1886:
---
Github user arunmahadevan commented on the
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 is set
[
https://issues.apache.org/jira/browse/STORM-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350577#comment-15350577
]
ASF GitHub Bot commented on STORM-1886:
---
Github user arunmahadevan commented on a di
[
https://issues.apache.org/jira/browse/STORM-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350573#comment-15350573
]
ASF GitHub Bot commented on STORM-1886:
---
Github user arunmahadevan commented on a di
[
https://issues.apache.org/jira/browse/STORM-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350575#comment-15350575
]
ASF GitHub Bot commented on STORM-1886:
---
Github user arunmahadevan commented on a di
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(lo
[
https://issues.apache.org/jira/browse/STORM-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350576#comment-15350576
]
ASF GitHub Bot commented on STORM-1886:
---
Github user arunmahadevan commented on a di
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(Str
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(Str
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(Str
52 matches
Mail list logo
