[jira] [Created] (FLINK-26378) caller's address isn't set to None properly when a message is coming from an ingress

2022-02-25 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-25936) MutableTypeCell is not setting correctly the value's type_name

2022-02-02 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-25935) Add a harness based entry point to simply getting started.

2022-02-02 Thread Igal Shilman (Jira)
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 Is

[jira] [Created] (FLINK-25934) Modernize statefun playground examples

2022-02-02 Thread Igal Shilman (Jira)
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: Improvemen

[jira] [Created] (FLINK-25933) Allow configuring different transports in RequestReplyFunctionBuilder

2022-02-02 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-25866) Support additional TLS configuration.

2022-01-28 Thread Igal Shilman (Jira)
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: Improvement

[jira] [Created] (FLINK-25752) Create a migration e2e test

2022-01-21 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-25367) Upgrade Flink dependency to 1.13.5

2021-12-17 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-25355) Upgrade Flink dependency to 1.13.3

2021-12-16 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-25309) Upgrade to the latest Flink version

2021-12-14 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-25308) Support different remote functions module names

2021-12-14 Thread Igal Shilman (Jira)
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: I

[jira] [Created] (FLINK-24534) Set async based transport for remote functions default

2021-10-13 Thread Igal Shilman (Jira)
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 Issue

[jira] [Created] (FLINK-24364) Add a delayed message cancellation to the embedded smoke test

2021-09-23 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-24322) Improve TypeScript support for the JS SDK

2021-09-17 Thread Igal Shilman (Jira)
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: Improve

[jira] [Created] (FLINK-24284) Add a greeter and a showcase for the JavaScript SDK

2021-09-14 Thread Igal Shilman (Jira)
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 Typ

[jira] [Created] (FLINK-24256) Add JavaScript SDK for Stateful Functions

2021-09-10 Thread Igal Shilman (Jira)
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: Improve

[jira] [Created] (FLINK-24132) directory-maven-plugin fails on Github action

2021-09-02 Thread Igal Shilman (Jira)
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: Imp

[jira] [Created] (FLINK-24107) StateFun doesn't open correctly in intellij when started with JDK11

2021-09-01 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-23966) Don't try to add swifts filesystem plugins in the Dockerfile

2021-08-25 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-23964) Add Shaded Netty TCnative to lib/ in the docker image

2021-08-25 Thread Igal Shilman (Jira)
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 T

[jira] [Created] (FLINK-23712) Improve Protobuf serialization performance

2021-08-10 Thread Igal Shilman (Jira)
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: Improv

[jira] [Created] (FLINK-23711) Add an asynchronous HTTP transport for the RequestReply function

2021-08-10 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-23039) Support pluggable transports for HTTP endpoints

2021-06-18 Thread Igal Shilman (Jira)
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: I

[jira] [Created] (FLINK-22809) Improve the exception message when a KafkaIngress receives a NULL key.

2021-05-31 Thread Igal Shilman (Jira)
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: Flink

[jira] [Created] (FLINK-22633) Add a Harness example to flink-statefun-playground

2021-05-11 Thread Igal Shilman (Jira)
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 Type

[jira] [Created] (FLINK-22584) Use protobuf-shaded in StateFun core.

2021-05-06 Thread Igal Shilman (Jira)
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: Improvement

[jira] [Created] (FLINK-22552) Rebase StateFun on Flink 1.13

2021-05-03 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-22533) Allow creating custom metrics

2021-04-29 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-22532) Improve the support for remote functions in the DataStream integration

2021-04-29 Thread Igal Shilman (Jira)
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: Flin

[jira] [Created] (FLINK-22531) Improve the support for finite streaming jobs with async operations.

2021-04-29 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-22185) Add k8s example to flink-statefun-playground

2021-04-09 Thread Igal Shilman (Jira)
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: Task

[jira] [Created] (FLINK-21961) Add JSON StateFun type to the Python SDK

2021-03-24 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-21960) Simplify module.yaml spec

2021-03-24 Thread Igal Shilman (Jira)
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 Componen

[jira] [Created] (FLINK-21959) Rename Kafka/Kinesis ingress/egress types.

2021-03-24 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-21958) Rename statefun-sdk to statefun-sdk-embedded

2021-03-24 Thread Igal Shilman (Jira)
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: Tas

[jira] [Created] (FLINK-21957) Rename statefun-python-sdk => statefun-sdk-python

2021-03-24 Thread Igal Shilman (Jira)
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 Type:

[jira] [Created] (FLINK-21956) NPE in Kafka ingress when the key is missing

2021-03-24 Thread Igal Shilman (Jira)
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: Task

[jira] [Created] (FLINK-21955) Remove the old examples

2021-03-24 Thread Igal Shilman (Jira)
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 Components

