| commit | 0d85a2c7b8bf6b1e0568d6e7ffcc8bbd0d5562ad | [log] [tgz] |
|---|---|---|
| author | Igal Shilman <igalshilman@gmail.com> | Mon Sep 21 21:00:08 2020 +0200 |
| committer | Tzu-Li (Gordon) Tai <tzulitai@apache.org> | Tue Sep 22 16:13:36 2020 +0800 |
| tree | b540c1d4347e7b26925d6e0ffc49ad43cbe6c76b | |
| parent | c37f4c4c4c230e25de14bad74d26da57117d2975 [diff] |
[FLINK-19330][core] 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 #159.