[FLINK-19396] Fix properties type cast error

• Type: Bug
• Status: Closed
• Priority: Not a Priority
• Resolution: Invalid
• Affects Version/s: 1.10.0, 1.10.1, 1.10.2, 1.11.0, 1.11.2
• Component/s: Connectors / Kafka
• Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available
• Assignee: Unassigned
• Reporter: zhangmeng
• Created: 24/Sep/20 10:50
• Updated: 16/Oct/23 07:08
• Resolved: 16/Oct/23 07:08

Description

Properties extends Hashtable<Object,Object> ，The key and value of the Properties class support object objects. If the user's value is a boolean type, this code "(String) k, (String) v" will occur an error.

 

 

链接kafka失败！！！java.lang.Boolean cannot be cast to java.lang.String
48704:java.lang.ClassCastException: java.lang.Boolean cannot be cast to java.lang.String
48787:at org.apache.flink.table.descriptors.Kafka.lambda$properties$0(Kafka.java:99)
48867:at java.util.Hashtable.forEach(Hashtable.java:878)
48919:at org.apache.flink.table.descriptors.Kafka.properties(Kafka.java:99)

 

Issue Links

• links to: GitHub Pull Request #13470
• links to: GitHub Pull Request #15025
• links to: GitHub Pull Request #15033
• links to: Pull request 13470