- 07 1月, 2019 10 次提交
-
-
由 blueszheng 提交于
This closes #7401.
-
由 Tzu-Li (Gordon) Tai 提交于
[hotfix] Rename keySerializerConfigSnapshot to keySerializerSnapshot in KeyedBackendSerializationProxy Remove "config" from the field names and getter name to reflect the new abstraction TypeSerializerSnapshot.
-
由 Tzu-Li (Gordon) Tai 提交于
This commit adapts the StateSerializerProvider to respect the COMPATIBLE_WITH_RECONFIGURED_SERIALIZER case, which effectively lets all state backends respect serializer reconfiguration because state serializers are always obtained via StateSerializerProviders. It also makes StateSerializerProvider work for both eagerly / lazily registered serializers. This is required so that the StateSerializerProvider can be used for the key serializer in AbstractKeyedStateBackend. For the key serializer, regardless of whether or not we're restoring old state, we always first get the new key serializer, and then maybe get the previous key serializer's snapshot in the restore phase. Therefore, after this commit, access the key serializer in AbstractKeyedStateBackend is also governed by a StateSerializerProvider. For a more fine-grained explaination of all the changes that build up to this, please refer to #7329. This closes #7329.
-
由 Tzu-Li (Gordon) Tai 提交于
[FLINK-11073] [core] Add COMPATIBLE_WITH_RECONFIGURED_SERIALIZER to TypeSerializerSchemaCompatibility
-
由 Tzu-Li Chen 提交于
-
由 Fokko Driesprong 提交于
-
由 Stefan Richter 提交于
This closes #7288. Co-authored-by: NStefan Richter <s.richter@data-artisans.com> Co-authored-by: Nklion26 <qcx978132955@gmail.com>
-
由 Stefan Richter 提交于
-
由 Stefan Richter 提交于
-
由 xueyu 提交于
This closes #7079.
-
- 05 1月, 2019 1 次提交
-
-
由 Shuyi Chen 提交于
This closes #7078
-
- 04 1月, 2019 24 次提交
-
-
由 Timo Walther 提交于
-
由 hequn8128 提交于
This closes #7271.
-
由 Timo Walther 提交于
-
由 wenhuitang 提交于
[FLINK-11173][table] Fix the exception message of proctime attribute validation in TableSourceUtil#validateTableSource This closes #7374.
-
由 Xingcan Cui 提交于
This closes #7373.
-
由 wenhuitang 提交于
This closes #7379.
-
由 Yangze Guo 提交于
-
由 EronWright 提交于
This closes #7388.
-
由 zentol 提交于
-
由 zentol 提交于
-
由 EronWright 提交于
- fix the logic in supportsBatch to properly declare a batch-only table - adjust CommonTestData to provide batch-only or streaming-only tables This closes #7386.
-
由 Matt 提交于
-
由 Chesnay Schepler 提交于
-
由 zentol 提交于
-
由 zentol 提交于
-
由 Chesnay Schepler 提交于
-
由 zentol 提交于
-
由 zentol 提交于
+es5
-
由 zentol 提交于
+es2
-
由 zentol 提交于
-
由 zentol 提交于
-
由 zentol 提交于
-
由 zentol 提交于
-
由 zentol 提交于
-
- 03 1月, 2019 1 次提交
-
-
由 hequn8128 提交于
This colses #7316
-
- 02 1月, 2019 4 次提交
-
-
由 lamber-ken 提交于
-
由 hequn8128 提交于
-
由 Hequn Cheng 提交于
[FLINK-10781][fs] Update BucketingSinkMigrationTest for Flink 1.7
-
由 hequn8128 提交于
-