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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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:
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
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
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
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
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
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
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:
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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:
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
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:
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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:
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
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
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:
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
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
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
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
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
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
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
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
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
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:
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
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
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
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
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
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 - 100 of 127 matches
Mail list logo