Search Hadoop -
Jarek Jarcec Cecho
Jaimin D Jetly
Edward J. Yoon
Joseph K. Bradley
Vinod Kumar Vavilapalli
mail # dev
mail # user
last 7 days (3)
last 30 days (4)
last 90 days (17)
last 6 months (30)
last 9 months (210)
and all its subprojects:
newest on top
oldest on top
. Results from
Loading phrases to help you
refine your search...
[STORM-1949] Backpressure can cause spout to stop emitting and stall topology
...Problem can be reproduced by this Word count topologywithin a IDE.I ran it with 1 spout instance, 2 splitter bolt instances, 2 counter bolt instances.The problem is more easily reproduced wi...
, 2016-08-24, 03:16
Re: Details about the Storm Scheduler
- [mail # dev]
...On 8/22/16, 6:55 AM, "Bobby Evans" wrote:I think that can be worked around by looking at the latency of eachcomponent instead of CPU consumption of each component.-roshan...
, 2016-08-23, 22:38
[FLUME-2442] Need an alternative to providing clear text passwords in flume config
...For some sources and sinks, currently, passwords to keystores/other are specified in clear text in the flume config file. Since flume config files are often easily accessible to a bro...
, 2016-08-17, 11:46
[FLUME-2901] Document Kerberos setup for Kafka channel
...Add details about configuring Kafka channel to work with a Kerberized Kafka cluster...
, 2016-08-10, 00:01
[expand - 1 more]
counting words (not frequency)
- [mail # user]
...Was trying to write a simple streaming Flink program that counts the total words(not the frequency) in a fie. I was thinking on the lines of :counts = text.flatMap(new Token...
, 2016-07-22, 02:06
Re: counting words (not frequency)
- [mail # user]
...Seems a bit convoluted for such a simple problem. I am thinking a customstreaming count() operator will simplify. Wasn¹t able to find examples forcustom Streaming operators.-roshanOn 7/21/16...
, 2016-07-22, 22:35
[FLUME-2761] Move Hive sink out of preview mode
...Been through one release. Move out of 'preview' mode....
, 2016-07-21, 03:30
[STORM-1909] Fix errors in HDFS Spout documentation
...There is mistake in the example provided for the HDFS spout. The source/archive/bad directory settings should not have the 'hdfs://' portion....
, 2016-07-18, 13:49
Re: Request for reviewing
- [mail # dev]
...STORM-1910 -roshanOn 7/14/16, 8:59 AM, "Jungtaek Lim" wrote: ...
, 2016-07-14, 19:43
[STORM-1956] Disable Backpressure by default
...Some of the context on this is captured in STORM-1949 In short.. wait for BP mechanism to mature some more and be production ready before we enable by default....
, 2016-07-14, 09:55
[FLUME-2947] Upgrade Hive and thrift libraries
...Upgrade Hive version to use new API call that captures additional info about the agent's sink name (HIVE-11956). Also upgrade thrift libraries as Hive is moving to 0.9.3 (HIVE-13724). Some o...
, 2016-07-06, 00:35
Apache Lucene, Apache Solr and all other Apache Software Foundation projects and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by