小编ftr*_*llo的帖子

我在尝试查询Cassandra 1.2.4中的一行时遇到问题当我尝试使用Cassandra-cli查询行时,我收到此错误:

框架尺寸(75209759)大于最大长度(15728640)!org.apache.thrift.transport.TTransportException:帧大小(75209759)大于最大长度(15728640)!org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:137)org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101)

我试图更改Cassandra.yaml中的下一个配置参数:

# Frame size for thrift (maximum field length).
thrift_framed_transport_size_in_mb: 1024

# The max length of a thrift message, including all fields and
# internal thrift overhead.
thrift_max_message_length_in_mb: 1048

但是当我尝试使用Cassandra cli查询行时,我得到了同样的错误.

当我在日志中出现cassndra时出现:

INFO 14:48:34,133 Using TFramedTransport with a max frame size of 1073741824 bytes.
 INFO 14:48:34,137 Using synchronous/threadpool thrift server on localhost : 9160
 INFO 14:48:34,137 Listening for thrift clients...

但是在Cassandra cli中没有反映出变化,这是我们使用的版本的问题吗？

谢谢你的帮助

我在具有单个节点的集群中使用cassandra 1.2.6.我正在尝试使用以下说明重命名群集:

Cassandra clustername不匹配

完成所有步骤后表明我在更改cassandra.yaml文件后启动cassandra时仍然出现相同的错误

有人知道这是否是cassandra 1.2.6的问题？

谢谢

我正在尝试使用datastax java驱动程序来更新和查询具有映射字段的列族.有没有人关于如何使用Datastax Java驱动程序使用cql集合的示例？

谢谢

这是我的工作配置:

 <step id="indelToMorph" next="multiThreaded_createIndividualMorphs_master">
            <tasklet>
                <chunk reader="indelReader" processor="indelProcessor" writer="indelWriter" commit-interval="100"/>
            </tasklet>
        </step>

        <step id="multiThreaded_createIndividualMorphs_master" next="createMarkers"> 
            <partition step="multiThreaded_createIndividualMorphs"  partitioner="partitionMorphAdvancedHandler"> 
                        <handler grid-size="10" task-executor="taskAsyncExecutor"/> 
             </partition>
            <listeners>
                <listener ref="calculateIndividualMorphListener"/>
            </listeners>
        </step>

        <step id="multiThreaded_createIndividualMorphs">
            <tasklet ref="createIndividualMorphsAdvancedTasklet"/>
        </step>

        <step id="createMarkers">
            <tasklet ref="verifyTasklet"/>
        </step>

并创建了bean:

@Bean
    @Scope("step")
    public Tasklet createIndividualMorphsAdvancedTasklet() {
        Tasklet createIndividualMorphsAdvancedTasklet = new CreateIndividualMorphsAdvancedTasklet();
        return createIndividualMorphsAdvancedTasklet;
    }

但它说:

Caused by: org.springframework.beans.factory.parsing.BeanDefinitionParsingException: Configuration problem: The element [multiThreaded_createIndividualMorphs] is unreachable

我错过了什么？

我正在尝试创建一个方面来监视某些方法的执行时间.当我尝试运行测试时,我收到此错误:

Caused by: java.lang.IllegalArgumentException: error at ::0 can't find referenced pointcut annotation
    at org.aspectj.weaver.tools.PointcutParser.parsePointcutExpression(PointcutParser.java:301)
    at org.springframework.aop.aspectj.AspectJExpressionPointcut.buildPointcutExpression(AspectJExpressionPointcut.java:207)

当ApplicationContext加载时.

我将注释定义为:

@Retention(RetentionPolicy.RUNTIME)
@Target(
{
    ElementType.METHOD, 
    ElementType.TYPE
})
public @interface TimePerformance {

}

这是方面代码:

@Aspect
public class MonitorImpl{

    private static final Log LOG = LogFactory.getLog(MonitorImpl.class);


    @Pointcut(value="execution(public * *(..))")
    public void anyPublicMethod() { }



    @Around("anyPublicMethod() && annotation(timePerformance)")
    public Object  timePerformance(ProceedingJoinPoint pjp,TimePerformance timePerformance) throws Throwable {

        if (LOG.isInfoEnabled()) {
             LOG.info("AOP - Before executing "+pjp.getSignature());
        }

        Long startTime = System.currentTimeMillis();

        Object result = pjp.proceed();

        Long stopTime = …