flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Simone Robutti <simone.robu...@radicalbit.io>
Subject Creating a custom operator
Date Fri, 29 Apr 2016 13:32:57 GMT
Hello,

I'm trying to create a custom operator to explore the internals of Flink.
Actually the one I'm working on is rather similar to Union and I'm trying
to mimick it for now. When I run my job though, this error arise:

Exception in thread "main" java.lang.IllegalArgumentException: Unknown
operator type: MyOperator - My Operator
at
org.apache.flink.optimizer.traversals.GraphCreatingVisitor.preVisit(GraphCreatingVisitor.java:237)
at
org.apache.flink.optimizer.traversals.GraphCreatingVisitor.preVisit(GraphCreatingVisitor.java:82)
at
org.apache.flink.api.common.operators.DualInputOperator.accept(DualInputOperator.java:279)
at
org.apache.flink.api.common.operators.GenericDataSinkBase.accept(GenericDataSinkBase.java:223)
at org.apache.flink.api.common.Plan.accept(Plan.java:348)
at org.apache.flink.optimizer.Optimizer.compile(Optimizer.java:454)
at org.apache.flink.optimizer.Optimizer.compile(Optimizer.java:398)
at
org.apache.flink.client.LocalExecutor.getOptimizerPlanAsJSON(LocalExecutor.java:213)
at
org.apache.flink.api.java.LocalEnvironment.getExecutionPlan(LocalEnvironment.java:107)
at io.radicalbit.flinkh2o.Job$.main(Job.scala:50)
at io.radicalbit.flinkh2o.Job.main(Job.scala)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:140)

I looked at the location of the error but it's not clear to me how to make
my operator recognizable from the optimizer.

Thank,

Simone

Mime
View raw message