You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by sj...@apache.org on 2021/05/11 15:43:27 UTC

[flink-statefun] branch master updated (f292544 -> ba67321)

This is an automated email from the ASF dual-hosted git repository.

sjwiesman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git.


    from f292544  [hotfix] Cross link ingress and egress module configuration to io module section
     add ba67321  [hotfix] Add duration to YAML config types

No new revisions were added by this update.

Summary of changes:
 docs/content/docs/deployment/module.md             |  4 +-
 docs/content/docs/io-module/apache-kafka.md        |  4 +-
 .../src/test/resources/remote-module/module.yaml   |  2 +-
 .../statefun/flink/common/json/Selectors.java      | 44 ++++++++++++++++++++++
 .../statefun/flink/common/json/SelectorsTest.java  | 32 ++++++++++++++++
 .../flink/io/kafka/KafkaEgressSpecJsonParser.java  | 17 ++++++++-
 .../src/test/resources/generic-kafka-egress.yaml   |  2 +-
 7 files changed, 97 insertions(+), 8 deletions(-)