[
https://issues.apache.org/jira/browse/KUDU-1426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15253322#comment-15253322
]
Min Wei commented on KUDU-1426:
-------------------------------
thanks for the follow up. I pulled the master and built it a couple of days
ago. These are the last two commits (assume this is what you are asking, to run
git log).
commit bde7294fc0b0f9423a77c88c51ffa5e7915017ac
commit e6052ac19958df48d0d9045ef2c0e10d39e02d91
> 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)
