toddlipcon

<configuration>
  <property>
    <name>dfs.nameservices</name>
    <value>nameservice1</value>
  </property>
  <property>
    <name>dfs.ha.namenodes.nameservice1</name>
    <value>nn1</value>
  </property>
  <property>

toddlipcon

  @Test
  public void testLoadTable() throws Exception {
    Table table = catalog_.getOrLoadTable("gftrrhrn_managed", "stitched_pts");
    if (table instanceof IncompleteTable) {
      IncompleteTable it = (IncompleteTable)table;
      LOG.warn("failed to load: {}", it.getCause());
    }
    LOG.info("cols: " + table.getColumnNames());

toddlipcon

r130 clang4
--------
Compressed 42553599 bytes into 10314046 bytes ==> 24.24%                       

 Performance counter stats for './lz4-r130.clang-4 -f akey /dev/null' (10 runs):

         88.483908      task-clock (msec)         #    0.995 CPUs utilized            ( +-  0.96% )
                 3      context-switches          #    0.035 K/sec                    ( +-  3.23% )
                 0      cpu-migrations            #    0.001 K/sec                    ( +-100.00% )
             1,456      page-faults               #    0.016 M/sec                    ( +-  0.01% )

toddlipcon

diff --git a/java/kudu-client/src/main/java/org/apache/kudu/client/AsyncKuduClient.java b/java/kudu-client/src/main/java/org/apache/kudu/client/AsyncKuduClient.java
index 0c7e800..4b93a34 100644
--- a/java/kudu-client/src/main/java/org/apache/kudu/client/AsyncKuduClient.java
+++ b/java/kudu-client/src/main/java/org/apache/kudu/client/AsyncKuduClient.java
@@ -406,7 +406,11 @@ public class AsyncKuduClient implements AutoCloseable {
       return null;
     }
     return newRpcProxy(
-        new ServerInfo("master-" + hostPort.toString(), hostPort, inetAddress), credentialsPolicy);
+        new ServerInfo(getFakeMasterUuid(hostPort), hostPort, inetAddress), credentialsPolicy);

toddlipcon

[ve0130.halxg.cloudera.com:21000] > show column stats ycsb_todd;
Query: show column stats ycsb_todd
+--------+--------+------------------+--------+----------+------------------+
| Column | Type   | #Distinct Values | #Nulls | Max Size | Avg Size         |
+--------+--------+------------------+--------+----------+------------------+
| key    | STRING | 10000000         | -1     | 23       | 22.8794994354248 |
| field0 | STRING | 10000000         | -1     | 100      | 100              |
| field1 | STRING | 10000000         | -1     | 100      | 100              |
| field2 | STRING | 10000000         | -1     | 100      | 100              |

toddlipcon

#!/usr/bin/env python
import base64
import random
import simplejson as json
import glob
from multiprocessing import Pool
import subprocess
import os
import signal
import time

toddlipcon

ninja: Entering directory `/src/kudu/build/debug'
[1/107] Recreating ../build/latest symlink
[2/107] cd /src/kudu/build/debug/src/kudu/util && /src/kudu/build-support/gen_version_info.py --version=1.7.0-SNAPSHOT --build-type=DEBUG /src/kudu/build/debug/src/kudu/generated/version_defines.h
Stacks at 0221 11:39:33.337439 (periodic):
  tids=[26778]
        0x302340f710 <unknown>
        0x30230dc657 <unknown>
           0x1c4212f kudu::(anonymous namespace)::PosixEnv::DeleteFile()
           0x1c4e157 kudu::env_util::DeleteExcessFilesByPattern()
           0x1c6a006 kudu::DeleteExcessLogFiles()

toddlipcon

#include <vector>
#include <iostream>

using namespace std;

int copied = 0;
int moved = 0;

struct Foo {
  Foo() = default;

toddlipcon

Collected stacks from 61 threads in 0.613s

TID 4057(sq_acceptor):
    @     0x7f41420124b0  (unknown)
    @     0x7f41420d874d  __poll
    @          0x12274d5  master_thread
    @     0x7f41442616ba  start_thread
    @     0x7f41420e441d  clone
    @              (nil)  (unknown)

toddlipcon

#include <thread>
#include <atomic>
#include <vector>
#include <unistd.h>
using namespace std;

int main() {
  vector<thread> threads;
  atomic<bool> done { false };
  for (int i = 0; i < 20; i++) {