joestein

cqlsh:ControlServerLogRequestCount> CREATE COLUMNFAMILY users (KEY varchar PRIMARY KEY,password varchar,gender varchar,session_token varchar,state varchar,birth_year bigint);
cqlsh:ControlServerLogRequestCount> INSERT INTO users (KEY, password) VALUES ('jsmith', 'ch@ngem3a');
cqlsh:ControlServerLogRequestCount>  select * from users where KEY='jsmith';
Traceback (most recent call last):
  File "bin/cqlsh", line 482, in perform_statement
    self.cursor.execute(statement, decoder=decoder)
  File "build/bdist.linux-x86_64/egg/cql/cursor.py", line 106, in execute
    self.description = self.decoder.decode_description(self.result[0])
  File "build/bdist.linux-x86_64/egg/cql/decoders.py", line 33, in decode_description
    comparator = schema.name_types.get(name, schema.default_name_type)

joestein

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

joestein

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

joestein

Index: core/src/main/scala/kafka/producer/SyncProducer.scala
===================================================================
--- core/src/main/scala/kafka/producer/SyncProducer.scala	(revision 1234442)
+++ core/src/main/scala/kafka/producer/SyncProducer.scala	(working copy)
@@ -107,15 +107,18 @@
   /**
    * Send a message
    */
-  def send(topic: String, partition: Int, messages: ByteBufferMessageSet) {
-    verifyMessageSize(messages)

joestein

Index: core/src/main/scala/kafka/producer/ProducerPool.scala
===================================================================
--- core/src/main/scala/kafka/producer/ProducerPool.scala	(revision 1234442)
+++ core/src/main/scala/kafka/producer/ProducerPool.scala	(working copy)
@@ -26,6 +26,8 @@
 import kafka.common.{UnavailableProducerException, InvalidConfigException}
 import kafka.utils.{Utils, Logging}
 import kafka.message.{NoCompressionCodec, ByteBufferMessageSet}
+import collection.mutable.{HashMap, ListBuffer}
+import kafka.api.{WiredTopic, WiredPartition}

joestein

Index: core/src/test/scala/unit/kafka/utils/TestUtils.scala
===================================================================
--- core/src/test/scala/unit/kafka/utils/TestUtils.scala	(revision 1234442)
+++ core/src/test/scala/unit/kafka/utils/TestUtils.scala	(working copy)
@@ -29,6 +29,7 @@
 import kafka.message._
 import org.I0Itec.zkclient.ZkClient
 import kafka.consumer.ConsumerConfig
+import kafka.api.{WiredTopic, WiredPartition}
 

joestein

Index: core/src/test/scala/unit/kafka/utils/TestUtils.scala
===================================================================
--- core/src/test/scala/unit/kafka/utils/TestUtils.scala	(revision 1234442)
+++ core/src/test/scala/unit/kafka/utils/TestUtils.scala	(working copy)
@@ -29,6 +29,7 @@
 import kafka.message._
 import org.I0Itec.zkclient.ZkClient
 import kafka.consumer.ConsumerConfig
+import kafka.api.{WiredTopic, WiredPartition}
 

joestein

Index: core/src/test/scala/unit/kafka/utils/TestUtils.scala
===================================================================
--- core/src/test/scala/unit/kafka/utils/TestUtils.scala	(revision 1234442)
+++ core/src/test/scala/unit/kafka/utils/TestUtils.scala	(working copy)
@@ -29,6 +29,7 @@
 import kafka.message._
 import org.I0Itec.zkclient.ZkClient
 import kafka.consumer.ConsumerConfig
+import kafka.api.{WiredTopic, WiredPartition}
 

joestein

Josephs-MacBook-Pro:~ josephstein$ cat test
1,,2
1,1,2
Josephs-MacBook-Pro:~ josephstein$ cat test |sort
1,,2
1,1,2

[root@megatron joestein]# cat test
1,,2
1,1,2

joestein

Index: lib/sbt-launch.jar
===================================================================
Cannot display: file marked as a binary type.
svn:mime-type = application/octet-stream
Index: project/plugins/Plugins.scala
===================================================================
--- project/plugins/Plugins.scala	(revision 1338516)
+++ project/plugins/Plugins.scala	(working copy)
@@ -1,23 +0,0 @@
-/**