[fix](fe_plugins) update fe plugins' dependency to fe 1.0-SNAPSHOT (#11141)

This commit is contained in:
Mingyu Chen
2022-07-25 09:13:15 +08:00
committed by GitHub
parent 829d534e12
commit d9066440f6
6 changed files with 27 additions and 11 deletions

View File

@ -58,7 +58,7 @@ After deployment is complete, and before installing the plugin, you need to crea
create table doris_audit_tbl__
(
query_id varchar(48) comment "Unique query id",
time datetime not null comment "Query start time",
`time` datetime not null comment "Query start time",
client_ip varchar(32) comment "Client IP",
user varchar(64) comment "User name",
db varchar(96) comment "Database of this query",
@ -76,8 +76,8 @@ create table doris_audit_tbl__
peak_memory_bytes bigint comment "Peak memory bytes used on all backends of this query",
stmt string comment "The original statement, trimed if longer than 2G"
) engine=OLAP
duplicate key(query_id, time, client_ip)
partition by range(time) ()
duplicate key(query_id, `time`, client_ip)
partition by range(`time`) ()
distributed by hash(query_id) buckets 1
properties(
"dynamic_partition.time_unit" = "DAY",

View File

@ -58,7 +58,7 @@ auditloader plugin的配置位于`${DORIS}/fe_plugins/auditloader/src/main/assem
create table doris_audit_tbl__
(
query_id varchar(48) comment "Unique query id",
time datetime not null comment "Query start time",
`time` datetime not null comment "Query start time",
client_ip varchar(32) comment "Client IP",
user varchar(64) comment "User name",
db varchar(96) comment "Database of this query",
@ -76,8 +76,8 @@ create table doris_audit_tbl__
peak_memory_bytes bigint comment "Peak memory bytes used on all backends of this query",
stmt string comment "The original statement, trimed if longer than 2G "
) engine=OLAP
duplicate key(query_id, time, client_ip)
partition by range(time) ()
duplicate key(query_id, `time`, client_ip)
partition by range(`time`) ()
distributed by hash(query_id) buckets 1
properties(
"dynamic_partition.time_unit" = "DAY",
@ -98,4 +98,4 @@ properties(
之后,连接到 Doris 后使用 `INSTALL PLUGIN` 命令完成安装。安装成功后,可以通过 `SHOW PLUGINS` 看到已经安装的插件,并且状态为 `INSTALLED`
完成后,插件会不断的以指定的时间间隔将审计日志插入到这个表中。
完成后,插件会不断的以指定的时间间隔将审计日志插入到这个表中。

View File

@ -80,7 +80,8 @@ public class DigitalVersion implements Comparable<DigitalVersion> {
int revision = Integer.parseInt(list[2].trim());
if (major >= 100 || minor >= 100 || revision >= 100) {
throw new IllegalArgumentException("Illegal version format: " + version);
throw new IllegalArgumentException(
"Illegal version format: " + version + ". Expected: major.minor.revision");
}
return new DigitalVersion((byte) major, (byte) minor, (byte) revision);

View File

@ -18,6 +18,6 @@
name=AuditLoader
type=AUDIT
description=load audit log to olap load, and user can view the statistic of queries
version=0.13.1
version=1.0.0
java.version=1.8.0
classname=org.apache.doris.plugin.audit.AuditLoaderPlugin

View File

@ -69,7 +69,7 @@ public class DorisStreamLoader {
conn.addRequestProperty("label", label);
conn.addRequestProperty("max_filter_ratio", "1.0");
conn.addRequestProperty("columns", "query_id, time, client_ip, user, db, state, query_time, scan_bytes," +
conn.addRequestProperty("columns", "query_id, `time`, client_ip, user, db, state, query_time, scan_bytes," +
" scan_rows, return_rows, stmt_id, is_query, frontend_ip, cpu_time_ms, sql_hash, sql_digest, peak_memory_bytes, stmt");
conn.setDoOutput(true);

View File

@ -68,7 +68,7 @@ under the License.
</modules>
<properties>
<log4j2.version>2.17.1</log4j2.version>
<doris.version>0.15-SNAPSHOT</doris.version>
<doris.version>1.0-SNAPSHOT</doris.version>
<project.scm.id>github</project.scm.id>
</properties>
<profiles>
@ -93,6 +93,21 @@ under the License.
</pluginRepository>
</pluginRepositories>
</profile>
<profile>
<id>general-env</id>
<activation>
<property>
<name>!env.CUSTOM_MAVEN_REPO</name>
</property>
</activation>
<repositories>
<!-- for java-cup -->
<repository>
<id>cloudera-public</id>
<url>https://repository.cloudera.com/artifactory/public/</url>
</repository>
</repositories>
</profile>
</profiles>
<dependencyManagement>
<dependencies>