flink 1.11 order by rowtime报错

[郑斌斌]

小伙伴们 ：

       大家好，请教个问题，执行order by SQL文时，为什么报下面的错误：

SQL文：select  order_id,product_id FROM kafka_order order by  rowtime

Thanks & Regards

[Evan]

Hi：
你的图挂了，建议直接贴代码，图片大家是看不到的



 
发件人： 郑斌斌
发送时间： 2020-08-18 17:45
收件人： user-zh
主题： flink 1.11 order by rowtime报错
小伙伴们 ：
       大家好，请教个问题，执行order by SQL文时，为什么报下面的错误：
SQL文：select  order_id,product_id FROM kafka_order order by  rowtime

Thanks & Regards

[china_tao]

错误呢？没看到。把代码贴出来看一下，是不是processtime没有设置或者设置不对



--
Sent from: http://apache-flink.147419.n8.nabble.com/

[china_tao]

没有看到错误，把代码贴出来把，是不是eventtime没有设置或者设置不正确



--
Sent from: http://apache-flink.147419.n8.nabble.com/

[china_tao]

贴代码。
看看是不是eventtime没有设置或者设置的不正确

> 在 2020年8月18日，下午5:45，郑斌斌 <[hidden email]> 写道：
>
> 小伙伴们 ：
>        大家好，请教个问题，执行order by SQL文时，为什么报下面的错误：
> SQL文：select  order_id,product_id FROM kafka_order order by  rowtime
>
>
> Thanks & Regards

[郑斌斌]

报下面的这个错误，并行度设置为1就没有问题了，不知道为什么

java.lang.NullPointerExcpetion
  at org.apache.flink.runtime.state.heap.StateTable.put(StateTable.java:336)
  at org.apache.flink.runtime.state.heap.StateTable.put(StateTable.java:159)
  at org.apache.flink.runtime.state.heap.HeapMapState.put(HeapMapState.java:101)

------------------------------------------------------------------
发件人：china_tao <[hidden email]>
发送时间：2020年8月19日(星期三) 00:17
收件人：user-zh <[hidden email]>
主　题：Re: flink 1.11 order by rowtime报错

错误呢？没看到。把代码贴出来看一下，是不是processtime没有设置或者设置不对



--
Sent from: http://apache-flink.147419.n8.nabble.com/

[Benchao Li-2]

Hi 斌斌，

感觉你应该是遇到了一个已知的bug[1]

[1] https://issues.apache.org/jira/browse/FLINK-16827

郑斌斌 <[hidden email]> 于2020年8月19日周三 下午1:20写道：

>
> 报下面的这个错误，并行度设置为1就没有问题了，不知道为什么
>
> java.lang.NullPointerExcpetion
>   at
> org.apache.flink.runtime.state.heap.StateTable.put(StateTable.java:336)
>   at
> org.apache.flink.runtime.state.heap.StateTable.put(StateTable.java:159)
>   at
> org.apache.flink.runtime.state.heap.HeapMapState.put(HeapMapState.java:101)
>
> ------------------------------------------------------------------
> 发件人：china_tao <[hidden email]>
> 发送时间：2020年8月19日(星期三) 00:17
> 收件人：user-zh <[hidden email]>
> 主 题：Re: flink 1.11 order by rowtime报错
>
> 错误呢？没看到。把代码贴出来看一下，是不是processtime没有设置或者设置不对
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>
>

--

Best,
Benchao Li

[郑斌斌]

   非常感谢，按照您给出的jira，我修改源码后好用了。
------------------------------------------------------------------
发件人：Benchao Li <[hidden email]>
发送时间：2020年8月19日(星期三) 19:48
收件人：user-zh <[hidden email]>; 郑斌斌 <[hidden email]>
主　题：Re: flink 1.11 order by rowtime报错

Hi 斌斌，

感觉你应该是遇到了一个已知的bug[1]

[1] https://issues.apache.org/jira/browse/FLINK-16827
郑斌斌 <[hidden email]> 于2020年8月19日周三 下午1:20写道：

 报下面的这个错误，并行度设置为1就没有问题了，不知道为什么

 java.lang.NullPointerExcpetion
   at org.apache.flink.runtime.state.heap.StateTable.put(StateTable.java:336)
   at org.apache.flink.runtime.state.heap.StateTable.put(StateTable.java:159)
   at org.apache.flink.runtime.state.heap.HeapMapState.put(HeapMapState.java:101)

 ------------------------------------------------------------------
 发件人：china_tao <[hidden email]>
 发送时间：2020年8月19日(星期三) 00:17
 收件人：user-zh <[hidden email]>
 主　题：Re: flink 1.11 order by rowtime报错

 错误呢？没看到。把代码贴出来看一下，是不是processtime没有设置或者设置不对



 --
 Sent from: http://apache-flink.147419.n8.nabble.com/



--

Best,
Benchao Li