Commit 914b0b11 authored by Domenico Giordano's avatar Domenico Giordano
Browse files

fix the rally test query

parent ee5e0d61
......@@ -162,11 +162,11 @@
filtered_df = spark.sql("select metadata.timestamp as atime, metadata.hostgroup as hostgroup,\
metadata.environment, metadata.host as host, data.process as process,\
data.short_task as task, data.deployment as deployment,\
data.raw,\
data.source as source, data.log_source as log_source, metadata._id as uid\
from tfull where data.log_level == 'ERROR' and data.log_source == 'rallytester.rallytester' ")
from tfull where data.log_level == 'ERROR' ")
##############
### Example of manipulation of strings
##############
#extract raw substring
......
......@@ -37,8 +37,7 @@ def getSparkDF(inpath, outpath, spark, schemafile):
metadata._id as uid\
from tfull\
where\
data.log_level == 'ERROR' and\
data.log_source == 'rallytester.rallytester'\
data.log_level == 'ERROR' \
")
# #######################################
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment