private void checkClusterNodes(String clusterNodes) {
        expectNotBlank(clusterNodes, "the nodes of Redis cluster must not null");
        String[] nodeArray = clusterNodes.split(",");
        expectNotEmpty(nodeArray, "the nodes of Redis cluster must not null");

        for (String node : nodeArray) {
            expectNotBlank(node, "Redis server host must not null!");
            String[] ipPort = node.split(":");
            expectTrue(ipPort.length == 2, "The ip and port of Redis server must be in form: ip:port");
            expectNotBlank(ipPort[0], IP_EMPTY);
            expectNotBlank(ipPort[1], PORT_EMPTY);
        }
    }
Redis sink operator, such as save or update redis field, etc.
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/redis/RedisSinkOperator.java