Unsubscribe

Unsubscribe

Re: Unsubscribe

I've also tried a few times now the last couple of months. I think it would be very nice if the "flink admin" could look into this, instead of us reaching out to the Apache Infrastructure team. Thanks, /Dan Den tors 6 maj 2021 kl 13:31 skrev Chesnay Schepler : > Could you reach out to the Apach

Re: A couple of question for Stateful Functions

Thanks for your quick reply. /Dan Den ons 2 sep. 2020 kl 12:24 skrev Igal Shilman : > Hi Dan, let me try to answer your questions: > > >> I guess my question is if one can >> freely mix Flink core with SF's code with regards to performance, >> fault-tolerance, and checkpointing? > > > The main l

Re: Initialization of a Stateful function

hare more details? For example: > 1. Any Stacktrace > 2. How does your StatefulFunctionProvider looks like? > Do you cache a single function instance, or return a new one in the > provider ? > 3. Are your functions keep any non PersistedValue state? > > Thanks, > Igal >

Initialization of a Stateful function

Hi all, I have had some race problems in method StatefulMatchFunction.ensureInitialized. The quick solution would be to introduce a double checked locking: private void ensureInitialized() { if (!setup) { synchronized (this) { if (!setup) { configure(matcher);

Re: Abstract classes in Stateful functions

Thanks! Den tis 7 jan. 2020 12:49Igal Shilman skrev: > Hi Dan, > Yes. You should be able to store “wheels” in “Vehicle”. > > Igal. > > On Monday, January 6, 2020, Dan Pettersson > wrote: > >> Hello again :-) >> >> When using an abstract class

Abstract classes in Stateful functions

Hello again :-) When using an abstract class should the instance variables be stored in PersistenceValues to conform to the fault tolerance? Exempel Car, Truck and Abstract Vehicle, should wheels in Vehicle be stored in a PersistenceValue? Thanks, /Dan

Re: Stateful functions and modules

t; Igal. > > On Saturday, January 4, 2020, Dan Pettersson > wrote: > >> Hi, >> >> What is the preferred way to expose functions (FunctionTypes) between >> modules? >> >> For example lets say i have the following maven modules: >> >> ->

Stateful functions and modules

Hi, What is the preferred way to expose functions (FunctionTypes) between modules? For example lets say i have the following maven modules: -> common -> statistics -> persister -> tradematching and I have some FunctionTypes in common and persister module that should be reach from all modules.

Re: Stateful function metrics

s the scope of > that persisted value? > If that is the question, then the scope is bound to the function > address(type+id) and not to the Java instance. > So it is safe. > > [1] - > https://ci.apache.org/projects/flink/flink-docs-release-1.9/monitoring/metrics.html > > H

Stateful function metrics

Hi all I'm trying to get hold of some metrics from the functions that I have created but can't find a way to get them. It's the metrics mentioned here I'm interested about: https://statefun.io/deployment_operations/metrics.html Any suggestions are appreciated. I also have a question regarding "be

Stateful functions

Hello, I've started to play around with Stateful functions and I like it a lot :-) Also Thanks for the comprehensive documentation and your very good talk Igal. I would appreciate if you could give some hints/ideas over how to structure an application with the following criteria: One kafka ingr