[FLINK-26537][statefun] Allow disabling StatefulFunctionsConfigValidator validation for classloader.parent-first-patterns.additional

[FLINK-25866][statefun] Support additional TLS configuration

[FLINK-26378][sdk][py] Set caller to None for ingress messages.

This commit makes sure that the caller's address would be None for
messages that are coming from an ingress.

[FLINK-26375][statefun-golang-sdk] Fix Statefun Golang SDK to return nil from Context.Caller when there is no caller

Change handler.go to only populate statefunContext.caller when a caller is present in the invocation
Add unit tests

[FLINK-26340][statefun-golang-sdk] Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying context.Context

Change sync.Mutex in statefunContext to be *sync.Mutex, to make it copyable, and update construction of statefunContext accordingly
Add WithContext to statefun.Context interface and implement on statefunContext
Add unit test

This closes #303

[FLINK-26153] Add update_playground_links.sh to update playground links

This commit adds a new update_playground_links.sh script that updates links to
Statefun's playground in various places.

This closes #302.

[hotfix] Fix typo in update_branch_version.sh

[hotfix] Update README.md links to point to release-3.2 playground version

[hotfix] Let Python README.md point to Statefun playground

[FLINK-25898] Add README.md to statefun-sdk-js

This closes #301.

[FLINK-25933][statefun] Add support for the async HTTP transport in request-reply function builder

Create StatefulFunctionBuilder base class for all function builders
Create AsyncRequestReplyFunctionBuilder to build async functions
Refactor existing RequestReplyFunctionBuilder to extend StatefulFunctionBuilder
Create new factory methods on StatefulFunctionBuilder and deprecate old factory method
Modify SerializableHttpFunctionProvider to properly choose client factory based on HttpFunctionEndpointSpec
Update docs

[hotfix][doc] Typo in link.

link was giving 404

[FLINK-25936][java-sdk] Adjust the ConcurrentAddressScopedStorageTest to reflect the request-reply protocol

According to the request reply protocol, in case of a missing value: a registered state
but without an assosciated value (deleted, expired, or simply never set) the invocation
will contain an associated TypedValue with the field has_value = false, and might or might not
provide the type_name field.
This commit refelects that in the test.

[FLINK-25936][java-sdk] Set value typename correctly in MutableTypeCell.

Before that commit, MutableTypeCell was assuming incorrectly
that the backend will send a TypedValue with a type_name field set even if the
value is missing (TypedValue.has_value = false). This is not the case, and hence
The type_name needs to be set explicitly.

[FLINK-25915][docs] Add Matomo tracking code to base layout

[FLINK-25915][docs] Remove Google Analytics implementation

[hotfix][doc] Remove invalid link in README

This closes #289.

[FLINK-25829] Skip deployment of statefun-sdk-js

This closes #286.

[FLINK-25828] Let build-stateful-functions.sh ignore javadoc and sources jar

This commit lets the build-stateful-functions.sh script ignore javadoc and sources jars that
can make the following copy commands to fail.

This closes #285.

[release] Add 3.2 release docs to docs/config.toml

[release] Update version to 3.3-SNAPSHOT

[FLINK-25775][doc] Add Javascript SDK documentation for NodeJS

[FLINK-25708] Bump Flink dependency to 1.14.3

This closes #283.

[hotfix] Move junit and hamcrest-all test dependency to dependencyManagement

This commit sets the junit and hamcrest-all test dependency version and scope in the
dependencyManagement section of the root pom to unify all dependencies. This has the
purpose to avoid the usage of different testing libraries.

[FLINK-25197] Fix serialization issue in RequestReplyFunctionBuilder

This closes #282.

[hotfix] Add k8s HA to helm chart

This closes #279

[FLINK-25333] Disable auto uid generation and enable restoring from a savepoint with missing operators

[FLINK-25333] Manually set UIDs on router operator

[FLINK-25308] Provide a custom remote module name

