commit | 653393fcfb9242d0d9169e4b2133de8bf5a08399 | [log] [tgz] |
---|---|---|
author | wangchao <wangchao@apexsoft.com.cn> | Fri Oct 30 11:01:25 2020 +0800 |
committer | Tzu-Li (Gordon) Tai <tzulitai@apache.org> | Wed Nov 04 14:14:21 2020 +0800 |
tree | 8f517b227ed2fe3978d9582548c51eaaef4a031f | |
parent | 243035937454e6dd5ee6e1d52e951efa40d6e09a [diff] |
[FLINK-19866] Move intialization logic to open() instead initializeState This commit moves the initialization logic of the operator to open() instead of initalizeState(). The reason is that starting from Flink 1.10, at intializeState the runtimeContext is not yet properly initialized. This closes #170.