[
https://issues.apache.org/jira/browse/FLINK-19488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satyam Shekhar updated FLINK-19488:
-----------------------------------
Description:
I have a table T0 with the following schema -
{{root}}
\{{ |-- C0: BIGINT}}
\{{ |-- C1: STRING}}
\{{ |-- blaze_itime: TIMESTAMP(3)}}
The following SQL query fails for the above table -
{{SELECT A.C0 AS output, A.C1 AS dim0 FROM T0 AS A WHERE (A.blaze_itime BETWEEN
NOW() - INTERVAL '10' MINUTE AND NOW());}}
{{The generated code for the above query tries to assign a long value to
timestamp type and fails to compile with the following exception -}}
{{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)}}
The generated code is added as an attachment to the issue.
was:
I have a table T0 with the following schema -
{{root}}
{{ |-- C0: BIGINT}}
{{ |-- C1: STRING}}
{{ |-- blaze_itime: TIMESTAMP(3)}}
The following SQL query fails for the above table -
{{SELECT A.C0 AS output, A.C1 AS dim0 FROM T0 AS A WHERE (A.blaze_itime BETWEEN
NOW() - INTERVAL '10' MINUTE AND NOW());}}
{{The generated code for the above query tries to assign a long value to
timestamp type and fails to compile with the following exception -}}
{{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)}}
{{Here is the generated code -}}
/* 1 */
/* 2 */ public class BatchCalc$14 extends
org.apache.flink.table.runtime.operators.TableStreamOperator
/* 3 */ implements
org.apache.flink.streaming.api.operators.OneInputStreamOperator {
/* 4 */
/* 5 */ private final Object[] references;
/* 6 */ org.apache.flink.table.data.BoxedWrapperRowData out = new
org.apache.flink.table.data.BoxedWrapperRowData(2);
/* 7 */ private final
org.apache.flink.streaming.runtime.streamrecord.StreamRecord outElement = new
org.apache.flink.streaming.runtime.streamrecord.StreamRecord(null);
/* 8 */
/* 9 */ public BatchCalc$14(
/* 10 */ Object[] references,
/* 11 */ org.apache.flink.streaming.runtime.tasks.StreamTask task,
/* 12 */ org.apache.flink.streaming.api.graph.StreamConfig config,
/* 13 */ org.apache.flink.streaming.api.operators.Output output,
/* 14 */ org.apache.flink.streaming.runtime.tasks.ProcessingTimeService
processingTimeService) throws Exception {
/* 15 */ this.references = references;
/* 16 */
/* 17 */ this.setup(task, config, output);
/* 18 */ if (this instanceof
org.apache.flink.streaming.api.operators.AbstractStreamOperator) {
/* 19 */ ((org.apache.flink.streaming.api.operators.AbstractStreamOperator)
this)
/* 20 */ .setProcessingTimeService(processingTimeService);
/* 21 */ }
/* 22 */ }
/* 23 */
/* 24 */ @Override
/* 25 */ public void open() throws Exception {
/* 26 */ super.open();
/* 27 */
/* 28 */ }
/* 29 */
/* 30 */ @Override
/* 31 */ public void
processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord
element) throws Exception {
/* 32 */ org.apache.flink.table.data.RowData in1 =
(org.apache.flink.table.data.RowData) element.getValue();
/* 33 */
/* 34 */ org.apache.flink.table.data.TimestampData field$2;
/* 35 */ boolean isNull$2;
/* 36 */ boolean isNull$3;
/* 37 */ org.apache.flink.table.data.TimestampData result$4;
/* 38 */ boolean isNull$5;
/* 39 */ org.apache.flink.table.data.TimestampData result$6;
/* 40 */ boolean isNull$7;
/* 41 */ boolean result$8;
/* 42 */ boolean isNull$9;
/* 43 */ org.apache.flink.table.data.TimestampData result$10;
/* 44 */ boolean isNull$11;
/* 45 */ boolean result$12;
/* 46 */
/* 47 */
/* 48 */ isNull$2 = in1.isNullAt(2);
/* 49 */ field$2 = null;
/* 50 */ if (!isNull$2) {
/* 51 */ field$2 = in1.getTimestamp(2, 3);
/* 52 */ }
/* 53 */ isNull$3 = false;
/* 54 */
/* 55 */ result$4 =
/* 56 */ org.apache.flink.table.runtime.functions.SqlDateTimeUtils.now()
/* 57 */ ;
/* 58 */
/* 59 */
/* 60 */
/* 61 */ isNull$5 = isNull$3 || false;
/* 62 */ result$6 = null;
/* 63 */ if (!isNull$5) {
/* 64 */
/* 65 */ result$6 =
org.apache.flink.table.data.TimestampData.fromEpochMillis(result$4.getMillisecond()
- ((long) 600000L), result$4.getNanoOfMillisecond());
/* 66 */
/* 67 */ }
/* 68 */
/* 69 */ isNull$7 = isNull$2 || isNull$5;
/* 70 */ result$8 = false;
/* 71 */ if (!isNull$7) {
/* 72 */
/* 73 */ result$8 = field$2.compareTo(result$6) >= 0;
/* 74 */
/* 75 */ }
/* 76 */
/* 77 */
/* 78 */ boolean result$13 = false;
/* 79 */ boolean isNull$13 = false;
/* 80 */ if (!isNull$7 && !result$8) {
/* 81 */ // left expr is false, skip right expr
/* 82 */ } else {
/* 83 */
/* 84 */
/* 85 */
/* 86 */
/* 87 */ isNull$9 = false;
/* 88 */
/* 89 */ result$10 =
/* 90 */ org.apache.flink.table.runtime.functions.SqlDateTimeUtils.now()
/* 91 */ ;
/* 92 */
/* 93 */
/* 94 */ isNull$11 = isNull$2 || isNull$9;
/* 95 */ result$12 = false;
/* 96 */ if (!isNull$11) {
/* 97 */
/* 98 */ result$12 = field$2.compareTo(result$10) <= 0;
/* 99 */
/* 100 */ }
/* 101 */
/* 102 */
/* 103 */ if (!isNull$7 && !isNull$11) {
/* 104 */ result$13 = result$8 && result$12;
/* 105 */ isNull$13 = false;
/* 106 */ }
/* 107 */ else if (!isNull$7 && result$8 && isNull$11) {
/* 108 */ result$13 = false;
/* 109 */ isNull$13 = true;
/* 110 */ }
/* 111 */ else if (!isNull$7 && !result$8 && isNull$11) {
/* 112 */ result$13 = false;
/* 113 */ isNull$13 = false;
/* 114 */ }
/* 115 */ else if (isNull$7 && !isNull$11 && result$12) {
/* 116 */ result$13 = false;
/* 117 */ isNull$13 = true;
/* 118 */ }
/* 119 */ else if (isNull$7 && !isNull$11 && !result$12) {
/* 120 */ result$13 = false;
/* 121 */ isNull$13 = false;
/* 122 */ }
/* 123 */ else {
/* 124 */ result$13 = false;
/* 125 */ isNull$13 = true;
/* 126 */ }
/* 127 */ }
/* 128 */ if (result$13) {
/* 129 */
/* 130 */
/* 131 */
/* 132 */
/* 133 */
/* 134 */
/* 135 */
/* 136 */ if (in1.isNullAt(0)) {
/* 137 */ out.setNullAt(0);
/* 138 */ } else {
/* 139 */ out.setLong(0, in1.getLong(0));
/* 140 */ }
/* 141 */
/* 142 */
/* 143 */
/* 144 */ if (in1.isNullAt(1)) {
/* 145 */ out.setNullAt(1);
/* 146 */ } else {
/* 147 */ out.setNonPrimitiveValue(1,
((org.apache.flink.table.data.binary.BinaryStringData) in1.getString(1)));
/* 148 */ }
/* 149 */
/* 150 */
/* 151 */ output.collect(outElement.replace(out));
/* 152 */
/* 153 */ }
/* 154 */
/* 155 */ }
/* 156 */
/* 157 */
/* 158 */
/* 159 */ @Override
/* 160 */ public void close() throws Exception {
/* 161 */ super.close();
/* 162 */
/* 163 */ }
/* 164 */
/* 165 */
/* 166 */ }
/* 167 */
> 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
> The Environment has the following configuration parameters -
> {{env.setParallelism(Integer.getInteger("flinkParallelism", 2));}}
> {{env.getConfig().enableObjectReuse();}}
> {{var settings = EnvironmentSettings.newInstance()}}
> {{ .useBlinkPlanner()}}
> {{ .inBatchMode()}}
> {{ .build();}}
> Reporter: Satyam Shekhar
> Priority: Major
> Attachments: code.java
>
>
> I have a table T0 with the following schema -
> {{root}}
> \{{ |-- C0: BIGINT}}
> \{{ |-- C1: STRING}}
> \{{ |-- blaze_itime: TIMESTAMP(3)}}
>
> The following SQL query fails for the above table -
> {{SELECT A.C0 AS output, A.C1 AS dim0 FROM T0 AS A WHERE (A.blaze_itime
> BETWEEN NOW() - INTERVAL '10' MINUTE AND NOW());}}
>
> {{The generated code for the above query tries to assign a long value to
> timestamp type and fails to compile with the following exception -}}
> {{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)}}
>
> The generated code is added as an attachment to the issue.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
