Setting `command` option in TableDescriptor leads to Java error about flink-connector-redis HOT 6 CLOSED

sink = ( TableDescriptor.for_connector("redis") .option("host", "redis") .option("port", "6379") .option("database", "1") .option("redis-mode", "single") .option("command", "set") .schema( Schema.new_builder() .column("k_", DataTypes.STRING()) .column("v_", DataTypes.STRING()) .build()) .build() ) statement_set.add_insert(sink, pacing_events_table.table) statement_set.attach_as_datastream() When I tried to do like this, I receive the following error: Caused by: java.lang.UnsupportedOperationException at java.base/java.util.Collections$UnmodifiableMap.put(Collections.java:1457) at org.apache.flink.streaming.connectors.redis.table.RedisDynamicTableFactory.createDynamicTableSink(RedisDynamicTableFactory.java:52) at org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:319) ... 28 more This looks like we cannot modify a Collection Map type. I traced back the error and seems the following block is the culprit: if (context.getCatalogTable().getOptions().containsKey(REDIS_COMMAND)) { context.getCatalogTable() .getOptions() .put( REDIS_COMMAND, context.getCatalogTable() .getOptions() .get(REDIS_COMMAND) .toUpperCase()); } Please help me with this issue. — Reply to this email directly, view it on GitHub <#46>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/AFNV7R4AO4LAV6IZJNZJOWLYGZKP5AVCNFSM6AAAAAA76N3NL2VHI2DSMVQWIX3LMV43ASLTON2WKOZSGAYTKMZVHE4DAMA> . You are receiving this because you are subscribed to this thread.Message ID: ***@***.***>