sure , as Rudraneel said
1. How many topologies?
>> one
2. What are the workload parameters (e.g. tuple arrival rate, number of
executors per component, size of each tuple)
>>
3. System environment ( Number of cores in each supervisor node, Available
RAM)
>> I have numbis working on 8 GB RAM but
Hi Sam,
Could you share you topology ? More background information will help us to
understand your problem.
And what kind of performance do you want to achieve, low latency or high
throughput ?
Cheers,
Manu Zhang
On Thu, Nov 17, 2016 at 5:34 AM sam mohel wrote:
> Please .Is there any help ?
>
Change the JSONObject import to
import org.apache.storm.shade.org.json.simple.JSONObject;
Resolved.
The missing exception stack information quiet misleads me !
2016-11-17 12:38 GMT+08:00 Zhechao Ma :
> I modify code in KafkaProducer.java to catch the exception stack, and
> finally get the re
I modify code in KafkaProducer.java to catch the exception stack, and
finally get the real Exception cause.
java.lang.ClassCastException:
org.apache.storm.shade.org.json.simple.JSONObject cannot be cast to
org.json.simple.JSONObject
So this problem is related to the maven shade plugin.
2016-11-
Thanks for your help
On Thursday, November 17, 2016, Rudraneel chakraborty <
rudraneel.chakrabo...@gmail.com> wrote:
> Hi,
>
> For any kin of performance analysis, first determine the following
> 1. How many topologies?
> 2. What are the workload parameters (e.g. tuple arrival rate, number of
> e
Hi,
For any kin of performance analysis, first determine the following
1. How many topologies?
2. What are the workload parameters (e.g. tuple arrival rate, number of
executors per component, size of each tuple)
3. System environment ( Number of cores in each supervisor node, Available
RAM)
4. Wha
Performance in what way?
If you mean from the storm Twitter example, that is part of the business logic.
It is a way of filtering.
Best Regards
Matthew Lowe
> On 16 Nov 2016, at 22:34, sam mohel wrote:
>
> Please .Is there any help ?
>
>> On Wednesday, November 16, 2016, sam mohel wrote:
>
Please .Is there any help ?
On Wednesday, November 16, 2016, sam mohel wrote:
> How can algoritm like" text similarity between tweets" affect on the
> performance of storm topology ?
Hi,
It is generally recommended for streaming engines, also including Storm to run
a separate master node - in the case of Storm, the Nimbus.
However, why should one in Storm run the Nimbus on a separate node?
Performance wise, the Nimbus isn’t intense unlike of course workers.
In terms of
Unsubscribe
How can algoritm like" text similarity between tweets" affect on the
performance of storm topology ?
Hi Amber,
Here is the code.
Properties prop = new Properties();
prop.put("bootstrap.servers", kafkaBrokers);
prop.put("ack", ack);
prop.put("key.serializer", keySerializer);
prop.put("value.serializer", valueSerializer);
KafkaBolt kafkaBolt = new KafkaBolt()
.withProducerProperti
12 matches
Mail list logo
