[FLINK-6211] Validation error in Kinesis Consumer when using AT_TIMESTAMP as start position

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.3.0
• Component/s: Connectors / Kinesis
• Assignee: Wei-Che Wei
• Reporter: Wei-Che Wei
• Created: 29/Mar/17 06:41
• Updated: 29/Mar/17 14:36
• Resolved: 29/Mar/17 14:36

Description

private static void validateOptionalDateProperty(Properties config, String key, String message) {
    if (config.containsKey(key)) {
        try {
            initTimestampDateFormat.parse(config.getProperty(key)); —
            double value = Double.parseDouble(config.getProperty(key)); —
            if (value < 0) { throw new NumberFormatException(); }
        } catch (ParseException | NumberFormatException e){
            throw new IllegalArgumentException(message); }
        }
    }
}

This validation function will always fail regardless of either string format or double type.

Issue Links

• links to: GitHub Pull Request #3636
• links to: GitHub Pull Request #3637