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 2235b79 [FLINK-20189] [test] Extend UnboundedFeedbackLoggerTests to
use RandomReadLengthByteArrayInputStream
new 2f7eb5f [FLINK-20265] [core] Add IncompleteInvocationContext to
FromFunction
new 62cf2e4 [FLINK-20265] [core] Allow PersistedRemoteFunctionValues to
register states based on protocol PersistedValueSpecs
new bf021cc [FLINK-20265] [core] Deprecate PersistedRemoteFunctionValues
constructor which supports eager state specs
new c966b29 [hotfix] [core] Refactor state utility methods into
PersistedRemoteFunctionValues
new 3a1584e [FLINK-20265] [core, test] Add UT to cover user contracts of
PersistedRemoteFunctionValues
new d0d999a [hotfix] [core] Remove redundant conditioning in
HttpRequestReplyClient.parseResponse
new df792ac [FLINK-20265] [core] Implement new extended protocol in
RequestReplyFunction
The 7 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:
.../flink/core/httpfn/HttpRequestReplyClient.java | 6 +-
.../reqreply/PersistedRemoteFunctionValues.java | 104 +++++++++++--
.../flink/core/reqreply/RequestReplyFunction.java | 109 ++++++-------
.../src/main/protobuf/http-function.proto | 33 +++-
.../PersistedRemoteFunctionValuesTest.java | 172 +++++++++++++++++++++
.../core/reqreply/RequestReplyFunctionTest.java | 48 ++++++
6 files changed, 397 insertions(+), 75 deletions(-)
create mode 100644
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValuesTest.java
