Pipe: Mask sensitive attributes in sink subtask display strings#17737
Pipe: Mask sensitive attributes in sink subtask display strings#17737luoluoyuyu wants to merge 2 commits into
Conversation
Use masked PipeParameters display string for logs, metrics and subtask names while keeping unmasked sorted string for internal lifecycle map keys. Also treat scp.password as a sensitive parameter. Co-authored-by: Cursor <cursoragent@cursor.com>
|
Medium: iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeSinkSubtaskManager.java:123 now writes
|
Key compressionTimerMap by per-subtask taskID instead of masked attribute string to avoid collisions when only sensitive fields differ. Use masked display strings in subtask-not-found exceptions and pass sinkTaskId from runtime environment to IoTDB sinks for timer lookup. Co-authored-by: Cursor <cursoragent@cursor.com>
Description
Use masked PipeParameters display string for logs, metrics and subtask names while keeping unmasked sorted string for internal lifecycle map keys. Also treat scp.password as a sensitive parameter.
This PR has:
for an unfamiliar reader.
for code coverage.
Key changed/added classes (or packages if there are too many classes) in this PR