Skip to content

Instantly share code, notes, and snippets.

View toddlipcon's full-sized avatar

Todd Lipcon toddlipcon

View GitHub Profile
19/06/06 14:58:01 ||1e2821aa-efec-4924-9300-d0ab8cd02f62|audit|0:0:0:0:0:0:0:1|KUDU||||access|uri|/gateway/sandbox/kudu/rpcz|unavailable|Request method: GET
19/06/06 14:58:01 ||1e2821aa-efec-4924-9300-d0ab8cd02f62|audit|0:0:0:0:0:0:0:1|KUDU|guest|||authentication|uri|/gateway/sandbox/kudu/rpcz|success|
19/06/06 14:58:01 ||1e2821aa-efec-4924-9300-d0ab8cd02f62|audit|0:0:0:0:0:0:0:1|KUDU|guest|||authentication|uri|/gateway/sandbox/kudu/rpcz|success|Groups: []
19/06/06 14:58:01 ||1e2821aa-efec-4924-9300-d0ab8cd02f62|audit|0:0:0:0:0:0:0:1|KUDU|guest|||dispatch|uri|http://localhost:8051/rpcz?user.name=guest|unavailable|Request method: GET
19/06/06 14:58:01 ||1e2821aa-efec-4924-9300-d0ab8cd02f62|audit|0:0:0:0:0:0:0:1|KUDU|guest|||dispatch|uri|http://localhost:8051/rpcz?user.name=guest|success|Response status: 200
19/06/06 14:58:01 |||audit|0:0:0:0:0:0:0:1|KUDU|guest|||access|uri|/gateway/sandbox/kudu/rpcz|success|Response status: 200
19/06/06 14:58:03 ||4fa691e0-477b-4bc9-b90f-a8dcc126006b|audit|0:0:0:0:0:0:0:1|KUDU
#!/usr/bin/env python
import random
from collections import Counter
num_tservers = 30
num_hash_buckets = 16
repl_factor = 3
ts_buckets = [random.randrange(0, num_hash_buckets) for i in xrange(num_tservers)]
ts_load = Counter()
#!/usr/bin/env python
import random
from collections import Counter
num_tservers = 30
num_hash_buckets = 16
repl_factor = 3
ts_buckets = [random.randrange(0, num_hash_buckets) for i in xrange(num_tservers)]
ts_load = Counter()
diff --git a/fe/src/main/java/org/apache/impala/analysis/AlterTableStmt.java b/fe/src/main/java/org/apache/impala/analysis/AlterTableStmt.java
index b5fda6280c..1a311955fb 100644
--- a/fe/src/main/java/org/apache/impala/analysis/AlterTableStmt.java
+++ b/fe/src/main/java/org/apache/impala/analysis/AlterTableStmt.java
@@ -90,8 +90,6 @@ public abstract class AlterTableStmt extends StatementBase {
}
Preconditions.checkState(tableRef instanceof BaseTableRef);
table_ = tableRef.getTable();
- // Adding the check here instead of tableRef.analyze because tableRef is
- // used at multiple places and will even disallow select.
todd@va1022:~$ ps auxw | grep cargo
todd 92089 0.0 0.0 10864 696 pts/21 S+ 11:36 0:00 run-cargo-script /home/todd/find_gaps.rs
todd 92090 0.0 0.0 153904 2868 pts/21 S+ 11:36 0:00 /home/todd/.cargo/bin/cargo-script script /home/todd/find_gaps.rs --
todd 92137 0.0 0.0 139324 10932 pts/21 Sl+ 11:36 0:00 /home/todd/.rustup/toolchains/stable-x86_64-unknown-linux-gnu/bin/cargo build --manifest-path /home/todd/.cargo/script-cache/file-find_gaps-8fc1e82ddc05826a/Cargo.toml --color always --release --message-format=json
todd 92791 0.0 0.0 112652 964 pts/26 S+ 11:39 0:00 grep --color=auto cargo
todd@va1022:~$ strace -p 92090
Process 92090 attached
wait4(92137, ^CProcess 92090 detached
<detached ...>
todd@va1022:~$ strace -p 92137
[westeros.edh.cloudera.com:21000] > describe queries;
Query: describe queries
+-----------------------------+--------------------------------+-----------------------------+
| name | type | comment |
+-----------------------------+--------------------------------+-----------------------------+
| queryid | string | Inferred from Parquet file. |
| sessionid | string | Inferred from Parquet file. |
| sessiontype | string | Inferred from Parquet file. |
| starttimemillis | bigint | Inferred from Parquet file. |
| endtimemillis | bigint | Inferred from Parquet file. |
#include <algorithm>
#include <iostream>
#include <vector>
#include <utility>
using namespace std;
int main( int argc, char *argv[] ) {
vector<pair<int, int>> pairs = {
{2, 3},
{2, 4},
// Compile with: clang++ -o test -lkrb5 -pthread test.cc
#include <krb5/krb5.h>
#include <iostream>
#include <functional>
#include <atomic>
#include <cassert>
#include <unistd.h>
#include <thread>
#include <vector>
#include <krb5/krb5.h>
#include <iostream>
#include <functional>
#include <atomic>
#include <cassert>
#include <unistd.h>
#include <thread>
#include <vector>
using namespace std;
#include <pthread.h>
#include <linux/futex.h>
#include <unistd.h>
#include <sys/syscall.h>
#include <sys/time.h>
int main() {
#if 0
pthread_mutex_t m = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cv = PTHREAD_COND_INITIALIZER;