Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id A0E2B200C23 for ; Wed, 22 Feb 2017 19:12:07 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 9F755160B75; Wed, 22 Feb 2017 18:12:07 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id B5A44160B62 for ; Wed, 22 Feb 2017 19:12:06 +0100 (CET) Received: (qmail 88389 invoked by uid 500); 22 Feb 2017 18:12:05 -0000 Mailing-List: contact commits-help@impala.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@impala.incubator.apache.org Delivered-To: mailing list commits@impala.incubator.apache.org Received: (qmail 88345 invoked by uid 99); 22 Feb 2017 18:12:05 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 22 Feb 2017 18:12:05 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 63F821A03C5 for ; Wed, 22 Feb 2017 18:12:05 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -6.218 X-Spam-Level: X-Spam-Status: No, score=-6.218 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-2.999, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id twlf5mkGF2Rq for ; Wed, 22 Feb 2017 18:12:03 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with SMTP id 2EAA65FCBB for ; Wed, 22 Feb 2017 18:12:01 +0000 (UTC) Received: (qmail 87292 invoked by uid 99); 22 Feb 2017 18:12:00 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 22 Feb 2017 18:12:00 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 42360DFF30; Wed, 22 Feb 2017 18:12:00 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: mjacobs@apache.org To: commits@impala.incubator.apache.org Date: Wed, 22 Feb 2017 18:12:04 -0000 Message-Id: In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [5/6] incubator-impala git commit: IMPALA-4934: Disable Kudu OpenSSL initialization archived-at: Wed, 22 Feb 2017 18:12:07 -0000 IMPALA-4934: Disable Kudu OpenSSL initialization Bumps the Kudu version to include the change to the client that allows Impala to disable SSL initialization. In authentication.cc, after Impala initializes OpenSSL, Impala then disables Kudu's OpenSSL init. Fixed a python test case that started failing after bumping the Kudu client version. Change-Id: I3f13f3af512c6d771979638da593685524c73086 Reviewed-on: http://gerrit.cloudera.org:8080/6056 Reviewed-by: Matthew Jacobs Tested-by: Impala Public Jenkins Project: http://git-wip-us.apache.org/repos/asf/incubator-impala/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-impala/commit/ed711330 Tree: http://git-wip-us.apache.org/repos/asf/incubator-impala/tree/ed711330 Diff: http://git-wip-us.apache.org/repos/asf/incubator-impala/diff/ed711330 Branch: refs/heads/master Commit: ed711330fce4b8b739e9f30a28720b1c8e90fc63 Parents: 441e15a Author: Matthew Jacobs Authored: Fri Feb 17 09:07:56 2017 -0800 Committer: Impala Public Jenkins Committed: Wed Feb 22 05:06:20 2017 +0000 ---------------------------------------------------------------------- be/src/rpc/authentication.cc | 9 ++++++++- bin/impala-config.sh | 4 ++-- infra/python/deps/download_requirements | 2 +- infra/python/deps/requirements.txt | 2 +- tests/query_test/test_kudu.py | 2 +- 5 files changed, 13 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/ed711330/be/src/rpc/authentication.cc ---------------------------------------------------------------------- diff --git a/be/src/rpc/authentication.cc b/be/src/rpc/authentication.cc index 665a68c..a42a1a4 100644 --- a/be/src/rpc/authentication.cc +++ b/be/src/rpc/authentication.cc @@ -643,7 +643,7 @@ Status InitAuth(const string& appname) { // Impala's SASL initialization. This must be called before any KuduClients are // created to ensure that Kudu doesn't init SASL first, and this returns an error if // Kudu has already initialized SASL. - if (impala::KuduIsAvailable()) { + if (KuduIsAvailable()) { KUDU_RETURN_IF_ERROR(kudu::client::DisableSaslInitialization(), "Unable to disable Kudu SASL initialization."); } @@ -656,7 +656,14 @@ Status InitAuth(const string& appname) { } } + // Initializes OpenSSL. RETURN_IF_ERROR(AuthManager::GetInstance()->Init()); + + // Prevent Kudu from re-initializing OpenSSL. + if (KuduIsAvailable()) { + KUDU_RETURN_IF_ERROR(kudu::client::DisableOpenSSLInitialization(), + "Unable to disable Kudu SSL initialization."); + } return Status::OK(); } http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/ed711330/bin/impala-config.sh ---------------------------------------------------------------------- diff --git a/bin/impala-config.sh b/bin/impala-config.sh index 1782577..af76ac9 100755 --- a/bin/impala-config.sh +++ b/bin/impala-config.sh @@ -120,10 +120,10 @@ if [[ $OSTYPE == "darwin"* ]]; then fi # Kudu version in the toolchain; provides libkudu_client.so and minicluster binaries. -export IMPALA_KUDU_VERSION=cd7b0dd +export IMPALA_KUDU_VERSION=2b0edbe # Kudu version used to identify Java client jar from maven -export KUDU_JAVA_VERSION=1.2.0-SNAPSHOT +export KUDU_JAVA_VERSION=1.3.0-SNAPSHOT # Versions of Hadoop ecosystem dependencies. # ------------------------------------------ http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/ed711330/infra/python/deps/download_requirements ---------------------------------------------------------------------- diff --git a/infra/python/deps/download_requirements b/infra/python/deps/download_requirements index 2ef8922..f610cab 100755 --- a/infra/python/deps/download_requirements +++ b/infra/python/deps/download_requirements @@ -29,5 +29,5 @@ PY26="$(./find_py26.py)" "$PY26" pip_download.py virtualenv 13.1.0 # kudu-python is downloaded separately because pip install attempts to execute a # setup.py subcommand for kudu-python that can fail even if the download succeeds. -"$PY26" pip_download.py kudu-python 1.1.0 +"$PY26" pip_download.py kudu-python 1.2.0 popd http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/ed711330/infra/python/deps/requirements.txt ---------------------------------------------------------------------- diff --git a/infra/python/deps/requirements.txt b/infra/python/deps/requirements.txt index 1c3a329..1fa5a28 100644 --- a/infra/python/deps/requirements.txt +++ b/infra/python/deps/requirements.txt @@ -82,7 +82,7 @@ texttable == 0.8.3 # functional and determines the expected kudu-python version. The version must be listed # in the format below including # and spacing. Keep this formatting! The kudu-python # version in download_requirements must be kept in sync with this version. -# kudu-python==1.1.0 +# kudu-python==1.2.0 Cython == 0.23.4 numpy == 1.10.4 http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/ed711330/tests/query_test/test_kudu.py ---------------------------------------------------------------------- diff --git a/tests/query_test/test_kudu.py b/tests/query_test/test_kudu.py index 50db7ee..0359161 100644 --- a/tests/query_test/test_kudu.py +++ b/tests/query_test/test_kudu.py @@ -204,7 +204,7 @@ class TestKuduOperations(KuduTestSuite): # Add some rows session = kudu_client.new_session() for i in range(100): - op = table.new_insert((i, None)) + op = table.new_insert((i, "foo")) session.apply(op) session.flush()