This commit adds a new flink-conf configuration key
that allows overriding the default remote module file name (module.yaml)
To provide a different name, for example prod.yaml that is located at /flink/usrlib/prod.yaml
One can add the following to their flink-conf.yaml:

statefun.remote.module-name: /flink/usrlib/prod.yaml

[hotfix][docs] Replace and with an in embedded.md

[hotfix][docs] Add missing be in logical.md documentation

[FLINK-24534] Use the async transport if transport is not specified.

This commit sets the Netty based, asynchronous transport as the default transport
for endpoint definitions that did not specify a particular transport.

This closes #276

[hotfix] Use JDK 8 Optional instead of shaded Optional class from Guava.

This closes #275

[FLINK-22533] Add user defined metrics

This commits adds the ability to define custom metrics in the embedded SDK.

[FLINK-24464][core] Metrics sometimes report negative backlog

This closes #273

[FLINK-24364][e2e] Add message cancellation embedded e2e case

This commit adds a message cancellation test case for the smoke e2e test.
The generation of message cancellation commands is disabled by default, and
only enabled for the embedded sdk e2e tests.

[FLINK-24356][remote] Attach a cancellation token to a delayed message

This commit fixes a bug with the RequestReply function that previously ignored
the cancellation token sent from a remote SDK.

[FLINK-24322][js] Various improvements to the consistency and style

* Improve imports/exports and minor TS improvements
* Use Protobuf types where possible
* Seperate public api to a separate file
* Add jest explicitly

[FLINK-24256][sdk] Add a JavaScript SDK

[FLINK-23985] Add document for adding new language SDK Smoke E2E

[hotfix][docs] fix documentation build

[hotfix][docs] drop unused io overview

[FLINK-24109] Correct egress string serialization

This closes #265

[FLINK-24110] Filter null ComponentJsonObjects

This closes #266

[FLINK-24132] Remove directory-maven-plugin

The only usage of that plugin is at statefun-e2e-tests/pom.xml
and to only invoke two shell script. We can simply use a relative path
Since the shell scripts resolve their basedir anyways.

[FLINK-23964] Use shaded tcnative in dev docker image

[hotfix] link to golang sdk from homepage

[hotfix][docs] remove trailing seperator

[FLINK-23600] [docs] Restructure module configuration docs

This closes #263

[hotfix] Add Java 11 profile to make StateFun work in IDEs (IntelliJ) that use JDK 11+

[hotfix][build] Add version for build helper plugin in statefun-protobuf-shaded

This commit pins the version to what was effectively used by the build process.

[hotfix] document go mod requirement

This closes #260.

[FLINK-23927] Fix go.mod file for SDK release

[hotfix] Add v1 to OkHttp transport's typename

[release] Update version to 3.2-SNAPSHOT

[FLINK-23853] Update Flink dependency to v1.13.2

This closes #258.

[FLINK-23878][go] make cell Write resumable

This closes #259

[hotfix][go] harden NewCell creation checks

[hotfix] add smoke test checkpoint directories to .gitignore

[hotfix] fix typo in log statement

[FLINK-18810][sdk] Document Golang SDK

This closes #250

[FLINK-18810][sdk] Golang remote functions smoke test

[FLINK-18810][sdk] Golang remote functions SDK

[FLINK-22752] More robust state configurations in base flink-conf.yaml

This closes #257.

[hotfix] [e2e, build] Move driver module copying to prepare-package phase

This was causing the doc builds to fail with "Artifact has not been
packaged yet. When used on reactor artifact, copy should be executed
after packaging: see MDEP-187.

According to MDEP-187, moving the copy to prepare-package solves the
issue.

[FLINK-23711] Enable async transport for the remote java-sdk e2e smoke test.

This closes #252.

[FLINK-23711] Add an asynchronous HTTP transport

This commits adds a new transport based on a shaded version of Netty.
This transport is currently opt-in, and can be enabled by adding to
the endpoint definition:
...
transport:
  type: io.statefun.transports.v1/async

[FLINK-20574] [core] Block first request to mitigate excessive IncompleteInvocationContext roundtrips

