[ https://issues.apache.org/jira/browse/FLINK-29135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sergey Nuyanzin resolved FLINK-29135. ------------------------------------- Resolution: Duplicate Close it in favor of https://issues.apache.org/jira/browse/FLINK-27995 > After updating to calcite 1.30.0 and janino 3.1.6 some tests started to fail > with compilation issues in generated code > ---------------------------------------------------------------------------------------------------------------------- > > Key: FLINK-29135 > URL: https://issues.apache.org/jira/browse/FLINK-29135 > Project: Flink > Issue Type: Sub-task > Components: Table SQL / API, Table SQL / Planner > Reporter: Sergey Nuyanzin > Priority: Major > > e.g. {{org.apache.flink.table.planner.functions.CastFunctionITCase}} for > {{cast(f0, ARRAY<BIGINT>) }} > {noformat} > /* 1 */ > /* 2 */ public class StreamExecCalc$4813 extends > org.apache.flink.table.runtime.operators.TableStreamOperator > /* 3 */ implements > org.apache.flink.streaming.api.operators.OneInputStreamOperator { > /* 4 */ > /* 5 */ private final Object[] references; > /* 6 */ > /* 7 */ org.apache.flink.table.data.binary.BinaryArrayData array$4805 > = new org.apache.flink.table.data.binary.BinaryArrayData(); > /* 8 */ org.apache.flink.table.data.writer.BinaryArrayWriter > writer$4806 = new > org.apache.flink.table.data.writer.BinaryArrayWriter(array$4805, 3, 4); > /* 9 */ > /* 10 */ org.apache.flink.table.data.BoxedWrapperRowData out = new > org.apache.flink.table.data.BoxedWrapperRowData(1); > /* 11 */ private final > org.apache.flink.streaming.runtime.streamrecord.StreamRecord outElement = new > org.apache.flink.streaming.runtime.streamrecord.StreamRecord(null); > /* 12 */ > /* 13 */ public StreamExecCalc$4813( > /* 14 */ Object[] references, > /* 15 */ org.apache.flink.streaming.runtime.tasks.StreamTask task, > /* 16 */ org.apache.flink.streaming.api.graph.StreamConfig config, > /* 17 */ org.apache.flink.streaming.api.operators.Output output, > /* 18 */ > org.apache.flink.streaming.runtime.tasks.ProcessingTimeService > processingTimeService) throws Exception { > /* 19 */ this.references = references; > /* 20 */ > /* 21 */ writer$4806.reset(); > /* 22 */ > /* 23 */ > /* 24 */ if (false) { > /* 25 */ writer$4806.setNullInt(0); > /* 26 */ } else { > /* 27 */ writer$4806.writeInt(0, ((int) 1)); > /* 28 */ } > /* 29 */ > /* 30 */ > /* 31 */ > /* 32 */ if (true) { > /* 33 */ writer$4806.setNullInt(1); > /* 34 */ } else { > /* 35 */ writer$4806.writeInt(1, ((int) -1)); > /* 36 */ } > /* 37 */ > /* 38 */ > /* 39 */ > /* 40 */ if (false) { > /* 41 */ writer$4806.setNullInt(2); > /* 42 */ } else { > /* 43 */ writer$4806.writeInt(2, ((int) 2)); > /* 44 */ } > /* 45 */ > /* 46 */ writer$4806.complete(); > /* 47 */ > /* 48 */ this.setup(task, config, output); > /* 49 */ if (this instanceof > org.apache.flink.streaming.api.operators.AbstractStreamOperator) { > /* 50 */ > ((org.apache.flink.streaming.api.operators.AbstractStreamOperator) this) > /* 51 */ .setProcessingTimeService(processingTimeService); > /* 52 */ } > /* 53 */ } > /* 54 */ > /* 55 */ @Override > /* 56 */ public void open() throws Exception { > /* 57 */ super.open(); > /* 58 */ > /* 59 */ } > /* 60 */ > /* 61 */ @Override > /* 62 */ public void > processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord > element) throws Exception { > /* 63 */ org.apache.flink.table.data.RowData in1 = > (org.apache.flink.table.data.RowData) element.getValue(); > /* 64 */ > /* 65 */ boolean isNull$4808; > /* 66 */ org.apache.flink.table.data.ArrayData result$4809; > /* 67 */ long result$4812; > /* 68 */ > /* 69 */ > /* 70 */ > /* 71 */ > /* 72 */ out.setRowKind(in1.getRowKind()); > /* 73 */ > /* 74 */ > /* 75 */ > /* 76 */ > /* 77 */ // --- Cast section generated by > org.apache.flink.table.planner.functions.casting.ArrayToArrayCastRule > /* 78 */ isNull$4808 = false; > /* 79 */ if (!isNull$4808) { > /* 80 */ java.lang.Long[] objArray$4810 = new > java.lang.Long[array$4805.size()]; > /* 81 */ for (int i$4811 = 0; i$4811 < array$4805.size(); i$4811++) { > /* 82 */ if (!array$4805.isNullAt(i$4811)) { > /* 83 */ result$4812 = ((long)(array$4805.getInt(i$4811))); > /* 84 */ objArray$4810[i$4811] = result$4812; > /* 85 */ } > /* 86 */ } > /* 87 */ result$4809 = new > org.apache.flink.table.data.GenericArrayData(objArray$4810); > /* 88 */ isNull$4808 = result$4809 == null; > /* 89 */ } else { > /* 90 */ result$4809 = null; > /* 91 */ } > /* 92 */ > /* 93 */ // --- End cast section > /* 94 */ > /* 95 */ if (isNull$4808) { > /* 96 */ out.setNullAt(0); > /* 97 */ } else { > /* 98 */ out.setNonPrimitiveValue(0, result$4809); > /* 99 */ } > /* 100 */ > /* 101 */ > /* 102 */ output.collect(outElement.replace(out)); > /* 103 */ > /* 104 */ > /* 105 */ } > /* 106 */ > /* 107 */ > /* 108 */ > /* 109 */ @Override > /* 110 */ public void close() throws Exception { > /* 111 */ super.close(); > /* 112 */ > /* 113 */ } > /* 114 */ > /* 115 */ > /* 116 */ } > /* 117 */ > /* 1 */ > /* 2 */ public class StreamExecCalc$4813 extends > org.apache.flink.table.runtime.operators.TableStreamOperator > /* 3 */ implements > org.apache.flink.streaming.api.operators.OneInputStreamOperator { > /* 4 */ > /* 5 */ private final Object[] references; > /* 6 */ > /* 7 */ org.apache.flink.table.data.binary.BinaryArrayData array$4805 > = new org.apache.flink.table.data.binary.BinaryArrayData(); > /* 8 */ org.apache.flink.table.data.writer.BinaryArrayWriter > writer$4806 = new > org.apache.flink.table.data.writer.BinaryArrayWriter(array$4805, 3, 4); > /* 9 */ > /* 10 */ org.apache.flink.table.data.BoxedWrapperRowData out = new > org.apache.flink.table.data.BoxedWrapperRowData(1); > /* 11 */ private final > org.apache.flink.streaming.runtime.streamrecord.StreamRecord outElement = new > org.apache.flink.streaming.runtime.streamrecord.StreamRecord(null); > /* 12 */ > /* 13 */ public StreamExecCalc$4813( > /* 14 */ Object[] references, > /* 15 */ org.apache.flink.streaming.runtime.tasks.StreamTask task, > /* 16 */ org.apache.flink.streaming.api.graph.StreamConfig config, > /* 17 */ org.apache.flink.streaming.api.operators.Output output, > /* 18 */ > org.apache.flink.streaming.runtime.tasks.ProcessingTimeService > processingTimeService) throws Exception { > /* 19 */ this.references = references; > /* 20 */ > /* 21 */ writer$4806.reset(); > /* 22 */ > /* 23 */ > /* 24 */ if (false) { > /* 25 */ writer$4806.setNullInt(0); > /* 26 */ } else { > /* 27 */ writer$4806.writeInt(0, ((int) 1)); > /* 28 */ } > /* 29 */ > /* 30 */ > /* 31 */ > /* 32 */ if (true) { > /* 33 */ writer$4806.setNullInt(1); > /* 34 */ } else { > /* 35 */ writer$4806.writeInt(1, ((int) -1)); > /* 36 */ } > /* 37 */ > /* 38 */ > /* 39 */ > /* 40 */ if (false) { > /* 41 */ writer$4806.setNullInt(2); > /* 42 */ } else { > /* 43 */ writer$4806.writeInt(2, ((int) 2)); > /* 44 */ } > /* 45 */ > /* 46 */ writer$4806.complete(); > /* 47 */ > /* 48 */ this.setup(task, config, output); > /* 49 */ if (this instanceof > org.apache.flink.streaming.api.operators.AbstractStreamOperator) { > /* 50 */ > ((org.apache.flink.streaming.api.operators.AbstractStreamOperator) this) > /* 51 */ .setProcessingTimeService(processingTimeService); > /* 52 */ } > /* 53 */ } > /* 54 */ > /* 55 */ @Override > /* 56 */ public void open() throws Exception { > /* 57 */ super.open(); > /* 58 */ > /* 59 */ } > /* 60 */ > /* 61 */ @Override > /* 62 */ public void > processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord > element) throws Exception { > /* 63 */ org.apache.flink.table.data.RowData in1 = > (org.apache.flink.table.data.RowData) element.getValue(); > /* 64 */ > /* 65 */ boolean isNull$4808; > /* 66 */ org.apache.flink.table.data.ArrayData result$4809; > /* 67 */ long result$4812; > /* 68 */ > /* 69 */ > /* 70 */ > /* 71 */ > /* 72 */ out.setRowKind(in1.getRowKind()); > /* 73 */ > /* 74 */ > /* 75 */ > /* 76 */ > /* 77 */ // --- Cast section generated by > org.apache.flink.table.planner.functions.casting.ArrayToArrayCastRule > /* 78 */ isNull$4808 = false; > /* 79 */ if (!isNull$4808) { > /* 80 */ java.lang.Long[] objArray$4810 = new > java.lang.Long[array$4805.size()]; > /* 81 */ for (int i$4811 = 0; i$4811 < array$4805.size(); i$4811++) { > /* 82 */ if (!array$4805.isNullAt(i$4811)) { > /* 83 */ result$4812 = ((long)(array$4805.getInt(i$4811))); > /* 84 */ objArray$4810[i$4811] = result$4812; > /* 85 */ } > /* 86 */ } > /* 87 */ result$4809 = new > org.apache.flink.table.data.GenericArrayData(objArray$4810); > /* 88 */ isNull$4808 = result$4809 == null; > /* 89 */ } else { > /* 90 */ result$4809 = null; > /* 91 */ } > /* 92 */ > /* 93 */ // --- End cast section > /* 94 */ > /* 95 */ if (isNull$4808) { > /* 96 */ out.setNullAt(0); > /* 97 */ } else { > /* 98 */ out.setNonPrimitiveValue(0, result$4809); > /* 99 */ } > /* 100 */ > /* 101 */ > /* 102 */ output.collect(outElement.replace(out)); > /* 103 */ > /* 104 */ > /* 105 */ } > /* 106 */ > /* 107 */ > /* 108 */ > /* 109 */ @Override > /* 110 */ public void close() throws Exception { > /* 111 */ super.close(); > /* 112 */ > /* 113 */ } > /* 114 */ > /* 115 */ > /* 116 */ } > /* 117 */ > /* 1 */ > /* 2 */ public class StreamExecCalc$4875 extends > org.apache.flink.table.runtime.operators.TableStreamOperator > /* 3 */ implements > org.apache.flink.streaming.api.operators.OneInputStreamOperator { > /* 4 */ > /* 5 */ private final Object[] references; > /* 6 */ > /* 7 */ org.apache.flink.table.data.binary.BinaryArrayData array$4859 > = new org.apache.flink.table.data.binary.BinaryArrayData(); > /* 8 */ org.apache.flink.table.data.writer.BinaryArrayWriter > writer$4860 = new > org.apache.flink.table.data.writer.BinaryArrayWriter(array$4859, 2, 4); > /* 9 */ > /* 10 */ org.apache.flink.table.data.BoxedWrapperRowData out = new > org.apache.flink.table.data.BoxedWrapperRowData(1); > /* 11 */ private final > org.apache.flink.streaming.runtime.streamrecord.StreamRecord outElement = new > org.apache.flink.streaming.runtime.streamrecord.StreamRecord(null); > /* 12 */ > /* 13 */ public StreamExecCalc$4875( > /* 14 */ Object[] references, > /* 15 */ org.apache.flink.streaming.runtime.tasks.StreamTask task, > /* 16 */ org.apache.flink.streaming.api.graph.StreamConfig config, > /* 17 */ org.apache.flink.streaming.api.operators.Output output, > /* 18 */ > org.apache.flink.streaming.runtime.tasks.ProcessingTimeService > processingTimeService) throws Exception { > /* 19 */ this.references = references; > /* 20 */ > /* 21 */ writer$4860.reset(); > /* 22 */ > /* 23 */ > /* 24 */ if (false) { > /* 25 */ writer$4860.setNullInt(0); > /* 26 */ } else { > /* 27 */ writer$4860.writeInt(0, ((int) 1)); > /* 28 */ } > /* 29 */ > /* 30 */ > /* 31 */ > /* 32 */ if (false) { > /* 33 */ writer$4860.setNullInt(1); > /* 34 */ } else { > /* 35 */ writer$4860.writeInt(1, ((int) 2)); > /* 36 */ } > /* 37 */ > /* 38 */ writer$4860.complete(); > /* 39 */ > /* 40 */ this.setup(task, config, output); > /* 41 */ if (this instanceof > org.apache.flink.streaming.api.operators.AbstractStreamOperator) { > /* 42 */ > ((org.apache.flink.streaming.api.operators.AbstractStreamOperator) this) > /* 43 */ .setProcessingTimeService(processingTimeService); > /* 44 */ } > /* 45 */ } > /* 46 */ > /* 47 */ @Override > /* 48 */ public void open() throws Exception { > /* 49 */ super.open(); > /* 50 */ > /* 51 */ } > /* 52 */ > /* 53 */ @Override > /* 54 */ public void > processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord > element) throws Exception { > /* 55 */ org.apache.flink.table.data.RowData in1 = > (org.apache.flink.table.data.RowData) element.getValue(); > /* 56 */ > /* 57 */ boolean isNull$4867; > /* 58 */ org.apache.flink.table.data.ArrayData result$4870; > /* 59 */ long result$4874; > /* 60 */ > /* 61 */ > /* 62 */ > /* 63 */ > /* 64 */ out.setRowKind(in1.getRowKind()); > /* 65 */ > /* 66 */ > /* 67 */ > /* 68 */ > /* 69 */ // --- Cast section generated by > org.apache.flink.table.planner.functions.casting.ArrayToArrayCastRule > /* 70 */ isNull$4867 = false; > /* 71 */ if (!isNull$4867) { > /* 72 */ long[] objArray$4871 = new long[array$4859.size()]; > /* 73 */ for (int i$4872 = 0; i$4872 < array$4859.size(); i$4872++) { > /* 74 */ result$4874 = ((long)(array$4859.getInt(i$4872))); > /* 75 */ objArray$4871[i$4872] = result$4874; > /* 76 */ } > /* 77 */ result$4870 = new > org.apache.flink.table.data.GenericArrayData(objArray$4871); > /* 78 */ isNull$4867 = result$4870 == null; > /* 79 */ } else { > /* 80 */ result$4870 = null; > /* 81 */ } > /* 82 */ > /* 83 */ // --- End cast section > /* 84 */ > /* 85 */ if (isNull$4867) { > /* 86 */ out.setNullAt(0); > /* 87 */ } else { > /* 88 */ out.setNonPrimitiveValue(0, result$4870); > /* 89 */ } > /* 90 */ > /* 91 */ > /* 92 */ output.collect(outElement.replace(out)); > /* 93 */ > /* 94 */ > /* 95 */ } > /* 96 */ > /* 97 */ > /* 98 */ > /* 99 */ @Override > /* 100 */ public void close() throws Exception { > /* 101 */ super.close(); > /* 102 */ > /* 103 */ } > /* 104 */ > /* 105 */ > /* 106 */ } > /* 107 */ > /* 1 */ > /* 2 */ public class StreamExecCalc$4875 extends > org.apache.flink.table.runtime.operators.TableStreamOperator > /* 3 */ implements > org.apache.flink.streaming.api.operators.OneInputStreamOperator { > /* 4 */ > /* 5 */ private final Object[] references; > /* 6 */ > /* 7 */ org.apache.flink.table.data.binary.BinaryArrayData array$4859 > = new org.apache.flink.table.data.binary.BinaryArrayData(); > /* 8 */ org.apache.flink.table.data.writer.BinaryArrayWriter > writer$4860 = new > org.apache.flink.table.data.writer.BinaryArrayWriter(array$4859, 2, 4); > /* 9 */ > /* 10 */ org.apache.flink.table.data.BoxedWrapperRowData out = new > org.apache.flink.table.data.BoxedWrapperRowData(1); > /* 11 */ private final > org.apache.flink.streaming.runtime.streamrecord.StreamRecord outElement = new > org.apache.flink.streaming.runtime.streamrecord.StreamRecord(null); > /* 12 */ > /* 13 */ public StreamExecCalc$4875( > /* 14 */ Object[] references, > /* 15 */ org.apache.flink.streaming.runtime.tasks.StreamTask task, > /* 16 */ org.apache.flink.streaming.api.graph.StreamConfig config, > /* 17 */ org.apache.flink.streaming.api.operators.Output output, > /* 18 */ > org.apache.flink.streaming.runtime.tasks.ProcessingTimeService > processingTimeService) throws Exception { > /* 19 */ this.references = references; > /* 20 */ > /* 21 */ writer$4860.reset(); > /* 22 */ > /* 23 */ > /* 24 */ if (false) { > /* 25 */ writer$4860.setNullInt(0); > /* 26 */ } else { > /* 27 */ writer$4860.writeInt(0, ((int) 1)); > /* 28 */ } > /* 29 */ > /* 30 */ > /* 31 */ > /* 32 */ if (false) { > /* 33 */ writer$4860.setNullInt(1); > /* 34 */ } else { > /* 35 */ writer$4860.writeInt(1, ((int) 2)); > /* 36 */ } > /* 37 */ > /* 38 */ writer$4860.complete(); > /* 39 */ > /* 40 */ this.setup(task, config, output); > /* 41 */ if (this instanceof > org.apache.flink.streaming.api.operators.AbstractStreamOperator) { > /* 42 */ > ((org.apache.flink.streaming.api.operators.AbstractStreamOperator) this) > /* 43 */ .setProcessingTimeService(processingTimeService); > /* 44 */ } > /* 45 */ } > /* 46 */ > /* 47 */ @Override > /* 48 */ public void open() throws Exception { > /* 49 */ super.open(); > /* 50 */ > /* 51 */ } > /* 52 */ > /* 53 */ @Override > /* 54 */ public void > processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord > element) throws Exception { > /* 55 */ org.apache.flink.table.data.RowData in1 = > (org.apache.flink.table.data.RowData) element.getValue(); > /* 56 */ > /* 57 */ boolean isNull$4867; > /* 58 */ org.apache.flink.table.data.ArrayData result$4870; > /* 59 */ long result$4874; > /* 60 */ > /* 61 */ > /* 62 */ > /* 63 */ > /* 64 */ out.setRowKind(in1.getRowKind()); > /* 65 */ > /* 66 */ > /* 67 */ > /* 68 */ > /* 69 */ // --- Cast section generated by > org.apache.flink.table.planner.functions.casting.ArrayToArrayCastRule > /* 70 */ isNull$4867 = false; > /* 71 */ if (!isNull$4867) { > /* 72 */ long[] objArray$4871 = new long[array$4859.size()]; > /* 73 */ for (int i$4872 = 0; i$4872 < array$4859.size(); i$4872++) { > /* 74 */ result$4874 = ((long)(array$4859.getInt(i$4872))); > /* 75 */ objArray$4871[i$4872] = result$4874; > /* 76 */ } > /* 77 */ result$4870 = new > org.apache.flink.table.data.GenericArrayData(objArray$4871); > /* 78 */ isNull$4867 = result$4870 == null; > /* 79 */ } else { > /* 80 */ result$4870 = null; > /* 81 */ } > /* 82 */ > /* 83 */ // --- End cast section > /* 84 */ > /* 85 */ if (isNull$4867) { > /* 86 */ out.setNullAt(0); > /* 87 */ } else { > /* 88 */ out.setNonPrimitiveValue(0, result$4870); > /* 89 */ } > /* 90 */ > /* 91 */ > /* 92 */ output.collect(outElement.replace(out)); > /* 93 */ > /* 94 */ > /* 95 */ } > /* 96 */ > /* 97 */ > /* 98 */ > /* 99 */ @Override > /* 100 */ public void close() throws Exception { > /* 101 */ super.close(); > /* 102 */ > /* 103 */ } > /* 104 */ > /* 105 */ > /* 106 */ } > /* 107 */ > /* 1 */ > /* 2 */ public class StreamExecCalc$4838 extends > org.apache.flink.table.runtime.operators.TableStreamOperator > /* 3 */ implements > org.apache.flink.streaming.api.operators.OneInputStreamOperator { > /* 4 */ > /* 5 */ private final Object[] references; > /* 6 */ > /* 7 */ org.apache.flink.table.data.binary.BinaryArrayData array$4823 > = new org.apache.flink.table.data.binary.BinaryArrayData(); > /* 8 */ org.apache.flink.table.data.writer.BinaryArrayWriter > writer$4824 = new > org.apache.flink.table.data.writer.BinaryArrayWriter(array$4823, 3, 4); > /* 9 */ > /* 10 */ org.apache.flink.table.data.BoxedWrapperRowData out = new > org.apache.flink.table.data.BoxedWrapperRowData(1); > /* 11 */ private final > org.apache.flink.streaming.runtime.streamrecord.StreamRecord outElement = new > org.apache.flink.streaming.runtime.streamrecord.StreamRecord(null); > /* 12 */ > /* 13 */ public StreamExecCalc$4838( > /* 14 */ Object[] references, > /* 15 */ org.apache.flink.streaming.runtime.tasks.StreamTask task, > /* 16 */ org.apache.flink.streaming.api.graph.StreamConfig config, > /* 17 */ org.apache.flink.streaming.api.operators.Output output, > /* 18 */ > org.apache.flink.streaming.runtime.tasks.ProcessingTimeService > processingTimeService) throws Exception { > /* 19 */ this.references = references; > /* 20 */ > /* 21 */ writer$4824.reset(); > /* 22 */ > /* 23 */ > /* 24 */ if (false) { > /* 25 */ writer$4824.setNullInt(0); > /* 26 */ } else { > /* 27 */ writer$4824.writeInt(0, ((int) 1)); > /* 28 */ } > /* 29 */ > /* 30 */ > /* 31 */ > /* 32 */ if (true) { > /* 33 */ writer$4824.setNullInt(1); > /* 34 */ } else { > /* 35 */ writer$4824.writeInt(1, ((int) -1)); > /* 36 */ } > /* 37 */ > /* 38 */ > /* 39 */ > /* 40 */ if (false) { > /* 41 */ writer$4824.setNullInt(2); > /* 42 */ } else { > /* 43 */ writer$4824.writeInt(2, ((int) 2)); > /* 44 */ } > /* 45 */ > /* 46 */ writer$4824.complete(); > /* 47 */ > /* 48 */ this.setup(task, config, output); > /* 49 */ if (this instanceof > org.apache.flink.streaming.api.operators.AbstractStreamOperator) { > /* 50 */ > ((org.apache.flink.streaming.api.operators.AbstractStreamOperator) this) > /* 51 */ .setProcessingTimeService(processingTimeService); > /* 52 */ } > /* 53 */ } > /* 54 */ > /* 55 */ @Override > /* 56 */ public void open() throws Exception { > /* 57 */ super.open(); > /* 58 */ > /* 59 */ } > /* 60 */ > /* 61 */ @Override > /* 62 */ public void > processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord > element) throws Exception { > /* 63 */ org.apache.flink.table.data.RowData in1 = > (org.apache.flink.table.data.RowData) element.getValue(); > /* 64 */ > /* 65 */ boolean isNull$4827; > /* 66 */ org.apache.flink.table.data.ArrayData result$4828; > /* 67 */ long result$4831; > /* 68 */ > /* 69 */ > /* 70 */ > /* 71 */ > /* 72 */ out.setRowKind(in1.getRowKind()); > /* 73 */ > /* 74 */ > /* 75 */ > /* 76 */ > /* 77 */ // --- Cast section generated by > org.apache.flink.table.planner.functions.casting.ArrayToArrayCastRule > /* 78 */ isNull$4827 = false; > /* 79 */ if (!isNull$4827) { > /* 80 */ java.lang.Long[] objArray$4829 = new > java.lang.Long[array$4823.size()]; > /* 81 */ for (int i$4830 = 0; i$4830 < array$4823.size(); i$4830++) { > /* 82 */ if (!array$4823.isNullAt(i$4830)) { > /* 83 */ result$4831 = ((long)(array$4823.getInt(i$4830))); > /* 84 */ objArray$4829[i$4830] = result$4831; > /* 85 */ } > /* 86 */ } > /* 87 */ result$4828 = new > org.apache.flink.table.data.GenericArrayData(objArray$4829); > /* 88 */ isNull$4827 = result$4828 == null; > /* 89 */ } else { > /* 90 */ result$4828 = null; > /* 91 */ } > /* 92 */ > /* 93 */ // --- End cast section > /* 94 */ > /* 95 */ if (isNull$4827) { > /* 96 */ out.setNullAt(0); > /* 97 */ } else { > /* 98 */ out.setNonPrimitiveValue(0, result$4828); > /* 99 */ } > /* 100 */ > /* 101 */ > /* 102 */ output.collect(outElement.replace(out)); > /* 103 */ > /* 104 */ > /* 105 */ } > /* 106 */ > /* 107 */ > /* 108 */ > /* 109 */ @Override > /* 110 */ public void close() throws Exception { > /* 111 */ super.close(); > /* 112 */ > /* 113 */ } > /* 114 */ > /* 115 */ > /* 116 */ } > /* 117 */ > /* 1 */ > /* 2 */ public class StreamExecCalc$4838 extends > org.apache.flink.table.runtime.operators.TableStreamOperator > /* 3 */ implements > org.apache.flink.streaming.api.operators.OneInputStreamOperator { > /* 4 */ > /* 5 */ private final Object[] references; > /* 6 */ > /* 7 */ org.apache.flink.table.data.binary.BinaryArrayData array$4823 > = new org.apache.flink.table.data.binary.BinaryArrayData(); > /* 8 */ org.apache.flink.table.data.writer.BinaryArrayWriter > writer$4824 = new > org.apache.flink.table.data.writer.BinaryArrayWriter(array$4823, 3, 4); > /* 9 */ > /* 10 */ org.apache.flink.table.data.BoxedWrapperRowData out = new > org.apache.flink.table.data.BoxedWrapperRowData(1); > /* 11 */ private final > org.apache.flink.streaming.runtime.streamrecord.StreamRecord outElement = new > org.apache.flink.streaming.runtime.streamrecord.StreamRecord(null); > /* 12 */ > /* 13 */ public StreamExecCalc$4838( > /* 14 */ Object[] references, > /* 15 */ org.apache.flink.streaming.runtime.tasks.StreamTask task, > /* 16 */ org.apache.flink.streaming.api.graph.StreamConfig config, > /* 17 */ org.apache.flink.streaming.api.operators.Output output, > /* 18 */ > org.apache.flink.streaming.runtime.tasks.ProcessingTimeService > processingTimeService) throws Exception { > /* 19 */ this.references = references; > /* 20 */ > /* 21 */ writer$4824.reset(); > /* 22 */ > /* 23 */ > /* 24 */ if (false) { > /* 25 */ writer$4824.setNullInt(0); > /* 26 */ } else { > /* 27 */ writer$4824.writeInt(0, ((int) 1)); > /* 28 */ } > /* 29 */ > /* 30 */ > /* 31 */ > /* 32 */ if (true) { > /* 33 */ writer$4824.setNullInt(1); > /* 34 */ } else { > /* 35 */ writer$4824.writeInt(1, ((int) -1)); > /* 36 */ } > /* 37 */ > /* 38 */ > /* 39 */ > /* 40 */ if (false) { > /* 41 */ writer$4824.setNullInt(2); > /* 42 */ } else { > /* 43 */ writer$4824.writeInt(2, ((int) 2)); > /* 44 */ } > /* 45 */ > /* 46 */ writer$4824.complete(); > /* 47 */ > /* 48 */ this.setup(task, config, output); > /* 49 */ if (this instanceof > org.apache.flink.streaming.api.operators.AbstractStreamOperator) { > /* 50 */ > ((org.apache.flink.streaming.api.operators.AbstractStreamOperator) this) > /* 51 */ .setProcessingTimeService(processingTimeService); > /* 52 */ } > /* 53 */ } > /* 54 */ > /* 55 */ @Override > /* 56 */ public void open() throws Exception { > /* 57 */ super.open(); > /* 58 */ > /* 59 */ } > /* 60 */ > /* 61 */ @Override > /* 62 */ public void > processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord > element) throws Exception { > /* 63 */ org.apache.flink.table.data.RowData in1 = > (org.apache.flink.table.data.RowData) element.getValue(); > /* 64 */ > /* 65 */ boolean isNull$4827; > /* 66 */ org.apache.flink.table.data.ArrayData result$4828; > /* 67 */ long result$4831; > /* 68 */ > /* 69 */ > /* 70 */ > /* 71 */ > /* 72 */ out.setRowKind(in1.getRowKind()); > /* 73 */ > /* 74 */ > /* 75 */ > /* 76 */ > /* 77 */ // --- Cast section generated by > org.apache.flink.table.planner.functions.casting.ArrayToArrayCastRule > /* 78 */ isNull$4827 = false; > /* 79 */ if (!isNull$4827) { > /* 80 */ java.lang.Long[] objArray$4829 = new > java.lang.Long[array$4823.size()]; > /* 81 */ for (int i$4830 = 0; i$4830 < array$4823.size(); i$4830++) { > /* 82 */ if (!array$4823.isNullAt(i$4830)) { > /* 83 */ result$4831 = ((long)(array$4823.getInt(i$4830))); > /* 84 */ objArray$4829[i$4830] = result$4831; > /* 85 */ } > /* 86 */ } > /* 87 */ result$4828 = new > org.apache.flink.table.data.GenericArrayData(objArray$4829); > /* 88 */ isNull$4827 = result$4828 == null; > /* 89 */ } else { > /* 90 */ result$4828 = null; > /* 91 */ } > /* 92 */ > /* 93 */ // --- End cast section > /* 94 */ > /* 95 */ if (isNull$4827) { > /* 96 */ out.setNullAt(0); > /* 97 */ } else { > /* 98 */ out.setNonPrimitiveValue(0, result$4828); > /* 99 */ } > /* 100 */ > /* 101 */ > /* 102 */ output.collect(outElement.replace(out)); > /* 103 */ > /* 104 */ > /* 105 */ } > /* 106 */ > /* 107 */ > /* 108 */ > /* 109 */ @Override > /* 110 */ public void close() throws Exception { > /* 111 */ super.close(); > /* 112 */ > /* 113 */ } > /* 114 */ > /* 115 */ > /* 116 */ } > /* 117 */ > /* 1 */ > /* 2 */ public class StreamExecCalc$4821 extends > org.apache.flink.table.runtime.operators.TableStreamOperator > /* 3 */ implements > org.apache.flink.streaming.api.operators.OneInputStreamOperator { > /* 4 */ > /* 5 */ private final Object[] references; > /* 6 */ > /* 7 */ org.apache.flink.table.data.binary.BinaryArrayData array$4804 > = new org.apache.flink.table.data.binary.BinaryArrayData(); > /* 8 */ org.apache.flink.table.data.writer.BinaryArrayWriter > writer$4807 = new > org.apache.flink.table.data.writer.BinaryArrayWriter(array$4804, 2, 4); > /* 9 */ > /* 10 */ org.apache.flink.table.data.BoxedWrapperRowData out = new > org.apache.flink.table.data.BoxedWrapperRowData(1); > /* 11 */ private final > org.apache.flink.streaming.runtime.streamrecord.StreamRecord outElement = new > org.apache.flink.streaming.runtime.streamrecord.StreamRecord(null); > /* 12 */ > /* 13 */ public StreamExecCalc$4821( > /* 14 */ Object[] references, > /* 15 */ org.apache.flink.streaming.runtime.tasks.StreamTask task, > /* 16 */ org.apache.flink.streaming.api.graph.StreamConfig config, > /* 17 */ org.apache.flink.streaming.api.operators.Output output, > /* 18 */ > org.apache.flink.streaming.runtime.tasks.ProcessingTimeService > processingTimeService) throws Exception { > /* 19 */ this.references = references; > /* 20 */ > /* 21 */ writer$4807.reset(); > /* 22 */ > /* 23 */ > /* 24 */ if (false) { > /* 25 */ writer$4807.setNullInt(0); > /* 26 */ } else { > /* 27 */ writer$4807.writeInt(0, ((int) 1)); > /* 28 */ } > /* 29 */ > /* 30 */ > /* 31 */ > /* 32 */ if (false) { > /* 33 */ writer$4807.setNullInt(1); > /* 34 */ } else { > /* 35 */ writer$4807.writeInt(1, ((int) 2)); > /* 36 */ } > /* 37 */ > /* 38 */ writer$4807.complete(); > /* 39 */ > /* 40 */ this.setup(task, config, output); > /* 41 */ if (this instanceof > org.apache.flink.streaming.api.operators.AbstractStreamOperator) { > /* 42 */ > ((org.apache.flink.streaming.api.operators.AbstractStreamOperator) this) > /* 43 */ .setProcessingTimeService(processingTimeService); > /* 44 */ } > /* 45 */ } > /* 46 */ > /* 47 */ @Override > /* 48 */ public void open() throws Exception { > /* 49 */ super.open(); > /* 50 */ > /* 51 */ } > /* 52 */ > /* 53 */ @Override > /* 54 */ public void > processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord > element) throws Exception { > /* 55 */ org.apache.flink.table.data.RowData in1 = > (org.apache.flink.table.data.RowData) element.getValue(); > /* 56 */ > /* 57 */ boolean isNull$4814; > /* 58 */ org.apache.flink.table.data.ArrayData result$4815; > /* 59 */ long result$4818; > /* 60 */ > /* 61 */ > /* 62 */ > /* 63 */ > /* 64 */ out.setRowKind(in1.getRowKind()); > /* 65 */ > /* 66 */ > /* 67 */ > /* 68 */ > /* 69 */ // --- Cast section generated by > org.apache.flink.table.planner.functions.casting.ArrayToArrayCastRule > /* 70 */ isNull$4814 = false; > /* 71 */ if (!isNull$4814) { > /* 72 */ long[] objArray$4816 = new long[array$4804.size()]; > /* 73 */ for (int i$4817 = 0; i$4817 < array$4804.size(); i$4817++) { > /* 74 */ result$4818 = ((long)(array$4804.getInt(i$4817))); > /* 75 */ objArray$4816[i$4817] = result$4818; > /* 76 */ } > /* 77 */ result$4815 = new > org.apache.flink.table.data.GenericArrayData(objArray$4816); > /* 78 */ isNull$4814 = result$4815 == null; > /* 79 */ } else { > /* 80 */ result$4815 = null; > /* 81 */ } > /* 82 */ > /* 83 */ // --- End cast section > /* 84 */ > /* 85 */ if (isNull$4814) { > /* 86 */ out.setNullAt(0); > /* 87 */ } else { > /* 88 */ out.setNonPrimitiveValue(0, result$4815); > /* 89 */ } > /* 90 */ > /* 91 */ > /* 92 */ output.collect(outElement.replace(out)); > /* 93 */ > /* 94 */ > /* 95 */ } > /* 96 */ > /* 97 */ > /* 98 */ > /* 99 */ @Override > /* 100 */ public void close() throws Exception { > /* 101 */ super.close(); > /* 102 */ > /* 103 */ } > /* 104 */ > /* 105 */ > /* 106 */ } > /* 107 */ > /* 1 */ > /* 2 */ public class StreamExecCalc$4821 extends > org.apache.flink.table.runtime.operators.TableStreamOperator > /* 3 */ implements > org.apache.flink.streaming.api.operators.OneInputStreamOperator { > /* 4 */ > /* 5 */ private final Object[] references; > /* 6 */ > /* 7 */ org.apache.flink.table.data.binary.BinaryArrayData array$4804 > = new org.apache.flink.table.data.binary.BinaryArrayData(); > /* 8 */ org.apache.flink.table.data.writer.BinaryArrayWriter > writer$4807 = new > org.apache.flink.table.data.writer.BinaryArrayWriter(array$4804, 2, 4); > /* 9 */ > /* 10 */ org.apache.flink.table.data.BoxedWrapperRowData out = new > org.apache.flink.table.data.BoxedWrapperRowData(1); > /* 11 */ private final > org.apache.flink.streaming.runtime.streamrecord.StreamRecord outElement = new > org.apache.flink.streaming.runtime.streamrecord.StreamRecord(null); > /* 12 */ > /* 13 */ public StreamExecCalc$4821( > /* 14 */ Object[] references, > /* 15 */ org.apache.flink.streaming.runtime.tasks.StreamTask task, > /* 16 */ org.apache.flink.streaming.api.graph.StreamConfig config, > /* 17 */ org.apache.flink.streaming.api.operators.Output output, > /* 18 */ > org.apache.flink.streaming.runtime.tasks.ProcessingTimeService > processingTimeService) throws Exception { > /* 19 */ this.references = references; > /* 20 */ > /* 21 */ writer$4807.reset(); > /* 22 */ > /* 23 */ > /* 24 */ if (false) { > /* 25 */ writer$4807.setNullInt(0); > /* 26 */ } else { > /* 27 */ writer$4807.writeInt(0, ((int) 1)); > /* 28 */ } > /* 29 */ > /* 30 */ > /* 31 */ > /* 32 */ if (false) { > /* 33 */ writer$4807.setNullInt(1); > /* 34 */ } else { > /* 35 */ writer$4807.writeInt(1, ((int) 2)); > /* 36 */ } > /* 37 */ > /* 38 */ writer$4807.complete(); > /* 39 */ > /* 40 */ this.setup(task, config, output); > /* 41 */ if (this instanceof > org.apache.flink.streaming.api.operators.AbstractStreamOperator) { > /* 42 */ > ((org.apache.flink.streaming.api.operators.AbstractStreamOperator) this) > /* 43 */ .setProcessingTimeService(processingTimeService); > /* 44 */ } > /* 45 */ } > /* 46 */ > /* 47 */ @Override > /* 48 */ public void open() throws Exception { > /* 49 */ super.open(); > /* 50 */ > /* 51 */ } > /* 52 */ > /* 53 */ @Override > /* 54 */ public void > processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord > element) throws Exception { > /* 55 */ org.apache.flink.table.data.RowData in1 = > (org.apache.flink.table.data.RowData) element.getValue(); > /* 56 */ > /* 57 */ boolean isNull$4814; > /* 58 */ org.apache.flink.table.data.ArrayData result$4815; > /* 59 */ long result$4818; > /* 60 */ > /* 61 */ > /* 62 */ > /* 63 */ > /* 64 */ out.setRowKind(in1.getRowKind()); > /* 65 */ > /* 66 */ > /* 67 */ > /* 68 */ > /* 69 */ // --- Cast section generated by > org.apache.flink.table.planner.functions.casting.ArrayToArrayCastRule > /* 70 */ isNull$4814 = false; > /* 71 */ if (!isNull$4814) { > /* 72 */ long[] objArray$4816 = new long[array$4804.size()]; > /* 73 */ for (int i$4817 = 0; i$4817 < array$4804.size(); i$4817++) { > /* 74 */ result$4818 = ((long)(array$4804.getInt(i$4817))); > /* 75 */ objArray$4816[i$4817] = result$4818; > /* 76 */ } > /* 77 */ result$4815 = new > org.apache.flink.table.data.GenericArrayData(objArray$4816); > /* 78 */ isNull$4814 = result$4815 == null; > /* 79 */ } else { > /* 80 */ result$4815 = null; > /* 81 */ } > /* 82 */ > /* 83 */ // --- End cast section > /* 84 */ > /* 85 */ if (isNull$4814) { > /* 86 */ out.setNullAt(0); > /* 87 */ } else { > /* 88 */ out.setNonPrimitiveValue(0, result$4815); > /* 89 */ } > /* 90 */ > /* 91 */ > /* 92 */ output.collect(outElement.replace(out)); > /* 93 */ > /* 94 */ > /* 95 */ } > /* 96 */ > /* 97 */ > /* 98 */ > /* 99 */ @Override > /* 100 */ public void close() throws Exception { > /* 101 */ super.close(); > /* 102 */ > /* 103 */ } > /* 104 */ > /* 105 */ > /* 106 */ } > /* 107 */ > java.lang.RuntimeException: Failed to fetch next result > at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109) > at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > at org.assertj.core.internal.Iterators.assertHasNext(Iterators.java:49) > at > org.assertj.core.api.AbstractIteratorAssert.hasNext(AbstractIteratorAssert.java:60) > at > org.apache.flink.table.planner.functions.BuiltInFunctionTestBase$ResultTestItem.test(BuiltInFunctionTestBase.java:356) > at > org.apache.flink.table.planner.functions.BuiltInFunctionTestBase$TestSetSpec.lambda$getTestCase$4(BuiltInFunctionTestBase.java:320) > at > org.apache.flink.table.planner.functions.BuiltInFunctionTestBase$TestCase.execute(BuiltInFunctionTestBase.java:113) > at > org.apache.flink.table.planner.functions.BuiltInFunctionTestBase.test(BuiltInFunctionTestBase.java:93) > at sun.reflect.GeneratedMethodAccessor4.invoke(Unknown Source) > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.lang.reflect.Method.invoke(Method.java:498) > at > org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:725) > at > org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60) > at > org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131) > at > org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149) > at > org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140) > at > org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92) > at > org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115) > at > org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105) > at > org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106) > at > org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64) > at > org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45) > at > org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37) > at > org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104) > at > org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98) > at > org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:214) > at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > at > org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:210) > at > org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:135) > at > org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:66) > at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151) > at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141) > at > org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137) > at > org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139) > at > org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) > at > org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138) > at > org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95) > at > org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185) > at java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189) > at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) > at > java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) > at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) > at > java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) > Caused by: java.io.IOException: Failed to fetch job execution result > at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:184) > at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:121) > at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > ... 44 more > Caused by: java.util.concurrent.ExecutionException: > org.apache.flink.runtime.client.JobExecutionException: Job execution failed. > at > java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) > at > java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928) > at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:182) > ... 46 more > Caused by: org.apache.flink.runtime.client.JobExecutionException: Job > execution failed. > at > org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) > at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:141) > at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) > at > java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:628) > at > java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:1996) > at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.getJobExecutionResult(MiniClusterJobClient.java:138) > at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:181) > ... 46 more > Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by > NoRestartBackoffTimeStrategy > at > org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:139) > at > org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:83) > at > org.apache.flink.runtime.scheduler.DefaultScheduler.recordTaskFailure(DefaultScheduler.java:256) > at > org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:247) > at > org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:240) > at > org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:738) > at > org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:715) > at > org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:78) > at > org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:477) > at sun.reflect.GeneratedMethodAccessor68.invoke(Unknown Source) > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.lang.reflect.Method.invoke(Method.java:498) > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:309) > at > org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:307) > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:222) > at > org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:84) > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:168) > at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) > at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) > at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) > at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) > at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) > at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) > at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) > at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) > at akka.actor.Actor.aroundReceive(Actor.scala:537) > at akka.actor.Actor.aroundReceive$(Actor.scala:535) > at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) > at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) > at akka.actor.ActorCell.invoke(ActorCell.scala:548) > at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) > at akka.dispatch.Mailbox.run(Mailbox.scala:231) > at akka.dispatch.Mailbox.exec(Mailbox.scala:243) > ... 4 more > Caused by: java.lang.RuntimeException: Could not instantiate generated class > 'StreamExecCalc$4838' > at > org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:84) > at > org.apache.flink.table.runtime.operators.CodeGenOperatorFactory.createStreamOperator(CodeGenOperatorFactory.java:40) > at > org.apache.flink.streaming.api.operators.StreamOperatorFactoryUtil.createOperator(StreamOperatorFactoryUtil.java:81) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperator(OperatorChain.java:762) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:736) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:676) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:195) > at > org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.<init>(RegularOperatorChain.java:60) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:678) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:666) > at > org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935) > at > org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:904) > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:550) > at java.lang.Thread.run(Thread.java:750) > Caused by: org.apache.flink.util.FlinkRuntimeException: > org.apache.flink.api.common.InvalidProgramException: Table program cannot be > compiled. This is a bug. Please file an issue. > at > org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:94) > at > org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:101) > at > org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:82) > ... 14 more > Caused by: > org.apache.flink.shaded.guava30.com.google.common.util.concurrent.UncheckedExecutionException: > org.apache.flink.api.common.InvalidProgramException: Table program cannot be > compiled. This is a bug. Please file an issue. > at > org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2051) > at > org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache.get(LocalCache.java:3962) > at > org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4859) > at > org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:92) > ... 16 more > Caused by: org.apache.flink.api.common.InvalidProgramException: Table program > cannot be compiled. This is a bug. Please file an issue. > at > org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:107) > at > org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$0(CompileUtils.java:92) > at > org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4864) > at > org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3529) > at > org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2278) > at > org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2155) > at > org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2045) > ... 19 more > Caused by: org.codehaus.commons.compiler.InternalCompilerException: Compiling > "StreamExecCalc$4838" in Line 2, Column 14: Line 62, Column 21: Compiling > "processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord > element)": Line 81, Column 32: Compiling "i$4830": Invalid local variable > index 8 > at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:369) > at org.codehaus.janino.UnitCompiler.access$000(UnitCompiler.java:231) > at > org.codehaus.janino.UnitCompiler$1.visitCompilationUnit(UnitCompiler.java:333) > at > org.codehaus.janino.UnitCompiler$1.visitCompilationUnit(UnitCompiler.java:330) > at org.codehaus.janino.Java$CompilationUnit.accept(Java.java:367) > at org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:330) > at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:245) > at > org.codehaus.janino.SimpleCompiler.compileToClassLoader(SimpleCompiler.java:473) > at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:223) > at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:209) > at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:82) > at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:77) > at > org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:104) > ... 25 more > Caused by: org.codehaus.commons.compiler.InternalCompilerException: Line 62, > Column 21: Compiling > "processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord > element)": Line 81, Column 32: Compiling "i$4830": Invalid local variable > index 8 > at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3222) > at > org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1379) > at > org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1352) > at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:800) > at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:412) > at org.codehaus.janino.UnitCompiler.access$400(UnitCompiler.java:231) > at > org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:391) > at > org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:386) > at > org.codehaus.janino.Java$PackageMemberClassDeclaration.accept(Java.java:1692) > at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:386) > at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:359) > ... 37 more > Caused by: org.codehaus.commons.compiler.InternalCompilerException: Line 81, > Column 32: Compiling "i$4830": Invalid local variable index 8 > at > org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5731) > at > org.codehaus.janino.UnitCompiler.compileBoolean2(UnitCompiler.java:4369) > at org.codehaus.janino.UnitCompiler.access$6500(UnitCompiler.java:231) > at > org.codehaus.janino.UnitCompiler$13.visitBinaryOperation(UnitCompiler.java:4166) > at > org.codehaus.janino.UnitCompiler$13.visitBinaryOperation(UnitCompiler.java:4144) > at org.codehaus.janino.Java$BinaryOperation.accept(Java.java:5222) > at > org.codehaus.janino.UnitCompiler.compileBoolean(UnitCompiler.java:4144) > at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:1714) > at org.codehaus.janino.UnitCompiler.access$2000(UnitCompiler.java:231) > at > org.codehaus.janino.UnitCompiler$6.visitForStatement(UnitCompiler.java:1532) > at > org.codehaus.janino.UnitCompiler$6.visitForStatement(UnitCompiler.java:1523) > at org.codehaus.janino.Java$ForStatement.accept(Java.java:3321) > at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1523) > at > org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1607) > at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:1592) > at org.codehaus.janino.UnitCompiler.access$1700(UnitCompiler.java:231) > at org.codehaus.janino.UnitCompiler$6.visitBlock(UnitCompiler.java:1529) > at org.codehaus.janino.UnitCompiler$6.visitBlock(UnitCompiler.java:1523) > at org.codehaus.janino.Java$Block.accept(Java.java:3103) > at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1523) > at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2509) > at org.codehaus.janino.UnitCompiler.access$1900(UnitCompiler.java:231) > at > org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1531) > at > org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1523) > at org.codehaus.janino.Java$IfStatement.accept(Java.java:3274) > at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1523) > at > org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1607) > at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:3531) > at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3218) > ... 47 more > Caused by: org.codehaus.commons.compiler.InternalCompilerException: Invalid > local variable index 8 > at > org.codehaus.janino.UnitCompiler.getLocalVariableTypeInfo(UnitCompiler.java:13214) > at org.codehaus.janino.UnitCompiler.load(UnitCompiler.java:12232) > at org.codehaus.janino.UnitCompiler.load(UnitCompiler.java:12209) > at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:4679) > at org.codehaus.janino.UnitCompiler.access$7900(UnitCompiler.java:231) > at > org.codehaus.janino.UnitCompiler$15$1.visitLocalVariableAccess(UnitCompiler.java:4616) > at > org.codehaus.janino.UnitCompiler$15$1.visitLocalVariableAccess(UnitCompiler.java:4608) > at org.codehaus.janino.Java$LocalVariableAccess.accept(Java.java:4632) > at > org.codehaus.janino.UnitCompiler$15.visitLvalue(UnitCompiler.java:4608) > at > org.codehaus.janino.UnitCompiler$15.visitLvalue(UnitCompiler.java:4604) > at org.codehaus.janino.Java$Lvalue.accept(Java.java:4498) > at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4604) > at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:4675) > at org.codehaus.janino.UnitCompiler.access$7400(UnitCompiler.java:231) > at > org.codehaus.janino.UnitCompiler$15$1.visitAmbiguousName(UnitCompiler.java:4611) > at > org.codehaus.janino.UnitCompiler$15$1.visitAmbiguousName(UnitCompiler.java:4608) > at org.codehaus.janino.Java$AmbiguousName.accept(Java.java:4574) > at > org.codehaus.janino.UnitCompiler$15.visitLvalue(UnitCompiler.java:4608) > at > org.codehaus.janino.UnitCompiler$15.visitLvalue(UnitCompiler.java:4604) > at org.codehaus.janino.Java$Lvalue.accept(Java.java:4498) > at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4604) > at > org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5729) > ... 75 more > {noformat} -- This message was sent by Atlassian Jira (v8.20.10#820010)