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 2020/05/20 19:33:13 UTC
[flink-statefun] branch master updated (dc92984 -> c04f111)
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 dc92984 [FLINK-17644] Add Expiration to the Persisted states
new 9bf1414 [hotfix] Add @ForRuntime annotation to Expiration constructor
new c04f111 [FLINK-16985][docker] Set default Flink Job name"
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../src/main/java/org/apache/flink/statefun/sdk/state/Expiration.java | 3 +++
tools/docker/flink-distribution-template/conf/flink-conf.yaml | 2 ++
2 files changed, 5 insertions(+)
[flink-statefun] 01/02: [hotfix] Add @ForRuntime annotation to
Expiration constructor
Posted by sj...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
sjwiesman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 9bf141494c605f7ff2103a9edc7adb8d76a968ae
Author: Seth Wiesman <sj...@gmail.com>
AuthorDate: Mon May 18 19:20:37 2020 -0500
[hotfix] Add @ForRuntime annotation to Expiration constructor
---
.../src/main/java/org/apache/flink/statefun/sdk/state/Expiration.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/Expiration.java b/statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/Expiration.java
index d7e5399..7ed9ba0 100644
--- a/statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/Expiration.java
+++ b/statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/Expiration.java
@@ -18,6 +18,8 @@
package org.apache.flink.statefun.sdk.state;
+import org.apache.flink.statefun.sdk.annotations.ForRuntime;
+
import java.time.Duration;
import java.util.Objects;
@@ -68,6 +70,7 @@ public final class Expiration {
private final Mode mode;
private final Duration duration;
+ @ForRuntime
public Expiration(Mode mode, Duration duration) {
this.mode = Objects.requireNonNull(mode);
this.duration = Objects.requireNonNull(duration);
[flink-statefun] 02/02: [FLINK-16985][docker] Set default Flink Job
name"
Posted by sj...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
sjwiesman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit c04f111e6937a10f960080f161f05e63cef3272e
Author: abc863377 <ab...@yahoo.com.tw>
AuthorDate: Thu May 21 02:41:28 2020 +0800
[FLINK-16985][docker] Set default Flink Job name"
This closes #106
---
tools/docker/flink-distribution-template/conf/flink-conf.yaml | 2 ++
1 file changed, 2 insertions(+)
diff --git a/tools/docker/flink-distribution-template/conf/flink-conf.yaml b/tools/docker/flink-distribution-template/conf/flink-conf.yaml
index 430c4cb..9fb1c69 100644
--- a/tools/docker/flink-distribution-template/conf/flink-conf.yaml
+++ b/tools/docker/flink-distribution-template/conf/flink-conf.yaml
@@ -29,3 +29,5 @@ state.backend.rocksdb.timer-service.factory: ROCKSDB
state.checkpoints.dir: file:///checkpoint-dir
state.backend.incremental: true
taskmanager.memory.process.size: 4g
+
+statefun.flink-job-name: Statefun Application