Hi devs,
I'm experimenting with ARRAY and MAP type with Calcite's JaninoRexCompiler.
(with Calcite 1.9.0)
While testing I found some behaviors, so would like to see they're
intentional
or bugs we want to resolve.
1. Even though I set map's key/value type or array's type explicitly,
compiler igno
GitHub user abellina opened a pull request:
https://github.com/apache/storm/pull/1713
Storm 2124 show requested cpu mem for each component
Work done by @jerrypeng at Yahoo. I tweaked the UI a bit. Most of the
change is in the generated thrift code.
You can merge this pull request i
Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/1710#discussion_r80324279
--- Diff:
storm-core/test/jvm/org/apache/storm/PaceMakerStateStorageFactoryTest.java ---
@@ -20,13 +20,22 @@
import org.apache.storm.cluster.PaceMakerStateSt
Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/1710#discussion_r80314321
--- Diff: conf/defaults.yaml ---
@@ -276,6 +276,7 @@ resource.aware.scheduler.priority.strategy:
"org.apache.storm.scheduler.resource
dev.zookeeper.path: "/t
Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/1710#discussion_r80323247
--- Diff:
storm-core/src/jvm/org/apache/storm/pacemaker/PacemakerClientHandler.java ---
@@ -69,7 +69,7 @@ else if(evm instanceof HBMessage) {
@Over
Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/1710#discussion_r80321800
--- Diff:
storm-core/src/jvm/org/apache/storm/cluster/PaceMakerStateStorage.java ---
@@ -160,13 +179,23 @@ public void set_worker_hb(String path, byte[] data,
Li
Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/1710#discussion_r80319044
--- Diff:
storm-core/src/jvm/org/apache/storm/pacemaker/PacemakerClientPool.java ---
@@ -0,0 +1,114 @@
+/**
+ * Licensed to the Apache Software Foundation
Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/1710#discussion_r80319682
--- Diff:
storm-core/src/jvm/org/apache/storm/pacemaker/PacemakerClientPool.java ---
@@ -0,0 +1,114 @@
+/**
+ * Licensed to the Apache Software Foundation
Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/1710#discussion_r80321976
--- Diff:
storm-core/src/jvm/org/apache/storm/cluster/PaceMakerStateStorageFactory.java
---
@@ -18,48 +18,22 @@
package org.apache.storm.cluster;
Github user asmaier commented on the issue:
https://github.com/apache/storm/pull/1711
I created the JIRA ticket STORM-2123 and added an Apache license header.
---
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 projec
Github user revans2 commented on the issue:
https://github.com/apache/storm/pull/1697
Still have #1699 and #1712 to backport before this is ready
---
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 ha
Github user revans2 commented on the issue:
https://github.com/apache/storm/pull/1712
The travis failure here is an odd one, it looks like it failed because some
integration tests that didn't run before are now running and took so long
travis timed them out.
---
If your project is s
Github user kamleshbhatt commented on a diff in the pull request:
https://github.com/apache/storm/pull/1677#discussion_r80296458
--- Diff: storm-core/src/jvm/org/apache/storm/command/AdminCommands.java ---
@@ -0,0 +1,133 @@
+/**
+ * Licensed to the Apache Software Foundation
Github user kamleshbhatt commented on a diff in the pull request:
https://github.com/apache/storm/pull/1677#discussion_r80294599
--- Diff: storm-core/src/jvm/org/apache/storm/command/AdminCommands.java ---
@@ -0,0 +1,133 @@
+/**
+ * Licensed to the Apache Software Foundation
Github user asfgit closed the pull request at:
https://github.com/apache/storm/pull/1705
---
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 kamleshbhatt commented on a diff in the pull request:
https://github.com/apache/storm/pull/1677#discussion_r80293802
--- Diff: bin/storm.py ---
@@ -572,6 +572,22 @@ def kill_workers(*args):
jvmtype="-client",
extrajars=[USER_CONF_DIR, os.path.jo
Github user knusbaum closed the pull request at:
https://github.com/apache/storm/pull/1710
---
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 en
GitHub user knusbaum reopened a pull request:
https://github.com/apache/storm/pull/1710
STORM-1546: Adding Read and Write Aggregations for Pacemaker to make it HA
compatible
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/knusba
Github user revans2 commented on the issue:
https://github.com/apache/storm/pull/1699
Rebased and addressed the review 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
e
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1699#discussion_r80282664
--- Diff:
storm-core/src/jvm/org/apache/storm/daemon/supervisor/timer/SupervisorHeartbeat.java
---
@@ -72,10 +72,10 @@ private SupervisorInfo buildSupervisor
Github user ptgoetz commented on a diff in the pull request:
https://github.com/apache/storm/pull/1711#discussion_r80280538
--- Diff:
external/storm-kafka/src/jvm/org/apache/storm/kafka/ByteKeyValueScheme.java ---
@@ -0,0 +1,33 @@
+package org.apache.storm.kafka;
--- End di
Github user ptgoetz commented on the issue:
https://github.com/apache/storm/pull/1711
@asmaier Could you create a JIRA ticket for this and update the title so
it's prefixed with the JIRA ID?
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user ptgoetz commented on the issue:
https://github.com/apache/storm/pull/1691
@raghavgautam Nope. All is 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
GitHub user revans2 opened a pull request:
https://github.com/apache/storm/pull/1712
STORM-2122: Cache dependency data, and serialize reading of the data.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/revans2/incubator-storm ST
Github user jerrypeng commented on the issue:
https://github.com/apache/storm/pull/1654
LGTM +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, or if the f
GitHub user asmaier opened a pull request:
https://github.com/apache/storm/pull/1711
Added ByteKeyValueScheme class.
It is a common use case to send and receive byte key and values via Kafka.
Unfortunately the storm-kafka package misses support for this. So I added a
ByteKeyValueSc
GitHub user knusbaum opened a pull request:
https://github.com/apache/storm/pull/1710
STORM-1546: Adding Read and Write Aggregations for Pacemaker to make it HA
compatible
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/knusbaum
27 matches
Mail list logo
