[ https://issues.apache.org/jira/browse/FLINK-31424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703543#comment-17703543 ]
lincoln lee commented on FLINK-31424: ------------------------------------- fixed in master: 824259ecf53fd82061d177b508594e6510e69060 > NullPointer when using StatementSet for multiple sinks > ------------------------------------------------------ > > Key: FLINK-31424 > URL: https://issues.apache.org/jira/browse/FLINK-31424 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner > Affects Versions: 1.16.1 > Reporter: jirawech.s > Assignee: Jane Chan > Priority: Major > Labels: pull-request-available > Fix For: 1.18.0, 1.17.1 > > Attachments: HelloFlinkWindowJoin.java > > > I got following error when i tried to execute multiple sinks using > StatementSet. I am not sure what it is and where to find possible solution. > Error > {code:java} > // code placeholder > Exception in thread "main" java.lang.NullPointerException > at > org.apache.flink.table.planner.plan.metadata.FlinkRelMdWindowProperties.getJoinWindowProperties(FlinkRelMdWindowProperties.scala:373) > at > org.apache.flink.table.planner.plan.metadata.FlinkRelMdWindowProperties.getWindowProperties(FlinkRelMdWindowProperties.scala:349) > at > GeneratedMetadataHandler_WindowProperties.getWindowProperties_$(Unknown > Source) > at GeneratedMetadataHandler_WindowProperties.getWindowProperties(Unknown > Source) > at > org.apache.flink.table.planner.plan.metadata.FlinkRelMetadataQuery.getRelWindowProperties(FlinkRelMetadataQuery.java:261) > at > org.apache.flink.table.planner.plan.optimize.StreamCommonSubGraphBasedOptimizer.createIntermediateRelTable(StreamCommonSubGraphBasedOptimizer.scala:287) > at > org.apache.flink.table.planner.plan.optimize.StreamCommonSubGraphBasedOptimizer.optimizeBlock(StreamCommonSubGraphBasedOptimizer.scala:138) > at > org.apache.flink.table.planner.plan.optimize.StreamCommonSubGraphBasedOptimizer.$anonfun$optimizeBlock$1(StreamCommonSubGraphBasedOptimizer.scala:111) > at > org.apache.flink.table.planner.plan.optimize.StreamCommonSubGraphBasedOptimizer.$anonfun$optimizeBlock$1$adapted(StreamCommonSubGraphBasedOptimizer.scala:109) > at > scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:58) > at > scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:51) > at > scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47){code} > You can test the code, please see the attachment -- This message was sent by Atlassian Jira (v8.20.10#820010)