For the first request, we block until response is received; for stateful
applications, especially at restore time of a restored execution where
there may be a large backlog of events and checkpointed inflight
requests, this helps mitigate excessive hoards of
IncompleteInvocationContext responses and retry attempt round-trips.

This closes #256.

[FLINK-23709] Remove SanityVerificationE2E and ExactlyOnceRemoteE2E

This closes #249.

[FLINK-23718] [build, sdk] Manage Python SDK as a Maven module

This closes #255.

[FLINK-23717] Allow setting configs using plain strings in StatefulFunctionsAppContainers

This closes #254.

[FLINK-23714] Expose both master and worker logs of StatefulFunctionsAppContainers

[FLINK-23712] Improve Protobuf serialization performance

Profiling allocations shows that around 25% of the allocations happens
while parsing Protobuf, this happens because
the CodedInputStream/CodedOutputStream allocate a 4kb buffer on construction.
This can be easily avoided by caching and reusing them.

This closes #251.

[hotfix] Incorrect toString() message in SmokeRunnerParameters

[hotfix] Add configuration for reproducible smoke tests

This closes #253.

[hotfix] [e2e] Simplify target function id creation in Java smoke E2E

[hotfix] [e2e] Pull smoke E2E test utilities and Commands into a common module

[hotfix] Let only *ITCase tests be picked up by surefire

[hotfix] Recreate shared OkHttpClient after shutdown in DefaultHttpRequestReplyClientFactory

[FLINK-23600] Rework remote module component parsing and binding

This closes #247.

[FLINK-23672] Add smoke-e2e-java for Java SDK smoke test

This closes #248.

[FLINK-23547][build] run integration tests on install

This closes #246

[hotfix][docs] fix typos in documentation

[docs] Change base urls to https://nightlies.apache.org

[FLINK-23296] [core] Introduce RequestReplyClientFactory extension

* Rename default HTTP request-reply client
* Implement default HTTP client factory
* Wire in RequestReplyClientFactory into HttpFunctionEndpointProvider
* Pass in ExtensionResolver when binding JsonEntities
* Bump YAML format version
* Implement v3.1 YAML format with transport spec parsing
* Implement context-safe decorator for RequestReplyClient
* Ensure correct classloader when using tranport clients and factories
* Move Classloader handling responsibility to factory implementations
* Add TransportClientsModule

This closes #243.

[FLINK-22771][java-sdk] Add testing utilities

* add hashCode/equals to EgressMessageWrapper/MessageWrapper
* add TestContext to Java SDK
* add documentation for Java SDK TestContext
* address review comments
* Fix various code style warnings
* Refactor Envelopes -> SideEffects
* ValueSpec needs to be identified by name, as it does not support equality.
* Support message cancellation

This closes #236.

[FLINK-23126] Refactor smoke-e2e into smoke-e2e-common and smoke-e2e-embedded

This closes #242.

[FLINK-21308][core] Support delayed message cancellation

This closes #241.

[hotfix] Correct endpoint definition in docs

This closes #240.

[FLINK-22529][kinesis] Allow Flink's ConsumerConfigConstants and flexibility in providing AWS region and credentials

This closes #237.

[FLINK-20336] [core] Do not silently pass UNRECOGNIZED state mutations

This closes #235.

[FLINK-22468] Add dependency to javax.annotations

This enables building StateFun with Java 11, since javax.annotations was
removed with JDK 11.

This closes #230.

[FLINK-22242][python] Improve missing attribute error on GeneratedAddressedScopedStorage

This closes #223

[FLINK-22552] Update Flink dependency to 1.13.0

This closes #234.

[hotfix] Add duration to YAML config types

[hotfix] Cross link ingress and egress module configuration to io module section

[hotfix][docs] fix invalid module configuration

This closes #232

[hotfix][docs] Fix typos in concepts

This closes #229.

[hotfix][docs] Fix typos in apache-kafka.md and aws-kinesis.md

[hotfix] Add missing configuration to documentation