Member since
10-01-2015
3933
Posts
1150
Kudos Received
374
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
2628 | 05-03-2017 05:13 PM | |
2197 | 05-02-2017 08:38 AM | |
2345 | 05-02-2017 08:13 AM | |
2380 | 04-10-2017 10:51 PM | |
1051 | 03-28-2017 02:27 AM |
10-23-2015
01:36 AM
I would also clean /usr/lib/python2.6/site-packages/ for any residual ambari-specific python files, specifically symlinks. It's a common problem, though, error is different.
... View more
10-23-2015
01:30 AM
3 Kudos
download it here http://www.microsoft.com/en-us/download/details.aspx?displaylang=en&id=11774, you need the tar.gz file, extract and place in sqoop lib folder.
... View more
10-21-2015
03:36 PM
the topic will still exist until you push new messages to this topic and then follow @AndrewGrande answer below
... View more
10-21-2015
03:19 PM
I'm trying to implement custom grouping feature as seen in OpenSOC for HBaseStreamPartitioner I'm declaring it like so declarer.customGrouping(
MAPPER_BOLT_ID,
new HBaseStreamPartitioner("clicks_tbl", 0, 60, zkQuorum, zkParent, zkPort)); What would cause the error below? What is the default stream id when you implement a custom grouping? My HBase bolt is 2nd bolt in chain after a mapper bolt that just deserializes byte array stream from Kafka to parsed values. 2015-10-21 11:06:56.829 b.s.d.executor [ERROR]
java.lang.RuntimeException: java.lang.IllegalArgumentException: No matching clause: default
at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:128) ~[storm-core-0.10.0.2.3.2.0-2950.jar:0.10.0.2.3.2.0-2950]
at backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:99) ~[storm-core-0.10.0.2.3.2.0-2950.jar:0.10.0.2.3.2.0-2950]
at backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:80) ~[storm-core-0.10.0.2.3.2.0-2950.jar:0.10.0.2.3.2.0-2950]
at backtype.storm.daemon.executor$fn__6214$fn__6227$fn__6278.invoke(executor.clj:808) ~[storm-core-0.10.0.2.3.2.0-2950.jar:0.10.0.2.3.2.0-2950]
at backtype.storm.util$async_loop$fn__543.invoke(util.clj:475) [storm-core-0.10.0.2.3.2.0-2950.jar:0.10.0.2.3.2.0-2950]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.6.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_40]
Caused by: java.lang.IllegalArgumentException: No matching clause: default
at backtype.storm.daemon.acker$mk_acker_bolt$reify__1380.execute(acker.clj:59) ~[storm-core-0.10.0.2.3.2.0-2950.jar:0.10.0.2.3.2.0-2950]
at backtype.storm.daemon.acker$_execute.invoke(acker.clj:101) ~[storm-core-0.10.0.2.3.2.0-2950.jar:0.10.0.2.3.2.0-2950]
at backtype.storm.daemon.acker.execute(Unknown Source) ~[storm-core-0.10.0.2.3.2.0-2950.jar:0.10.0.2.3.2.0-2950]
at backtype.storm.daemon.executor$fn__6214$tuple_action_fn__6216.invoke(executor.clj:670) ~[storm-core-0.10.0.2.3.2.0-2950.jar:0.10.0.2.3.2.0-2950]
at backtype.storm.daemon.executor$mk_task_receiver$fn__6137.invoke(executor.clj:426) ~[storm-core-0.10.0.2.3.2.0-2950.jar:0.10.0.2.3.2.0-2950]
at backtype.storm.disruptor$clojure_handler$reify__5713.onEvent(disruptor.clj:58) ~[storm-core-0.10.0.2.3.2.0-2950.jar:0.10.0.2.3.2.0-2950]
at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:120) ~[storm-core-0.10.0.2.3.2.0-2950.jar:0.10.0.2.3.2.0-2950]
... View more
Labels:
- Labels:
-
Apache HBase
-
Apache Storm
10-18-2015
10:43 PM
And url should not say jdbc:mysql it needs to be sql server specific, look that up, i dont remember exactly if its just jdbc:mssql
... View more
10-18-2015
10:40 PM
i see your jdbc URL is for MySQL but driver is SQL server. Which do you need to access? Standard SQL server port is 1433.
... View more
10-17-2015
04:11 PM
1 Kudo
All RS return this message. I followed all tuning practices as described on SME list.
... View more
10-17-2015
03:27 AM
Labels:
- Labels:
-
Apache Hadoop
-
Apache HBase
10-05-2015
12:55 PM
using localcluster utility from storm works pretty well. I also used examples from https://github.com/nathanmarz/storm-starter/blob/master/test/jvm/storm/starter/bolt/RollingCountBoltTest.java for my own unit tests. MockTuple is the way to go
... View more
10-05-2015
12:52 PM
I try to monitor http://public-repo-1.hortonworks.com/ once in a while for new bits. Always go with the latest .x release that is not .0 release.
... View more
- « Previous
- Next »