mirror of
https://github.com/apache/impala.git
synced 2025-12-19 18:12:08 -05:00
6f2ac8a406
This patch make impala_connection.py to use the same log format as declared in conftest.py. Connection specific logs will have the protocol name printed. Modified set_configuration() and set_configuration_option() to make option related logging more concise. Moved LOG_FORMAT from conftest.py to patterns.py for reuse in impala_connection.py. Testing: - Run TestExprLimits locally and confirm that the log lines printed at logs/ee_tests/results/TEST-impala-parallel.xml is OK. Change-Id: I44ea7fbec15684ac5379703f781a400b4f17da8d Reviewed-on: http://gerrit.cloudera.org:8080/22577 Tested-by: Impala Public Jenkins <impala-public-jenkins@cloudera.com> Reviewed-by: Csaba Ringhofer <csringhofer@cloudera.com>
40 lines
1.6 KiB
Python
40 lines
1.6 KiB
Python
# Licensed to the Apache Software Foundation (ASF) under one
|
|
# or more contributor license agreements. See the NOTICE file
|
|
# distributed with this work for additional information
|
|
# regarding copyright ownership. The ASF licenses this file
|
|
# to you under the Apache License, Version 2.0 (the
|
|
# "License"); you may not use this file except in compliance
|
|
# with the License. You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing,
|
|
# software distributed under the License is distributed on an
|
|
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
# KIND, either express or implied. See the License for the
|
|
# specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
# Common patterns that ought to be the same throughout the framework should be placed
|
|
# here.
|
|
|
|
from __future__ import absolute_import, division, print_function
|
|
import re
|
|
|
|
# http://www.cloudera.com/content/www/en-us/documentation/enterprise/latest/topics/impala_identifiers.html
|
|
VALID_IMPALA_IDENTIFIER_REGEX = re.compile(r'^[a-zA-Z][a-zA-Z0-9_]{,127}$')
|
|
|
|
INT64_MASK = (1 << 64) - 1
|
|
|
|
LOG_FORMAT = "-- %(asctime)s %(levelname)-8s %(threadName)s: %(message)s"
|
|
|
|
|
|
def is_valid_impala_identifier(identifier):
|
|
"""Return True if identifier is a valid Impala identifier, False otherwise."""
|
|
return VALID_IMPALA_IDENTIFIER_REGEX.match(identifier) is not None
|
|
|
|
|
|
def print_id(id):
|
|
"""Stringify a TUniqueId as e.g. 8a4673c8fbe83a74:309751e900000000"""
|
|
return '{:016x}:{:016x}'.format(id.hi & INT64_MASK, id.lo & INT64_MASK)
|