You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2020/02/21 14:34:15 UTC
[flink-statefun] branch master updated (641c251 -> c308c2e)
This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git.
from 641c251 [FLINK-16002] [testutil] Add stateful functions test utilities
add 3c73285 [hotfix] Update feedback logger configuration to use typed memory sizes
add b7a0788 [FLINK-16149][core] Create stateful functions config object to centrally manage all configurations
add a77aa5d [FLINK-16149][core] Wire StatefulFunctionsConfig through the codebase
add c308c2e [FLINK-16149][docs] Document new configuration options
No new revisions were added by this update.
Summary of changes:
.../docs/api_concepts/stateful_functions.rst | 2 +-
.../docs/deployment_operations/configurations.rst | 36 +---
.../flink/statefun/examples/async/RunnerTest.java | 1 -
.../statefun/examples/harness/RunnerTest.java | 1 -
.../flink/core/StatefulFunctionsConfig.java | 201 +++++++++++++++++++++
.../statefun/flink/core/StatefulFunctionsJob.java | 60 +++---
.../flink/core/StatefulFunctionsJobConstants.java | 26 ---
.../core/StatefulFunctionsUniverseProvider.java | 3 +-
.../flink/core/StatefulFunctionsUniverses.java | 15 +-
.../flink/core/common/ConfigurationUtil.java | 47 -----
.../flink/core/feedback/FeedbackConfiguration.java | 8 +-
.../feedback/FeedbackUnionOperatorFactory.java | 7 +-
.../functions/FunctionGroupDispatchFactory.java | 11 +-
.../core/functions/FunctionGroupOperator.java | 30 +--
.../flink/statefun/flink/core/spi/Modules.java | 13 +-
.../flink/core/translation/FlinkUniverse.java | 12 +-
.../core/translation/IngressRouterOperator.java | 26 +--
.../flink/core/translation/RouterTranslator.java | 8 +-
.../statefun/flink/core/translation/Sources.java | 14 +-
.../flink/core/StatefulFunctionsConfigTest.java | 48 +++++
.../flink/statefun/flink/harness/Harness.java | 53 ++++--
21 files changed, 385 insertions(+), 237 deletions(-)
create mode 100644 statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java
delete mode 100644 statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/common/ConfigurationUtil.java
create mode 100644 statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfigTest.java