Issue With Invalid/NULL Range Column

ycql_null_insert.py

# pip install yb-cassandra-driver

from cassandra.cluster import Cluster
from cassandra.query import UNSET_VALUE
import time
import random
import os

from multiprocessing.dummy import Pool as ThreadPool

# Load Phase params
num_users=2

cluster = Cluster(['127.0.0.1'])
session = cluster.connect()

def create_table():
  start_time = time.time()
  session.execute("""CREATE KEYSPACE IF NOT EXISTS k""");
  session.execute("""USE k""");
  session.execute("""DROP TABLE IF EXISTS users""");
  now_time = time.time()
  print("Dropped (if exists): users table")
  print("Time: %s ms" % ((now_time - start_time) * 1000))
  print("====================")
  start_time = time.time()
  session.execute("""
        CREATE TABLE IF NOT EXISTS users(
           id     text,
           name   text,
           age    int,
           info   text,
           PRIMARY KEY((id), name)
        );
    """)
  now_time = time.time()
  print("Created users table")
  print("Time: %s ms" % ((now_time - start_time) * 1000))


def load_data():
  prepared = session.prepare("""INSERT INTO users (id, name, age, info) VALUES (?, ?, ?, ?)""");
  for idx in range(num_users):
    input_data = "I am a test " + str(idx);
    session.execute(prepared,
                    ("id-"+str(idx), UNSET_VALUE,
                     20 + (idx % 50),
                     input_data))

def select_data():
  results = session.execute("SELECT * FROM users LIMIT 10")
  for row in results:
    print('id='+row.id)
    print('name='+row.name)
    print('age='+str(row.age))
    print('info='+row.info)


# Main
create_table()

load_data()
select_data()