SET STATEMENT#

SET 语句用于在 OpenMLDB 上设置系统变量。目前OpenMLDB的系统变量包括会话系统变量和全局系统变量。对会话变量的修改,只会影响到当前的会话(也就是当前的数据库连接)。对全局变量的修改会对所有会话生效。

Syntax#

SetStatement ::=
    'SET' variableName '=' value

variableName ::=
	sessionVariableName
	
sessionVariableName ::= '@@'Identifier | '@@session.'Identifier | '@@global.'Identifier

或者用下面的语法格式

'SET' [ GLOBAL | SESSION ] <variableName> '=' <value>
  • 会话系统变量一般以@session前缀,如SET @@session.execute_mode = "offline";。会话系统变量也可以选择直接以@@为前缀,即SET @@execute_mode = "offline"和前面的配置语句是等价的。

  • 全局系统变量以@global为前缀,如SET @@global.enable_trace = true;

  • 会话系统变量也可以选择直接以@@为前缀,即SET @@execute_mode = "offline"和前面的配置语句是等价的。

  • OpenMLDB的SET语句只能用于设置/修改已存在(内置的)的系统变量。

目前支持的系统变量#

SESSION 系统变量#

SESSION系统变量

变量描述

变量值

默认值

@@session.execute_mode|@@execute_mode

OpenMDLB在当前会话下的执行模式。目前支持offlineonline两种模式。
在离线执行模式下,只会导入/插入以及查询离线数据。
在在线执行模式下,只会导入/插入以及查询在线数据。

“offline” | “online”

“offline”

@@session.enable_trace|@@enable_trace

当该变量值为 true,SQL语句有语法错误或者在计划生成过程发生错误时,会打印错误信息栈。
当该变量值为 false,SQL语句有语法错误或者在计划生成过程发生错误时,仅打印基本错误信息。

“true” | “false”

“false”

@@session.sync_job|@@sync_job

当该变量值为 true,离线的命令将变为同步,等待执行的最终结果。
当该变量值为 false,离线的命令即时返回,若要查看命令的执行情况,请使用SHOW JOB

“true” | “false”

“false”

@@session.job_timeout|@@job_timeout

可配置离线异步命令或离线管理命令的等待时间(以毫秒为单位),将立即返回。离线异步命令返回后仍可通过SHOW JOB查看命令执行情况。

Int

“20000”

@@session.spark_config|@@spark_config

设置离线任务的 Spark 参数,配置项参考 ‘spark.executor.memory=2g;spark.executor.cores=2’。注意此 Spark 配置优先级高于 TaskManager 默认 Spark 配置,低于命令行的 Spark 配置文件。

String

“”

@@session.insert_memory_usage_limit|@@insert_memory_usage_limit

设置数据插入或者数据导入时服务端内存使用率限制。取值范围为0-100。如果服务端内存使用率超过设置的值,就会插入失败。设置为0表示不限制

Int

“0”

Example#

设置和显示会话系统变量#

> SHOW VARIABLES;
 --------------- ---------
  Variable_name   Value
 --------------- ---------
  enable_trace    false
  execute_mode    offline
  job_timeout     20000
  sync_job        false
 --------------- ---------

4 rows in set
> SET @@session.execute_mode = "online";
-- SUCCEED
> SHOW VARIABLES;
 --------------- ---------
  Variable_name   Value
 --------------- ---------
  enable_trace    false
  execute_mode    online
  job_timeout     20000
  sync_job        false
 --------------- ---------

4 rows in set
> SET @@session.enable_trace = "true";
 -- SUCCEED
> SHOW VARIABLES;
  --------------- ---------
  Variable_name   Value
 --------------- ---------
  enable_trace    true
  execute_mode    online
  job_timeout     20000
  sync_job        false
 --------------- ---------

4 rows in set

设置和显示全局系统变量#

> SHOW GLOBAL VARIABLES;
 --------------- ----------------
  Variable_name   Variable_value
 --------------- ----------------
  enable_trace    false
  sync_job        false
  job_timeout     20000
  execute_mode    offline
 --------------- ----------------

4 rows in set
> SET @@global.enable_trace = "true";
-- SUCCEED
> SHOW GLOBAL VARIABLES;
 --------------- ----------------
  Variable_name   Variable_value
 --------------- ----------------
  enable_trace    true
  sync_job        false
  job_timeout     20000
  execute_mode    offline
 --------------- ----------------

4 rows in set

配置enable_trace#

  • 创建一个数据库db1,并建立表t1

CREATE DATABASE db1;
-- SUCCEED
USE db1;
-- SUCCEED: Database changed
CREATE TABLE t1 (col0 STRING, col1 int, std_time TIMESTAMP, INDEX(KEY=col1, TS=std_time, TTL_TYPE=absolute, TTL=30d));
--SUCCEED
  • 关闭enable_trace时,执行错误的SQL:

> set @@enable_trace = "false";
-- SUCCEED    
> select sum(col1) over w1 from t1 window w1 as (partition by col1 order by col0 rows_range between 10d preceding and current row);
-- ERROR: Invalid Order column type : kVarchar
  • 打开enable_trace时,执行错误的SQL:

> set @@enable_trace = "true";
-- SUCCEED
> select sum(col1) over w1 from t1 window w1 as (partition by col1 order by col0 rows_range between 10d preceding and current row);
-- ERROR: Invalid Order column type : kVarchar
    (At /Users/chenjing/work/chenjing/OpenMLDB/hybridse/src/vm/sql_compiler.cc:263)
    (At /Users/chenjing/work/chenjing/OpenMLDB/hybridse/src/vm/sql_compiler.cc:166)
    (Caused by) Fail to generate physical plan batch mode
    (At /Users/chenjing/work/chenjing/OpenMLDB/hybridse/src/vm/transform.cc:1672)
    (Caused by) Fail to transform query statement
    (At /Users/chenjing/work/chenjing/OpenMLDB/hybridse/src/vm/transform.cc:103)
    (At /Users/chenjing/work/chenjing/OpenMLDB/hybridse/src/vm/transform.cc:1249)
    (At /Users/chenjing/work/chenjing/OpenMLDB/hybridse/src/vm/transform.cc:1997)

离线命令配置详情#

  • 设置离线命令同步执行,同步的超时时间将自动设置为30min(gflag sync_job_timeout,同时也是与TaskManager的最大超时时间),通常情况不用手动设置job_timeout

> SET @@sync_job = "true";

Caution

如果离线同步命令执行时间超过30min,需要同时调整TaskManager配置和客户端的配置。

  • 调大TaskManager的server.channel_keep_alive_time,单位为秒。

  • 二选一:

    • 手动设置更大的会话超时时间,我们会使用max(session_job_timeout, default_gflag_sync_job_timeout)

    • 配置客户端--sync_job_timeout,不可大于server.channel_keep_alive_time,不用手动SET。SDK暂不支持修改。

  • 设置离线异步命令或离线管理命令的等待时间,单位为毫秒,默认为1min:

> SET @@job_timeout = "600000";

相关SQL语句#

SHOW VARIABLES