Hive sql用正则提取任务id {"渠道":"mina","业务类型":"汽车票","refid":"319527329","任务id":17616,"用户类型":"新","按钮类型":"主动发放","主副策略":"主","操作类型":"曝光","触达类型":"弹窗"}

在Hive SQL中，可以使用正则表达式来提取任务id。以下是一个示例查询语句：

SELECT REGEXP_EXTRACT(json_data, '"任务id":(\d+)', 1) AS task_id
FROM your_table;

在这个查询语句中，假设你的数据存储在名为`your_table`的表中，且任务信息以JSON格式存储在名为`json_data`的列中。`REGEXP_EXTRACT`函数用于提取任务id，其中正则表达式`'"任务id":(\d+)'`匹配了`"任务id":`后面的数字，并将其作为结果返回。

请注意，你需要根据实际情况修改表名和列名。

相关问题

hive 正则函数提取业务类型：^env:mina^refid:1623888689^机型属性:安卓^策略id: 548^业务类型：汽车票^出发城市: 洛阳^

可以使用Hive正则函数提取业务类型，具体方法如下：

SELECT regexp_extract('env:mina^refid:1623888689^机型属性:安卓^策略id: 548^业务类型：汽车票^出发城市: 洛阳^', '\\^业务类型：([^\\^]+)', 1)

该语句中，`regexp_extract`函数用于提取业务类型，第一个参数为待提取的字符串，第二个参数为正则表达式，`\\^业务类型：([^\\^]+)`表示匹配以`^业务类型：`开头，后面跟着任意非`^`字符的字符串，并将其中的业务类型部分提取出来。第三个参数为提取的分组编号，这里为1，表示提取正则表达式中第一个括号内的内容。

因此，该语句的返回结果为`汽车票`。

hive sql使用了group by 执行任务没正常结束，一直输出spark.ContextCleaner: Cleaned accumulator

这种情况可能是由于数据量太大，导致Spark任务执行时间过长而超时。可以尝试以下几种方法：

1. 增加Spark任务的超时时间，可以在Hive中设置参数hive.execution.engine.spark.session.timeout来增加超时时间。

2. 对于数据量较大的情况，可以考虑对数据进行拆分，分批处理。

3. 对于group by操作，可以考虑使用分桶表或者分区表来优化查询效率。

4. 增加Spark的资源配置，例如增加executor的数量、内存等。

5. 检查日志信息，看是否有其他异常信息或者错误提示，以便定位问题。