yukim

/*
 * 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

yukim

Cassandra Metrics

ATTENTION!: This page describes new metrics(CASSANDRA-4009) planned in upcoming version 1.2, which is still under development.

Overview

Apache Cassandra version 1.1 introduced metrics using Codahale's Metrics library. The library enables easier exposure of metrics and integration with other systems. What you can get from metrics are basically the same with 1.1 but reimplemented and put them in order using Metrics library. You can still query using old JMX paths,

yukim

From 01018acd8f8c2460f94138a6e73dcf399e5bd92e Mon Sep 17 00:00:00 2001
From: Yuki Morishita <yukim@apache.org>
Date: Fri, 27 Jul 2012 10:11:18 -0500
Subject: [PATCH] use slf4j api instead of log4j

---
 src/java/org/apache/cassandra/db/CounterColumn.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/java/org/apache/cassandra/db/CounterColumn.java b/src/java/org/apache/cassandra/db/CounterColumn.java

yukim

diff --git a/src/java/org/apache/cassandra/net/MessagingService.java b/src/java/org/apache/cassandra/net/MessagingService.java
index cb58314..553301d 100644
--- a/src/java/org/apache/cassandra/net/MessagingService.java
+++ b/src/java/org/apache/cassandra/net/MessagingService.java
@@ -469,11 +469,7 @@ public final class MessagingService implements MessagingServiceMBean
         OutboundTcpConnectionPool cp = connectionManagers.get(to);
         if (cp == null)
             return;
-        // these null guards are simply for tests
-        if (cp.ackCon != null)

yukim

diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java
index 0206f40..17b21d9 100644
--- a/src/java/org/apache/cassandra/service/StorageService.java
+++ b/src/java/org/apache/cassandra/service/StorageService.java
@@ -410,6 +410,7 @@ public class StorageService implements IEndpointStateChangeSubscriber, StorageSe
                 throw new UnsupportedOperationException("StorageService does not support switching modes.");
             return;
         }
+        initialized = true;
         isClientMode = false;

yukim

Manifest-Version: 1.0
Premain-Class: com.datastax.example.ReportAgent

yukim

@oranie さんのブログ記事への返信です。 たいへん遅くなりました。申し訳ないです。

repairとcompactionのコストが高すぎる

Cassandraにノードを追加する(Bootstrap)と、そのノードが担当するレプリカのデータを他のノードから取得します。 Repairはノードが保持するレプリカの整合性を検証して修復します。

どちらもデータを他のノードから取得しますが、ファイルを1つづつやり取りするため時間がかかるのは事実です。 この部分にまだまだ改善の余地があります。次のメジャーバージョンで抜本的に見直します。

yukim

Apache Cassandra Streaming API(CASSANDRA-5286)

Design goal

• Better control
  • One API for all (bootstrap, move, bulkload, repair...)
  • IN/OUT in one session
  • Event notification
• Better performance
• Pipelined stream

yukim

diff --git a/src/java/org/apache/cassandra/db/commitlog/CommitLogSegmentManager.java b/src/java/org/apache/cassandra/db/commitlog/CommitLogSegmentManager.java
index 4275362..815616b 100644
--- a/src/java/org/apache/cassandra/db/commitlog/CommitLogSegmentManager.java
+++ b/src/java/org/apache/cassandra/db/commitlog/CommitLogSegmentManager.java
@@ -288,10 +288,9 @@ public class CommitLogSegmentManager
         advanceAllocatingFrom(last);
 
         // flush and wait for all CFs that are dirty in segments up-to and including 'last'
-        Future<?> future = flushDataFrom(segmentsToRecycle);
         try

yukim

package org.apache.cassandra;

import java.util.concurrent.TimeUnit;

import com.yammer.metrics.stats.EWMA;

import static java.lang.Math.exp;

public class EWMATest
{