- 17 7月, 2018 9 次提交
-
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Depending on RocksDBOptions#TIMER_SERVICE_IMPL we have to adapt the testCancelFullyAsyncCheckpoints wrt how many checkpointing streams we skip.
-
由 Till Rohrmann 提交于
In order to fully enable the RocksDBOptions#TIMER_SERVICE_IMPL we should use the default value of this config option instead of "".
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Rename from backend.rocksdb.priority_queue_state_type into state.backend.rocksdb.timer-service.impl
-
由 Till Rohrmann 提交于
-
由 Stefan Richter 提交于
Optimization for relaxed bulk polls Deactivate optimization for now because it still contains a bug This closes #6333.
-
由 kkloudas 提交于
-
由 Stephan Ewen 提交于
-
- 16 7月, 2018 22 次提交
-
-
由 Nico Kruber 提交于
This closes #6327.
-
由 zentol 提交于
This closes #6340.
-
由 Deepak Sharnma 提交于
This closes #6289.
-
由 Dawid Wysakowicz 提交于
This closes #6338
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Stephan Ewen 提交于
[FLINK-9314] [security] (part 4) Add mutual authentication for internal Netty and Blob Server connections This closes #6326.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[FLINK-9313] [security] (part 2) Split SSL configuration into internal (rpc, data transport, blob server) and external (REST) This also uses SSLEngineFactory for all SSLEngine creations.
-
由 Stephan Ewen 提交于
This removes hostname verification from SSL client sockets. With client authentication, this is no longer needed and it is not compatible with various container environments.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Timo Walther 提交于
This closes #6332.
-
由 Yun Tang 提交于
This closes #6260
-
由 Bowen Li 提交于
This closes #6109
-
由 Bill Lee 提交于
This closes #5516
-
由 maqingxiang-it 提交于
[FLINK-9404] [file sink] Bucketing sink uses target directory rather than home directory during reflectTruncate This closes #6050
-
- 15 7月, 2018 5 次提交
-
-
由 Timo Walther 提交于
Usually it is very uncommon to define both a batch and streaming source in the same factory. Separating by environment is a concept that can be find throughout the entire flink-table module because both sources and sinks behave quite different per environment. This closes #6323.
-
由 Timo Walther 提交于
The declaration of a table type is SQL Client/context specific and should not be part of a descriptor.
-
由 Timo Walther 提交于
- Rename to TableFactory and move it to org.apache.flink.table.factories package - Unify source/sink/format factories with same logic and exceptions
-
由 Shuyi Chen 提交于
This closes #6201.
-
由 Timo Walther 提交于
This PR introduces a format discovery mechanism based on Java Service Providers. The general `TableFormatFactory` is similar to the existing table source discovery mechanism. However, it allows for arbirary format interfaces that might be introduced in the future. At the moment, a connector can request configured instances of `DeserializationSchema` and `SerializationSchema`. In the future we can add interfaces such as a `Writer` or `KeyedSerializationSchema` without breaking backwards compatibility. This PR deprecates the existing strong coupling of connector and format for the Kafa table sources and table source factories. It introduces descriptor-based alternatives.
-
- 14 7月, 2018 4 次提交
-
-
由 Andrey Zagrebin 提交于
[FLINK-9701] [state] (follow up) Use StateTtlConfiguration.DISABLED instead of null, make it Serializable and add convenience methods to its builder This closes #6331.
-
由 Dawid Wysakowicz 提交于
Added NoOrFixedIfCheckpointingEnabledRestartStrategy This closes #6283.
-
由 sihuazhou 提交于
This closes #6185.
-
由 Till Rohrmann 提交于
Extend the flink-container/docker/build.sh script to also accept a Flink archive to build the image from. This makes it easier to build an image from one of the convenience releases.
-