[IOTDB-2789] [Trigger] Status code: EXECUTE_STATEMENT_ERROR(400), operation: checkAuthority failed

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 0.13.0
• Component/s: Core/Server
• Assignee: Unassigned
• Reporter: 刘珍
• Created: 23/Mar/22 06:42
• Updated: 23/Nov/22 05:50
• Resolved: 17/Nov/22 02:56

Description

0.13.0 rc1
复现用例：
delete storage group root.**;
set storage group to root.sg1;
CREATE TIMESERIES root.sg1.dev1.s_1 WITH DATATYPE=INT32, ENCODING=GORILLA;
CREATE TIMESERIES root.sg1.dev1.s_2 WITH DATATYPE=INT64, ENCODING=PLAIN;
CREATE TIMESERIES root.sg1.dev1.s_3 WITH DATATYPE=float, ENCODING=RLE;
CREATE TIMESERIES root.sg1.dev1.s_4 WITH DATATYPE=double, ENCODING=TS_2DIFF;
CREATE TIMESERIES root.sg1.dev1.s_5 WITH DATATYPE=text, ENCODING=DICTIONARY;
CREATE TIMESERIES root.sg1.dev1.s_6 WITH DATATYPE=boolean, ENCODING=PLAIN;

CREATE TRIGGER trig1
AFTER INSERT
ON root.sg1.dev1.s_1
AS 'TriggerTest'
WITH (
'ts_type' = 'int32',
'remote_ip' = '127.0.0.1',
'trig_name'='trig1'
);

CREATE TRIGGER trig2
AFTER INSERT
ON root.sg1.dev1.s_2
AS 'TriggerTest'
WITH (
'ts_type' = 'int64',
'remote_ip' = '127.0.0.1',
'trig_name'='trig2'
);

insert into root.sg1.dev1(time,s_1,s_2) values(1,100,200);
insert into root.sg1.dev1(time,s_1,s_2) values(2,300,400);

select * from root.sg1.dev1;
select * from root.target.alerting;

delete timeseries root.sg1.dev1.s_1;

insert into root.sg1.dev1(time,s_2) values(100,1600);
select * from root.sg1.dev1;
select * from root.target.alerting;
最后一条查询，下图红框不应该是null，应该是1600

错误日志：
2022-03-23 14:37:21,435 [pool-3-thread-1] ERROR o.a.i.d.u.ErrorHandlingUtils:59 - Status code: EXECUTE_STATEMENT_ERROR(400), operation: checkAuthority failed
java.lang.NullPointerException: null
at org.apache.iotdb.db.concurrent.HashLock.readLock(HashLock.java:48)
at org.apache.iotdb.db.auth.user.BasicUserManager.getUser(BasicUserManager.java:86)
at org.apache.iotdb.db.auth.authorizer.BasicAuthorizer.checkUserPrivileges(BasicAuthorizer.java:285)
at org.apache.iotdb.db.auth.AuthorityChecker.checkOnePath(AuthorityChecker.java:87)
at org.apache.iotdb.db.auth.AuthorityChecker.check(AuthorityChecker.java:72)
at org.apache.iotdb.db.service.basic.ServiceProvider.checkAuthorization(ServiceProvider.java:126)
at org.apache.iotdb.db.service.basic.ServiceProvider.checkAuthority(ServiceProvider.java:132)
at org.apache.iotdb.db.protocol.mqtt.PublishHandler.onPublish(PublishHandler.java:122)
at io.moquette.interception.BrokerInterceptor.lambda$notifyTopicPublished$3(BrokerInterceptor.java:133)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)

Issue Links

• duplicates: IOTDB-4343 [master]After starting mqtt, after executing Trigger's SQL, there is an NPE error in the log