Merge branch '3.0' of https://github.com/taosdata/TDengine into fix/T…

…S-5468

cmake/addr2line_CMakeLists.txt.in

@@ -2,7 +2,7 @@
 # addr2line
 ExternalProject_Add(addr2line
         GIT_REPOSITORY https://github.com/davea42/libdwarf-addr2line.git
-        GIT_TAG master
+        GIT_TAG main
         SOURCE_DIR "${TD_CONTRIB_DIR}/addr2line"
         BINARY_DIR "${TD_CONTRIB_DIR}/addr2line"
         CONFIGURE_COMMAND ""

cmake/cmake.version

@@ -2,7 +2,7 @@
 IF (DEFINED VERNUMBER)
   SET(TD_VER_NUMBER ${VERNUMBER})
 ELSE ()
-  SET(TD_VER_NUMBER "3.3.5.0.alpha")
+  SET(TD_VER_NUMBER "3.3.5.2.alpha")
 ENDIF ()
 
 IF (DEFINED VERCOMPATIBLE)

cmake/curl_CMakeLists.txt.in

@@ -12,7 +12,7 @@ ExternalProject_Add(curl2
         BUILD_IN_SOURCE TRUE
         BUILD_ALWAYS 1
         UPDATE_COMMAND ""
-        CONFIGURE_COMMAND ./configure --prefix=$ENV{HOME}/.cos-local.2 --with-ssl=$ENV{HOME}/.cos-local.2  --enable-shared=no --disable-ldap --disable-ldaps --without-brotli --without-zstd --without-libidn2 --without-nghttp2 --without-libpsl #--enable-debug
+        CONFIGURE_COMMAND ${CONTRIB_CONFIG_ENV} ./configure --prefix=$ENV{HOME}/.cos-local.2 --with-ssl=$ENV{HOME}/.cos-local.2  --enable-websockets --enable-shared=no --disable-ldap --disable-ldaps --without-brotli --without-zstd --without-libidn2 --without-nghttp2 --without-libpsl #--enable-debug
         BUILD_COMMAND make -j
         INSTALL_COMMAND make install
         TEST_COMMAND ""

cmake/ssl_CMakeLists.txt.in

@@ -6,9 +6,9 @@ ExternalProject_Add(openssl
         DOWNLOAD_DIR "${TD_CONTRIB_DIR}/deps-download"
         SOURCE_DIR "${TD_CONTRIB_DIR}/openssl"
         BUILD_IN_SOURCE TRUE
-        #BUILD_ALWAYS 1
-        #UPDATE_COMMAND ""
-        CONFIGURE_COMMAND ./Configure --prefix=$ENV{HOME}/.cos-local.2 no-shared
+        BUILD_ALWAYS 1
+        UPDATE_COMMAND ""
+        CONFIGURE_COMMAND ${CONTRIB_CONFIG_ENV} ./Configure --prefix=$ENV{HOME}/.cos-local.2 no-shared
         BUILD_COMMAND make -j
         INSTALL_COMMAND make install_sw -j
         TEST_COMMAND ""

contrib/CMakeLists.txt

@@ -17,7 +17,6 @@ elseif(${BUILD_WITH_COS})
         file(MAKE_DIRECTORY $ENV{HOME}/.cos-local.1/)
         cat("${TD_SUPPORT_DIR}/mxml_CMakeLists.txt.in" ${CONTRIB_TMP_FILE3})
         cat("${TD_SUPPORT_DIR}/apr_CMakeLists.txt.in" ${CONTRIB_TMP_FILE3})
-        cat("${TD_SUPPORT_DIR}/curl_CMakeLists.txt.in" ${CONTRIB_TMP_FILE3})
     endif(${BUILD_WITH_COS})
 
     configure_file(${CONTRIB_TMP_FILE3} "${TD_CONTRIB_DIR}/deps-download/CMakeLists.txt")
@@ -146,11 +145,16 @@ if(${BUILD_WITH_SQLITE})
     cat("${TD_SUPPORT_DIR}/sqlite_CMakeLists.txt.in" ${CONTRIB_TMP_FILE})
 endif(${BUILD_WITH_SQLITE})
 
+# libcurl
+if(NOT ${TD_WINDOWS})
+    file(MAKE_DIRECTORY $ENV{HOME}/.cos-local.2/)
+    cat("${TD_SUPPORT_DIR}/ssl_CMakeLists.txt.in" ${CONTRIB_TMP_FILE})
+    cat("${TD_SUPPORT_DIR}/curl_CMakeLists.txt.in" ${CONTRIB_TMP_FILE})
+endif(NOT ${TD_WINDOWS})
+
 # s3
 if(${BUILD_WITH_S3})
-    cat("${TD_SUPPORT_DIR}/ssl_CMakeLists.txt.in" ${CONTRIB_TMP_FILE})
     cat("${TD_SUPPORT_DIR}/xml2_CMakeLists.txt.in" ${CONTRIB_TMP_FILE})
-    cat("${TD_SUPPORT_DIR}/curl_CMakeLists.txt.in" ${CONTRIB_TMP_FILE})
     cat("${TD_SUPPORT_DIR}/libs3_CMakeLists.txt.in" ${CONTRIB_TMP_FILE})
     cat("${TD_SUPPORT_DIR}/azure_CMakeLists.txt.in" ${CONTRIB_TMP_FILE})
     add_definitions(-DUSE_S3)
@@ -160,7 +164,6 @@ elseif(${BUILD_WITH_COS})
     # cat("${TD_SUPPORT_DIR}/mxml_CMakeLists.txt.in" ${CONTRIB_TMP_FILE})
     # cat("${TD_SUPPORT_DIR}/apr_CMakeLists.txt.in" ${CONTRIB_TMP_FILE})
     # cat("${TD_SUPPORT_DIR}/apr-util_CMakeLists.txt.in" ${CONTRIB_TMP_FILE})
-    # cat("${TD_SUPPORT_DIR}/curl_CMakeLists.txt.in" ${CONTRIB_TMP_FILE})
     cat("${TD_SUPPORT_DIR}/cos_CMakeLists.txt.in" ${CONTRIB_TMP_FILE})
     add_definitions(-DUSE_COS)
 endif()
@@ -199,6 +202,11 @@ endif()
 # lemon
 cat("${TD_SUPPORT_DIR}/lemon_CMakeLists.txt.in" ${CONTRIB_TMP_FILE})
 
+# Force specify CC=cc on MacOS. Because the default CC setting in the generated Makefile has issues finding standard library headers
+IF(${TD_DARWIN})
+    SET(CONTRIB_CONFIG_ENV "CC=cc")
+ENDIF()
+
 # download dependencies
 configure_file(${CONTRIB_TMP_FILE} "${TD_CONTRIB_DIR}/deps-download/CMakeLists.txt")
 execute_process(COMMAND "${CMAKE_COMMAND}" -G "${CMAKE_GENERATOR}" .

docs/en/10-third-party/01-collection/flink.md

@@ -26,7 +26,8 @@ Flink Connector supports all platforms that can run Flink 1.19 and above version
 
 | Flink Connector Version | Major Changes | TDengine Version|
 |-------------------------| ------------------------------------ | ---------------- |
-| 2.0.0                   | 1.Support SQL queries on data in TDengine database. <br/> 2. Support CDC subscription to data in TDengine database.<br/> 3. Supports reading and writing to TDengine database using Table SQL. | 3.3.5.0  and higher|
+| 2.0.1                   | Sink supports writing types from Rowdata implementations.| - |
+| 2.0.0                   | 1.Support SQL queries on data in TDengine database. <br/> 2. Support CDC subscription to data in TDengine database.<br/> 3. Supports reading and writing to TDengine database using Table SQL. | 3.3.5.1  and higher|
 | 1.0.0                   | Support Sink function to write data from other sources to TDengine in the future.| 3.3.2.0 and higher|
 
 ## Exception and error codes
@@ -114,7 +115,7 @@ If using Maven to manage a project, simply add the following dependencies in pom
 <dependency>
     <groupId>com.taosdata.flink</groupId>
     <artifactId>flink-connector-tdengine</artifactId>
-    <version>2.0.0</version>
+    <version>2.0.1</version>
 </dependency>
 ```
 

docs/en/28-releases/01-tdengine.md

@@ -25,6 +25,10 @@ Download links for TDengine 3.x version installation packages are as follows:
 
 import Release from "/components/ReleaseV3";
 
+## 3.3.5.2
+
+<Release type="tdengine" version="3.3.5.2" />
+
 ## 3.3.5.0
 
 <Release type="tdengine" version="3.3.5.0" />

docs/en/28-releases/03-notes/3.3.5.2.md

@@ -0,0 +1,43 @@
+---
+title: TDengine 3.3.5.2 Release Notes
+sidebar_label: 3.3.5.2
+description: Version 3.3.5.2 Notes
+slug: /release-history/release-notes/3.3.5.2
+---
+
+## Features
+  1. feat: taosX now support multiple stables with template for MQTT 
+
+## Enhancements
+  1. enh: improve taosX error message if database is invalid 
+  2. enh: use poetry group depencencies and reduce dep when install [#251](https://github.com/taosdata/taos-connector-python/issues/251)
+  3. enh: improve backup restore using taosX 
+  4. enh: during the multi-level storage data migration, if the migration time is too long, it may cause the Vnode to switch leader 
+  5. enh: adjust the systemctl strategy for managing the taosd process, if three consecutive restarts fail within 60 seconds, the next restart will be delayed until 900 seconds later
+
+## Fixes
+  1. fix: the maxRetryWaitTime parameter is used to control the maximum reconnection timeout time for the client when the cluster is unable to provide services, but it does not take effect when encountering a Sync timeout error 
+  2. fix: supports immediate subscription to the new tag value after modifying the tag value of the sub-table 
+  3. fix: the tmq_consumer_poll function for data subscription does not return an error code when the call fails
+  4. fix: taosd may crash when more than 100 views are created and the show views command is executed
+  5. fix: when using stmt2 to insert data, if not all data columns are bound, the insertion operation will fail
+  6. fix: when using stmt2 to insert data, if the database name or table name is enclosed in backticks, the insertion operation will fail 
+  7. fix: when closing a vnode, if there are ongoing file merge tasks, taosd may crash 
+  8. fix: frequent execution of the “drop table with tb_uid” statement may lead to a deadlock in taosd 
+  9. fix: the potential deadlock during the switching of log files 
+ 10. fix: prohibit the creation of databases with the same names as system databases (information_schema, performance_schema) 
+ 11. fix: when the inner query of a nested query come from a super table, the sorting information cannot be pushed up 
+ 12. fix: incorrect error reporting when attempting to write Geometry data types that do not conform to topological specifications through the STMT interface 
+ 13. fix: when using the percentile function and session window in a query statement, if an error occurs, taosd may crash 
+ 14. fix: the issue of being unable to dynamically modify system parameters 
+ 15. fix: random error of tranlict transaction in replication 
+ 16. fix: the same consumer executes the unsubscribe operation and immediately attempts to subscribe to other different topics, the subscription API will return an error 
+ 17. fix: fix CVE-2022-28948 security issue in go connector 
+ 18. fix: when a subquery in a view contains an ORDER BY clause with an alias, and the query function itself also has an alias, querying the view will result in an error 
+ 19. fix: when changing the database from a single replica to a mulit replica, if there are some metadata generated by earlier versions that are no longer used in the new version, the modification operation will fail 
+ 20. fix: column names were not correctly copied when using SELECT * FROM subqueries 
+ 21. fix: when performing max/min function on string type data, the results are inaccurate and taosd will crash 
+ 22. fix: stream computing does not support the use of the HAVING clause, but no error is reported during creation 
+ 23. fix: the version information displayed by taos shell for the server is inaccurate, such as being unable to correctly distinguish between the community edition and the enterprise edition 
+ 24. fix: in certain specific query scenarios, when JOIN and CAST are used together, taosd may crash 
+

docs/en/28-releases/03-notes/index.md

@@ -5,6 +5,7 @@ slug: /release-history/release-notes
 
 [3.3.5.0](./3-3-5-0/)
 
+[3.3.5.2](./3.3.5.2)  
 [3.3.4.8](./3-3-4-8/)
 
 [3.3.4.3](./3-3-4-3/)

docs/examples/flink/Main.java

@@ -263,7 +263,7 @@ void testBatchSource() throws Exception {
         Class<SourceRecords<RowData>> typeClass = (Class<SourceRecords<RowData>>) (Class<?>) SourceRecords.class;
         SourceSplitSql sql = new SourceSplitSql("select ts, `current`, voltage, phase, tbname from meters");
         TDengineSource<SourceRecords<RowData>> source = new TDengineSource<>(connProps, sql, typeClass);
-        DataStreamSource<SourceRecords<RowData>> input = env.fromSource(source, WatermarkStrategy.noWatermarks(), "kafka-source");
+        DataStreamSource<SourceRecords<RowData>> input = env.fromSource(source, WatermarkStrategy.noWatermarks(), "tdengine-source");
         DataStream<String> resultStream = input.map((MapFunction<SourceRecords<RowData>, String>) records -> {
             StringBuilder sb = new StringBuilder();
             Iterator<RowData> iterator = records.iterator();
@@ -304,7 +304,7 @@ void testTDengineCdc() throws Exception {
         config.setProperty(TDengineCdcParams.VALUE_DESERIALIZER, "RowData");
         config.setProperty(TDengineCdcParams.VALUE_DESERIALIZER_ENCODING, "UTF-8");
         TDengineCdcSource<RowData> tdengineSource = new TDengineCdcSource<>("topic_meters", config, RowData.class);
-        DataStreamSource<RowData> input = env.fromSource(tdengineSource, WatermarkStrategy.noWatermarks(), "kafka-source");
+        DataStreamSource<RowData> input = env.fromSource(tdengineSource, WatermarkStrategy.noWatermarks(), "tdengine-source");
         DataStream<String> resultStream = input.map((MapFunction<RowData, String>) rowData -> {
             StringBuilder sb = new StringBuilder();
             sb.append("tsxx: " + rowData.getTimestamp(0, 0) +
@@ -343,7 +343,7 @@ void testTDengineCdcBatch() throws Exception {
 
         Class<ConsumerRecords<RowData>> typeClass = (Class<ConsumerRecords<RowData>>) (Class<?>) ConsumerRecords.class;
         TDengineCdcSource<ConsumerRecords<RowData>> tdengineSource = new TDengineCdcSource<>("topic_meters", config, typeClass);
-        DataStreamSource<ConsumerRecords<RowData>> input = env.fromSource(tdengineSource, WatermarkStrategy.noWatermarks(), "kafka-source");
+        DataStreamSource<ConsumerRecords<RowData>> input = env.fromSource(tdengineSource, WatermarkStrategy.noWatermarks(), "tdengine-source");
         DataStream<String> resultStream = input.map((MapFunction<ConsumerRecords<RowData>, String>) records -> {
             Iterator<ConsumerRecord<RowData>> iterator = records.iterator();
             StringBuilder sb = new StringBuilder();
@@ -388,7 +388,7 @@ static void testCustomTypeCdc() throws Exception {
         config.setProperty(TDengineCdcParams.VALUE_DESERIALIZER, "com.taosdata.flink.entity.ResultDeserializer");
         config.setProperty(TDengineCdcParams.VALUE_DESERIALIZER_ENCODING, "UTF-8");
         TDengineCdcSource<ResultBean> tdengineSource = new TDengineCdcSource<>("topic_meters", config, ResultBean.class);
-        DataStreamSource<ResultBean> input = env.fromSource(tdengineSource, WatermarkStrategy.noWatermarks(), "kafka-source");
+        DataStreamSource<ResultBean> input = env.fromSource(tdengineSource, WatermarkStrategy.noWatermarks(), "tdengine-source");
         DataStream<String> resultStream = input.map((MapFunction<ResultBean, String>) rowData -> {
             StringBuilder sb = new StringBuilder();
             sb.append("ts: " + rowData.getTs() +

docs/zh/10-third-party/01-collection/12-flink.md

@@ -24,7 +24,8 @@ Flink Connector 支持所有能运行 Flink 1.19 及以上版本的平台。
 ## 版本历史
 | Flink Connector 版本 |                   主要变化         |   TDengine 版本   |
 | ------------------| ------------------------------------ | ---------------- |
-|        2.0.0      | 1. 支持 SQL 查询 TDengine 数据库中的数据<br/> 2. 支持 CDC 订阅 TDengine 数据库中的数据<br/> 3. 支持 Table SQL 方式读取和写入 TDengine 数据库| 3.3.5.0 及以上版本 |
+|        2.0.1      | Sink 支持对所有继承自 RowData 并已实现的类型进行数据写入| - |
+|        2.0.0      | 1. 支持 SQL 查询 TDengine 数据库中的数据<br/> 2. 支持 CDC 订阅 TDengine 数据库中的数据<br/> 3. 支持 Table SQL 方式读取和写入 TDengine 数据库| 3.3.5.1 及以上版本 |
 |        1.0.0      | 支持 Sink 功能，将来着其他数据源的数据写入到 TDengine| 3.3.2.0 及以上版本|
 
 ## 异常和错误码
@@ -111,7 +112,7 @@ env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.AT_LEAST_ONCE);
 <dependency>
     <groupId>com.taosdata.flink</groupId>
     <artifactId>flink-connector-tdengine</artifactId>
-    <version>2.0.0</version>
+    <version>2.0.1</version>
 </dependency>
 ```
 

docs/zh/28-releases/01-tdengine.md

@@ -24,6 +24,10 @@ TDengine 3.x 各版本安装包下载链接如下：
 
 import Release from "/components/ReleaseV3";
 
+## 3.3.5.2
+
+<Release type="tdengine" version="3.3.5.2" />
+
 ## 3.3.5.0
 
 <Release type="tdengine" version="3.3.5.0" />

docs/zh/28-releases/03-notes/3.3.5.2.md

@@ -0,0 +1,42 @@
+---
+title: 3.3.5.2 版本说明
+sidebar_label: 3.3.5.2
+description: 3.3.5.2 版本说明
+---
+
+## 特性
+  1. 特性：taosX MQTT 数据源支持根据模板创建多个超级表 
+
+## 优化
+  1. 优化：改进 taosX 数据库不可用时的错误信息 
+  2. 优化：使用 Poetry 标准管理依赖项并减少 Python 连接器安装依赖项 [#251](https://github.com/taosdata/taos-connector-python/issues/251)
+  3. 优化：taosX 增量备份和恢复优化 
+  4. 优化：在多级存储数据迁移过程中，如果迁移时间过长，可能会导致 Vnode 切主 
+  5. 优化：调整 systemctl 守护 taosd 进程的策略，如果 60 秒内连续三次重启失败，下次重启将推迟至 900 秒后 
+
+## 修复
+  1. 修复：maxRetryWaitTime 参数用于控制当集群无法提供服务时客户端的最大重连超时时间，但在遇到 Sync timeout 错误时，该参数不生效 
+  2. 修复：支持在修改子表的 tag 值后，即时订阅到更新后的 tag 值
+  3. 修复：数据订阅的 tmq_consumer_poll 函数调用失败时没有返回错误码 
+  4. 修复：当创建超过 100 个视图并执行 show views 命令时，taosd 可能会发生崩溃 
+  5. 修复：当使用 stmt2 写入数据时，如果未绑定所有的数据列，写入操作将会失败 
+  6. 修复：当使用 stmt2 写入数据时，如果数据库名或表名使用了反引号，写入操作将会失败 
+  7. 修复：关闭 vnode 时如果有正在进行的文件合并任务，taosd 可能会崩溃 
+  8. 修复：频繁执行 drop table with `tb_uid` 语句可能导致 taosd 死锁 
+  9. 修复：日志文件切换过程中可能出现的死锁问题 
+ 10. 修复：禁止创建与系统库（information_schema, performance_schema）同名的数据库 
+ 11. 修复：当嵌套查询的内层查询来源于超级表时，排序信息无法被上推 
+ 12. 修复：通过 STMT 接口尝试写入不符合拓扑规范的 Geometry 数据类型时误报错误 
+ 13. 修复：在查询语句中使用 percentile 函数和会话窗口时，如果出现错误，taosd 可能会崩溃 
+ 14. 修复：无法动态修改系统参数的问题 
+ 15. 修复：订阅同步偶发 Translict transaction 错误 
+ 16. 修复：同一消费者在执行取消订阅操作后，立即尝试订阅其他不同的主题时，会返回错误 
+ 17. 修复：Go 连接器安全修复 CVE-2022-28948 
+ 18. 修复：当视图中的子查询包含带别名的 ORDER BY 子句，并且查询函数自身也带有别名时，查询该视图会引发错误 
+ 19. 修复：在将数据库从单副本修改为多副本时，如果存在一些由较早版本生成且在新版本中已不再使用的元数据，会导致修改操作失败
+ 20. 修复：在使用 SELECT * FROM 子查询时，列名未能正确复制到外层查询 
+ 21. 修复：对字符串类型数据执行 max/min 函数时，结果不准确且 taosd 可能会崩溃 
+ 22. 修复：流式计算不支持使用 HAVING 语句，但在创建时未报告错误 
+ 23. 修复：taos shell 显示的服务端版本信息不准确，例如无法正确区分社区版和企业版
+ 24. 修复：在某些特定的查询场景下，当 JOIN 和 CAST 联合使用时，taosd 可能会崩溃
+

docs/zh/28-releases/03-notes/index.md

@@ -4,6 +4,7 @@ sidebar_label: 版本说明
 description: 各版本版本说明
 ---
 
+[3.3.5.2](./3.3.5.2)  
 [3.3.5.0](./3.3.5.0)  
 [3.3.4.8](./3.3.4.8)  
 [3.3.4.3](./3.3.4.3)  

include/common/tcommon.h

@@ -160,6 +160,7 @@ typedef enum EStreamType {
   STREAM_PARTITION_DELETE_DATA,
   STREAM_GET_RESULT,
   STREAM_DROP_CHILD_TABLE,
+  STREAM_NOTIFY_EVENT,
   STREAM_RECALCULATE_DATA,
   STREAM_RECALCULATE_DELETE,
   STREAM_RECALCULATE_START,
@@ -412,6 +413,9 @@ typedef struct STUidTagInfo {
 #define UD_GROUPID_COLUMN_INDEX    1
 #define UD_TAG_COLUMN_INDEX        2
 
+// stream notify event block column
+#define NOTIFY_EVENT_STR_COLUMN_INDEX 0
+
 int32_t taosGenCrashJsonMsg(int signum, char** pMsg, int64_t clusterId, int64_t startTime);
 int32_t dumpConfToDataBlock(SSDataBlock* pBlock, int32_t startCol);
 

include/common/tdatablock.h

@@ -285,6 +285,8 @@ bool    isAutoTableName(char* ctbName);
 int32_t buildCtbNameAddGroupId(const char* stbName, char* ctbName, uint64_t groupId, size_t cap);
 int32_t buildCtbNameByGroupId(const char* stbName, uint64_t groupId, char** pName);
 int32_t buildCtbNameByGroupIdImpl(const char* stbName, uint64_t groupId, char* pBuf);
+int32_t buildSinkDestTableName(char* parTbName, const char* stbFullName, uint64_t gid, bool newSubTableRule,
+                               char** dstTableName);
 
 int32_t trimDataBlock(SSDataBlock* pBlock, int32_t totalRows, const bool* pBoolList);
 

include/common/tglobal.h

@@ -34,6 +34,9 @@ extern "C" {
 #define GLOBAL_CONFIG_FILE_VERSION 1
 #define LOCAL_CONFIG_FILE_VERSION  1
 
+#define RPC_MEMORY_USAGE_RATIO   0.1
+#define QUEUE_MEMORY_USAGE_RATIO 0.6
+
 typedef enum {
   DND_CA_SM4 = 1,
 } EEncryptAlgor;
@@ -110,6 +113,7 @@ extern int32_t tsNumOfQnodeFetchThreads;
 extern int32_t tsNumOfSnodeStreamThreads;
 extern int32_t tsNumOfSnodeWriteThreads;
 extern int64_t tsQueueMemoryAllowed;
+extern int64_t tsApplyMemoryAllowed;
 extern int32_t tsRetentionSpeedLimitMB;
 
 extern int32_t tsNumOfCompactThreads;

include/common/tmsg.h

@@ -269,6 +269,7 @@ typedef enum ENodeType {
   QUERY_NODE_TSMA_OPTIONS,
   QUERY_NODE_ANOMALY_WINDOW,
   QUERY_NODE_RANGE_AROUND,
+  QUERY_NODE_STREAM_NOTIFY_OPTIONS,
 
   // Statement nodes are used in parser and planner module.
   QUERY_NODE_SET_OPERATOR = 100,
@@ -2959,6 +2960,11 @@ typedef struct {
   // 3.3.0.0
   SArray* pCols;  // array of SField
   int64_t smaId;
+  // 3.3.6.0
+  SArray* pNotifyAddrUrls;
+  int32_t notifyEventTypes;
+  int32_t notifyErrorHandle;
+  int8_t  notifyHistory;
   int64_t recalculateInterval;
 } SCMCreateStreamReq;