[jira] [Comment Edited] (FLINK-19488) Failed compilation of generated class

["Jark Wu (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-19488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227718#comment-17227718 ] 

Jark Wu edited comment on FLINK-19488 at 11/7/20, 4:03 AM:
-----------------------------------------------------------

[~satyamshekhar], There is a bug when in code generation for NOW() function. This has been fixed by FLINK-19948 recently. 

Could you use {{CURRENT_TIMESTAMP()}} and try again? It has the same semantic with NOW(). 
You can also build the latest release-1.11 branch and try the NOW() function. 


was (Author: jark):
[~satyamshekhar], There is a bug when in code generation for NOW() function. This has been fixed by FLINK-19948 recently. 

Could you use {{CURRENT_TIMESTAMP()}} and try again? It has the same semantic with NOW(). 
You can also build the latest release-1.11 branch and try the NOW() function that. 

> Failed compilation of generated class
> -------------------------------------
>
>                 Key: FLINK-19488
>                 URL: https://issues.apache.org/jira/browse/FLINK-19488
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / Runtime
>    Affects Versions: 1.11.1
>         Environment: Flink version: 1.11.1
>  
>            Reporter: Satyam Shekhar
>            Priority: Major
>         Attachments: code.java
>
>
> I have a table T0 with the following schema -
>  
> {code:java}
> root
>      |-- C0: BIGINT
>      |-- C1: STRING
>      |-- blaze_itime: TIMESTAMP(3)
> {code}
>  
> The following SQL query fails for the above table - 
> {code:java}
> SELECT A.C0 AS output, A.C1 AS dim0 FROM T0 AS A WHERE (A.blaze_itime BETWEEN NOW() - INTERVAL '10' MINUTE AND NOW());
> {code}
>  
> The generated code for the above query tries to assign a long value to timestamp type and fails to compile with the following exception -
> {code:java}
> java.lang.RuntimeException: Could not instantiate generated class 'BatchCalc$14'java.lang.RuntimeException: Could not instantiate generated class 'BatchCalc$14' at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:67) at org.apache.flink.table.runtime.operators.CodeGenOperatorFactory.createStreamOperator(CodeGenOperatorFactory.java:40) at org.apache.flink.streaming.api.operators.StreamOperatorFactoryUtil.createOperator(StreamOperatorFactoryUtil.java:70) at org.apache.flink.streaming.runtime.tasks.OperatorChain.createChainedOperator(OperatorChain.java:470) at
> ...
> Caused by: org.codehaus.commons.compiler.CompileException: Line 55, Column 21: Assignment conversion not possible from type "long" to type "org.apache.flink.table.data.TimestampData"Caused by: org.codehaus.commons.compiler.CompileException: Line 55, Column 21: Assignment conversion not possible from type "long" to type "org.apache.flink.table.data.TimestampData" at org.codehaus.janino.UnitCompiler.compileError(UnitCompiler.java:12124) at org.codehaus.janino.UnitCompiler.assignmentConversion(UnitCompiler.java:10975) at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:3788) at org.codehaus.janino.UnitCompiler.access$6100(UnitCompiler.java:215)
> {code}
>  
> The generated code is added as an attachment to the issue.
>  
> The Environment has the following configuration parameters -
> {code:java}
> env.setParallelism(Integer.getInteger("flinkParallelism", 2));
> env.getConfig().enableObjectReuse();
> var settings = EnvironmentSettings.newInstance()
>   .useBlinkPlanner()
>   .inBatchMode()
>   .build();
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)