看日志中提示required字段没有给全： Reason: Required context properties mismatch.
The following properties are requested: connector.type=redis host=localhost port=6379 schema.0.data-type=VARCHAR(2147483647) schema.0.name=username schema.1.data-type=VARCHAR(2147483647) schema.1.name=c 你的requiredOptions()函数中是不是添加了schema*那几个参数 -- Sent from: http://apache-flink.147419.n8.nabble.com/
