smith jayden created FLINK-22903:
------------------------------------
Summary: Code of method xxx of class "StreamExecCalc$1248" grows
beyond 64 KB
Key: FLINK-22903
URL: https://issues.apache.org/jira/browse/FLINK-22903
Project: Flink
Issue Type: Bug
Components: Table SQL / Runtime
Affects Versions: 1.13.0
Environment: my sql query is under below:
insert into `jz_lbs_data_cnt`
select case when substr(geohash,1,8) in
('wecntxr1','wecntxr3','wecntxr9','wecntxrc','wecntz21','wecntz23','wecntxr4','wecntxr6','wecntxrd','wecntxrf','wecntz24','wecntz26','wecntz2d','wecntxr7','wecntxre','wecntxrg','wecntz25','wecntz27','wecntz2e','wecntxrk','wecntxrs','wecntxru','wecntz2h','wecntz2k','wecntz2s','wecntz2u','wecntxrm','wecntxrt','wecntxrv','wecntz2j','wecntz2m','wecntz2t','wecntz2v','wecntz3j','wecntxrq','wecntxrw','wecntxry','wecntz2n','wecntz2q','wecntz2w','wecntz2y','wecntz3n','wecntxrx','wecntxrz','wecntz2p','wecntz2r','wecntz2x','wecntz2z','wecntz3p','wecntz3r','wecntxx8','wecntxxb','wecntz80','wecntz82','wecntz88','wecntz8b','wecntz90','wecntz92','wecntxxc','wecntz81','wecntz83','wecntz89','wecntz8c','wecntz91','wecntz93','wecntz84','wecntz86','wecntz8d','wecntz8f','wecntz94','wecntz96','wecntz9d','wecntz87','wecntz8e','wecntz8g','wecntz95','wecntz97','wecntz9e','wecntz8s','wecntz8u','wecntz9h','wecntz9k','wecntz9s','wecntz9u','wecntz8v','wecntz9j','wecntz9m','wecntz9t','wecntz9v','wecntz8y','wecntz9n','wecntz9q','wecntz9w','wecntz9p','wecntz9r','wecntzc2')
then '202008240001'
when substr(geohash,1,8) in
('wecnwrvh','wecnwrvk','wecnwrvs','wecnwrvu','wecnwryh','wecnwryk','wecnwrum','wecnwrut','wecnwruv','wecnwrvj','wecnwrvm','wecnwrvt','wecnwrvv','wecnwryj','wecnwrym','wecnwryt','wecnwrun','wecnwruq','wecnwruw','wecnwruy','wecnwrvn','wecnwrvq','wecnwrvw','wecnwrvy','wecnwryn','wecnwryq','wecnwryw','wecnwrgz','wecnwrup','wecnwrur','wecnwrux','wecnwruz','wecnwrvp','wecnwrvr','wecnwrvx','wecnwrvz','wecnwryp','wecnwryr','wecnwryx','wecny258','wecny25b','wecny2h0','wecny2h2','wecny2h8','wecny2hb','wecny2j0','wecny2j2','wecny2j8','wecny2jb','wecny2n0','wecny2n2','wecny2n8','wecny259','wecny25c','wecny2h1','wecny2h3','wecny2h9','wecny2hc','wecny2j1','wecny2j3','wecny2j9','wecny2jc','wecny2n1','wecny25d','wecny25f','wecny2h4','wecny2h6','wecny2hd','wecny2hf','wecny2j4','wecny2j6','wecny2jd','wecny2jf','wecny257','wecny25e','wecny25g','wecny2h5','wecny2h7','wecny2he','wecny2hg','wecny2j5','wecny2j7','wecny2je','wecny25k','wecny25s','wecny25u','wecny2hh','wecny2hk','wecny2hs','wecny2hu','wecny2jh','wecny25m','wecny25t','wecny25v','wecny2hj','wecny2hm','wecny2ht','wecny2hv','wecny25q','wecny25w','wecny25y','wecny2hn','wecny2hq','wecny2hw','wecny25x','wecny25z','wecny2hp')
then '202105180001' else '其他' end as tag
,TUMBLE_START(eventTime, INTERVAL '10' MINUTE) as window_start
,TUMBLE_END(eventTime, INTERVAL '10' MINUTE) as window_end
,count(distinct gid) as cnt
from chengjw.gt_lbs_type11
where
-- area in (0,81000000) and
substr(geohash,1,8) in
('wecntxr1','wecntxr3','wecntxr9','wecntxrc','wecntz21','wecntz23','wecntxr4','wecntxr6','wecntxrd','wecntxrf','wecntz24','wecntz26','wecntz2d','wecntxr7','wecntxre','wecntxrg','wecntz25','wecntz27','wecntz2e','wecntxrk','wecntxrs','wecntxru','wecntz2h','wecntz2k','wecntz2s','wecntz2u','wecntxrm','wecntxrt','wecntxrv','wecntz2j','wecntz2m','wecntz2t','wecntz2v','wecntz3j','wecntxrq','wecntxrw','wecntxry','wecntz2n','wecntz2q','wecntz2w','wecntz2y','wecntz3n','wecntxrx','wecntxrz','wecntz2p','wecntz2r','wecntz2x','wecntz2z','wecntz3p','wecntz3r','wecntxx8','wecntxxb','wecntz80','wecntz82','wecntz88','wecntz8b','wecntz90','wecntz92','wecntxxc','wecntz81','wecntz83','wecntz89','wecntz8c','wecntz91','wecntz93','wecntz84','wecntz86','wecntz8d','wecntz8f','wecntz94','wecntz96','wecntz9d','wecntz87','wecntz8e','wecntz8g','wecntz95','wecntz97','wecntz9e','wecntz8s','wecntz8u','wecntz9h','wecntz9k','wecntz9s','wecntz9u','wecntz8v','wecntz9j','wecntz9m','wecntz9t','wecntz9v','wecntz8y','wecntz9n','wecntz9q','wecntz9w','wecntz9p','wecntz9r','wecntzc2','wecnwrvh','wecnwrvk','wecnwrvs','wecnwrvu','wecnwryh','wecnwryk','wecnwrum','wecnwrut','wecnwruv','wecnwrvj','wecnwrvm','wecnwrvt','wecnwrvv','wecnwryj','wecnwrym','wecnwryt','wecnwrun','wecnwruq','wecnwruw','wecnwruy','wecnwrvn','wecnwrvq','wecnwrvw','wecnwrvy','wecnwryn','wecnwryq','wecnwryw','wecnwrgz','wecnwrup','wecnwrur','wecnwrux','wecnwruz','wecnwrvp','wecnwrvr','wecnwrvx','wecnwrvz','wecnwryp','wecnwryr','wecnwryx','wecny258','wecny25b','wecny2h0','wecny2h2','wecny2h8','wecny2hb','wecny2j0','wecny2j2','wecny2j8','wecny2jb','wecny2n0','wecny2n2','wecny2n8','wecny259','wecny25c','wecny2h1','wecny2h3','wecny2h9','wecny2hc','wecny2j1','wecny2j3','wecny2j9','wecny2jc','wecny2n1','wecny25d','wecny25f','wecny2h4','wecny2h6','wecny2hd','wecny2hf','wecny2j4','wecny2j6','wecny2jd','wecny2jf','wecny257','wecny25e','wecny25g','wecny2h5','wecny2h7','wecny2he','wecny2hg','wecny2j5','wecny2j7','wecny2je','wecny25k','wecny25s','wecny25u','wecny2hh','wecny2hk','wecny2hs','wecny2hu','wecny2jh','wecny25m','wecny25t','wecny25v','wecny2hj','wecny2hm','wecny2ht','wecny2hv','wecny25q','wecny25w','wecny25y','wecny2hn','wecny2hq','wecny2hw','wecny25x','wecny25z','wecny2hp')
group by case when substr(geohash,1,8) in
('wecntxr1','wecntxr3','wecntxr9','wecntxrc','wecntz21','wecntz23','wecntxr4','wecntxr6','wecntxrd','wecntxrf','wecntz24','wecntz26','wecntz2d','wecntxr7','wecntxre','wecntxrg','wecntz25','wecntz27','wecntz2e','wecntxrk','wecntxrs','wecntxru','wecntz2h','wecntz2k','wecntz2s','wecntz2u','wecntxrm','wecntxrt','wecntxrv','wecntz2j','wecntz2m','wecntz2t','wecntz2v','wecntz3j','wecntxrq','wecntxrw','wecntxry','wecntz2n','wecntz2q','wecntz2w','wecntz2y','wecntz3n','wecntxrx','wecntxrz','wecntz2p','wecntz2r','wecntz2x','wecntz2z','wecntz3p','wecntz3r','wecntxx8','wecntxxb','wecntz80','wecntz82','wecntz88','wecntz8b','wecntz90','wecntz92','wecntxxc','wecntz81','wecntz83','wecntz89','wecntz8c','wecntz91','wecntz93','wecntz84','wecntz86','wecntz8d','wecntz8f','wecntz94','wecntz96','wecntz9d','wecntz87','wecntz8e','wecntz8g','wecntz95','wecntz97','wecntz9e','wecntz8s','wecntz8u','wecntz9h','wecntz9k','wecntz9s','wecntz9u','wecntz8v','wecntz9j','wecntz9m','wecntz9t','wecntz9v','wecntz8y','wecntz9n','wecntz9q','wecntz9w','wecntz9p','wecntz9r','wecntzc2')
then '202008240001'
when substr(geohash,1,8) in
('wecnwrvh','wecnwrvk','wecnwrvs','wecnwrvu','wecnwryh','wecnwryk','wecnwrum','wecnwrut','wecnwruv','wecnwrvj','wecnwrvm','wecnwrvt','wecnwrvv','wecnwryj','wecnwrym','wecnwryt','wecnwrun','wecnwruq','wecnwruw','wecnwruy','wecnwrvn','wecnwrvq','wecnwrvw','wecnwrvy','wecnwryn','wecnwryq','wecnwryw','wecnwrgz','wecnwrup','wecnwrur','wecnwrux','wecnwruz','wecnwrvp','wecnwrvr','wecnwrvx','wecnwrvz','wecnwryp','wecnwryr','wecnwryx','wecny258','wecny25b','wecny2h0','wecny2h2','wecny2h8','wecny2hb','wecny2j0','wecny2j2','wecny2j8','wecny2jb','wecny2n0','wecny2n2','wecny2n8','wecny259','wecny25c','wecny2h1','wecny2h3','wecny2h9','wecny2hc','wecny2j1','wecny2j3','wecny2j9','wecny2jc','wecny2n1','wecny25d','wecny25f','wecny2h4','wecny2h6','wecny2hd','wecny2hf','wecny2j4','wecny2j6','wecny2jd','wecny2jf','wecny257','wecny25e','wecny25g','wecny2h5','wecny2h7','wecny2he','wecny2hg','wecny2j5','wecny2j7','wecny2je','wecny25k','wecny25s','wecny25u','wecny2hh','wecny2hk','wecny2hs','wecny2hu','wecny2jh','wecny25m','wecny25t','wecny25v','wecny2hj','wecny2hm','wecny2ht','wecny2hv','wecny25q','wecny25w','wecny25y','wecny2hn','wecny2hq','wecny2hw','wecny25x','wecny25z','wecny2hp')
then '202105180001' else '其他' end
,TUMBLE(eventTime, INTERVAL '10' MINUTE)
;
Reporter: smith jayden
when I select a table from kafka, the logs is under below:
java.lang.RuntimeException: Could not instantiate generated class
'StreamExecCalc$1248'
at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:66)
at
org.apache.flink.table.runtime.operators.CodeGenOperatorFactory.createStreamOperator(CodeGenOperatorFactory.java:40)
at
org.apache.flink.streaming.api.operators.StreamOperatorFactoryUtil.createOperator(StreamOperatorFactoryUtil.java:80)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperator(OperatorChain.java:652)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:626)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:566)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:181)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.executeRestore(StreamTask.java:548)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:647)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:537)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:759)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
at java.lang.Thread.run(Thread.java:748)
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:76)
at
org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:77)
at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:64)
... 12 more
Caused by:
org.apache.flink.shaded.guava18.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.guava18.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2203)
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache.get(LocalCache.java:3937)
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4739)
at
org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:74)
... 14 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:89)
at
org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$1(CompileUtils.java:74)
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4742)
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3527)
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2319)
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2282)
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2197)
... 17 more
Caused by: org.codehaus.janino.InternalCompilerException: Compiling
"StreamExecCalc$1248": Code of method "split$1245$(LStreamExecCalc$1248;)V" of
class "StreamExecCalc$1248" grows beyond 64 KB
at org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:382)
at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:237)
at
org.codehaus.janino.SimpleCompiler.compileToClassLoader(SimpleCompiler.java:465)
at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:216)
at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:207)
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.runtime.generated.CompileUtils.doCompile(CompileUtils.java:86)
... 23 more
Caused by: org.codehaus.janino.InternalCompilerException: Code of method
"split$1245$(LStreamExecCalc$1248;)V" of class "StreamExecCalc$1248" grows
beyond 64 KB
at org.codehaus.janino.CodeContext.makeSpace(CodeContext.java:1048)
at org.codehaus.janino.CodeContext.write(CodeContext.java:957)
at org.codehaus.janino.CodeContext.writeBranch(CodeContext.java:1077)
at org.codehaus.janino.UnitCompiler.writeBranch(UnitCompiler.java:12301)
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2466)
at org.codehaus.janino.UnitCompiler.access$1900(UnitCompiler.java:215)
at
org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1495)
at
org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1487)
at org.codehaus.janino.Java$IfStatement.accept(Java.java:2950)
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487)
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2468)
at org.codehaus.janino.UnitCompiler.access$1900(UnitCompiler.java:215)
at
org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1495)
at
org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1487)
at org.codehaus.janino.Java$IfStatement.accept(Java.java:2950)
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487)
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2468)
at org.codehaus.janino.UnitCompiler.access$1900(UnitCompiler.java:215)
at
org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1495)
at
org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1487)
at org.codehaus.janino.Java$IfStatement.accept(Java.java:2950)
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487)
at
org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1567)
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:1553)
at org.codehaus.janino.UnitCompiler.access$1700(UnitCompiler.java:215)
at org.codehaus.janino.UnitCompiler$6.visitBlock(UnitCompiler.java:1493)
at org.codehaus.janino.UnitCompiler$6.visitBlock(UnitCompiler.java:1487)
at org.codehaus.janino.Java$Block.accept(Java.java:2779)
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487)
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2486)
at org.codehaus.janino.UnitCompiler.access$1900(UnitCompiler.java:215)
at
org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1495)
at
org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1487)
at org.codehaus.janino.Java$IfStatement.accept(Java.java:2950)
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487)
at
org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1567)
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:1553)
at org.codehaus.janino.UnitCompiler.access$1700(UnitCompiler.java:215)
at org.codehaus.janino.UnitCompiler$6.visitBlock(UnitCompiler.java:1493)
at org.codehaus.janino.UnitCompiler$6.visitBlock(UnitCompiler.java:1487)
at org.codehaus.janino.Java$Block.accept(Java.java:2779)
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487)
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2468)
at org.codehaus.janino.UnitCompiler.access$1900(UnitCompiler.java:215)
at
org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1495)
at
org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1487)
at org.codehaus.janino.Java$IfStatement.accept(Java.java:2950)
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487)
at
org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1567)
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3388)
at
org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1357)
at
org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1330)
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:822)
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:432)
at org.codehaus.janino.UnitCompiler.access$400(UnitCompiler.java:215)
at
org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:411)
at
org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:406)
at
org.codehaus.janino.Java$PackageMemberClassDeclaration.accept(Java.java:1414)
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:406)
at org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:378)
... 30 more
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
