You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@kudu.apache.org by "Adar Dembo (JIRA)" <ji...@apache.org> on 2016/04/22 04:35:12 UTC
[jira] [Commented] (KUDU-1426) kudu master crashes on Mac OS X
[ https://issues.apache.org/jira/browse/KUDU-1426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15253219#comment-15253219 ]
Adar Dembo commented on KUDU-1426:
----------------------------------
Sounds an awful lot like the bug fixed by commit 75d5c82. Is that commit compiled into your cluster binaries? If not, can you update your tree, rebuild, and see if the problem persists?
> 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)