sunjincheng created FLINK-11242: ----------------------------------- Summary: The predicate `'o_c_id === Null(Types.STRING)` not work in TableAPI Key: FLINK-11242 URL: https://issues.apache.org/jira/browse/FLINK-11242 Project: Flink Issue Type: Bug Components: Table API & SQL Affects Versions: 1.8.0 Reporter: sunjincheng
Schema: {code:java} Table(c_id:String, o_c_id:String){code} Data: {code:java} c_001,c_001 c_002,c_002 c_003,null{code} TableAPI: {code:java} val result = tab .select('c_id, 'o_c_id) .where('o_c_id === Null(Types.STRING)){code} Result: We expect `c_003, null`, but got empty. BTW, we can got the correct result by follows TableAPI: {code:java} val result = tab .select('c_id, 'o_c_id) .where('o_c_id isNull){code} I think is better for we let `.where('o_c_id === Null(Types.STRING))` work well. What do you think? -- This message was sent by Atlassian JIRA (v7.6.3#76005)