incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject git commit: Fixing class cast exception with ClusterExecuteServerReadCommands.
Date Wed, 17 Jun 2015 21:04:28 GMT
Repository: incubator-blur
Updated Branches:
  refs/heads/master b50880d67 -> 020f90ab0


Fixing class cast exception with ClusterExecuteServerReadCommands.


Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/020f90ab
Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/020f90ab
Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/020f90ab

Branch: refs/heads/master
Commit: 020f90ab0f19eec72ddfdb148d267e290efb8655
Parents: b50880d
Author: Aaron McCurry <amccurry@gmail.com>
Authored: Wed Jun 17 17:04:08 2015 -0400
Committer: Aaron McCurry <amccurry@gmail.com>
Committed: Wed Jun 17 17:04:08 2015 -0400

----------------------------------------------------------------------
 .../java/org/apache/blur/command/ControllerCommandManager.java  | 4 ----
 .../command/commandtype/ClusterExecuteServerReadCommand.java    | 5 ++---
 2 files changed, 2 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/020f90ab/blur-core/src/main/java/org/apache/blur/command/ControllerCommandManager.java
----------------------------------------------------------------------
diff --git a/blur-core/src/main/java/org/apache/blur/command/ControllerCommandManager.java
b/blur-core/src/main/java/org/apache/blur/command/ControllerCommandManager.java
index 6f19257..b11d09a 100644
--- a/blur-core/src/main/java/org/apache/blur/command/ControllerCommandManager.java
+++ b/blur-core/src/main/java/org/apache/blur/command/ControllerCommandManager.java
@@ -7,7 +7,6 @@ import java.util.concurrent.Callable;
 
 import org.apache.blur.BlurConfiguration;
 import org.apache.blur.command.commandtype.ClusterExecuteCommand;
-import org.apache.blur.command.commandtype.ClusterExecuteServerReadCommand;
 import org.apache.blur.command.commandtype.ClusterIndexReadCommand;
 import org.apache.blur.command.commandtype.ClusterServerReadCommand;
 import org.apache.blur.command.commandtype.IndexReadCommand;
@@ -69,9 +68,6 @@ public class ControllerCommandManager extends BaseCommandManager {
             CombiningContext combiningContext = getCombiningContext(tableContextFactory);
             return executeClusterReadCombiningCommand(context, command, combiningContext);
           }
-          if (command instanceof ClusterExecuteServerReadCommand) {
-            return executeClusterCommand(context, command);
-          }
           if (command instanceof ClusterExecuteCommand) {
             return executeClusterCommand(context, command);
           }

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/020f90ab/blur-core/src/main/java/org/apache/blur/command/commandtype/ClusterExecuteServerReadCommand.java
----------------------------------------------------------------------
diff --git a/blur-core/src/main/java/org/apache/blur/command/commandtype/ClusterExecuteServerReadCommand.java
b/blur-core/src/main/java/org/apache/blur/command/commandtype/ClusterExecuteServerReadCommand.java
index 4a7c986..0fee2e9 100644
--- a/blur-core/src/main/java/org/apache/blur/command/commandtype/ClusterExecuteServerReadCommand.java
+++ b/blur-core/src/main/java/org/apache/blur/command/commandtype/ClusterExecuteServerReadCommand.java
@@ -22,16 +22,15 @@ import java.util.Map;
 
 import org.apache.blur.command.ClusterContext;
 import org.apache.blur.command.CombiningContext;
-import org.apache.blur.command.Command;
 import org.apache.blur.command.CommandRunner;
 import org.apache.blur.command.IndexContext;
-import org.apache.blur.command.ServerRead;
 import org.apache.blur.command.Location;
+import org.apache.blur.command.ServerRead;
 import org.apache.blur.thirdparty.thrift_0_9_0.TException;
 import org.apache.blur.thrift.generated.Blur.Iface;
 import org.apache.blur.thrift.generated.BlurException;
 
-public abstract class ClusterExecuteServerReadCommand<T> extends Command<T> implements
ServerRead<T, T> {
+public abstract class ClusterExecuteServerReadCommand<T> extends ClusterExecuteCommand<T>
implements ServerRead<T, T> {
 
   public abstract T execute(IndexContext context) throws IOException, InterruptedException;
 


Mime
View raw message