[FLINK-16727] Fix cast exception when having time point literal as parameters

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.0
• Fix Version/s: 1.10.1, 1.11.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available

Environment

Flinktest.zip

• Assignee: Jark Wu
• Reporter: Matrix42
• Created: 23/Mar/20 12:50
• Updated: 30/Mar/20 06:23
• Resolved: 30/Mar/20 06:23

Description

I defined as ScalarFunction as follow:

 

public class DateFunc extends ScalarFunction {


    public String eval(Date date) {
      return date.toString();
    }

    @Override
    public TypeInformation<?> getResultType(Class<?>[] signature) {
        return Types.STRING;
    }

   @Override
   public TypeInformation<?>[] getParameterTypes(Class<?>[] signature) {
      return new TypeInformation[]{Types.INT};
   }
}

I ues it in sql: `select func(DATE '2020-11-12') as a from source` , Flink throws 'cannot cast 2020-11-12 as class java.time.LocalDate '

 

The full code is in the Flinktest.zip Main class is com.lorinda.template.TestDateFunction

Issue Links

• links to: GitHub Pull Request #11550