Hi Aron,
As you suggested me last time, I used Blur 0.2.2. I am trying to perform
real time insert using thrift API, but facing some error. I created the
Table from Blur Shell with 5 shards. The table I am trying to index will
have single family and many columns and every rowid have one record.id.
There are many such rows I want to index.
Is there anything wrong I am doing ? I am using Blur 2.2. Thrift mutation
API.
Connection connection = new Connection("10.254.71.171:40010");
Iface client = BlurClient.getClient(connection);
Record record = new Record();
record.setRecordId(id);
record.setFamily(family);
record.addToColumns(new Column(key, value));
List recordMutations = new ArrayList();
recordMutations.add(new
RecordMutation(RecordMutationType.REPLACE_ENTIRE_RECORD, record));
RowMutation mutation = new RowMutation(
TABLE_NAME,rowid,RowMutationType.REPLACE_ROW,
recordMutations);
mutation.setRecordMutations(recordMutations);
client.mutate(mutation);
and below is the exception.....
BlurException(message:Unknown error during mutation of
[RowMutation(table:mytable, rowId:1db5793577dd8595dd483a5ec87aad1,
rowMutationType:REPLACE_ROW,
recordMutations:[RecordMutation(recordMutationType:REPLACE_ENTIRE_RECORD,
record:Record(recordId:1391378450807, family:my_family,
columns:[Column(name:actor.location.ip, value:10.201.1.195),
Column(name:context.campusId, value:24754975),
Column(name:generator.market, value:digitalvellum),
Column(name:context.questiondata,
value:{"numericsubmissions":[{"choicenumber":2}]}), Column(name:object.id,
value:52458965), Column(name:target.id, value:9431547), Column(name:verb,
value:assessments.question.save), Column(name:generator.source,
value:js_base_client), Column(name:generator.channel, value:seer-activity),
Column(name:target.objectType, value:eclg.courseId), Column(name:actor.id,
value:24754975), Column(name:generator.userAgent, value:Mozilla/5.0
(compatible; MSIE 10.0; Windows NT 6.2; WOW64; Trident/6.0)),
Column(name:object.objectType, value:assessments.questionsave),
Column(name:serverDate, value:2014-02-02T22:00:52.068Z),
Column(name:published, value:2014-02-02T22:00:50.807Z),
Column(name:generator.appId, value:dvcourse)]))])],
stackTraceStr:java.lang.NullPointerException
at
org.apache.blur.thrift.BlurControllerServer.mutate(BlurControllerServer.java:1027)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.apache.blur.utils.BlurUtil$2.invoke(BlurUtil.java:255)
at com.sun.proxy.$Proxy0.mutate(Unknown Source)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.apache.blur.utils.BlurUtil$7.invoke(BlurUtil.java:1216)
at com.sun.proxy.$Proxy0.mutate(Unknown Source)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.apache.blur.utils.BlurUtil$8.invoke(BlurUtil.java:1258)
at com.sun.proxy.$Proxy0.mutate(Unknown Source)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.apache.blur.utils.BlurUtil$1.invoke(BlurUtil.java:178)
at com.sun.proxy.$Proxy0.mutate(Unknown Source)
at
org.apache.blur.thrift.generated.Blur$Processor$mutate.getResult(Blur.java:3369)
at
org.apache.blur.thrift.generated.Blur$Processor$mutate.getResult(Blur.java:3353)
at
org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction.process(ProcessFunction.java:54)
at
org.apache.blur.thirdparty.thrift_0_9_0.TBaseProcessor.process(TBaseProcessor.java:57)
at
org.apache.blur.thrift.server.AbstractNonblockingServer$FrameBuffer.invoke(AbstractNonblockingServer.java:555)
at org.apache.blur.thrift.server.Invocation.run(Invocation.java:34)
at
org.apache.blur.concurrent.ThreadWatcher$ThreadWatcherExecutorService$1.run(ThreadWatcher.java:127)
at
org.apache.blur.concurrent.BlurThreadPoolExecutor$1.run(BlurThreadPoolExecutor.java:83)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:744)
, errorType:UNKNOWN)
at
org.apache.blur.thrift.generated.Blur$mutate_result$mutate_resultStandardScheme.read(Blur.java:20163)
at
org.apache.blur.thrift.generated.Blur$mutate_result$mutate_resultStandardScheme.read(Blur.java:20149)
at
org.apache.blur.thrift.generated.Blur$mutate_result.read(Blur.java:20099)
at
org.apache.blur.thirdparty.thrift_0_9_0.TServiceClient.receiveBase(TServiceClient.java:78)
at
org.apache.blur.thrift.generated.Blur$Client.recv_mutate(Blur.java:1003)
at
org.apache.blur.thrift.generated.SafeClientGen.recv_mutate(SafeClientGen.java:326)
at
org.apache.blur.thrift.generated.Blur$Client.mutate(Blur.java:990)
at
org.apache.blur.thrift.generated.SafeClientGen.mutate(SafeClientGen.java:165)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at
org.apache.blur.thrift.BlurClient$BlurClientInvocationHandler$1.call(BlurClient.java:60)
at
org.apache.blur.thrift.BlurClient$BlurClientInvocationHandler$1.call(BlurClient.java:56)
at
org.apache.blur.thrift.AbstractCommand.call(AbstractCommand.java:62)
at
org.apache.blur.thrift.BlurClientManager.execute(BlurClientManager.java:192)
at
org.apache.blur.thrift.BlurClient$BlurClientInvocationHandler.invoke(BlurClient.java:56)
at com.sun.proxy.$Proxy0.mutate(Unknown Source)
at
com.pearson.blur.thrift.client.BlurLoader.load(BlurLoader.java:85)
at
com.pearson.blur.thrift.client.BlurLoader.main(BlurLoader.java:39)
