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

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

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

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

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

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

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

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

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

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

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

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

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

[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-16757) Refactor Helm charts

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

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

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

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

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

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

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

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-25309) Upgrade to the latest Flink version

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-25355) Upgrade Flink dependency to 1.13.3

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-25367) Upgrade Flink dependency to 1.13.5

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-25752) Create a migration e2e test

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-25866) Support additional TLS configuration.

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-25933) Allow configuring different transports in RequestReplyFunctionBuilder

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-25934) Modernize statefun playground examples

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-25935) Add a harness based entry point to simply getting started.

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-25936) MutableTypeCell is not setting correctly the value's type_name

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-26378) caller's address isn't set to None properly when a message is coming from an ingress

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-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] [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] [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] [Created] (FLINK-21642) RequestReplyFunction recovery fails with a remote SDK

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

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

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

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

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

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

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

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

[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-22185) Add k8s example to flink-statefun-playground

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

[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

  1   2   >