You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2022/08/30 07:29:00 UTC
[jira] [Created] (FLINK-29135) After updating to calcite 1.30.0 and janino 3.1.6 some tests started to fail with compilation issues in generated code
Sergey Nuyanzin created FLINK-29135:
---------------------------------------
Summary: 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
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)