带有分区键的Cassandra GetEndpoints有空间

Question

我的分区键是id(int)和name(text)。 以下命令工作正常，直到名称(文本)中没有空格。nodetool getendpoint test testtable2 1：aaa;

如果我使用NodeTool getEndpoint Test Testtable2 3：AAC CC;它抛出一个错误：nodetool：getEndpoints需要键空间，表和分区键参数请参阅"nodetool帮助"或"nodetool帮助"。

我通过执行获得了令牌从test.testtable2中选择id，name，token(id，name)，其中name='aac cc'和id=3;并尝试搜索nodetool getendpoint test testtable2 -7072928299163215694;错误：对于输入字符串："-7072928299163215694" -- 堆栈跟踪 -- java.lang.NumberFormatException：对于输入字符串："-7072928299163215694">

如何搜索分区键(名称)是否有空间？

Answer 1

这是nodetool命令的问题。

我已经修改了nodetool脚本并创建了getendpoints脚本以支持具有分区键有空间的getendpoints

。这是getendpoints代码：

#!/bin/sh
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements.  See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership.  The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License.  You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
if [ "`basename "$0"`" = 'nodeprobe' ]; then
echo "***************************************************************" >&2
echo "WARNING: $0 is obsolete, use `dirname "$0"`/nodetool instead" >&2
echo "***************************************************************" >&2
fi
if [ "x$CASSANDRA_INCLUDE" = "x" ]; then
for include in "`dirname "$0"`/cassandra.in.sh" 
"$HOME/.cassandra.in.sh" 
/usr/share/cassandra/cassandra.in.sh 
/usr/local/share/cassandra/cassandra.in.sh 
/opt/cassandra/cassandra.in.sh; do
if [ -r "$include" ]; then
. "$include"
break
fi
done
elif [ -r "$CASSANDRA_INCLUDE" ]; then
. "$CASSANDRA_INCLUDE"
fi
# Use JAVA_HOME if set, otherwise look for java in PATH
if [ -x "$JAVA_HOME/bin/java" ]; then
JAVA="$JAVA_HOME/bin/java"
else
JAVA="`which java`"
fi
if [ -z "$CASSANDRA_CONF" -o -z "$CLASSPATH" ]; then
echo "You must set the CASSANDRA_CONF and CLASSPATH vars" >&2
exit 1
fi
# Run cassandra-env.sh to pick up JMX_PORT
if [ -f "$CASSANDRA_CONF/cassandra-env.sh" ]; then
. "$CASSANDRA_CONF/cassandra-env.sh"
fi
# JMX Port passed via cmd line args (-p 9999 / --port 9999 / --port=9999)
# should override the value from cassandra-env.sh
ARGS=""
JVM_ARGS=""
SSL_FILE=$HOME/.cassandra/nodetool-ssl.properties
KS=""
CF=""
KEY=""
while true
do
if [ ! $1 ]; then break; fi
case $1 in
-p)
JMX_PORT=$2
shift
;;
--port=*)
JMX_PORT=$(echo $1 | cut -d '=' -f 2)
;;
--port)
JMX_PORT=$2
shift
;;
--ssl)
if [ -f $SSL_FILE ]
then 
SSL_ARGS=$(cat $SSL_FILE | tr 'n' ' ')
fi
JVM_ARGS="$JVM_ARGS -Dssl.enable=true $SSL_ARGS"
;;
-D*)
JVM_ARGS="$JVM_ARGS $1"
;;
-k)
KS=$2
shift
;;
-t)
CF=$2
shift
;;
*)
if [ ! $KEY ]; then 
KEY="$1"
else
KEY="$KEY $1"
fi
;;
esac
shift
done
# Special-case path variables.
case "`uname`" in
CYGWIN*) 
CLASSPATH="`cygpath -p -w "$CLASSPATH"`"
CASSANDRA_CONF="`cygpath -p -w "$CASSANDRA_CONF"`"
;;
esac
"$JAVA" $JAVA_AGENT -cp "$CLASSPATH" 
-Xmx128m 
-Dcassandra.storagedir="$cassandra_storagedir" 
-Dlogback.configurationFile=logback-tools.xml 
-Dstorage-config="$CASSANDRA_CONF" 
$JVM_ARGS 
org.apache.cassandra.tools.NodeTool -p $JMX_PORT getendpoints $KS $CF "$KEY"

getendpoints文件放在$CASSANDRA_HOME/bin目录下。

现在您可以使用nodetool参数以及以下参数运行此文件

getendpoints -k keyspace_name -t table_name key

例：

getendpoints -k test -t testtable2 3:aac cc

Answer 2

您正在使用哪个Cassandra版本。

我已经从Cassandra 2.x和Cassandra 3.x版本对其进行了测试。它工作正常。

root@cqlsh：test_db> 从test_temp中选择令牌(名称);  系统令牌(名称) ---------------------  -907920378987128470 nodetool getendpoint test_db test_temp -907920378987128470; 192.168.8.52

更新答案：遇到问题

当分区键的第一部分为 int 时，会生成问题。

创建表测试6 ( 年龄 int 主键， 名称文本 ); bin/nodetool getendpoint test test6 -7072928299163215694

error: For input string: "-7072928299163215694"java.lang.NumberFormatException: For input string:"-
7072928299163215694"
at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
at java.lang.Integer.parseInt(Integer.java:583)
at java.lang.Integer.parseInt(Integer.java:615)

但适用于以下输入

bin/nodetool getendpoint test test6 -7072 127.0.0.1

来自 DataStax Doc：

提供拥有分区键的终结点。分区程序返回密钥的令牌。Cassandra 将返回一个端点，无论该令牌的已识别节点上是否存在数据。 ** 键是要获取的终结点的分区键。

nodetool getEndpoint 实际上将分区键的值作为输入。在这种情况下，'-7072928299163215694'将其解析为整数，因此最终会引发异常。它正在工作长或字符串(它将"-7072928299163215694"值作为字符串)，因为它已将其作为键的值而不是实际令牌。它不是解析令牌。因此，提供令牌作为输入将不起作用。

getEndpoint 根据密钥的值生成令牌，并为你提供密钥所在的终结点(节点)。

请查看此链接： Cassandra将数据存储在哪个节点上？

为此提供了修补程序：

https://issues.apache.org/jira/browse/CASSANDRA-4551

希望这有帮助。