question: @ Override public void createIndexKeyspace ( final String ksname , final int replicationFactor ) throws IOException { try { Keyspace ks = Keyspace . open ( ksname ) ; if ( ks != null && ! ( ks . getReplicationStrategy ( ) instanceof NetworkTopologyStrategy ) ) { throw new IOException ( "Cannot create index, underlying keyspace requires the NetworkTopologyStrategy." ) ; } } catch ( AssertionError e ) { } try { QueryProcessor . process ( String . format ( "CREATE KEYSPACE IF NOT EXISTS \"%s\" WITH replication = {'class':'NetworkTopologyStrategy', '%s':'%d' };" , ksname , DatabaseDescriptor . getLocalDataCenter ( ) , replicationFactor ) , ConsistencyLevel . LOCAL_ONE ) ; } catch ( Throwable e ) { throw new IOException ( e . getMessage ( ) , e ) ; } }
target:  Don't use QueryProcessor.executeInternal, we need to propagate this on all nodes.