- 09 1月, 2019 10 次提交
-
-
由 Dawid Wysakowicz 提交于
-
由 Dawid Wysakowicz 提交于
-
由 Dawid Wysakowicz 提交于
-
由 Dawid Wysakowicz 提交于
return null
-
由 Tony Wei 提交于
-
由 Bo WANG 提交于
-
由 ZILI CHEN 提交于
-
由 Till Rohrmann 提交于
-
由 Tzu-Li Chen 提交于
[FLINK-10555] tests are all of BlobServer initialization, also remove already covered tests This closes #6849.
-
由 Tzu-Li (Gordon) Tai 提交于
After introducing CompositeTypeSerializerSnapshot, the CompositeSerializerSnapshot has been reworked to only deal with concerns of delegating reading and writing of the nested serializers' snapshots. It no longer deals with resolving the final compatibility result for the outer composite serializer. Therefore, it is renamed properly as NestedSerializersSnapshotDelegate, and also annotated as an internal class, since we want users to use the more powerful CompositeTypeSerializerSnapshot instead. This closes #7422.
-
- 08 1月, 2019 20 次提交
-
-
由 Tzu-Li (Gordon) Tai 提交于
[hotfix] [core] Assert current serializer snapshot is expected snapshot class in TypeSerializerSnapshotMigrationTestBase This strengthens the test base to make use of the provided snapshot class in the test specifications, to assert that serializers are really using the expected classes for their current serializer snapshots.
-
由 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 10 次提交
-
-
由 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>
-