Review Request 41416: SAMZA-449 Expose RocksDB statistic

/scala/org/apache/samza/storage/kv/TestRocksDbKeyValueStore.scala 0c86a5a1550894645c2ab0010b70b124ad3dbd98 Diff: https://reviews.apache.org/r/41416/diff/ Testing --- Thanks, Gustavo Anatoly F. V. Solís

Re: Review Request 39422: SAMZA-449 Expose RocksDB statistic

; I agree, to keep the only essencial. "Seems like most of these metrics are only useful for someone trying to benchmark the application's local state performance. Can we make turning on these metrics optional?" Nice, it'

Review Request 39422: SAMZA-449 Expose RocksDB statistic

-CREATION samza-kv-rocksdb/src/test/scala/org/apache/samza/storage/kv/TestRocksDbKeyValueStore.scala a428a16bc1e9ab4980a6f17db4fd810057d31136 Diff: https://reviews.apache.org/r/39422/diff/ Testing --- Thanks, Gustavo Anatoly F. V. Solís

Re: Review Request 36692: SAMZA-717 Expose the TaskNameGrouper API

/ContainerModel.java (line 32) <https://reviews.apache.org/r/36692/#comment146791> Remove trailing spaces - Gustavo Anatoly F. V. Solís On Julho 22, 2015, 2:03 p.m., József Márton Jung wrote: > > --- > This is an automatically gener

Re: Samza job on YARN stuck Unassigned

Hi Krzysztof, I had connectivity errors, but in my case was the /etc/hosts misconfigured. Cheers. 2015-07-10 12:11 GMT-03:00 Roger Hoover : > Hi Krzysztof, > > I haven't seen that error before. It does sound like it could be a > connection issue. Did you check that the YARN node has access >

Re: Review Request 36006: Writing a tool to read from the coordinator stream and react to config changes accordingly.

tps://reviews.apache.org/r/36006/#comment144096> Remove trailing whitespaces - Gustavo Anatoly F. V. Solís On Julho 2, 2015, 7:20 p.m., Shadi A. Noghabi wrote: > > --- > This is an automatically generated e-mail. To reply,

Re: Review Request 36163: SAMZA-690: changelog topic creation should not be in the container code

(line 62) <https://reviews.apache.org/r/36163/#comment144063> Hi, Robert. There are trailing whitespaces, that should be removed. You can use git diff before to submit the patch and check if there are some spaces. Cheers. - Gustavo Anatoly F. V. Solís On Julho 3, 2

Re: Review Request 35933: SAMZA-449 Expose RocksDB statistic

/RocksDbStatisticMetrics.scala PRE-CREATION samza-kv-rocksdb/src/test/scala/org/apache/samza/storage/kv/TestRocksDbKeyValueStore.scala a428a16bc1e9ab4980a6f17db4fd810057d31136 Diff: https://reviews.apache.org/r/35933/diff/ Testing --- Thanks, Gustavo Anatoly F. V. Solís

Re: Review Request 35933: SAMZA-449 Expose RocksDB statistic

/RocksDbStatisticMetrics.scala PRE-CREATION samza-kv-rocksdb/src/test/scala/org/apache/samza/storage/kv/TestRocksDbKeyValueStore.scala a428a16bc1e9ab4980a6f17db4fd810057d31136 Diff: https://reviews.apache.org/r/35933/diff/ Testing --- Thanks, Gustavo Anatoly F. V. Solís

Re: Review Request 35933: SAMZA-449 Expose RocksDB statistic

file993429line40> > > > > can we use the lower case for the all names of metrics? It's better to > > keep the name convension consistent in the Samza. ok, this is will be changed - Gustavo Anatoly --- Thi

Review Request 35933: SAMZA-449 Expose RocksDB statistic

/apache/samza/storage/kv/TestRocksDbKeyValueStore.scala a428a16bc1e9ab4980a6f17db4fd810057d31136 Diff: https://reviews.apache.org/r/35933/diff/ Testing --- Thanks, Gustavo Anatoly F. V. Solís

Re: [DISCUSS] Samza 0.9.1 release

+1 Thanks. 2015-06-16 14:15 GMT-03:00 Yan Fang : > Agreed on this. > > Thanks, > > Fang, Yan > yanfang...@gmail.com > > On Tue, Jun 16, 2015 at 10:14 AM, Guozhang Wang > wrote: > > > Hi all, > > > > We have been running a couple of our jobs against `0.9.1` branch last > week > > at LinkedIn wit

Review Request 35515: SAMZA-449 Expose RocksDB statistic

: https://reviews.apache.org/r/35515/diff/ Testing --- Thanks, Gustavo Anatoly F. V. Solís

Re: Reprocessing old events no longer in Kafka

Hi, Zach In my humble opinion once I dont have much experience with Samza. But I think that a possible solution could be hybrid. Using HBase Coprocessor to running a Samza application to process the events and storing the results on HBase. Thus you have the history available to query it. Thanks.

Review Request 34812: SAMZA-687 Add samza-graphite package to hello-samza

--- Add samza-graphite package to hello-samza Diffs - pom.xml b4f58993bd43a253757e04f723c74abe8cdf3692 src/main/assembly/src.xml f57fee2acb0c27f78761efdcc63ed8208a1888bd Diff: https://reviews.apache.org/r/34812/diff/ Testing --- Thanks, Gustavo Anatoly F. V. Solís

Re: Clojure Samza Task

Hi, Michael Ravits. The error happens when the Log class try to read the jetty-logging.properties file. Please take a look the line at ( org.eclipse.jetty.util.log.Log.java:94) URL testProps = Log.class.getClassLoader().getResource( "jetty-logging.properties"); Thus, the question is if this file

Re: Yarn redundancy

Hi, Shekar. The failed happens when: *sprdargas403t/10.180.195.33 to sprdargas403:8031* I suggest that you verify: 1)* $nmap -sT sprdargas * to check whether the port 8031 is open; 2) Use *traceroute* to check if the name of machine is being resolved correctly; 3) Check your /etc/hosts whethe

Review Request 34226: SAMZA-643: Improve error message for null stream in OutgoingMessageEnvelope

ef5a55b6a6a14e08d36a549813570a8bf38f1e28 Diff: https://reviews.apache.org/r/34226/diff/ Testing --- Thanks, Gustavo Anatoly F. V. Solís

Review Request 34155: SAMZA-643: Improve error message for null stream in OutgoingMessageEnvelope

/system/TestOutgoingMessageEnvelope.java PRE-CREATION samza-api/src/test/java/org/apache/samza/system/TestSystemStreamPartitionIterator.java 5af2a11812983cfb8b6a8a0927ef6f3eba7d340f Diff: https://reviews.apache.org/r/34155/diff/ Testing --- Thanks, Gustavo Anatoly F. V. Solís