You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "jack sun (Jira)" <ji...@apache.org> on 2020/08/21 10:05:00 UTC
[jira] [Created] (FLINK-19015) java.lang.RuntimeException: Could
not instantiate generated class 'GroupAggsHandler$15'
jack sun created FLINK-19015:
--------------------------------
Summary: java.lang.RuntimeException: Could not instantiate generated class 'GroupAggsHandler$15'
Key: FLINK-19015
URL: https://issues.apache.org/jira/browse/FLINK-19015
Project: Flink
Issue Type: Bug
Components: Table SQL / Runtime
Affects Versions: 1.11.1
Reporter: jack sun
source code :
import org.apache.flink.api.common.eventtime.{Watermark, WatermarkGenerator, WatermarkGeneratorSupplier, WatermarkOutput, WatermarkStrategy}
import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.table.functions.AggregateFunction
import org.apache.flink.streaming.api.scala._
import org.apache.flink.table.api._
import org.apache.flink.table.api.bridge.scala._
import org.apache.flink.types.Row
object TestAggFunction {
def main(args: Array[String]) {
val env = StreamExecutionEnvironment.getExecutionEnvironment
val tenv = StreamTableEnvironment.create(env, EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build())
env.setParallelism(1)
env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime)
val socketStream = env.socketTextStream("127.0.0.1",9090)
.map(x=>{
val c=x.split(" ").toList
Temp3(c(0),c(1).toInt,System.currentTimeMillis())
})
.assignTimestampsAndWatermarks(new WatermarkStrategy[Temp3] {
override def createWatermarkGenerator(context: WatermarkGeneratorSupplier.Context): WatermarkGenerator[Temp3] = {
new WatermarkGenerator[Temp3] {
val delay:Long = 0L//Time.seconds(10).toMilliseconds
var maxTimestamp: Long = 0L
override def onEvent(t: Temp3, l: Long, watermarkOutput: WatermarkOutput): Unit = {
maxTimestamp = maxTimestamp.max(t.timestamp)
val wm = new Watermark(maxTimestamp - delay)
watermarkOutput.emitWatermark(wm)
}
override def onPeriodicEmit(watermarkOutput: WatermarkOutput): Unit = Nil
}
}
})
val table = tenv.fromDataStream(socketStream,'role,'value,'pt.proctime)
tenv.createTemporaryView("t1",table)
tenv.registerFunction("testMax",new MaxAgg)
tenv.sqlQuery("select role,testMax(`value`) from t1 group by role").toRetractStream[Row].print()
// tenv.sqlQuery("select * from t1").toRetractStream[Row].print()
env.execute("test")
}
}
case class Temp3(role:String,value:Int,timestamp:Long)
class MaxAgg extends AggregateFunction[Int,Int]{
override def getValue(acc: Int): Int = acc
override def createAccumulator(): Int = 0
def accumulate(acc: Int, rowVal:Int): Unit = acc.max(rowVal)
}
exceptions:
/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/bin/java -javaagent:/Applications/IntelliJ IDEA CE.app/Contents/lib/idea_rt.jar=57789:/Applications/IntelliJ IDEA CE.app/Contents/bin -Dfile.encoding=UTF-8 -classpath /Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/deploy.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/ext/cldrdata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/ext/dnsns.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/ext/jaccess.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/ext/jfxrt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/ext/localedata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/ext/nashorn.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/ext/sunec.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/ext/sunjce_provider.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/ext/sunpkcs11.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/ext/zipfs.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/javaws.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/jce.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/jfr.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/jfxswt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/jsse.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/management-agent.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/plugin.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/resources.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/jre/lib/rt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/lib/ant-javafx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/lib/dt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/lib/javafx-mx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/lib/jconsole.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/lib/packager.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/lib/sa-jdi.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home/lib/tools.jar:/Users/panziliang/Desktop/www/youyan3/src/da/youyan-flink/target/classes:/Users/panziliang/.m2/repository/org/scala-lang/scala-reflect/2.11.12/scala-reflect-2.11.12.jar:/Users/panziliang/.m2/repository/org/scala-lang/scala-library/2.11.12/scala-library-2.11.12.jar:/Users/panziliang/.m2/repository/org/scala-lang/scala-library/2.11.12/scala-library-2.11.12-sources.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-scala_2.11/1.11.1/flink-scala_2.11-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-core/1.11.1/flink-core-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-annotations/1.11.1/flink-annotations-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-metrics-core/1.11.1/flink-metrics-core-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/commons/commons-lang3/3.3.2/commons-lang3-3.3.2.jar:/Users/panziliang/.m2/repository/com/esotericsoftware/kryo/kryo/2.24.0/kryo-2.24.0.jar:/Users/panziliang/.m2/repository/com/esotericsoftware/minlog/minlog/1.2/minlog-1.2.jar:/Users/panziliang/.m2/repository/org/objenesis/objenesis/2.1/objenesis-2.1.jar:/Users/panziliang/.m2/repository/commons-collections/commons-collections/3.2.2/commons-collections-3.2.2.jar:/Users/panziliang/.m2/repository/org/apache/commons/commons-compress/1.20/commons-compress-1.20.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-shaded-guava/18.0-11.0/flink-shaded-guava-18.0-11.0.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-java/1.11.1/flink-java-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/commons/commons-math3/3.5/commons-math3-3.5.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-shaded-asm-7/7.1-11.0/flink-shaded-asm-7-7.1-11.0.jar:/Users/panziliang/.m2/repository/org/scala-lang/scala-compiler/2.11.12/scala-compiler-2.11.12.jar:/Users/panziliang/.m2/repository/org/scala-lang/modules/scala-xml_2.11/1.0.5/scala-xml_2.11-1.0.5.jar:/Users/panziliang/.m2/repository/org/scala-lang/modules/scala-parser-combinators_2.11/1.0.4/scala-parser-combinators_2.11-1.0.4.jar:/Users/panziliang/.m2/repository/org/slf4j/slf4j-api/1.7.15/slf4j-api-1.7.15.jar:/Users/panziliang/.m2/repository/com/google/code/findbugs/jsr305/1.3.9/jsr305-1.3.9.jar:/Users/panziliang/.m2/repository/org/apache/flink/force-shading/1.11.1/force-shading-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-streaming-scala_2.11/1.11.1/flink-streaming-scala_2.11-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-streaming-java_2.11/1.11.1/flink-streaming-java_2.11-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-statebackend-rocksdb_2.11/1.11.1/flink-statebackend-rocksdb_2.11-1.11.1.jar:/Users/panziliang/.m2/repository/com/data-artisans/frocksdbjni/5.17.2-artisans-2.0/frocksdbjni-5.17.2-artisans-2.0.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-table-api-scala-bridge_2.11/1.11.1/flink-table-api-scala-bridge_2.11-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-table-api-scala_2.11/1.11.1/flink-table-api-scala_2.11-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-table-planner-blink_2.11/1.11.1/flink-table-planner-blink_2.11-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-table-api-java/1.11.1/flink-table-api-java-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-table-api-java-bridge_2.11/1.11.1/flink-table-api-java-bridge_2.11-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-streaming-java_2.11/1.11.1/flink-streaming-java_2.11-1.11.1-tests.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-table-runtime-blink_2.11/1.11.1/flink-table-runtime-blink_2.11-1.11.1.jar:/Users/panziliang/.m2/repository/org/codehaus/janino/janino/3.0.9/janino-3.0.9.jar:/Users/panziliang/.m2/repository/org/codehaus/janino/commons-compiler/3.0.9/commons-compiler-3.0.9.jar:/Users/panziliang/.m2/repository/org/apache/calcite/avatica/avatica-core/1.16.0/avatica-core-1.16.0.jar:/Users/panziliang/.m2/repository/org/reflections/reflections/0.9.10/reflections-0.9.10.jar:/Users/panziliang/.m2/repository/org/javassist/javassist/3.19.0-GA/javassist-3.19.0-GA.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-table-common/1.11.1/flink-table-common-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-clients_2.11/1.11.1/flink-clients_2.11-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-runtime_2.11/1.11.1/flink-runtime_2.11-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-queryable-state-client-java/1.11.1/flink-queryable-state-client-java-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-hadoop-fs/1.11.1/flink-hadoop-fs-1.11.1.jar:/Users/panziliang/.m2/repository/commons-io/commons-io/2.4/commons-io-2.4.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-shaded-netty/4.1.39.Final-11.0/flink-shaded-netty-4.1.39.Final-11.0.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-shaded-jackson/2.10.1-11.0/flink-shaded-jackson-2.10.1-11.0.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-shaded-zookeeper-3/3.4.14-11.0/flink-shaded-zookeeper-3-3.4.14-11.0.jar:/Users/panziliang/.m2/repository/com/typesafe/akka/akka-actor_2.11/2.5.21/akka-actor_2.11-2.5.21.jar:/Users/panziliang/.m2/repository/com/typesafe/config/1.3.3/config-1.3.3.jar:/Users/panziliang/.m2/repository/org/scala-lang/modules/scala-java8-compat_2.11/0.7.0/scala-java8-compat_2.11-0.7.0.jar:/Users/panziliang/.m2/repository/com/typesafe/akka/akka-stream_2.11/2.5.21/akka-stream_2.11-2.5.21.jar:/Users/panziliang/.m2/repository/org/reactivestreams/reactive-streams/1.0.2/reactive-streams-1.0.2.jar:/Users/panziliang/.m2/repository/com/typesafe/ssl-config-core_2.11/0.3.7/ssl-config-core_2.11-0.3.7.jar:/Users/panziliang/.m2/repository/com/typesafe/akka/akka-protobuf_2.11/2.5.21/akka-protobuf_2.11-2.5.21.jar:/Users/panziliang/.m2/repository/com/typesafe/akka/akka-slf4j_2.11/2.5.21/akka-slf4j_2.11-2.5.21.jar:/Users/panziliang/.m2/repository/org/clapper/grizzled-slf4j_2.11/1.3.2/grizzled-slf4j_2.11-1.3.2.jar:/Users/panziliang/.m2/repository/com/github/scopt/scopt_2.11/3.5.0/scopt_2.11-3.5.0.jar:/Users/panziliang/.m2/repository/org/xerial/snappy/snappy-java/1.1.4/snappy-java-1.1.4.jar:/Users/panziliang/.m2/repository/com/twitter/chill_2.11/0.7.6/chill_2.11-0.7.6.jar:/Users/panziliang/.m2/repository/com/twitter/chill-java/0.7.6/chill-java-0.7.6.jar:/Users/panziliang/.m2/repository/org/lz4/lz4-java/1.6.0/lz4-java-1.6.0.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-optimizer_2.11/1.11.1/flink-optimizer_2.11-1.11.1.jar:/Users/panziliang/.m2/repository/commons-cli/commons-cli/1.3.1/commons-cli-1.3.1.jar:/Users/panziliang/.m2/repository/org/apache/bahir/flink-connector-kudu_2.11/1.1-SNAPSHOT/flink-connector-kudu_2.11-1.1-20190927.160502-1.jar:/Users/panziliang/.m2/repository/org/apache/kudu/kudu-client/1.10.0-cdh6.3.0/kudu-client-1.10.0-cdh6.3.0.jar:/Users/panziliang/.m2/repository/com/stumbleupon/async/1.4.1/async-1.4.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-connector-kafka-0.11_2.11/1.11.1/flink-connector-kafka-0.11_2.11-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-connector-kafka-0.10_2.11/1.11.1/flink-connector-kafka-0.10_2.11-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/flink/flink-connector-kafka-base_2.11/1.11.1/flink-connector-kafka-base_2.11-1.11.1.jar:/Users/panziliang/.m2/repository/org/apache/kafka/kafka-clients/0.11.0.2/kafka-clients-0.11.0.2.jar:/Users/panziliang/.m2/repository/net/jpountz/lz4/lz4/1.3.0/lz4-1.3.0.jar:/Users/panziliang/.m2/repository/mysql/mysql-connector-java/8.0.19/mysql-connector-java-8.0.19.jar:/Users/panziliang/.m2/repository/com/google/protobuf/protobuf-java/3.6.1/protobuf-java-3.6.1.jar:/Users/panziliang/.m2/repository/org/apache/commons/commons-pool2/2.8.0/commons-pool2-2.8.0.jar:/Users/panziliang/.m2/repository/org/apache/commons/commons-dbcp2/2.7.0/commons-dbcp2-2.7.0.jar:/Users/panziliang/.m2/repository/commons-logging/commons-logging/1.2/commons-logging-1.2.jar:/Users/panziliang/.m2/repository/org/apache/hadoop/hadoop-client/3.0.0-cdh6.3.0/hadoop-client-3.0.0-cdh6.3.0.jar:/Users/panziliang/.m2/repository/org/apache/hadoop/hadoop-common/3.0.0-cdh6.3.0/hadoop-common-3.0.0-cdh6.3.0.jar:/Users/panziliang/.m2/repository/com/google/guava/guava/11.0.2/guava-11.0.2.jar:/Users/panziliang/.m2/repository/org/apache/httpcomponents/httpclient/4.5.3/httpclient-4.5.3.jar:/Users/panziliang/.m2/repository/org/apache/httpcomponents/httpcore/4.4.6/httpcore-4.4.6.jar:/Users/panziliang/.m2/repository/commons-codec/commons-codec/1.11/commons-codec-1.11.jar:/Users/panziliang/.m2/repository/commons-net/commons-net/3.1/commons-net-3.1.jar:/Users/panziliang/.m2/repository/javax/activation/javax.activation-api/1.2.0/javax.activation-api-1.2.0.jar:/Users/panziliang/.m2/repository/org/eclipse/jetty/jetty-servlet/9.3.25.v20180904/jetty-servlet-9.3.25.v20180904.jar:/Users/panziliang/.m2/repository/org/eclipse/jetty/jetty-security/9.3.25.v20180904/jetty-security-9.3.25.v20180904.jar:/Users/panziliang/.m2/repository/org/eclipse/jetty/jetty-webapp/9.3.25.v20180904/jetty-webapp-9.3.25.v20180904.jar:/Users/panziliang/.m2/repository/org/eclipse/jetty/jetty-xml/9.3.25.v20180904/jetty-xml-9.3.25.v20180904.jar:/Users/panziliang/.m2/repository/javax/servlet/jsp/jsp-api/2.1/jsp-api-2.1.jar:/Users/panziliang/.m2/repository/com/sun/jersey/jersey-servlet/1.19/jersey-servlet-1.19.jar:/Users/panziliang/.m2/repository/commons-lang/commons-lang/2.6/commons-lang-2.6.jar:/Users/panziliang/.m2/repository/commons-beanutils/commons-beanutils/1.9.3/commons-beanutils-1.9.3.jar:/Users/panziliang/.m2/repository/org/apache/commons/commons-configuration2/2.1.1/commons-configuration2-2.1.1.jar:/Users/panziliang/.m2/repository/org/apache/avro/avro/1.8.2-cdh6.3.0/avro-1.8.2-cdh6.3.0.jar:/Users/panziliang/.m2/repository/org/codehaus/jackson/jackson-core-asl/1.9.13/jackson-core-asl-1.9.13.jar:/Users/panziliang/.m2/repository/org/codehaus/jackson/jackson-mapper-asl/1.9.13-cloudera.1/jackson-mapper-asl-1.9.13-cloudera.1.jar:/Users/panziliang/.m2/repository/com/thoughtworks/paranamer/paranamer/2.8/paranamer-2.8.jar:/Users/panziliang/.m2/repository/org/tukaani/xz/1.6/xz-1.6.jar:/Users/panziliang/.m2/repository/com/google/re2j/re2j/1.1/re2j-1.1.jar:/Users/panziliang/.m2/repository/com/google/code/gson/gson/2.2.4/gson-2.2.4.jar:/Users/panziliang/.m2/repository/org/apache/hadoop/hadoop-auth/3.0.0-cdh6.3.0/hadoop-auth-3.0.0-cdh6.3.0.jar:/Users/panziliang/.m2/repository/com/nimbusds/nimbus-jose-jwt/4.41.1/nimbus-jose-jwt-4.41.1.jar:/Users/panziliang/.m2/repository/com/github/stephenc/jcip/jcip-annotations/1.0-1/jcip-annotations-1.0-1.jar:/Users/panziliang/.m2/repository/net/minidev/json-smart/2.3/json-smart-2.3.jar:/Users/panziliang/.m2/repository/net/minidev/accessors-smart/1.2/accessors-smart-1.2.jar:/Users/panziliang/.m2/repository/org/ow2/asm/asm/5.0.4/asm-5.0.4.jar:/Users/panziliang/.m2/repository/org/apache/curator/curator-framework/2.12.0/curator-framework-2.12.0.jar:/Users/panziliang/.m2/repository/org/apache/curator/curator-client/2.12.0/curator-client-2.12.0.jar:/Users/panziliang/.m2/repository/org/apache/curator/curator-recipes/2.12.0/curator-recipes-2.12.0.jar:/Users/panziliang/.m2/repository/org/apache/htrace/htrace-core4/4.1.0-incubating/htrace-core4-4.1.0-incubating.jar:/Users/panziliang/.m2/repository/org/apache/kerby/kerb-simplekdc/1.0.0/kerb-simplekdc-1.0.0.jar:/Users/panziliang/.m2/repository/org/apache/kerby/kerb-client/1.0.0/kerb-client-1.0.0.jar:/Users/panziliang/.m2/repository/org/apache/kerby/kerby-config/1.0.0/kerby-config-1.0.0.jar:/Users/panziliang/.m2/repository/org/apache/kerby/kerb-core/1.0.0/kerb-core-1.0.0.jar:/Users/panziliang/.m2/repository/org/apache/kerby/kerby-pkix/1.0.0/kerby-pkix-1.0.0.jar:/Users/panziliang/.m2/repository/org/apache/kerby/kerby-asn1/1.0.0/kerby-asn1-1.0.0.jar:/Users/panziliang/.m2/repository/org/apache/kerby/kerby-util/1.0.0/kerby-util-1.0.0.jar:/Users/panziliang/.m2/repository/org/apache/kerby/kerb-common/1.0.0/kerb-common-1.0.0.jar:/Users/panziliang/.m2/repository/org/apache/kerby/kerb-crypto/1.0.0/kerb-crypto-1.0.0.jar:/Users/panziliang/.m2/repository/org/apache/kerby/kerb-util/1.0.0/kerb-util-1.0.0.jar:/Users/panziliang/.m2/repository/org/apache/kerby/kerb-admin/1.0.0/kerb-admin-1.0.0.jar:/Users/panziliang/.m2/repository/org/apache/kerby/kerb-server/1.0.0/kerb-server-1.0.0.jar:/Users/panziliang/.m2/repository/org/apache/kerby/kerb-identity/1.0.0/kerb-identity-1.0.0.jar:/Users/panziliang/.m2/repository/org/apache/kerby/kerby-xdr/1.0.0/kerby-xdr-1.0.0.jar:/Users/panziliang/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.9.9/jackson-databind-2.9.9.jar:/Users/panziliang/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.9.9/jackson-core-2.9.9.jar:/Users/panziliang/.m2/repository/org/codehaus/woodstox/stax2-api/3.1.4/stax2-api-3.1.4.jar:/Users/panziliang/.m2/repository/com/fasterxml/woodstox/woodstox-core/5.0.3/woodstox-core-5.0.3.jar:/Users/panziliang/.m2/repository/org/apache/hadoop/hadoop-hdfs-client/3.0.0-cdh6.3.0/hadoop-hdfs-client-3.0.0-cdh6.3.0.jar:/Users/panziliang/.m2/repository/com/squareup/okhttp/okhttp/2.7.5/okhttp-2.7.5.jar:/Users/panziliang/.m2/repository/com/squareup/okio/okio/1.6.0/okio-1.6.0.jar:/Users/panziliang/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.9.9/jackson-annotations-2.9.9.jar:/Users/panziliang/.m2/repository/org/apache/hadoop/hadoop-yarn-api/3.0.0-cdh6.3.0/hadoop-yarn-api-3.0.0-cdh6.3.0.jar:/Users/panziliang/.m2/repository/javax/xml/bind/jaxb-api/2.2.11/jaxb-api-2.2.11.jar:/Users/panziliang/.m2/repository/org/apache/hadoop/hadoop-yarn-client/3.0.0-cdh6.3.0/hadoop-yarn-client-3.0.0-cdh6.3.0.jar:/Users/panziliang/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-core/3.0.0-cdh6.3.0/hadoop-mapreduce-client-core-3.0.0-cdh6.3.0.jar:/Users/panziliang/.m2/repository/org/apache/hadoop/hadoop-yarn-common/3.0.0-cdh6.3.0/hadoop-yarn-common-3.0.0-cdh6.3.0.jar:/Users/panziliang/.m2/repository/javax/servlet/javax.servlet-api/3.1.0/javax.servlet-api-3.1.0.jar:/Users/panziliang/.m2/repository/org/eclipse/jetty/jetty-util/9.3.25.v20180904/jetty-util-9.3.25.v20180904.jar:/Users/panziliang/.m2/repository/com/sun/jersey/jersey-core/1.19/jersey-core-1.19.jar:/Users/panziliang/.m2/repository/javax/ws/rs/jsr311-api/1.1.1/jsr311-api-1.1.1.jar:/Users/panziliang/.m2/repository/com/sun/jersey/jersey-client/1.19/jersey-client-1.19.jar:/Users/panziliang/.m2/repository/com/fasterxml/jackson/module/jackson-module-jaxb-annotations/2.9.9/jackson-module-jaxb-annotations-2.9.9.jar:/Users/panziliang/.m2/repository/com/fasterxml/jackson/jaxrs/jackson-jaxrs-json-provider/2.9.9/jackson-jaxrs-json-provider-2.9.9.jar:/Users/panziliang/.m2/repository/com/fasterxml/jackson/jaxrs/jackson-jaxrs-base/2.9.9/jackson-jaxrs-base-2.9.9.jar:/Users/panziliang/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-jobclient/3.0.0-cdh6.3.0/hadoop-mapreduce-client-jobclient-3.0.0-cdh6.3.0.jar:/Users/panziliang/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-common/3.0.0-cdh6.3.0/hadoop-mapreduce-client-common-3.0.0-cdh6.3.0.jar:/Users/panziliang/.m2/repository/org/apache/hadoop/hadoop-annotations/3.0.0-cdh6.3.0/hadoop-annotations-3.0.0-cdh6.3.0.jar:/Users/panziliang/.m2/repository/org/slf4j/slf4j-log4j12/1.7.7/slf4j-log4j12-1.7.7.jar:/Users/panziliang/.m2/repository/log4j/log4j/1.2.17/log4j-1.2.17.jar com.youyantech.streamJobs.TestAggFunction
17:57:53,061 WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils - Log file environment variable 'log.file' is not set.
17:57:53,062 WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils - JobManager log files are unavailable in the web dashboard. Log file location not found in environment variable 'log.file' or configuration key 'web.log.path'.
17:57:53,476 WARN org.apache.flink.metrics.MetricGroup - The operator name SourceConversion(table=[default_catalog.default_database.t1], fields=[role, value, pt]) exceeded the 80 characters length limit and was truncated.
/* 1 */
/* 2 */ public final class GroupAggsHandler$15 implements org.apache.flink.table.runtime.generated.AggsHandleFunction {
/* 3 */
/* 4 */ private transient com.youyantech.streamJobs.MaxAgg function_com$youyantech$streamJobs$MaxAgg$b5e566eecccd9c2ccca51abaa3afee5e;
/* 5 */ org.apache.flink.table.data.GenericRowData acc$7 = new org.apache.flink.table.data.GenericRowData(1);
/* 6 */ org.apache.flink.table.data.GenericRowData acc$8 = new org.apache.flink.table.data.GenericRowData(1);
/* 7 */ private java.lang.Integer agg0_acc_internal;
/* 8 */ private java.lang.Integer agg0_acc_external;
/* 9 */ org.apache.flink.table.data.GenericRowData aggValue$14 = new org.apache.flink.table.data.GenericRowData(1);
/* 10 */
/* 11 */ private org.apache.flink.table.runtime.dataview.StateDataViewStore store;
/* 12 */
/* 13 */ public GroupAggsHandler$15(java.lang.Object[] references) throws Exception {
/* 14 */ function_com$youyantech$streamJobs$MaxAgg$b5e566eecccd9c2ccca51abaa3afee5e = (((com.youyantech.streamJobs.MaxAgg) references[0]));
/* 15 */ }
/* 16 */
/* 17 */ private org.apache.flink.api.common.functions.RuntimeContext getRuntimeContext() {
/* 18 */ return store.getRuntimeContext();
/* 19 */ }
/* 20 */
/* 21 */ @Override
/* 22 */ public void open(org.apache.flink.table.runtime.dataview.StateDataViewStore store) throws Exception {
/* 23 */ this.store = store;
/* 24 */
/* 25 */ function_com$youyantech$streamJobs$MaxAgg$b5e566eecccd9c2ccca51abaa3afee5e.open(new org.apache.flink.table.functions.FunctionContext(store.getRuntimeContext()));
/* 26 */
/* 27 */ }
/* 28 */
/* 29 */ @Override
/* 30 */ public void accumulate(org.apache.flink.table.data.RowData accInput) throws Exception {
/* 31 */
/* 32 */ int field$10;
/* 33 */ boolean isNull$10;
/* 34 */ isNull$10 = accInput.isNullAt(1);
/* 35 */ field$10 = -1;
/* 36 */ if (!isNull$10) {
/* 37 */ field$10 = accInput.getInt(1);
/* 38 */ }
/* 39 */
/* 40 */
/* 41 */ function_com$youyantech$streamJobs$MaxAgg$b5e566eecccd9c2ccca51abaa3afee5e.accumulate(agg0_acc_external, field$10);
/* 42 */
/* 43 */
/* 44 */ }
/* 45 */
/* 46 */ @Override
/* 47 */ public void retract(org.apache.flink.table.data.RowData retractInput) throws Exception {
/* 48 */
/* 49 */ throw new java.lang.RuntimeException("This function not require retract method, but the retract method is called.");
/* 50 */
/* 51 */ }
/* 52 */
/* 53 */ @Override
/* 54 */ public void merge(org.apache.flink.table.data.RowData otherAcc) throws Exception {
/* 55 */
/* 56 */ throw new java.lang.RuntimeException("This function not require merge method, but the merge method is called.");
/* 57 */
/* 58 */ }
/* 59 */
/* 60 */ @Override
/* 61 */ public void setAccumulators(org.apache.flink.table.data.RowData acc) throws Exception {
/* 62 */
/* 63 */ int field$9;
/* 64 */ boolean isNull$9;
/* 65 */ isNull$9 = acc.isNullAt(0);
/* 66 */ field$9 = -1;
/* 67 */ if (!isNull$9) {
/* 68 */ field$9 = acc.getInt(0);
/* 69 */ }
/* 70 */
/* 71 */ agg0_acc_internal = field$9;
/* 72 */ agg0_acc_external = agg0_acc_internal;
/* 73 */
/* 74 */
/* 75 */ }
/* 76 */
/* 77 */ @Override
/* 78 */ public void resetAccumulators() throws Exception {
/* 79 */
/* 80 */
/* 81 */
/* 82 */ agg0_acc_external = (java.lang.Integer) function_com$youyantech$streamJobs$MaxAgg$b5e566eecccd9c2ccca51abaa3afee5e.createAccumulator();
/* 83 */ agg0_acc_internal = agg0_acc_external;
/* 84 */
/* 85 */
/* 86 */ }
/* 87 */
/* 88 */ @Override
/* 89 */ public org.apache.flink.table.data.RowData getAccumulators() throws Exception {
/* 90 */
/* 91 */
/* 92 */
/* 93 */ acc$8 = new org.apache.flink.table.data.GenericRowData(1);
/* 94 */
/* 95 */ agg0_acc_internal = agg0_acc_external;
/* 96 */ if (false) {
/* 97 */ acc$8.setField(0, null);
/* 98 */ } else {
/* 99 */ acc$8.setField(0, agg0_acc_internal);
/* 100 */ }
/* 101 */
/* 102 */
/* 103 */ return acc$8;
/* 104 */
/* 105 */ }
/* 106 */
/* 107 */ @Override
/* 108 */ public org.apache.flink.table.data.RowData createAccumulators() throws Exception {
/* 109 */
/* 110 */
/* 111 */
/* 112 */ acc$7 = new org.apache.flink.table.data.GenericRowData(1);
/* 113 */
/* 114 */ java.lang.Integer acc_internal$6 = (java.lang.Integer) function_com$youyantech$streamJobs$MaxAgg$b5e566eecccd9c2ccca51abaa3afee5e.createAccumulator();
/* 115 */ if (false) {
/* 116 */ acc$7.setField(0, null);
/* 117 */ } else {
/* 118 */ acc$7.setField(0, acc_internal$6);
/* 119 */ }
/* 120 */
/* 121 */
/* 122 */ return acc$7;
/* 123 */
/* 124 */ }
/* 125 */
/* 126 */ @Override
/* 127 */ public org.apache.flink.table.data.RowData getValue() throws Exception {
/* 128 */
/* 129 */
/* 130 */
/* 131 */ aggValue$14 = new org.apache.flink.table.data.GenericRowData(1);
/* 132 */
/* 133 */
/* 134 */ java.lang.Integer value_external$11 = (java.lang.Integer)
/* 135 */ function_com$youyantech$streamJobs$MaxAgg$b5e566eecccd9c2ccca51abaa3afee5e.getValue(agg0_acc_external);
/* 136 */ java.lang.Integer value_internal$12 =
/* 137 */ value_external$11;
/* 138 */ boolean valueIsNull$13 = value_internal$12 == null;
/* 139 */
/* 140 */ if (valueIsNull$13) {
/* 141 */ aggValue$14.setField(0, null);
/* 142 */ } else {
/* 143 */ aggValue$14.setField(0, value_internal$12);
/* 144 */ }
/* 145 */
/* 146 */
/* 147 */ return aggValue$14;
/* 148 */
/* 149 */ }
/* 150 */
/* 151 */ @Override
/* 152 */ public void cleanup() throws Exception {
/* 153 */
/* 154 */
/* 155 */ }
/* 156 */
/* 157 */ @Override
/* 158 */ public void close() throws Exception {
/* 159 */
/* 160 */ function_com$youyantech$streamJobs$MaxAgg$b5e566eecccd9c2ccca51abaa3afee5e.close();
/* 161 */
/* 162 */ }
/* 163 */ }
/* 164 */
17:57:53,512 WARN org.apache.flink.runtime.taskmanager.Task - GroupAggregate(groupBy=[role], select=[role, testMax(value) AS EXPR$1]) -> SinkConversionToTuple2 -> Sink: Print to Std. Out (1/1) (b18bcad474d4465817ed5f80bda95d0e) switched from RUNNING to FAILED.
java.lang.RuntimeException: Could not instantiate generated class 'GroupAggsHandler$15'
at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:57)
at org.apache.flink.table.runtime.operators.aggregate.GroupAggFunction.open(GroupAggFunction.java:119)
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.KeyedProcessOperator.open(KeyedProcessOperator.java:57)
at org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:291)
at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$0(StreamTask.java:473)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:47)
at org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:469)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:522)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:546)
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:68)
at org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:78)
at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:52)
... 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:66)
... 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:81)
at org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$1(CompileUtils.java:66)
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 "GroupAggsHandler$15": Incompatible return types
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:78)
... 23 more
Caused by: org.codehaus.janino.InternalCompilerException: Incompatible return types
at org.codehaus.janino.UnitCompiler.findMostSpecificIInvocable(UnitCompiler.java:9393)
at org.codehaus.janino.UnitCompiler.findMostSpecificIInvocable(UnitCompiler.java:9154)
at org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:9036)
at org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:8938)
at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5060)
at org.codehaus.janino.UnitCompiler.access$9100(UnitCompiler.java:215)
at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4421)
at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4394)
at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5062)
at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4394)
at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5575)
at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5019)
at org.codehaus.janino.UnitCompiler.access$8600(UnitCompiler.java:215)
at org.codehaus.janino.UnitCompiler$16.visitCast(UnitCompiler.java:4416)
at org.codehaus.janino.UnitCompiler$16.visitCast(UnitCompiler.java:4394)
at org.codehaus.janino.Java$Cast.accept(Java.java:4887)
at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4394)
at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5575)
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:3790)
at org.codehaus.janino.UnitCompiler.access$6100(UnitCompiler.java:215)
at org.codehaus.janino.UnitCompiler$13.visitAssignment(UnitCompiler.java:3752)
at org.codehaus.janino.UnitCompiler$13.visitAssignment(UnitCompiler.java:3732)
at org.codehaus.janino.Java$Assignment.accept(Java.java:4466)
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3732)
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2360)
at org.codehaus.janino.UnitCompiler.access$1800(UnitCompiler.java:215)
at org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1494)
at org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1487)
at org.codehaus.janino.Java$ExpressionStatement.accept(Java.java:2871)
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
Exception in thread "main" 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:1895)
at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1719)
at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:74)
at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1699)
at org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.scala:699)
at com.youyantech.streamJobs.TestAggFunction$.main(TestAggFunction.scala:54)
at com.youyantech.streamJobs.TestAggFunction.main(TestAggFunction.scala)
Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:147)
at org.apache.flink.client.program.PerJobMiniClusterFactory$PerJobMiniClusterJobClient.lambda$getJobExecutionResult$2(PerJobMiniClusterFactory.java:186)
at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:602)
at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:577)
at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962)
at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:229)
at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962)
at org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:892)
at akka.dispatch.OnComplete.internal(Future.scala:264)
at akka.dispatch.OnComplete.internal(Future.scala:261)
at akka.dispatch.japi$CallbackBridge.apply(Future.scala:191)
at akka.dispatch.japi$CallbackBridge.apply(Future.scala:188)
at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
at org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:74)
at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44)
at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252)
at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572)
at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22)
at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21)
at scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436)
at scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435)
at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)
at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91)
at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)
at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72)
at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:90)
at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44)
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:116)
at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:78)
at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:192)
at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:185)
at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:179)
at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:503)
at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:386)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
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.handleRpcInvocation(AkkaRpcActor.java:284)
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:199)
at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
at akka.actor.ActorCell.invoke(ActorCell.scala:561)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
at akka.dispatch.Mailbox.run(Mailbox.scala:225)
at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
... 4 more
Caused by: java.lang.RuntimeException: Could not instantiate generated class 'GroupAggsHandler$15'
at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:57)
at org.apache.flink.table.runtime.operators.aggregate.GroupAggFunction.open(GroupAggFunction.java:119)
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.KeyedProcessOperator.open(KeyedProcessOperator.java:57)
at org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:291)
at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$0(StreamTask.java:473)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:47)
at org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:469)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:522)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:546)
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:68)
at org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:78)
at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:52)
... 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:66)
... 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:81)
at org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$1(CompileUtils.java:66)
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 "GroupAggsHandler$15": Incompatible return types
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:78)
... 23 more
Caused by: org.codehaus.janino.InternalCompilerException: Incompatible return types
at org.codehaus.janino.UnitCompiler.findMostSpecificIInvocable(UnitCompiler.java:9393)
at org.codehaus.janino.UnitCompiler.findMostSpecificIInvocable(UnitCompiler.java:9154)
at org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:9036)
at org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:8938)
at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5060)
at org.codehaus.janino.UnitCompiler.access$9100(UnitCompiler.java:215)
at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4421)
at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4394)
at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5062)
at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4394)
at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5575)
at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5019)
at org.codehaus.janino.UnitCompiler.access$8600(UnitCompiler.java:215)
at org.codehaus.janino.UnitCompiler$16.visitCast(UnitCompiler.java:4416)
at org.codehaus.janino.UnitCompiler$16.visitCast(UnitCompiler.java:4394)
at org.codehaus.janino.Java$Cast.accept(Java.java:4887)
at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4394)
at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5575)
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:3790)
at org.codehaus.janino.UnitCompiler.access$6100(UnitCompiler.java:215)
at org.codehaus.janino.UnitCompiler$13.visitAssignment(UnitCompiler.java:3752)
at org.codehaus.janino.UnitCompiler$13.visitAssignment(UnitCompiler.java:3732)
at org.codehaus.janino.Java$Assignment.accept(Java.java:4466)
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3732)
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2360)
at org.codehaus.janino.UnitCompiler.access$1800(UnitCompiler.java:215)
at org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1494)
at org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1487)
at org.codehaus.janino.Java$ExpressionStatement.accept(Java.java:2871)
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
Process finished with exit code 1
--
This message was sent by Atlassian Jira
(v8.3.4#803005)