[jira] [Created] (FLINK-21932) Add a Python SDK showcase to the playground

2021-03-23 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-21882) Create a Python based greeter example

2021-03-19 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-21828) Add an AWS-λ example to stateful-playground

2021-03-16 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-21827) Migrate the Python examples to the new SDK

2021-03-16 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-21826) Migrate the shopping-cart-example to the new SDK.

2021-03-16 Thread Igal Shilman (Jira)
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:

[jira] [Created] (FLINK-21824) Add a simple Json Kafka producer script

2021-03-16 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-21721) Add a generic egress message builder to the SDK

2021-03-10 Thread Igal Shilman (Jira)
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: T

[jira] [Created] (FLINK-21692) Update the Python SDK to reflect the latest changes in the request-reply protocol

2021-03-09 Thread Igal Shilman (Jira)
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 Pro

[jira] [Created] (FLINK-21642) RequestReplyFunction recovery fails with a remote SDK

2021-03-06 Thread Igal Shilman (Jira)
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 T

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

2021-02-24 Thread Igal Shilman (Jira)
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] [Created] (FLINK-21457) Add support to differentiate a zero length value bytes and non existing value.

2021-02-23 Thread Igal Shilman (Jira)
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] [Created] (FLINK-21280) Investigate a way to disable object reuse in StateFun

2021-02-04 Thread Igal Shilman (Jira)
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] [Created] (FLINK-21243) Add Java SDK maven module

2021-02-02 Thread Igal Shilman (Jira)
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-21230) Add protobuf wrapper types for the StateFun SDK types.

2021-02-01 Thread Igal Shilman (Jira)
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-21154) Move the shared request-reply protobuf files to a separate artifact.

2021-01-26 Thread Igal Shilman (Jira)
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-20699) Feedback invocation_id must not be constant.

2020-12-21 Thread Igal Shilman (Jira)
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: Impr

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

2020-11-23 Thread Igal Shilman (Jira)
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-19975) Bump testconatiners version

2020-11-04 Thread Igal Shilman (Jira)
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] [Created] (FLINK-19840) Add a rocksdb and heap timers configuration validation

2020-10-27 Thread Igal Shilman (Jira)
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

[jira] [Created] (FLINK-19827) Allow the harness to start a MiniCluster with a user provided Flink configuration

2020-10-27 Thread Igal Shilman (Jira)
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 Pro

[jira] [Created] (FLINK-19826) StateFun Dockerfile copies plugins with a specific version instead of a wildcard

2020-10-27 Thread Igal Shilman (Jira)
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 Proj

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

2020-09-29 Thread Igal Shilman (Jira)
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] [Created] (FLINK-19399) Add Python AsyncRequestReplyHandler docs

2020-09-24 Thread Igal Shilman (Jira)
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-19380) Add support for a gRPC transport for the RequestReply protocol.

2020-09-23 Thread Igal Shilman (Jira)
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-19330) Recovery with async operations fails due to unitialized runtimeContext

2020-09-21 Thread Igal Shilman (Jira)
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] [Created] (FLINK-19329) FunctionGroupOperator#dispose might throw an NPE

2020-09-21 Thread Igal Shilman (Jira)
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] [Created] (FLINK-19327) Helm charts specify a too low value for the job manager's heap size

2020-09-21 Thread Igal Shilman (Jira)
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] [Created] (FLINK-19296) RetryingCallback is not aware of task cancaltion

2020-09-20 Thread Igal Shilman (Jira)
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-19279) Remove StatefulFunctionUnvierse cache

2020-09-17 Thread Igal Shilman (Jira)
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-19220) Add a way to close internal resources

2020-09-14 Thread Igal Shilman (Jira)
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] [Created] (FLINK-19203) Use Flink-*-scala2.12 variants for StateFun

2020-09-11 Thread Igal Shilman (Jira)
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-19192) Set higher limit on the HTTP connection pool

2020-09-10 Thread Igal Shilman (Jira)
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] [Created] (FLINK-19191) Reduce the default number for async operations

2020-09-10 Thread Igal Shilman (Jira)
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] [Created] (FLINK-19190) Use camelCase for metric names

2020-09-10 Thread Igal Shilman (Jira)
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-19129) Helm charts are missing the latest log4j-console file

2020-09-02 Thread Igal Shilman (Jira)
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] [Created] (FLINK-19020) Add more metrics around async operations and backpressure

2020-08-21 Thread Igal Shilman (Jira)
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-19019) Add HDFS / S3 / GCS support to Flink-StateFun Docker image.

2020-08-21 Thread Igal Shilman (Jira)
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-19018) Add connection timeout to remote functions.

2020-08-21 Thread Igal Shilman (Jira)
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-19017) Increases the visibility of a remote function call retry

