- 08 1月, 2019 19 次提交
-
-
由 Tzu-Li (Gordon) Tai 提交于
-
由 Tzu-Li (Gordon) Tai 提交于
[FLINK-11073] [core] Replace GenericArraySerializerConfigSnapshot with new GenericArraySerializerSnapshot
-
由 Tzu-Li (Gordon) Tai 提交于
-
由 Tzu-Li (Gordon) Tai 提交于
-
由 Tzu-Li (Gordon) Tai 提交于
-
由 Tzu-Li (Gordon) Tai 提交于
-
由 Tzu-Li (Gordon) Tai 提交于
-
由 Tzu-Li (Gordon) Tai 提交于
-
由 Tzu-Li (Gordon) Tai 提交于
-
由 Tzu-Li (Gordon) Tai 提交于
The CompositeTypeSerializerSnapshot encapsulates logic for handling writing, reading, and deriving final compatibility results for composite serializers that have multiple nested serializers as well as some static outer configuration (e.g. type class in the GenericArraySerializer). his base class has its own versioning for the format in which it writes the outer snapshot and the nested serializer snapshots. The version of the serialization format of this based class is defined by getCurrentVersion(). This is independent of the version in which subclasses writes their outer snapshot, defined by getCurrentOuterSnapshotVersion(). This means that the outer snapshot's version can be maintained only taking into account changes in how the outer snapshot is written. Any changes in the base format does not require upticks in the outer snapshot's version
-
由 Tzu-Li (Gordon) Tai 提交于
[FLINK-11280] [state backends, tests] Do not set current key before restore in TtlStateTestBase tests
-
由 Tzu-Li (Gordon) Tai 提交于
-
由 Tzu-Li (Gordon) Tai 提交于
-
由 Tzu-Li (Gordon) Tai 提交于
Prior to this commit, the composite key builder was created in the constructor of the RocksDBKeyedStateBackend. The creation of the builder requires providing a key serializer. This is problematic, because the key serializer may be reconfigured during the restore phase, therefore invalidating the key serializer used by the composite key builder. This commit resolves this by lazily creating the composite key builder only after the restore phase, which would be the point-in-time when we are certain the key serializer will no longer be changed and is final.
-
由 Till Rohrmann 提交于
Revert "[FLINK-10848][YARN] properly remove YARN ContainerRequest upon container allocation success" This reverts commit e26d90fc.
-
由 Dawid Wysakowicz 提交于
Added a validation that checks if no ambiguous columns are defined in MATCH_RECOGNIZE clause. Without the check there is a cryptic message thrown from code generation stack. This closes #7328.
-
由 XuQianJin-Stars 提交于
This closes #7426.
-
由 acqua.csq 提交于
This closes #7370
-
由 Stefan Richter 提交于
[FLINK-11273][state] Fix shared InputView object between event processing and queryable state thread This was introduced with FLINK-9702.
-
- 07 1月, 2019 13 次提交
-
-
由 leesf 提交于
-
由 zhuzhu.zz 提交于
-
由 lamber-ken 提交于
This closes #7361.
-
由 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 7 次提交
-
-
由 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 提交于
-