This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| TRACE 2023-11-02 18:31:57,596 [shard 0] cluster - controller_backend.cc:848 - [{kafka/panda-topic/16}] (retry 0) executing operation: {type: addition, revision: 17, assignment: { id: 16, group_id: 17, replicas: {{node_id: 2, shard: 0}, {node_id: 3, shard: 0}, {node_id: 1, shard: 0}} }, previous assignment: {nullopt}} | |
| DEBUG 2023-11-02 18:31:57,596 [shard 0] cloud_storage - partition_recovery_manager.cc:100 - No manifest override for {kafka/panda-topic/16} found, skipping | |
| TRACE 2023-11-02 18:31:57,596 [shard 1] cluster - controller_backend.cc:848 - [{kafka/panda-topic/16}] (retry 0) executing operation: {type: addition, revision: 17, assignment: { id: 16, group_id: 17, replicas: {{node_id: 2, shard: 0}, {node_id: 3, shard: 0}, {node_id: 1, shard: 0}} }, previous assignment: {nullopt}} | |
| DEBUG 2023-11-02 18:31:57,596 [shard 1] cluster - controller_backend.cc:768 - [{kafka/panda-topic/16}] (retry 0) finished operation: {type: addition, revision: 17, assignment: { id: 16, group_id: 17, replicas: {{node_id: 2, shard: |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import kudu | |
| import pandas as pd | |
| import pyarrow as pa | |
| import time | |
| def main(): | |
| client = kudu.connect("0.0.0.0", 8764) | |
| num_rows = 100000 | |
| num_rows_per_batch = 1000 | |
| num_non_pks = 100 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| commit 4d2ed5ca7b18c0883242e4596374483cd5a9e68c | |
| Author: Andrew Wong <[email protected]> | |
| Date: Tue Jul 7 21:10:49 2020 -0700 | |
| docker: build the website | |
| Adds a docs_build image that includes most of the required pieces for | |
| running make_site.sh. | |
| Some manual steps are still needed, e.g. before running anything, I |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| diff --git a/src/kudu/master/table_locations_cache.cc b/src/kudu/master/table_locations_cache.cc | |
| index adf2a4a1a..a903889e3 100644 | |
| --- a/src/kudu/master/table_locations_cache.cc | |
| +++ b/src/kudu/master/table_locations_cache.cc | |
| @@ -39,7 +39,7 @@ namespace kudu { | |
| namespace master { | |
| TableLocationsCache::TableLocationsCache(size_t capacity_bytes) | |
| - : eviction_cb_(new EvictionCallback(this)), | |
| + : eviction_cb_(this), |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| From d1d8e6d72209521cc884dde419725c657d86f4ec Mon Sep 17 00:00:00 2001 | |
| From: Andrew Wong <[email protected]> | |
| Date: Thu, 02 Jul 2020 20:08:02 -0700 | |
| Subject: [PATCH] ranger: add some logging | |
| Debugging KUDU-3154 | |
| Change-Id: I06502d182b88ab1d7c77e842b8986c9228ed8245 | |
| --- |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| commit 3ab9ac2f8f98edf9fae393f5514af4a01000e1fa | |
| Author: Andrew Wong <[email protected]> | |
| Date: Wed Apr 8 15:08:14 2020 -0700 | |
| reuse Sentry/Ranger-agnostic code | |
| Change-Id: I826d89b4289c3c6116b6a7a540ed12827e21f4b6 | |
| diff --git a/src/kudu/integration-tests/master_authz-itest.cc b/src/kudu/integration-tests/master_authz-itest.cc | |
| index bfc1b0405..839b9bb86 100644 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| commit 6fee34dc46a6dd19112a42ab0f51046f23913c30 | |
| Author: Andrew Wong <[email protected]> | |
| Date: Wed Apr 8 15:08:14 2020 -0700 | |
| reuse Sentry/Ranger-agnostic code | |
| Change-Id: I826d89b4289c3c6116b6a7a540ed12827e21f4b6 | |
| diff --git a/src/kudu/integration-tests/master_authz-itest.cc b/src/kudu/integration-tests/master_authz-itest.cc | |
| index bfc1b0405..8de02cacb 100644 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| export KUDU_QUICKSTART_IP=$(ifconfig | grep "inet " | grep -Fv 127.0.0.1 | awk '{print $2}' | tail -1) | |
| docker pull apache/kudu:latest | |
| docker run -it -p 8050:8050 -p 7050:7050 -p 8051:8051 -p 7051:7051 apache/kudu:latest bash | |
| mkdir master | |
| mkdir tserver | |
| # Run a tablet server and master. | |
| ./bin/kudu-tserver --fs_wal_dir=/opt/kudu/tserver/test-wal --logtostderr --use_hybrid_clock=false --rpc_bind_addresses=0.0.0.0:7050 --rpc_advertised_addresses=${KUDU_QUICKSTART_IP}:7050 --webserver_port=8050 --webserver_advertised_addresses=${KUDU_QUICKSTART_IP}:8050 --webserver_doc_root=/opt/kudu/www --stderrthreshold=0 &> tserver.log & | |
| ./bin/kudu-master --fs_wal_dir=/opt/kudu/master/test-wal --logtostderr --use_hybrid_clock=false --rpc_bind_addresses=0.0.0.0:7051 --rpc_advertised_addresses=${KUDU_QUICKSTART_IP}:7051 --webserver_port=8051 --webserver_advertised_addresses=${KUDU_QUICKSTART_IP}:8051 --webserver_doc_root=/opt/kudu/www --stderrthreshold=0 &> master.log & |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| docker pull apache/kudu:latest | |
| docker run -it --network="docker_default" -p 8050:8050 -p 7050:7050 -p 8051:8051 -p 7051:7051 apache/kudu:latest bash | |
| mkdir master | |
| mkdir tserver | |
| # Run a tablet server and master. | |
| ./bin/kudu-tserver --fs_wal_dir=/opt/kudu/tserver/test-wal --logtostderr --use_hybrid_clock=false --rpc_bind_addresses=0.0.0.0:7050 --rpc_advertised_addresses=${KUDU_QUICKSTART_IP}:7050 --webserver_port=8050 --webserver_advertised_addresses=${KUDU_QUICKSTART_IP}:8050 --webserver_doc_root=/opt/kudu/www --stderrthreshold=0 &> tserver.log & | |
| ./bin/kudu-master --fs_wal_dir=/opt/kudu/master/test-wal --logtostderr --use_hybrid_clock=false --rpc_bind_addresses=0.0.0.0:7051 --rpc_advertised_addresses=${KUDU_QUICKSTART_IP}:7051 --webserver_port=8051 --webserver_advertised_addresses=${KUDU_QUICKSTART_IP}:8051 --webserver_doc_root=/opt/kudu/www --stderrthreshold=0 &> master.log & | |
| # Now create a table. |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| diff --git a/src/kudu/master/sentry_authz_provider-test.cc b/src/kudu/master/sentry_authz_provider-test.cc | |
| index e7304ab..42ad8f0 100644 | |
| --- a/src/kudu/master/sentry_authz_provider-test.cc | |
| +++ b/src/kudu/master/sentry_authz_provider-test.cc | |
| @@ -59,6 +59,7 @@ | |
| #include "kudu/util/random.h" | |
| #include "kudu/util/random_util.h" | |
| #include "kudu/util/status.h" | |
| +#include "kudu/util/stopwatch.h" | |
| #include "kudu/util/test_macros.h" |
NewerOlder