[jira] [Created] (FLINK-10605) Upgrade AvroSerializer snapshot to implement new TypeSerializerSnapshot interface

Igal Shilman created FLINK-10605: Summary: Upgrade AvroSerializer snapshot to implement new TypeSerializerSnapshot interface Key: FLINK-10605 URL: https://issues.apache.org/jira/browse/FLINK-10605 Pro

[jira] [Commented] (FLINK-11053) Examples in documentation not compiling

[ https://issues.apache.org/jira/browse/FLINK-11053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16714861#comment-16714861 ] Igal Shilman commented on FLINK-11053: -- Hello [~avilevi], thank you for reporting t

[jira] [Created] (FLINK-19975) Bump testconatiners version

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

[jira] [Updated] (FLINK-19975) Upgrade to the latest testconatiners version

[ https://issues.apache.org/jira/browse/FLINK-19975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-19975: - Summary: Upgrade to the latest testconatiners version (was: Bump testconatiners version ) > U

[jira] [Created] (FLINK-20303) Add a SmokeE2E test

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 Compone

[jira] [Created] (FLINK-16886) Helm chart worker/master image name is using the wrong template value

Igal Shilman created FLINK-16886: Summary: Helm chart worker/master image name is using the wrong template value Key: FLINK-16886 URL: https://issues.apache.org/jira/browse/FLINK-16886 Project: Flink

[jira] [Created] (FLINK-16898) Helm chart worker deployment is using the wrong port for lives checks

Igal Shilman created FLINK-16898: Summary: Helm chart worker deployment is using the wrong port for lives checks Key: FLINK-16898 URL: https://issues.apache.org/jira/browse/FLINK-16898 Project: Flink

[jira] [Created] (FLINK-16899) Adjust module.yaml of python-k8s example to match python-worker-service

Igal Shilman created FLINK-16899: Summary: Adjust module.yaml of python-k8s example to match python-worker-service Key: FLINK-16899 URL: https://issues.apache.org/jira/browse/FLINK-16899 Project: Flin

[jira] [Updated] (FLINK-16899) Adjust module.yaml of python-k8s example to match python-worker-service

[ https://issues.apache.org/jira/browse/FLINK-16899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-16899: - Component/s: Stateful Functions > Adjust module.yaml of python-k8s example to match python-worke

[jira] [Created] (FLINK-16926) Values present at flink-conf.yaml are not respected via the StreamPlanEnvironment

Igal Shilman created FLINK-16926: Summary: Values present at flink-conf.yaml are not respected via the StreamPlanEnvironment Key: FLINK-16926 URL: https://issues.apache.org/jira/browse/FLINK-16926 Pr

[jira] [Updated] (FLINK-16926) Values present at flink-conf.yaml are not respected via the StreamPlanEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-16926: - Description: Values present at flink-conf.yaml are not respected via the StreamPlanEnvironment,

[jira] [Assigned] (FLINK-16926) Values present at flink-conf.yaml are not respected via the StreamPlanEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-16926: Assignee: Igal Shilman > Values present at flink-conf.yaml are not respected via the > S

[jira] [Created] (FLINK-16930) Drop StatefulFunctionsClusterEntryPoint

Igal Shilman created FLINK-16930: Summary: Drop StatefulFunctionsClusterEntryPoint Key: FLINK-16930 URL: https://issues.apache.org/jira/browse/FLINK-16930 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-16950) Kafka console consumer displays uncommitted records.

Igal Shilman created FLINK-16950: Summary: Kafka console consumer displays uncommitted records. Key: FLINK-16950 URL: https://issues.apache.org/jira/browse/FLINK-16950 Project: Flink Issue Ty

[jira] [Created] (FLINK-19190) Use camelCase for metric names

Igal Shilman created FLINK-19190: Summary: Use camelCase for metric names Key: FLINK-19190 URL: https://issues.apache.org/jira/browse/FLINK-19190 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-19191) Reduce the default number for async operations

Igal Shilman created FLINK-19191: Summary: Reduce the default number for async operations Key: FLINK-19191 URL: https://issues.apache.org/jira/browse/FLINK-19191 Project: Flink Issue Type: I

[jira] [Assigned] (FLINK-19192) Set higher limit on the HTTP connection pool

[ https://issues.apache.org/jira/browse/FLINK-19192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-19192: Assignee: Igal Shilman > Set higher limit on the HTTP connection pool > -

[jira] [Created] (FLINK-19192) Set higher limit on the HTTP connection pool

Igal Shilman created FLINK-19192: Summary: Set higher limit on the HTTP connection pool Key: FLINK-19192 URL: https://issues.apache.org/jira/browse/FLINK-19192 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-19176) Support ScalaPB as a message payload serializer in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194219#comment-17194219 ] Igal Shilman commented on FLINK-19176: -- Hi [~galenwarren], welcome to project! Ind

[jira] [Created] (FLINK-19203) Use Flink-*-scala2.12 variants for StateFun

Igal Shilman created FLINK-19203: Summary: Use Flink-*-scala2.12 variants for StateFun Key: FLINK-19203 URL: https://issues.apache.org/jira/browse/FLINK-19203 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-19220) Add a way to close internal resources

Igal Shilman created FLINK-19220: Summary: Add a way to close internal resources Key: FLINK-19220 URL: https://issues.apache.org/jira/browse/FLINK-19220 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-19220) Add a way to close internal resources

[ https://issues.apache.org/jira/browse/FLINK-19220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-19220: Assignee: Igal Shilman > Add a way to close internal resources >

[jira] [Commented] (FLINK-19176) Support ScalaPB as a message payload serializer in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17195551#comment-17195551 ] Igal Shilman commented on FLINK-19176: -- Hi [~galenwarren],  Thanks for working on

[jira] [Commented] (FLINK-19176) Support ScalaPB as a message payload serializer in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17195596#comment-17195596 ] Igal Shilman commented on FLINK-19176: -- I've went through all the classes that are

[jira] [Commented] (FLINK-19176) Support ScalaPB as a message payload serializer in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-19176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197029#comment-17197029 ] Igal Shilman commented on FLINK-19176: -- Thanks [~galenwarren]! let's continue to co

[jira] [Created] (FLINK-19279) Remove StatefulFunctionUnvierse cache

Igal Shilman created FLINK-19279: Summary: Remove StatefulFunctionUnvierse cache Key: FLINK-19279 URL: https://issues.apache.org/jira/browse/FLINK-19279 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19296) RetryingCallback is not aware of task cancaltion

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:

[jira] [Created] (FLINK-19327) Helm charts specify a too low value for the job manager's heap size

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

[jira] [Updated] (FLINK-19327) Helm charts specify a too low value for the job manager's heap size

[ https://issues.apache.org/jira/browse/FLINK-19327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-19327: - Description: Currently our Helm chart specify the value of  jobmanager.memory.process.size to b

[jira] [Created] (FLINK-19329) FunctionGroupOperator#dispose might throw an NPE

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:

[jira] [Updated] (FLINK-19329) FunctionGroupOperator#dispose might throw an NPE during operator dispose

[ https://issues.apache.org/jira/browse/FLINK-19329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-19329: - Priority: Minor (was: Major) > FunctionGroupOperator#dispose might throw an NPE during operator

[jira] [Updated] (FLINK-19329) FunctionGroupOperator#dispose might throw an NPE during operator dispose

[ https://issues.apache.org/jira/browse/FLINK-19329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-19329: - Summary: FunctionGroupOperator#dispose might throw an NPE during operator dispose (was: Functio

[jira] [Updated] (FLINK-19329) FunctionGroupOperator#dispose might throw an NPE during operator dispose

[ https://issues.apache.org/jira/browse/FLINK-19329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-19329: - Description: The dispose method of an operator can be called without a successful call to inita

[jira] [Created] (FLINK-19330) Recovery with async operations fails due to unitialized runtimeContext

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: Flink

[jira] [Updated] (FLINK-19330) Recovery with async operations fails due to unitialized runtimeContext

[ https://issues.apache.org/jira/browse/FLINK-19330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-19330: - Description: In Flink 1.11, the AbstractStreamOperator's runtimeContext is not fully initialize

[jira] [Created] (FLINK-19380) Add support for a gRPC transport for the RequestReply protocol.

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

[jira] [Created] (FLINK-19399) Add Python AsyncRequestReplyHandler docs

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

[jira] [Created] (FLINK-21154) Move the shared request-reply protobuf files to a separate artifact.

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

[jira] [Created] (FLINK-21230) Add protobuf wrapper types for the StateFun SDK types.

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

[jira] [Created] (FLINK-21243) Add Java SDK maven module

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 Componen

[jira] [Created] (FLINK-21280) Investigate a way to disable object reuse in StateFun

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 T

[jira] [Commented] (FLINK-21280) Investigate a way to disable object reuse in StateFun

[ https://issues.apache.org/jira/browse/FLINK-21280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17279001#comment-17279001 ] Igal Shilman commented on FLINK-21280: -- This could be solved by modifying: [https:

[jira] [Created] (FLINK-17644) Add support for state TTL.

Igal Shilman created FLINK-17644: Summary: Add support for state TTL. Key: FLINK-17644 URL: https://issues.apache.org/jira/browse/FLINK-17644 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105753#comment-17105753 ] Igal Shilman commented on FLINK-17611: -- Hi [~slinkydeveloper], Welcome to the proj

[jira] [Comment Edited] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105753#comment-17105753 ] Igal Shilman edited comment on FLINK-17611 at 5/12/20, 9:24 PM: --

[jira] [Comment Edited] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105753#comment-17105753 ] Igal Shilman edited comment on FLINK-17611 at 5/12/20, 9:25 PM: --

[jira] [Commented] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106405#comment-17106405 ] Igal Shilman commented on FLINK-17611: -- Thanks [~slinkydeveloper]. If okhttp clien

[jira] [Commented] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107244#comment-17107244 ] Igal Shilman commented on FLINK-17611: -- [~slinkydeveloper] having an endpoint in ad

[jira] [Comment Edited] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107244#comment-17107244 ] Igal Shilman edited comment on FLINK-17611 at 5/14/20, 12:11 PM: -

[jira] [Comment Edited] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107244#comment-17107244 ] Igal Shilman edited comment on FLINK-17611 at 5/14/20, 12:11 PM: -

[jira] [Comment Edited] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107244#comment-17107244 ] Igal Shilman edited comment on FLINK-17611 at 5/14/20, 12:11 PM: -

[jira] [Created] (FLINK-17690) Python function wrapper omits docstr

Igal Shilman created FLINK-17690: Summary: Python function wrapper omits docstr Key: FLINK-17690 URL: https://issues.apache.org/jira/browse/FLINK-17690 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-19451) Add HELM chart distribution to StateFun release process

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 Issue

[jira] [Commented] (FLINK-19515) Async RequestReply handler concurrency bug

[ https://issues.apache.org/jira/browse/FLINK-19515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17209119#comment-17209119 ] Igal Shilman commented on FLINK-19515: -- Hi, I think that you are correct, and it do

[jira] [Created] (FLINK-21457) Add support to differentiate a zero length value bytes and non existing value.

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 Projec

[jira] [Updated] (FLINK-21457) Add support to differentiate a zero length value bytes and non existing value.

[ https://issues.apache.org/jira/browse/FLINK-21457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-21457: - Description: The TypedValue Protobuf message has a value bytes field, but since Protobuf doesn't

[jira] [Created] (FLINK-21483) Disable the spot bugs plugin.

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 Comp

[jira] [Assigned] (FLINK-11865) Code generation in TraversableSerializer is prohibitively slow

[ https://issues.apache.org/jira/browse/FLINK-11865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-11865: Assignee: Igal Shilman > Code generation in TraversableSerializer is prohibitively slow >

[jira] [Created] (FLINK-18518) Add Async RequestReply handler for the Python SDK

Igal Shilman created FLINK-18518: Summary: Add Async RequestReply handler for the Python SDK Key: FLINK-18518 URL: https://issues.apache.org/jira/browse/FLINK-18518 Project: Flink Issue Type:

[jira] [Updated] (FLINK-18518) Add Async RequestReply handler for the Python SDK

[ https://issues.apache.org/jira/browse/FLINK-18518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-18518: - Labels: beginner-friendly (was: ) > Add Async RequestReply handler for the Python SDK > ---

[jira] [Commented] (FLINK-15756) StateFun poms are inconsistent in their scala version usages

[ https://issues.apache.org/jira/browse/FLINK-15756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024406#comment-17024406 ] Igal Shilman commented on FLINK-15756: -- I'll replace the hardcoded 2.11 references

[jira] [Commented] (FLINK-15757) statefun-kafka-io pom comment is incomplete

[ https://issues.apache.org/jira/browse/FLINK-15757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024419#comment-17024419 ] Igal Shilman commented on FLINK-15757: -- I will remove that comment altogether becau

[jira] [Commented] (FLINK-15759) ridesharing-example-simulator does not compile on Java 11

[ https://issues.apache.org/jira/browse/FLINK-15759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024421#comment-17024421 ] Igal Shilman commented on FLINK-15759: -- I will just remove lombok. > ridesharing-e

[jira] [Commented] (FLINK-15760) ridesharing-example-simulator depends on different parent pom

[ https://issues.apache.org/jira/browse/FLINK-15760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024556#comment-17024556 ] Igal Shilman commented on FLINK-15760: -- This is indeed on propose, the intention wa

[jira] [Commented] (FLINK-15764) Document why snappy-java is excluded from kafka-clients

[ https://issues.apache.org/jira/browse/FLINK-15764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024571#comment-17024571 ] Igal Shilman commented on FLINK-15764: -- [~chesnay] I will create a PR with a commen

[jira] [Commented] (FLINK-15760) ridesharing-example-simulator depends on different parent pom

[ https://issues.apache.org/jira/browse/FLINK-15760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17027278#comment-17027278 ] Igal Shilman commented on FLINK-15760: -- This is fixed in master at 69d72782444c5aff

[jira] [Closed] (FLINK-15760) ridesharing-example-simulator depends on different parent pom

[ https://issues.apache.org/jira/browse/FLINK-15760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman closed FLINK-15760. Fix Version/s: statefun-1.1 Resolution: Fixed Fixed at 69d72782444c5aff2c24ed5751ca5ec6fc27

[jira] [Updated] (FLINK-18894) StateFun job stalls on stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-18894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-18894: - Component/s: Stateful Functions > StateFun job stalls on stop-with-savepoint > -

[jira] [Commented] (FLINK-18894) StateFun job stalls on stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-18894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176335#comment-17176335 ] Igal Shilman commented on FLINK-18894: -- Thanks for reporting this Seth, I was able

[jira] [Assigned] (FLINK-18894) StateFun job stalls on stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-18894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-18894: Assignee: Igal Shilman > StateFun job stalls on stop-with-savepoint > ---

[jira] [Updated] (FLINK-18894) StateFun job stalls on stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-18894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-18894: - Attachment: stacktrace.txt > StateFun job stalls on stop-with-savepoint > --

[jira] [Commented] (FLINK-18894) StateFun job stalls on stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-18894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176351#comment-17176351 ] Igal Shilman commented on FLINK-18894: -- So, it seems like the problem is with the w

[jira] [Commented] (FLINK-18894) StateFun job stalls on stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-18894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176417#comment-17176417 ] Igal Shilman commented on FLINK-18894: -- Obtaining a MAX_PRIO mailbox from StreamTas

[jira] [Created] (FLINK-19001) Add data-stream integration for stateful functions

Igal Shilman created FLINK-19001: Summary: Add data-stream integration for stateful functions Key: FLINK-19001 URL: https://issues.apache.org/jira/browse/FLINK-19001 Project: Flink Issue Typ

[jira] [Created] (FLINK-19017) Increases the visibility of a remote function call retry

Igal Shilman created FLINK-19017: Summary: Increases the visibility of a remote function call retry Key: FLINK-19017 URL: https://issues.apache.org/jira/browse/FLINK-19017 Project: Flink Issu

[jira] [Updated] (FLINK-19017) Increases the visibility of a remote function call failures and retires

[ https://issues.apache.org/jira/browse/FLINK-19017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-19017: - Summary: Increases the visibility of a remote function call failures and retires (was: Increase

[jira] [Created] (FLINK-19018) Add connection timeout to remote functions.

Igal Shilman created FLINK-19018: Summary: Add connection timeout to remote functions. Key: FLINK-19018 URL: https://issues.apache.org/jira/browse/FLINK-19018 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-19019) Add HDFS / S3 / GCS support to Flink-StateFun Docker image.

Igal Shilman created FLINK-19019: Summary: Add HDFS / S3 / GCS support to Flink-StateFun Docker image. Key: FLINK-19019 URL: https://issues.apache.org/jira/browse/FLINK-19019 Project: Flink

[jira] [Created] (FLINK-19020) Add more metrics around async operations and backpressure

Igal Shilman created FLINK-19020: Summary: Add more metrics around async operations and backpressure Key: FLINK-19020 URL: https://issues.apache.org/jira/browse/FLINK-19020 Project: Flink Iss

[jira] [Created] (FLINK-19129) Helm charts are missing the latest log4j-console file

Igal Shilman created FLINK-19129: Summary: Helm charts are missing the latest log4j-console file Key: FLINK-19129 URL: https://issues.apache.org/jira/browse/FLINK-19129 Project: Flink Issue T

[jira] [Commented] (FLINK-17690) Python function wrapper omits docstr

[ https://issues.apache.org/jira/browse/FLINK-17690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114023#comment-17114023 ] Igal Shilman commented on FLINK-17690: -- Assigned, thanks! > Python function wrappe

[jira] [Assigned] (FLINK-17690) Python function wrapper omits docstr

[ https://issues.apache.org/jira/browse/FLINK-17690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-17690: Assignee: UnityLung > Python function wrapper omits docstr >

[jira] [Assigned] (FLINK-17319) Fix broken link to walkthrough guide

[ https://issues.apache.org/jira/browse/FLINK-17319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-17319: Assignee: Patrick Wiener > Fix broken link to walkthrough guide > ---

[jira] [Closed] (FLINK-17319) Fix broken link to walkthrough guide

[ https://issues.apache.org/jira/browse/FLINK-17319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman closed FLINK-17319. Fix Version/s: statefun-2.1.0 Resolution: Fixed Fixed at f3ebc7b71e6197b96f8c4ef9884d14460b

[jira] [Created] (FLINK-17533) Add support for concurrent checkpoints in SateFun

Igal Shilman created FLINK-17533: Summary: Add support for concurrent checkpoints in SateFun Key: FLINK-17533 URL: https://issues.apache.org/jira/browse/FLINK-17533 Project: Flink Issue Type:

[jira] [Commented] (FLINK-17549) Support running Stateful Functions on native Kubernetes setup

[ https://issues.apache.org/jira/browse/FLINK-17549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17101730#comment-17101730 ] Igal Shilman commented on FLINK-17549: -- Hey, thank you for taking the initiative he

[jira] [Closed] (FLINK-17193) k8s-python-example build-example.sh improvements

[ https://issues.apache.org/jira/browse/FLINK-17193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman closed FLINK-17193. Resolution: Fixed > k8s-python-example build-example.sh improvements > ---

[jira] [Assigned] (FLINK-17193) k8s-python-example build-example.sh improvements

[ https://issues.apache.org/jira/browse/FLINK-17193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-17193: Assignee: Rafi Aroch > k8s-python-example build-example.sh improvements > ---

[jira] [Assigned] (FLINK-16244) Add Asynchronous operations to state lazily.

[ https://issues.apache.org/jira/browse/FLINK-16244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-16244: Assignee: Igal Shilman > Add Asynchronous operations to state lazily. > -

[jira] [Commented] (FLINK-16274) Add typed builder methods for setting dynamic configuration on StatefulFunctionsAppContainers

[ https://issues.apache.org/jira/browse/FLINK-16274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17045574#comment-17045574 ] Igal Shilman commented on FLINK-16274: -- Hey [~tzulitai], as it indeed looks nicer i

[jira] [Comment Edited] (FLINK-16274) Add typed builder methods for setting dynamic configuration on StatefulFunctionsAppContainers

[ https://issues.apache.org/jira/browse/FLINK-16274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17045574#comment-17045574 ] Igal Shilman edited comment on FLINK-16274 at 2/26/20 2:22 PM: ---

[jira] [Created] (FLINK-16290) HttpUrl might return NULL if a schema is missing

Igal Shilman created FLINK-16290: Summary: HttpUrl might return NULL if a schema is missing Key: FLINK-16290 URL: https://issues.apache.org/jira/browse/FLINK-16290 Project: Flink Issue Type:

[jira] [Updated] (FLINK-16321) Refactor HttpFunction

[ https://issues.apache.org/jira/browse/FLINK-16321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-16321: - Summary: Refactor HttpFunction (was: Refactor HttpFunction to improve testability) > Refactor

[jira] [Created] (FLINK-16321) Refactor HttpFunction to improve testability

Igal Shilman created FLINK-16321: Summary: Refactor HttpFunction to improve testability Key: FLINK-16321 URL: https://issues.apache.org/jira/browse/FLINK-16321 Project: Flink Issue Type: Impr

[jira] [Assigned] (FLINK-16321) Refactor HttpFunction

[ https://issues.apache.org/jira/browse/FLINK-16321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-16321: Assignee: Igal Shilman > Refactor HttpFunction > - > >

[jira] [Commented] (FLINK-16274) Add typed builder methods for setting dynamic configuration on StatefulFunctionsAppContainers

[ https://issues.apache.org/jira/browse/FLINK-16274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17047377#comment-17047377 ] Igal Shilman commented on FLINK-16274: -- Hi [~tzulitai], After giving more thought

[jira] [Created] (FLINK-16391) Enhance the RequestReply protocol with Egresses and Delayed Messages

Igal Shilman created FLINK-16391: Summary: Enhance the RequestReply protocol with Egresses and Delayed Messages Key: FLINK-16391 URL: https://issues.apache.org/jira/browse/FLINK-16391 Project: Flink

[jira] [Comment Edited] (FLINK-16398) Rename Protobuf Kafka Ingress / Routable Kafka Ingress type identifier strings

[ https://issues.apache.org/jira/browse/FLINK-16398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17050957#comment-17050957 ] Igal Shilman edited comment on FLINK-16398 at 3/4/20, 7:23 AM: ---

[jira] [Commented] (FLINK-16398) Rename Protobuf Kafka Ingress / Routable Kafka Ingress type identifier strings

[ https://issues.apache.org/jira/browse/FLINK-16398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17050957#comment-17050957 ] Igal Shilman commented on FLINK-16398: -- +1 for ingress, and +1 for shorter strings.

[jira] [Created] (FLINK-16415) Add a version property to module.yaml

Igal Shilman created FLINK-16415: Summary: Add a version property to module.yaml Key: FLINK-16415 URL: https://issues.apache.org/jira/browse/FLINK-16415 Project: Flink Issue Type: Improvement

  1   2   3   4   >