Jzow commented on issue #11751:
URL: https://github.com/apache/inlong/issues/11751#issuecomment-2666233957
local testing, it has been verified.
manager-all.log:
```java
[ ] 2025-02-19 00:22:23.021 - INFO [http-nio-8083-exec-7]
.g.UpdateGroupCompleteListener:68 - begin to execute
UpdateGroupCompleteListener for groupId=test_off_group, operateType=DELETE
[ ] 2025-02-19 00:22:23.033 -DEBUG [http-nio-8083-exec-7]
.m.s.s.InlongStreamServiceImpl:481 - begin to update inlong stream without
check, request=InlongStreamRequest(id=19, inlongGroupId=test_off_group,
inlongStreamId=test_off_group, name=null, description=,
mqResource=test_off_group, dataType=null, dataEncoding=UTF-8,
dataSeparator=124, dataEscapeChar=null, syncSend=0, dailyRecords=10,
dailyStorage=10, peakRecords=1000, maxLength=10240, storagePeriod=1,
extParams={"ignoreParseError":null,"kvSeparator":null,"lineSeparator":null,"useExtendedFields":false,"predefinedFields":null,"sinkMultipleEnable":false,"extendedFieldSize":0},
fieldList=null, extList=null, version=1, ignoreParseError=null,
useExtendedFields=false, extendedFieldSize=0, sinkMultipleEnable=false,
syncField=false, wrapType=INLONG_MSG_V0)
[ ] 2025-02-19 00:22:23.036 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Preparing: select id,
inlong_group_id, inlong_stream_id, name, description, mq_resource, data_type,
wrap_type, data_encoding, data_separator, data_escape_char, sync_send,
daily_records, daily_storage, peak_records, max_length, storage_period,
ext_params, status, previous_status, is_deleted, creator, modifier,
create_time, modify_time, version from inlong_stream WHERE is_deleted = 0 and
inlong_group_id = ? and inlong_stream_id = ?
[ ] 2025-02-19 00:22:23.038 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Parameters: test_off_group(String),
test_off_group(String)
[ ] 2025-02-19 00:22:23.038 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - <== Total: 1
[ ] 2025-02-19 00:22:23.042 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Preparing: update inlong_stream SET
inlong_group_id = ?, inlong_stream_id = ?, description = ?, mq_resource = ?,
wrap_type = ?, data_encoding = ?, data_separator = ?, sync_send = ?,
daily_records= ?, daily_storage= ?, peak_records= ?, max_length= ?,
storage_period = ?, ext_params = ?, status = ?, previous_status = ?, is_deleted
= ?, creator = ?, modifier = ?, version = ? + 1 where inlong_group_id = ? and
inlong_stream_id = ? and is_deleted = 0 and version = ?
[ ] 2025-02-19 00:22:23.044 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Parameters: test_off_group(String),
test_off_group(String), (String), test_off_group(String),
INLONG_MSG_V0(String), UTF-8(String), 124(String), 0(Integer), 10(Integer),
10(Integer), 1000(Integer), 10240(Integer), 1(Integer),
{"ignoreParseError":null,"kvSeparator":null,"lineSeparator":null,"useExtendedFields":false,"predefinedFields":null,"sinkMultipleEnable":false,"extendedFieldSize":0}(String),
100(Integer), 100(Integer), 0(Integer), admin(String), admin(String),
1(Integer), test_off_group(String), test_off_group(String), 1(Integer)
[ ] 2025-02-19 00:22:23.048 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - <== Updates: 1
[ ] 2025-02-19 00:22:23.048 -DEBUG [http-nio-8083-exec-7]
.m.s.s.InlongStreamServiceImpl:907 - begin to update inlong stream field,
groupId=test_off_group, streamId=test_off_group, field=null
[ ] 2025-02-19 00:22:23.049 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Preparing: delete from
inlong_stream_field where inlong_group_id = ? and inlong_stream_id = ? and
is_deleted = 0
[ ] 2025-02-19 00:22:23.052 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Parameters: test_off_group(String),
test_off_group(String)
[ ] 2025-02-19 00:22:23.054 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - <== Updates: 0
[ ] 2025-02-19 00:22:23.055 - INFO [http-nio-8083-exec-7]
.m.s.s.InlongStreamServiceImpl:912 - success to update inlong stream field for
groupId=test_off_group
[ ] 2025-02-19 00:22:23.056 - INFO [http-nio-8083-exec-7]
.m.s.s.InlongStreamServiceImpl:937 - begin to save or update inlong stream ext
info, groupId=test_off_group, streamId=test_off_group, ext=null
[ ] 2025-02-19 00:22:23.056 - INFO [http-nio-8083-exec-7]
.m.s.s.InlongStreamServiceImpl:519 - success to update inlong stream without
check for groupId=test_off_group streamId=test_off_group
[ ] 2025-02-19 00:22:23.058 - INFO [http-nio-8083-exec-7]
i.m.s.g.InlongGroupServiceImpl:668 - begin to delete inlong group for
groupId=test_off_group by user=admin
[ ] 2025-02-19 00:22:23.059 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Preparing: select id,
inlong_group_id, name, description, tenant, mq_type, mq_resource,
daily_records, daily_storage, peak_records, max_length, enable_zookeeper,
enable_create_resource, inlong_group_mode, data_report_type,
inlong_cluster_tag, ext_params, in_charges, followers, status, previous_status,
is_deleted, creator, modifier, create_time, modify_time, version from
inlong_group WHERE inlong_group_id = ? and is_deleted = 0 and tenant = ?
[ ] 2025-02-19 00:22:23.062 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Parameters: test_off_group(String),
public(String)
[ ] 2025-02-19 00:22:23.063 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - <== Total: 1
[ ] 2025-02-19 00:22:23.065 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Preparing: update inlong_group SET
name = ?, description = ?, mq_type = ?, mq_resource = ?, daily_records = ?,
daily_storage = ?, peak_records = ?, max_length = ?, enable_zookeeper = ?,
enable_create_resource = ?, inlong_group_mode = ?, data_report_type = ?,
in_charges = ?, previous_status = status, status = ?, is_deleted = ?, modifier
= ?, version = ? + 1 WHERE inlong_group_id = ? and tenant = ? and is_deleted =
0 and version = ?
[ ] 2025-02-19 00:22:23.067 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Parameters: (String), 1231313(String),
NONE(String), test_off_group(String), 10(Integer), 10(Integer), 1000(Integer),
10240(Integer), 0(Integer), 1(Integer), 2(Integer), 0(Integer), admin(String),
40(Integer), 19(Integer), admin(String), 1(Integer), test_off_group(String),
public(String), 1(Integer)
[ ] 2025-02-19 00:22:23.068 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - <== Updates: 1
[ ] 2025-02-19 00:22:23.071 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Preparing: update inlong_group_ext
set is_deleted = id where inlong_group_id = ? and is_deleted = 0
[ ] 2025-02-19 00:22:23.072 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Parameters: test_off_group(String)
[ ] 2025-02-19 00:22:23.074 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - <== Updates: 0
[ ] 2025-02-19 00:22:23.074 -DEBUG [http-nio-8083-exec-7]
.a.i.m.s.s.ScheduleServiceImpl:154 - begin to delete schedule info for
groupId=test_off_group
[ ] 2025-02-19 00:22:23.075 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Preparing: select id,
inlong_group_id, name, description, tenant, mq_type, mq_resource,
daily_records, daily_storage, peak_records, max_length, enable_zookeeper,
enable_create_resource, inlong_group_mode, data_report_type,
inlong_cluster_tag, ext_params, in_charges, followers, status, previous_status,
is_deleted, creator, modifier, create_time, modify_time, version from
inlong_group WHERE inlong_group_id = ? and is_deleted = 0 and tenant = ?
[ ] 2025-02-19 00:22:23.076 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Parameters: test_off_group(String),
public(String)
[ ] 2025-02-19 00:22:23.077 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - <== Total: 0
[ ] 2025-02-19 00:22:23.077 -ERROR [http-nio-8083-exec-7]
.a.i.m.s.s.ScheduleServiceImpl:179 - inlong group not found by
groupId=test_off_group
[ ] 2025-02-19 00:22:23.079 - WARN [http-nio-8083-exec-7]
i.m.s.g.InlongGroupServiceImpl:694 - failed to delete schedule info for
groupId=test_off_group, error msg: Inlong group does not exist/no operation
authority
[ ] 2025-02-19 00:22:23.079 - INFO [http-nio-8083-exec-7]
i.m.s.g.InlongGroupServiceImpl:698 - success to delete group and group ext
property for groupId=test_off_group by user=admin
[ ] 2025-02-19 00:22:23.081 - INFO [http-nio-8083-exec-7]
.m.s.s.StreamSourceServiceImpl:442 - begin to logic delete all source info by
groupId=test_off_group, streamId=null
[ ] 2025-02-19 00:22:23.083 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Preparing: select id,
inlong_group_id, inlong_stream_id, source_type, source_name, task_map_id,
agent_ip, uuid, data_node_name, inlong_cluster_name, inlong_cluster_node_group,
serialization_type, snapshot, report_time, data_time_zone, ext_params, version,
status, previous_status, is_deleted, creator, modifier, create_time,
modify_time from stream_source WHERE is_deleted = 0 and inlong_group_id = ?
[ ] 2025-02-19 00:22:23.085 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Parameters: test_off_group(String)
[ ] 2025-02-19 00:22:23.086 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - <== Total: 0
[ ] 2025-02-19 00:22:23.086 - INFO [http-nio-8083-exec-7]
.m.s.s.StreamSourceServiceImpl:465 - success to logic delete all source by
groupId=test_off_group, streamId=null
[ ] 2025-02-19 00:22:23.087 - INFO [http-nio-8083-exec-7]
.g.UpdateGroupCompleteListener:104 - success to execute
UpdateGroupCompleteListener for groupId=test_off_group, operateType=DELETE
[ ] 2025-02-19 00:22:23.089 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Preparing: insert into
workflow_event_log (id, process_id, process_name, process_display_name,
inlong_group_id, task_id, element_name, element_display_name, event_type,
event, listener, status, async, ip, start_time, end_time, remark, exception)
values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
[ ] 2025-02-19 00:22:23.090 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - ==> Parameters: null, 11(Integer),
DELETE_GROUP_PROCESS(String), Delete Group(String), test_off_group(String),
null, EndEvent(String), EndEvent(String), ProcessEvent(String),
COMPLETE(String), UpdateGroupCompleteListener(String), 1(Integer), 0(Integer),
192.168.157.1(String), 2025-02-19 00:22:23.021(Timestamp), 2025-02-19
00:22:23.087(Timestamp), null, null
[ ] 2025-02-19 00:22:23.092 -DEBUG [http-nio-8083-exec-7]
o.a.i.l.j.BaseJdbcLogger :137 - <== Updates: 1
[ ] 2025-02-19 00:22:23.098 - INFO [http-nio-8083-exec-7]
.s.g.InlongGroupProcessService:267 - success to delete group for
groupId=test_off_group by user=admin
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
