Hello Fil,
I think that adding a very simple interpolation mechanism for remote
functions can be useful.
And also your suggested place should be good.
Can you create a JIRA issue with this description, and there we can
continue the conversation and scope this?
Thanks!
Igal.
On Mon, Mar 7, 2022
Igal Shilman created FLINK-26378:
Summary: caller's address isn't set to None properly when a
message is coming from an ingress
Key: FLINK-26378
URL: https://issues.apache.org/jira/browse/FLINK-26378
Hi Galen,
I think that you are right this does seem like a bug, looking at the Java
SDK, we replace an empty address with a null value.[1]
We should do the same here.
I've also checked the Python SDK[2], and the JS SDK[3] and they have the
same problem.
Looking forward to your contribution!
Igal Shilman created FLINK-25936:
Summary: MutableTypeCell is not setting correctly the value's
type_name
Key: FLINK-25936
URL: https://issues.apache.org/jira/browse/FLINK-25936
Project: Flink
I could post something to the
> dev list if you want.
>
> On Wed, Feb 2, 2022 at 2:39 PM Igal Shilman wrote:
>
> > Hi Galen,
> > You are right, it is not possible, but there is no real reason for that.
> > We should fix this, and I've created the following JIRA iss
Igal Shilman created FLINK-25935:
Summary: Add a harness based entry point to simply getting started.
Key: FLINK-25935
URL: https://issues.apache.org/jira/browse/FLINK-25935
Project: Flink
Igal Shilman created FLINK-25934:
Summary: Modernize statefun playground examples
Key: FLINK-25934
URL: https://issues.apache.org/jira/browse/FLINK-25934
Project: Flink
Issue Type
Hi Galen,
You are right, it is not possible, but there is no real reason for that.
We should fix this, and I've created the following JIRA issue [1]
[1] https://issues.apache.org/jira/browse/FLINK-25933
On Wed, Feb 2, 2022 at 6:30 PM Galen Warren wrote:
> Is it possible to choose the async
Igal Shilman created FLINK-25933:
Summary: Allow configuring different transports in
RequestReplyFunctionBuilder
Key: FLINK-25933
URL: https://issues.apache.org/jira/browse/FLINK-25933
Project: Flink
Igal Shilman created FLINK-25866:
Summary: Support additional TLS configuration.
Key: FLINK-25866
URL: https://issues.apache.org/jira/browse/FLINK-25866
Project: Flink
Issue Type
+1 (binding)
- verified checksum and signatures
- build from source code
- run e2e tests
- verified that there are no binary artifacts in the source release
- built the python sdk from sources, and run the python greeter example
- built from source the js sdk and run the javascript greeter
+1 and thanks for volunteering to be the release manager!
Cheers,
Igal.
On Mon, Jan 24, 2022 at 4:13 PM Seth Wiesman wrote:
> +1
>
> These are already a useful set of features to release to our users.
>
> Seth
>
> On Mon, Jan 24, 2022 at 8:45 AM Till Rohrmann
> wrote:
>
> > Hi everyone,
> >
>
+1 for publishing to npm in addition to an official source release, would
be very beneficial.
Looking at other Apache projects that produce js artifacts[1] , it seems
like they also publish to npm.
[1]
https://github.com/orgs/apache/repositories?q==all=javascript=
Cheers,
Igal.
On Mon, Jan 24,
Igal Shilman created FLINK-25752:
Summary: Create a migration e2e test
Key: FLINK-25752
URL: https://issues.apache.org/jira/browse/FLINK-25752
Project: Flink
Issue Type: Improvement
The Apache Flink community is very happy to announce the release of Apache
Flink Stateful Functions (StateFun) 3.1.1.
This is a bugfix release that addresses the recent log4j vulnerabilities,
users are encouraged to upgrade.
StateFun is a cross-platform stack for building Stateful Serverless
I'm happy to announce that we have unanimously approved this release.
There are 4 approving votes, 3 of which are binding:
* Seth Wiesman (non-binding)
* Tzu-Li (Gordon) Tai (binding)
* Till Rohrmann (binding)
* Igal Shilman (binding)
There are no disapproving votes.
Thanks everyone!
> > Thanks,
> > Gordon
> >
> > On Mon, Dec 20, 2021, 13:55 Seth Wiesman wrote:
> >
> > > +1 (non-binding)
> > >
> > > - Verified signatures
> > > - Checked diff
> > > - Checked site PR
> > > - Build from source a
Hi everyone,
Please review and vote on the release candidate #2 for the version 3.1.1 of
Apache Flink Stateful Functions, as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
This release updates the Flink version to fix the log4j CVEs
Igal Shilman created FLINK-25367:
Summary: Upgrade Flink dependency to 1.13.5
Key: FLINK-25367
URL: https://issues.apache.org/jira/browse/FLINK-25367
Project: Flink
Issue Type: Improvement
Igal Shilman created FLINK-25355:
Summary: Upgrade Flink dependency to 1.13.3
Key: FLINK-25355
URL: https://issues.apache.org/jira/browse/FLINK-25355
Project: Flink
Issue Type: Improvement
Hi All,
Following the recent Apache Flink releases due to the log4j vulnerability,
I'd like to propose an immediate StateFun release - 3.1.1.
This release is basically the same as 3.1 but updates the Flink dependency
to 1.13.3.
Please raise your concerns if any, otherwise we'll proceed with the
Igal Shilman created FLINK-25309:
Summary: Upgrade to the latest Flink version
Key: FLINK-25309
URL: https://issues.apache.org/jira/browse/FLINK-25309
Project: Flink
Issue Type: Improvement
Igal Shilman created FLINK-25308:
Summary: Support different remote functions module names
Key: FLINK-25308
URL: https://issues.apache.org/jira/browse/FLINK-25308
Project: Flink
Issue Type
Igal Shilman created FLINK-24534:
Summary: Set async based transport for remote functions default
Key: FLINK-24534
URL: https://issues.apache.org/jira/browse/FLINK-24534
Project: Flink
Igal Shilman created FLINK-24364:
Summary: Add a delayed message cancellation to the embedded smoke
test
Key: FLINK-24364
URL: https://issues.apache.org/jira/browse/FLINK-24364
Project: Flink
Igal Shilman created FLINK-24322:
Summary: Improve TypeScript support for the JS SDK
Key: FLINK-24322
URL: https://issues.apache.org/jira/browse/FLINK-24322
Project: Flink
Issue Type
Igal Shilman created FLINK-24284:
Summary: Add a greeter and a showcase for the JavaScript SDK
Key: FLINK-24284
URL: https://issues.apache.org/jira/browse/FLINK-24284
Project: Flink
Issue
Hi Evans,
Welcome aboard :) I'll definitely keep that in mind!
Meanwhile I would also like to point out that Statefun is built using
Apache Flink, and any improvement in Flink, directly contributes to
StateFun,
so I would definitely encourage you to consider contributing to Flink
as-well, I'm
Igal Shilman created FLINK-24256:
Summary: Add JavaScript SDK for Stateful Functions
Key: FLINK-24256
URL: https://issues.apache.org/jira/browse/FLINK-24256
Project: Flink
Issue Type
Igal Shilman created FLINK-24132:
Summary: directory-maven-plugin fails on Github action
Key: FLINK-24132
URL: https://issues.apache.org/jira/browse/FLINK-24132
Project: Flink
Issue Type
Igal Shilman created FLINK-24107:
Summary: StateFun doesn't open correctly in intellij when started
with JDK11
Key: FLINK-24107
URL: https://issues.apache.org/jira/browse/FLINK-24107
Project: Flink
The Apache Flink community is very happy to announce the release of Apache
Flink Stateful Functions (StateFun) 3.1.0.
StateFun is a cross-platform stack for building Stateful Serverless
applications, making it radically simpler to develop scalable, consistent,
and elastic distributed
Thank you all for testing this RC and casting your votes! The vote has
passed successfully.
Total 5 +1 votes, and 3 of them are binding:
- Igal Shilman
- Seth Wiesman
- Gordon (Tzu-Li Tai)
- Arvid Heise
- Stephan Ewen
I will announce the release in a separate thread, once all the artifacts
, and async transport enabled.
- verified that the docker image [2] builds and inspected the contents
manually.
Thanks,
Igal
[1] https://github.com/apache/flink-statefun-playground/tree/dev
[2] https://github.com/apache/flink-statefun-docker/pull/15
On Tue, Aug 24, 2021 at 3:34 PM Igal Shilman wrote
Igal Shilman created FLINK-23966:
Summary: Don't try to add swifts filesystem plugins in the
Dockerfile
Key: FLINK-23966
URL: https://issues.apache.org/jira/browse/FLINK-23966
Project: Flink
Igal Shilman created FLINK-23964:
Summary: Add Shaded Netty TCnative to lib/ in the docker image
Key: FLINK-23964
URL: https://issues.apache.org/jira/browse/FLINK-23964
Project: Flink
Issue
Sorry, the subject of the previous message should have said "[VOTE] Apache
Flink Stateful Functions 3.1.0, release candidate #2".
On Tue, Aug 24, 2021 at 3:24 PM Igal Shilman wrote:
> Hi everyone,
>
> Please review and vote on the release candidate #2 for the version 3.1.
Hi everyone,
Please review and vote on the release candidate #2 for the version 3.1.0 of
Apache Flink Stateful Functions, as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
**Testing Guideline**
You can find here [1] a page in the
h the release.
>
> [1] https://github.com/apache/flink-statefun/pull/260
>
> On Mon, Aug 23, 2021 at 10:38 AM Igal Shilman wrote:
>
> > Hi everyone,
> >
> > Please review and vote on the release candidate #1 for the version 3.1.0
> of
> > Apache Flink
Hi everyone,
Please review and vote on the release candidate #1 for the version 3.1.0 of
Apache Flink Stateful Functions, as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
**Testing Guideline**
You can find here [1] a page in the
Hi everyone!
We would like to kick off a new StateFun release (3.1.0), this release will
have some major features that users would benefit from, such as:
* [FLINK-21308] Support delayed message cancellation.
* [FLINK-23296] Support pluggable transports for remote functions
invocation.
*
Igal Shilman created FLINK-23712:
Summary: Improve Protobuf serialization performance
Key: FLINK-23712
URL: https://issues.apache.org/jira/browse/FLINK-23712
Project: Flink
Issue Type
Igal Shilman created FLINK-23711:
Summary: Add an asynchronous HTTP transport for the RequestReply
function
Key: FLINK-23711
URL: https://issues.apache.org/jira/browse/FLINK-23711
Project: Flink
Hi Tom!
I'm very happy to see this! and would be very happy to help out!
We can continue to conversation over here, and in addition we can setup a
call,
Where we can go over some of your questions.
Regarding the specific question about the "incomplete context”.
You are absolutely right, the
Congratulations Arvid!
Super well deserved!
On Thu, Jun 24, 2021 at 11:33 AM 刘建刚 wrote:
> Congratulations
>
> Best
> liujiangang
>
> Matthias Pohl 于2021年6月23日周三 下午2:11写道：
>
> > Congratulations, Arvid! :-)
> >
> > On Thu, Jun 17, 2021 at 9:02 AM Arvid Heise wrote:
> >
> > > Thank you for your
Igal Shilman created FLINK-23039:
Summary: Support pluggable transports for HTTP endpoints
Key: FLINK-23039
URL: https://issues.apache.org/jira/browse/FLINK-23039
Project: Flink
Issue Type
Igal Shilman created FLINK-22809:
Summary: Improve the exception message when a KafkaIngress
receives a NULL key.
Key: FLINK-22809
URL: https://issues.apache.org/jira/browse/FLINK-22809
Project
these timeouts [1]
[1]
https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.0/docs/deployment/module/#timeouts
On Fri, May 21, 2021 at 10:53 AM Igal Shilman wrote:
> Hi Jan,
>
> I haven't stumbled upon this but I will try to reconstruct that scenario
> with a stress test and
Hi Jan,
I haven't stumbled upon this but I will try to reconstruct that scenario
with a stress test and report back.
Can you share a little bit about your environment. For example do you use
gunicorn, ngnix, aiohttp/or flask perhaps?
I'd suggest maybe checking for request size limits parameters
Igal Shilman created FLINK-22633:
Summary: Add a Harness example to flink-statefun-playground
Key: FLINK-22633
URL: https://issues.apache.org/jira/browse/FLINK-22633
Project: Flink
Issue
Igal Shilman created FLINK-22584:
Summary: Use protobuf-shaded in StateFun core.
Key: FLINK-22584
URL: https://issues.apache.org/jira/browse/FLINK-22584
Project: Flink
Issue Type
Igal Shilman created FLINK-22552:
Summary: Rebase StateFun on Flink 1.13
Key: FLINK-22552
URL: https://issues.apache.org/jira/browse/FLINK-22552
Project: Flink
Issue Type: Improvement
Igal Shilman created FLINK-22533:
Summary: Allow creating custom metrics
Key: FLINK-22533
URL: https://issues.apache.org/jira/browse/FLINK-22533
Project: Flink
Issue Type: Improvement
Igal Shilman created FLINK-22532:
Summary: Improve the support for remote functions in the
DataStream integration
Key: FLINK-22532
URL: https://issues.apache.org/jira/browse/FLINK-22532
Project
Igal Shilman created FLINK-22531:
Summary: Improve the support for finite streaming jobs with async
operations.
Key: FLINK-22531
URL: https://issues.apache.org/jira/browse/FLINK-22531
Project: Flink
Igal Shilman created FLINK-22185:
Summary: Add k8s example to flink-statefun-playground
Key: FLINK-22185
URL: https://issues.apache.org/jira/browse/FLINK-22185
Project: Flink
Issue Type
Thanks Gordon for managing the release!
+1 (non binding) from my side:
Here are the results of my testing:
- verified the signatures
- verified that the source distribution doesn't contain any binary files
- ran mvn clean install -Prun-e2e-tests with java8
- ran the smoke test that sends 100
Igal Shilman created FLINK-21961:
Summary: Add JSON StateFun type to the Python SDK
Key: FLINK-21961
URL: https://issues.apache.org/jira/browse/FLINK-21961
Project: Flink
Issue Type: Task
Igal Shilman created FLINK-21960:
Summary: Simplify module.yaml spec
Key: FLINK-21960
URL: https://issues.apache.org/jira/browse/FLINK-21960
Project: Flink
Issue Type: Task
Igal Shilman created FLINK-21959:
Summary: Rename Kafka/Kinesis ingress/egress types.
Key: FLINK-21959
URL: https://issues.apache.org/jira/browse/FLINK-21959
Project: Flink
Issue Type: Task
Igal Shilman created FLINK-21958:
Summary: Rename statefun-sdk to statefun-sdk-embedded
Key: FLINK-21958
URL: https://issues.apache.org/jira/browse/FLINK-21958
Project: Flink
Issue Type
Igal Shilman created FLINK-21957:
Summary: Rename statefun-python-sdk => statefun-sdk-python
Key: FLINK-21957
URL: https://issues.apache.org/jira/browse/FLINK-21957
Project: Flink
Issue T
Igal Shilman created FLINK-21956:
Summary: NPE in Kafka ingress when the key is missing
Key: FLINK-21956
URL: https://issues.apache.org/jira/browse/FLINK-21956
Project: Flink
Issue Type
Igal Shilman created FLINK-21955:
Summary: Remove the old examples
Key: FLINK-21955
URL: https://issues.apache.org/jira/browse/FLINK-21955
Project: Flink
Issue Type: Task
Igal Shilman created FLINK-21932:
Summary: Add a Python SDK showcase to the playground
Key: FLINK-21932
URL: https://issues.apache.org/jira/browse/FLINK-21932
Project: Flink
Issue Type: Task
Igal Shilman created FLINK-21882:
Summary: Create a Python based greeter example
Key: FLINK-21882
URL: https://issues.apache.org/jira/browse/FLINK-21882
Project: Flink
Issue Type: Task
Igal Shilman created FLINK-21828:
Summary: Add an AWS-λ example to stateful-playground
Key: FLINK-21828
URL: https://issues.apache.org/jira/browse/FLINK-21828
Project: Flink
Issue Type: Task
Igal Shilman created FLINK-21827:
Summary: Migrate the Python examples to the new SDK
Key: FLINK-21827
URL: https://issues.apache.org/jira/browse/FLINK-21827
Project: Flink
Issue Type: Task
Igal Shilman created FLINK-21826:
Summary: Migrate the shopping-cart-example to the new SDK.
Key: FLINK-21826
URL: https://issues.apache.org/jira/browse/FLINK-21826
Project: Flink
Issue Type
Igal Shilman created FLINK-21824:
Summary: Add a simple Json Kafka producer script
Key: FLINK-21824
URL: https://issues.apache.org/jira/browse/FLINK-21824
Project: Flink
Issue Type: Task
Igal Shilman created FLINK-21721:
Summary: Add a generic egress message builder to the SDK
Key: FLINK-21721
URL: https://issues.apache.org/jira/browse/FLINK-21721
Project: Flink
Issue Type
Igal Shilman created FLINK-21692:
Summary: Update the Python SDK to reflect the latest changes in
the request-reply protocol
Key: FLINK-21692
URL: https://issues.apache.org/jira/browse/FLINK-21692
Igal Shilman created FLINK-21642:
Summary: RequestReplyFunction recovery fails with a remote SDK
Key: FLINK-21642
URL: https://issues.apache.org/jira/browse/FLINK-21642
Project: Flink
Issue
Hi Roman,
Regarding StateFun having a separate mailing list, I'm ok with it going
either-way, however when we first contributed
the project there was already a discussion about having a separate mailing
list for StateFun [1] and the feedback was
having StateFun be part of the regular mailing
Igal Shilman created FLINK-21483:
Summary: Disable the spot bugs plugin.
Key: FLINK-21483
URL: https://issues.apache.org/jira/browse/FLINK-21483
Project: Flink
Issue Type: Task
Igal Shilman created FLINK-21457:
Summary: Add support to differentiate a zero length value bytes
and non existing value.
Key: FLINK-21457
URL: https://issues.apache.org/jira/browse/FLINK-21457
Welcome Roman!
Top-notch stuff! :)
All the best,
Igal.
On Wed, Feb 10, 2021 at 2:15 PM Kostas Kloudas wrote:
> Congrats Roman!
>
> Kostas
>
> On Wed, Feb 10, 2021 at 2:08 PM Arvid Heise wrote:
> >
> > Congrats! Well deserved.
> >
> > On Wed, Feb 10, 2021 at 1:54 PM Yun Gao
> > wrote:
> >
> >
Igal Shilman created FLINK-21280:
Summary: Investigate a way to disable object reuse in StateFun
Key: FLINK-21280
URL: https://issues.apache.org/jira/browse/FLINK-21280
Project: Flink
Issue
Igal Shilman created FLINK-21243:
Summary: Add Java SDK maven module
Key: FLINK-21243
URL: https://issues.apache.org/jira/browse/FLINK-21243
Project: Flink
Issue Type: Task
Igal Shilman created FLINK-21230:
Summary: Add protobuf wrapper types for the StateFun SDK types.
Key: FLINK-21230
URL: https://issues.apache.org/jira/browse/FLINK-21230
Project: Flink
Issue
Igal Shilman created FLINK-21154:
Summary: Move the shared request-reply protobuf files to a
separate artifact.
Key: FLINK-21154
URL: https://issues.apache.org/jira/browse/FLINK-21154
Project: Flink
Thanks for driving the release Gordon!
here is a +1 (non binding) from my side:
- verified checksums, signatures etc’.
- verified that there are no binary files in the source distribution.
- built successfully with jdk11
- built successfully with jdk8
- e2e passes with jdk11
- e2e passes
Igal Shilman created FLINK-20699:
Summary: Feedback invocation_id must not be constant.
Key: FLINK-20699
URL: https://issues.apache.org/jira/browse/FLINK-20699
Project: Flink
Issue Type
+1 it works really well in StateFun for quite some time.
On Thursday, December 17, 2020, Wei Zhong wrote:
> +1 for the coding style automation. Thanks for driving this!
>
> Best,
> Wei
>
> > 在 2020年12月17日，10:10，Xingbo Huang 写道：
> >
> > +1 asap. Spotless can greatly help us save the time of
Igal Shilman created FLINK-20303:
Summary: Add a SmokeE2E test
Key: FLINK-20303
URL: https://issues.apache.org/jira/browse/FLINK-20303
Project: Flink
Issue Type: Improvement
+1 (non binding)
Legal:
- Checked signatures
- Checked that no binaries were included in source artifacts
Build
- Built source `mvn clean install -Prun-e2e-tests` with jdk8
- Built source mvn clean install -Prun-e2e-tests' with jdk11
- Built the python SDK
- Built the Docker Image
Functional:
-
Igal Shilman created FLINK-19975:
Summary: Bump testconatiners version
Key: FLINK-19975
URL: https://issues.apache.org/jira/browse/FLINK-19975
Project: Flink
Issue Type: Improvement
Hi Gordon,
Thanks for driving this discussion!
I would go with the second suggestion - having two consecutive StateFun
releases 2.2.1 and 2.2.2, since the Flink-1.11.3 release
might take a while, and this hot-fix release is important enough to get out
as early as possible.
Cheers,
Igal.
On
Igal Shilman created FLINK-19840:
Summary: Add a rocksdb and heap timers configuration validation
Key: FLINK-19840
URL: https://issues.apache.org/jira/browse/FLINK-19840
Project: Flink
Issue
Igal Shilman created FLINK-19827:
Summary: Allow the harness to start a MiniCluster with a user
provided Flink configuration
Key: FLINK-19827
URL: https://issues.apache.org/jira/browse/FLINK-19827
Igal Shilman created FLINK-19826:
Summary: StateFun Dockerfile copies plugins with a specific
version instead of a wildcard
Key: FLINK-19826
URL: https://issues.apache.org/jira/browse/FLINK-19826
Igal Shilman created FLINK-19451:
Summary: Add HELM chart distribution to StateFun release process
Key: FLINK-19451
URL: https://issues.apache.org/jira/browse/FLINK-19451
Project: Flink
Igal Shilman created FLINK-19399:
Summary: Add Python AsyncRequestReplyHandler docs
Key: FLINK-19399
URL: https://issues.apache.org/jira/browse/FLINK-19399
Project: Flink
Issue Type: Task
+1 (non binding)
- Verified the signatures and the checksums
- Built with JDK11 and JDK8
- Verified that the source distribution does not contain any binary data.
- Run e2e tests.
- Run few examples via docker-compose
- Deployed to Kubernetes with checkpointing to S3, with failure scenarios:
--
Igal Shilman created FLINK-19380:
Summary: Add support for a gRPC transport for the RequestReply
protocol.
Key: FLINK-19380
URL: https://issues.apache.org/jira/browse/FLINK-19380
Project: Flink
Hi everyone,
This vote is canceled. We have found few blocking
issues [FLINK-19330], [FLINK-19327]
a new RC would be out tomorrow.
Thanks,
Igal.
On Mon, Sep 21, 2020 at 8:56 AM Tzu-Li (Gordon) Tai
wrote:
> Hi everyone,
>
> Please review and vote on the release candidate #1 for the version
Igal Shilman created FLINK-19330:
Summary: Recovery with async operations fails due to unitialized
runtimeContext
Key: FLINK-19330
URL: https://issues.apache.org/jira/browse/FLINK-19330
Project
Igal Shilman created FLINK-19329:
Summary: FunctionGroupOperator#dispose might throw an NPE
Key: FLINK-19329
URL: https://issues.apache.org/jira/browse/FLINK-19329
Project: Flink
Issue Type
Igal Shilman created FLINK-19327:
Summary: Helm charts specify a too low value for the job manager's
heap size
Key: FLINK-19327
URL: https://issues.apache.org/jira/browse/FLINK-19327
Project: Flink
Igal Shilman created FLINK-19296:
Summary: RetryingCallback is not aware of task cancaltion
Key: FLINK-19296
URL: https://issues.apache.org/jira/browse/FLINK-19296
Project: Flink
Issue Type
1 - 100 of 184 matches
Mail list logo
