[jira] [Reopened] (FLINK-8685) Code of method "processElement(Ljava/lang/Object;Lorg/apache/flink/streaming/api/functions/ProcessFunction$Context;Lorg/apache/flink/util/Collector;)V" of class "DataStreamCalcRule$3069" grows beyond 64 KB

["Aljoscha Krettek (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-8685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Aljoscha Krettek reopened FLINK-8685:
-------------------------------------

reopen to change fixVersion

> Code of method "processElement(Ljava/lang/Object;Lorg/apache/flink/streaming/api/functions/ProcessFunction$Context;Lorg/apache/flink/util/Collector;)V" of class "DataStreamCalcRule$3069" grows beyond 64 KB
> -------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-8685
>                 URL: https://issues.apache.org/jira/browse/FLINK-8685
>             Project: Flink
>          Issue Type: Bug
>          Components: DataStream API, Table API & SQL
>         Environment: Fedora 27
>            Reporter: Jahandar Musayev
>            Priority: Blocker
>
> I want to use DataStream API and Table API & SQL. I want to read data from Apache Kafka and transpose it using SQL. It throws the error below.
> A version of this code for DataSet API works fine.
>  
> {noformat}
> org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.
>     at org.apache.flink.table.codegen.Compiler$class.compile(Compiler.scala:36)
>     at org.apache.flink.table.runtime.CRowProcessRunner.compile(CRowProcessRunner.scala:35)
>     at org.apache.flink.table.runtime.CRowProcessRunner.open(CRowProcessRunner.scala:49)
>     at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
>     at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
>     at org.apache.flink.streaming.api.operators.ProcessOperator.open(ProcessOperator.java:56)
>     at org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:393)
>     at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:254)
>     at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718)
>     at java.lang.Thread.run(Thread.java:748)
> Caused by: java.lang.RuntimeException: Compiling "DataStreamCalcRule$3069": Code of method "processElement(Ljava/lang/Object;Lorg/apache/flink/streaming/api/functions/ProcessFunction$Context;Lorg/apache/flink/util/Collector;)V" of class "DataStreamCalcRule$3069" grows beyond 64 KB
>     at org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:361)
>     at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:234)
>     at org.codehaus.janino.SimpleCompiler.compileToClassLoader(SimpleCompiler.java:446)
>     at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:213)
>     at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:204)
>     at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:80)
>     at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:75)
>     at org.apache.flink.table.codegen.Compiler$class.compile(Compiler.scala:33)
>     ... 9 more
> Caused by: org.codehaus.janino.JaninoRuntimeException: Code of method "processElement(Ljava/lang/Object;Lorg/apache/flink/streaming/api/functions/ProcessFunction$Context;Lorg/apache/flink/util/Collector;)V" of class "DataStreamCalcRule$3069" grows beyond 64 KB
>     at org.codehaus.janino.CodeContext.makeSpace(CodeContext.java:974)
>     at org.codehaus.janino.CodeContext.write(CodeContext.java:867)
>     at org.codehaus.janino.UnitCompiler.writeOpcode(UnitCompiler.java:11753)
>     at org.codehaus.janino.UnitCompiler.writeLdc(UnitCompiler.java:10512)
>     at org.codehaus.janino.UnitCompiler.pushConstant(UnitCompiler.java:10280)
>     at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5202)
>     at org.codehaus.janino.UnitCompiler.access$8400(UnitCompiler.java:212)
>     at org.codehaus.janino.UnitCompiler$12.visitIntegerLiteral(UnitCompiler.java:4073)
>     at org.codehaus.janino.UnitCompiler$12.visitIntegerLiteral(UnitCompiler.java:4044)
>     at org.codehaus.janino.Java$IntegerLiteral.accept(Java.java:5250)
>     at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4044)
>     at org.codehaus.janino.UnitCompiler.fakeCompile(UnitCompiler.java:3383)
>     at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5218)
>     at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:4813)
>     at org.codehaus.janino.UnitCompiler.access$8200(UnitCompiler.java:212)
>     at org.codehaus.janino.UnitCompiler$12.visitMethodInvocation(UnitCompiler.java:4071)
>     at org.codehaus.janino.UnitCompiler$12.visitMethodInvocation(UnitCompiler.java:4044)
>     at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:4874)
>     at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4044)
>     at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5224)
>     at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:3445)
>     at org.codehaus.janino.UnitCompiler.access$5000(UnitCompiler.java:212)
>     at org.codehaus.janino.UnitCompiler$9.visitMethodInvocation(UnitCompiler.java:3424)
>     at org.codehaus.janino.UnitCompiler$9.visitMethodInvocation(UnitCompiler.java:3396)
>     at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:4874)
>     at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3396)
>     at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2316)
>     at org.codehaus.janino.UnitCompiler.access$1700(UnitCompiler.java:212)
>     at org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1450)
>     at org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1443)
>     at org.codehaus.janino.Java$ExpressionStatement.accept(Java.java:2848)
>     at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1443)
>     at org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1523)
>     at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:1509)
>     at org.codehaus.janino.UnitCompiler.access$1600(UnitCompiler.java:212)
>     at org.codehaus.janino.UnitCompiler$6.visitBlock(UnitCompiler.java:1449)
>     at org.codehaus.janino.UnitCompiler$6.visitBlock(UnitCompiler.java:1443)
>     at org.codehaus.janino.Java$Block.accept(Java.java:2753)
>     at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1443)
>     at org.codehaus.janino.UnitCompiler.fakeCompile(UnitCompiler.java:1485)
>     at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2390)
>     at org.codehaus.janino.UnitCompiler.access$1800(UnitCompiler.java:212)
>     at org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1451)
>     at org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1443)
>     at org.codehaus.janino.Java$IfStatement.accept(Java.java:2923)
>     at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1443)
>     at org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1523)
>     at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3052)
>     at org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1313)
>     at org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1286)
>     at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:785)
>     at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:436)
>     at org.codehaus.janino.UnitCompiler.access$400(UnitCompiler.java:212)
>     at org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:390)
>     at org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:385)
>     at org.codehaus.janino.Java$PackageMemberClassDeclaration.accept(Java.java:1405)
>     at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:385)
>     at org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:357)
>     ... 16 more
> {noformat}
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)