Min Wei created KUDU-1426:
-----------------------------

             Summary: kudu master crashes on Mac OS X 
                 Key: KUDU-1426
                 URL: https://issues.apache.org/jira/browse/KUDU-1426
             Project: Kudu
          Issue Type: Bug
         Environment: Mac OS X
            Reporter: Min Wei


This is on the master. I am just following the build instructions to do some 
simple testing. 

It seems happening on Mac OS X, consistently, with the stock sample code. 
   1) start master with 3 ts instances 
   2) Run the following code a few times
   3) master crash with:
=====
F0421 19:13:38.765300 3211264 rowset_info.cc:233] Check failed: 'active[rs]' 
Must be non NULL 
*** Check failure stack trace: ***
    @        0x1033c2190  google::LogMessage::SendToLog()
    @        0x1033c2831  google::LogMessage::Flush()
    @        0x1033c63ff  google::LogMessageFatal::~LogMessageFatal()
    @        0x1033c30a9  google::LogMessageFatal::~LogMessageFatal()
    @        0x100a6e3e0  google::CheckNotNull<>()
    @        0x100a6a0cb  kudu::tablet::RowSetInfo::CollectOrdered()
    @        0x100a0bf41  
kudu::tablet::BudgetedCompactionPolicy::SetupKnapsackInput()
    @        0x100a0c3f6  
kudu::tablet::BudgetedCompactionPolicy::PickRowSets()
    @        0x1009493df  kudu::tablet::Tablet::UpdateCompactionStats()
    @        0x100948e50  kudu::tablet::CompactRowSetsOp::UpdateStats()
    @        0x100a2ff54  kudu::MaintenanceManager::FindBestOp()
    @        0x100a2e08d  kudu::MaintenanceManager::RunSchedulerThread()
    @        0x100975b79  kudu::internal::RunnableAdapter<>::Run()
    @        0x100a36cc0  boost::_bi::list1<>::operator()<>()
    @        0x100a36c6a  boost::_bi::bind_t<>::operator()()
    @        0x100a36a4d  
boost::detail::function::void_function_obj_invoker0<>::invoke()
    @        0x102f68b58  boost::function0<>::operator()()
    @        0x102fe1961  kudu::Thread::SuperviseThread()
    @     0x7fff9397999d  _pthread_body
    @     0x7fff9397991a  _pthread_start
    @     0x7fff93977351  thread_start
Abort trap: 6

====
import org.kududb.ColumnSchema;
import org.kududb.Schema;
import org.kududb.Type;
import org.kududb.client.*;

import java.util.ArrayList;
import java.util.List;

public class Sample {

  private static final String KUDU_MASTER = System.getProperty(
      "kuduMaster", "localhost");

  public static void main(String[] args) {
    System.out.println("-----------------------------------------------");
    System.out.println("Will try to connect to Kudu master at " + KUDU_MASTER);
    System.out.println("Run with -DkuduMaster=myHost:port to override.");
    System.out.println("-----------------------------------------------");
    String tableName = "acme_sample-" + System.currentTimeMillis();
    KuduClient client = new KuduClient.KuduClientBuilder(KUDU_MASTER).build();

    try {
      List<ColumnSchema> columns = new ArrayList(2);
      columns.add(new ColumnSchema.ColumnSchemaBuilder("key", Type.INT32)
          .key(true)
          .build());
      columns.add(new ColumnSchema.ColumnSchemaBuilder("value", Type.STRING)
          .build());
      Schema schema = new Schema(columns);
      client.createTable(tableName, schema);

      KuduTable table = client.openTable(tableName);
      KuduSession session = client.newSession();
      for (int i = 0; i < 10; i++) {
        Insert insert = table.newInsert();
        PartialRow row = insert.getRow();
        row.addInt(0, i);
        row.addString(1, "value " + i);
        session.apply(insert);
      }

      List<String> projectColumns = new ArrayList<>(1);
      projectColumns.add("value");
      KuduScanner scanner = client.newScannerBuilder(table)
          .setProjectedColumnNames(projectColumns)
          .build();
      while (scanner.hasMoreRows()) {
        RowResultIterator results = scanner.nextRows();
        while (results.hasNext()) {
          RowResult result = results.next();
          System.out.println(result.getString(0));
        }
      }
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      try {
        client.deleteTable(tableName);
      } catch (Exception e) {
        e.printStackTrace();
      } finally {
        try {
          client.shutdown();
        } catch (Exception e) {
          e.printStackTrace();
        }
      }
    }
  }
}




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to