2020-08-21 Thread Igal Shilman (Jira)
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] [Created] (FLINK-19001) Add data-stream integration for stateful functions

2020-08-19 Thread Igal Shilman (Jira)
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-18790) Set a connection timeout that is lower than the request timeout for remote functions

2020-07-31 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-18790: Summary: Set a connection timeout that is lower than the request timeout for remote functions Key: FLINK-18790 URL: https://issues.apache.org/jira/browse/FLINK-18790

[jira] [Created] (FLINK-18645) Add community driven SDKs to StateFun documentations.

2020-07-20 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-18645: Summary: Add community driven SDKs to StateFun documentations. Key: FLINK-18645 URL: https://issues.apache.org/jira/browse/FLINK-18645 Project: Flink Issue T

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

2020-07-07 Thread Igal Shilman (Jira)
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] [Created] (FLINK-17690) Python function wrapper omits docstr

2020-05-14 Thread Igal Shilman (Jira)
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-17644) Add support for state TTL.

2020-05-12 Thread Igal Shilman (Jira)
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] [Created] (FLINK-17533) Add support for concurrent checkpoints in SateFun

2020-05-05 Thread Igal Shilman (Jira)
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] [Created] (FLINK-16950) Kafka console consumer displays uncommitted records.

2020-04-02 Thread Igal Shilman (Jira)
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-16930) Drop StatefulFunctionsClusterEntryPoint

2020-04-01 Thread Igal Shilman (Jira)
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-16926) Values present at flink-conf.yaml are not respected via the StreamPlanEnvironment

2020-04-01 Thread Igal Shilman (Jira)
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] [Created] (FLINK-16899) Adjust module.yaml of python-k8s example to match python-worker-service

2020-03-31 Thread Igal Shilman (Jira)
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] [Created] (FLINK-16898) Helm chart worker deployment is using the wrong port for lives checks

2020-03-31 Thread Igal Shilman (Jira)
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-16886) Helm chart worker/master image name is using the wrong template value

2020-03-31 Thread Igal Shilman (Jira)
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-16785) Add a README to the Python SDK

2020-03-25 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16785: Summary: Add a README to the Python SDK Key: FLINK-16785 URL: https://issues.apache.org/jira/browse/FLINK-16785 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16783) Add Polyglot Docker-compose example

2020-03-25 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16783: Summary: Add Polyglot Docker-compose example Key: FLINK-16783 URL: https://issues.apache.org/jira/browse/FLINK-16783 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16757) Refactor Helm charts

2020-03-24 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16757: Summary: Refactor Helm charts Key: FLINK-16757 URL: https://issues.apache.org/jira/browse/FLINK-16757 Project: Flink Issue Type: Improvement Compon

[jira] [Created] (FLINK-16756) Move Bootstrap API example to statefun-examples/

2020-03-24 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16756: Summary: Move Bootstrap API example to statefun-examples/ Key: FLINK-16756 URL: https://issues.apache.org/jira/browse/FLINK-16756 Project: Flink Issue Type:

[jira] [Created] (FLINK-16752) Ridesharing example doesn't start

2020-03-24 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16752: Summary: Ridesharing example doesn't start Key: FLINK-16752 URL: https://issues.apache.org/jira/browse/FLINK-16752 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-16723) Move Python SDK example out of statefun-python-sdk

2020-03-23 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16723: Summary: Move Python SDK example out of statefun-python-sdk Key: FLINK-16723 URL: https://issues.apache.org/jira/browse/FLINK-16723 Project: Flink Issue Typ

[jira] [Created] (FLINK-16722) Add Python SDK walkthrough

2020-03-23 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16722: Summary: Add Python SDK walkthrough Key: FLINK-16722 URL: https://issues.apache.org/jira/browse/FLINK-16722 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16685) Add an example of how to deploy a multi-language function to Kubernetes.

2020-03-19 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16685: Summary: Add an example of how to deploy a multi-language function to Kubernetes. Key: FLINK-16685 URL: https://issues.apache.org/jira/browse/FLINK-16685 Project: Fli

[jira] [Created] (FLINK-16617) Automatic Any unpacking is broken with type deduction.

2020-03-16 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16617: Summary: Automatic Any unpacking is broken with type deduction. Key: FLINK-16617 URL: https://issues.apache.org/jira/browse/FLINK-16617 Project: Flink Issue

[jira] [Created] (FLINK-16603) statefun-quickstart generates invalid pom.xml

2020-03-15 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16603: Summary: statefun-quickstart generates invalid pom.xml Key: FLINK-16603 URL: https://issues.apache.org/jira/browse/FLINK-16603 Project: Flink Issue Type: Bug

  1   2   >