[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

[jira] [Created] (FLINK-11323) Upgrade KryoSerializer snapshot to implement new TypeSerializerSnapshot interface

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

[jira] [Created] (FLINK-11436) Java deserialization failure of the AvroSerializer when used in an old CompositeSerializers

Igal Shilman created FLINK-11436: Summary: Java deserialization failure of the AvroSerializer when used in an old CompositeSerializers Key: FLINK-11436 URL: https://issues.apache.org/jira/browse/FLINK-11436

[jira] [Created] (FLINK-11773) KryoSerializerSnapshot would fail to deserialize if a type is missing

Igal Shilman created FLINK-11773: Summary: KryoSerializerSnapshot would fail to deserialize if a type is missing Key: FLINK-11773 URL: https://issues.apache.org/jira/browse/FLINK-11773 Project: Flink

[jira] [Created] (FLINK-11753) Add utils for serialization compatibility tests

Igal Shilman created FLINK-11753: Summary: Add utils for serialization compatibility tests Key: FLINK-11753 URL: https://issues.apache.org/jira/browse/FLINK-11753 Project: Flink Issue Type:

[jira] [Created] (FLINK-13326) Support asynchronous writing to raw operator (and raw keyed) state

Igal Shilman created FLINK-13326: Summary: Support asynchronous writing to raw operator (and raw keyed) state Key: FLINK-13326 URL: https://issues.apache.org/jira/browse/FLINK-13326 Project: Flink

[jira] [Created] (FLINK-14862) Fuse initalizeState and open passes in StreamTask#invoke

Igal Shilman created FLINK-14862: Summary: Fuse initalizeState and open passes in StreamTask#invoke Key: FLINK-14862 URL: https://issues.apache.org/jira/browse/FLINK-14862 Project: Flink

[jira] [Created] (FLINK-16020) Use Flink-1.10 released version instead of the snapshot version

Igal Shilman created FLINK-16020: Summary: Use Flink-1.10 released version instead of the snapshot version Key: FLINK-16020 URL: https://issues.apache.org/jira/browse/FLINK-16020 Project: Flink

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

Igal Shilman created FLINK-16244: Summary: Add Asynchronous operations to state lazily. Key: FLINK-16244 URL: https://issues.apache.org/jira/browse/FLINK-16244 Project: Flink Issue Type:

[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] [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:

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

[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] [Created] (FLINK-15954) Introduce a PersistedTable to the SDK

Igal Shilman created FLINK-15954: Summary: Introduce a PersistedTable to the SDK Key: FLINK-15954 URL: https://issues.apache.org/jira/browse/FLINK-15954 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-15955) Split RemoteFunction into GRPC Function/HttpFunction

Igal Shilman created FLINK-15955: Summary: Split RemoteFunction into GRPC Function/HttpFunction Key: FLINK-15955 URL: https://issues.apache.org/jira/browse/FLINK-15955 Project: Flink Issue

[jira] [Created] (FLINK-15952) Don't use raw byte[] in MultiplexedState

Igal Shilman created FLINK-15952: Summary: Don't use raw byte[] in MultiplexedState Key: FLINK-15952 URL: https://issues.apache.org/jira/browse/FLINK-15952 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15956) Introduce an HttpRemoteFunction

Igal Shilman created FLINK-15956: Summary: Introduce an HttpRemoteFunction Key: FLINK-15956 URL: https://issues.apache.org/jira/browse/FLINK-15956 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-16123) Add routable Kafka connector

Igal Shilman created FLINK-16123: Summary: Add routable Kafka connector Key: FLINK-16123 URL: https://issues.apache.org/jira/browse/FLINK-16123 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-16062) Remove the use of a checkpointLock

Igal Shilman created FLINK-16062: Summary: Remove the use of a checkpointLock Key: FLINK-16062 URL: https://issues.apache.org/jira/browse/FLINK-16062 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-16061) Disable state multiplexing

Igal Shilman created FLINK-16061: Summary: Disable state multiplexing Key: FLINK-16061 URL: https://issues.apache.org/jira/browse/FLINK-16061 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-16064) Introduce HELM charts for StatefulFunctions

Igal Shilman created FLINK-16064: Summary: Introduce HELM charts for StatefulFunctions Key: FLINK-16064 URL: https://issues.apache.org/jira/browse/FLINK-16064 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-16063) Add back-pressure mechanism

Igal Shilman created FLINK-16063: Summary: Add back-pressure mechanism Key: FLINK-16063 URL: https://issues.apache.org/jira/browse/FLINK-16063 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-16066) StateBinder should pickup persisted values in inner class

Igal Shilman created FLINK-16066: Summary: StateBinder should pickup persisted values in inner class Key: FLINK-16066 URL: https://issues.apache.org/jira/browse/FLINK-16066 Project: Flink

[jira] [Created] (FLINK-16176) Use AppendingBuffer in HttpFunction

Igal Shilman created FLINK-16176: Summary: Use AppendingBuffer in HttpFunction Key: FLINK-16176 URL: https://issues.apache.org/jira/browse/FLINK-16176 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-16106) Add PersistedList to the SDK

Igal Shilman created FLINK-16106: Summary: Add PersistedList to the SDK Key: FLINK-16106 URL: https://issues.apache.org/jira/browse/FLINK-16106 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-16226) Add back pressure to HttpFunction.

Igal Shilman created FLINK-16226: Summary: Add back pressure to HttpFunction. Key: FLINK-16226 URL: https://issues.apache.org/jira/browse/FLINK-16226 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-16490) Add a minimal statefun Python SDK

Igal Shilman created FLINK-16490: Summary: Add a minimal statefun Python SDK Key: FLINK-16490 URL: https://issues.apache.org/jira/browse/FLINK-16490 Project: Flink Issue Type: Task

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

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:

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

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-16785) Add a README to the Python SDK

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

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

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

[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

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

[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

[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-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] [Created] (FLINK-16685) Add an example of how to deploy a multi-language function to Kubernetes.

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:

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

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

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

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-16752) Ridesharing example doesn't start

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

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

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

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

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

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

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

[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

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

[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

[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

[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

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

[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-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-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

[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

[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] [Created] (FLINK-19827) Allow the harness to start a MiniCluster with a user provided Flink configuration

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

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

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

[jira] [Created] (FLINK-19840) Add a rocksdb and heap timers configuration validation

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-18790) Set a connection timeout that is lower than the request timeout for remote functions

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

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

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

[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

[jira] [Created] (FLINK-20699) Feedback invocation_id must not be constant.

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:

[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] [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-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-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

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

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:

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

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:

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

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

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

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:

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

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-22533) Allow creating custom metrics

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

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:

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

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

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

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

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

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:

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

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

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:

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

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

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

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

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

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-21932) Add a Python SDK showcase to the playground

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-21824) Add a simple Json Kafka producer script

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-21826) Migrate the shopping-cart-example to the new SDK.

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

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

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-21828) Add an AWS-λ example to stateful-playground

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-21692) Update the Python SDK to reflect the latest changes in the request-reply protocol

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

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

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:

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

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

  1   2   >