[jira] [Created] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

Tzu-Li (Gordon) Tai created FLINK-32455: --- Summary: Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT Key: FLINK-32455 URL:

[jira] [Created] (FLINK-32453) flink-connector-kafka does not build against Flink 1.18-SNAPSHOT

Tzu-Li (Gordon) Tai created FLINK-32453: --- Summary: flink-connector-kafka does not build against Flink 1.18-SNAPSHOT Key: FLINK-32453 URL: https://issues.apache.org/jira/browse/FLINK-32453

[jira] [Created] (FLINK-31740) Allow setting boundedness for upsert-kafka SQL connector

Tzu-Li (Gordon) Tai created FLINK-31740: --- Summary: Allow setting boundedness for upsert-kafka SQL connector Key: FLINK-31740 URL: https://issues.apache.org/jira/browse/FLINK-31740 Project: Flink

[jira] [Created] (FLINK-23853) Update StateFun's Flink dependency to 1.13.2

Tzu-Li (Gordon) Tai created FLINK-23853: --- Summary: Update StateFun's Flink dependency to 1.13.2 Key: FLINK-23853 URL: https://issues.apache.org/jira/browse/FLINK-23853 Project: Flink

[jira] [Created] (FLINK-23762) Revisit RequestReplyFunctionTest unit tests

Tzu-Li (Gordon) Tai created FLINK-23762: --- Summary: Revisit RequestReplyFunctionTest unit tests Key: FLINK-23762 URL: https://issues.apache.org/jira/browse/FLINK-23762 Project: Flink

[jira] [Created] (FLINK-23718) Manage StateFun Python SDK as a Maven module

Tzu-Li (Gordon) Tai created FLINK-23718: --- Summary: Manage StateFun Python SDK as a Maven module Key: FLINK-23718 URL: https://issues.apache.org/jira/browse/FLINK-23718 Project: Flink

[jira] [Created] (FLINK-23717) Allow setting configs using plain strings in StatefulFunctionsAppContainers

Tzu-Li (Gordon) Tai created FLINK-23717: --- Summary: Allow setting configs using plain strings in StatefulFunctionsAppContainers Key: FLINK-23717 URL: https://issues.apache.org/jira/browse/FLINK-23717

[jira] [Created] (FLINK-23714) Expose both master and worker logs when using StatefulFunctionsAppContainers

Tzu-Li (Gordon) Tai created FLINK-23714: --- Summary: Expose both master and worker logs when using StatefulFunctionsAppContainers Key: FLINK-23714 URL: https://issues.apache.org/jira/browse/FLINK-23714

[jira] [Created] (FLINK-23709) Remove SanityVerificationE2E and ExactlyOnceRemoteE2E

Tzu-Li (Gordon) Tai created FLINK-23709: --- Summary: Remove SanityVerificationE2E and ExactlyOnceRemoteE2E Key: FLINK-23709 URL: https://issues.apache.org/jira/browse/FLINK-23709 Project: Flink

[jira] [Created] (FLINK-23600) Rework StateFun's remote module parsing and binding

Tzu-Li (Gordon) Tai created FLINK-23600: --- Summary: Rework StateFun's remote module parsing and binding Key: FLINK-23600 URL: https://issues.apache.org/jira/browse/FLINK-23600 Project: Flink

[jira] [Created] (FLINK-23296) Add RequestReplyClientFactory as a pluggable extension

Tzu-Li (Gordon) Tai created FLINK-23296: --- Summary: Add RequestReplyClientFactory as a pluggable extension Key: FLINK-23296 URL: https://issues.apache.org/jira/browse/FLINK-23296 Project: Flink

[jira] [Created] (FLINK-23295) Introduce extension module SPI to StateFun

Tzu-Li (Gordon) Tai created FLINK-23295: --- Summary: Introduce extension module SPI to StateFun Key: FLINK-23295 URL: https://issues.apache.org/jira/browse/FLINK-23295 Project: Flink

[jira] [Created] (FLINK-23293) Support pluggable / extendable HTTP transport for StateFun remote invocations

Tzu-Li (Gordon) Tai created FLINK-23293: --- Summary: Support pluggable / extendable HTTP transport for StateFun remote invocations Key: FLINK-23293 URL: https://issues.apache.org/jira/browse/FLINK-23293

[jira] [Created] (FLINK-22529) StateFun Kinesis ingresses should support configs that are available via FlinkKinesisConsumer's ConsumerConfigConstants

Tzu-Li (Gordon) Tai created FLINK-22529: --- Summary: StateFun Kinesis ingresses should support configs that are available via FlinkKinesisConsumer's ConsumerConfigConstants Key: FLINK-22529 URL:

[jira] [Created] (FLINK-22023) Remove outdated StateFun quickstart archetype

Tzu-Li (Gordon) Tai created FLINK-22023: --- Summary: Remove outdated StateFun quickstart archetype Key: FLINK-22023 URL: https://issues.apache.org/jira/browse/FLINK-22023 Project: Flink

[jira] [Created] (FLINK-21904) parseJmJvmArgsAndExportLogs: command not found warning when starting StateFun

Tzu-Li (Gordon) Tai created FLINK-21904: --- Summary: parseJmJvmArgsAndExportLogs: command not found warning when starting StateFun Key: FLINK-21904 URL: https://issues.apache.org/jira/browse/FLINK-21904

[jira] [Created] (FLINK-21901) Update StateFun version to 3.0-SNAPSHOT

Tzu-Li (Gordon) Tai created FLINK-21901: --- Summary: Update StateFun version to 3.0-SNAPSHOT Key: FLINK-21901 URL: https://issues.apache.org/jira/browse/FLINK-21901 Project: Flink Issue

[jira] [Created] (FLINK-21865) Add a Docker Compose greeter example to StateFun playgrounds

Tzu-Li (Gordon) Tai created FLINK-21865: --- Summary: Add a Docker Compose greeter example to StateFun playgrounds Key: FLINK-21865 URL: https://issues.apache.org/jira/browse/FLINK-21865 Project:

[jira] [Created] (FLINK-21862) Add a Java SDK showcase tutorial to StateFun playground

Tzu-Li (Gordon) Tai created FLINK-21862: --- Summary: Add a Java SDK showcase tutorial to StateFun playground Key: FLINK-21862 URL: https://issues.apache.org/jira/browse/FLINK-21862 Project: Flink

[jira] [Created] (FLINK-21705) Add a SliceType to the StateFun Java SDK

Tzu-Li (Gordon) Tai created FLINK-21705: --- Summary: Add a SliceType to the StateFun Java SDK Key: FLINK-21705 URL: https://issues.apache.org/jira/browse/FLINK-21705 Project: Flink Issue

[jira] [Created] (FLINK-21678) Rename Expiration.expiresAfterReadOrWrite to Expiration.expiresAfterCall in StateFun

Tzu-Li (Gordon) Tai created FLINK-21678: --- Summary: Rename Expiration.expiresAfterReadOrWrite to Expiration.expiresAfterCall in StateFun Key: FLINK-21678 URL:

[jira] [Created] (FLINK-21676) Ensure that state names are valid identifiers in the StateFun Java SDK

Tzu-Li (Gordon) Tai created FLINK-21676: --- Summary: Ensure that state names are valid identifiers in the StateFun Java SDK Key: FLINK-21676 URL: https://issues.apache.org/jira/browse/FLINK-21676

[jira] [Created] (FLINK-21663) Reject duplicate StatefulFunction registrations under the same typename

Tzu-Li (Gordon) Tai created FLINK-21663: --- Summary: Reject duplicate StatefulFunction registrations under the same typename Key: FLINK-21663 URL: https://issues.apache.org/jira/browse/FLINK-21663

[jira] [Created] (FLINK-21662) Reject duplicate ValueSpec registrations under the same state name

Tzu-Li (Gordon) Tai created FLINK-21662: --- Summary: Reject duplicate ValueSpec registrations under the same state name Key: FLINK-21662 URL: https://issues.apache.org/jira/browse/FLINK-21662

[jira] [Created] (FLINK-21577) SimpleType.simpleTypeFrom(...) complains with "Collection is empty"

Tzu-Li (Gordon) Tai created FLINK-21577: --- Summary: SimpleType.simpleTypeFrom(...) complains with "Collection is empty" Key: FLINK-21577 URL: https://issues.apache.org/jira/browse/FLINK-21577

[jira] [Created] (FLINK-21530) Precompute TypeName's canonical string representation

Tzu-Li (Gordon) Tai created FLINK-21530: --- Summary: Precompute TypeName's canonical string representation Key: FLINK-21530 URL: https://issues.apache.org/jira/browse/FLINK-21530 Project: Flink

[jira] [Created] (FLINK-21498) Avoid copying when converting byte[] to ByteString in StateFun

Tzu-Li (Gordon) Tai created FLINK-21498: --- Summary: Avoid copying when converting byte[] to ByteString in StateFun Key: FLINK-21498 URL: https://issues.apache.org/jira/browse/FLINK-21498

[jira] [Created] (FLINK-21496) Upgrade Testcontainers to 1.15.1 in Stateful Functions

Tzu-Li (Gordon) Tai created FLINK-21496: --- Summary: Upgrade Testcontainers to 1.15.1 in Stateful Functions Key: FLINK-21496 URL: https://issues.apache.org/jira/browse/FLINK-21496 Project: Flink

[jira] [Created] (FLINK-21491) Properly shade Protobuf in statefun-sdk-java

Tzu-Li (Gordon) Tai created FLINK-21491: --- Summary: Properly shade Protobuf in statefun-sdk-java Key: FLINK-21491 URL: https://issues.apache.org/jira/browse/FLINK-21491 Project: Flink

[jira] [Created] (FLINK-21459) Implement remote Java SDK for Stateful Functions

Tzu-Li (Gordon) Tai created FLINK-21459: --- Summary: Implement remote Java SDK for Stateful Functions Key: FLINK-21459 URL: https://issues.apache.org/jira/browse/FLINK-21459 Project: Flink

[jira] [Created] (FLINK-21276) flink-statefun/statefun-sdk-java should mention Protobuf in NOTICE and bundle its license

Tzu-Li (Gordon) Tai created FLINK-21276: --- Summary: flink-statefun/statefun-sdk-java should mention Protobuf in NOTICE and bundle its license Key: FLINK-21276 URL:

[jira] [Created] (FLINK-21171) Introduce TypedValue to the StateFun request-reply protocol

Tzu-Li (Gordon) Tai created FLINK-21171: --- Summary: Introduce TypedValue to the StateFun request-reply protocol Key: FLINK-21171 URL: https://issues.apache.org/jira/browse/FLINK-21171 Project:

[jira] [Created] (FLINK-21061) Introduce RemotePersistedValue construct in Stateful Functions

Tzu-Li (Gordon) Tai created FLINK-21061: --- Summary: Introduce RemotePersistedValue construct in Stateful Functions Key: FLINK-21061 URL: https://issues.apache.org/jira/browse/FLINK-21061

[jira] [Created] (FLINK-20987) Upgrade Stateful Functions to use Flink 1.12

Tzu-Li (Gordon) Tai created FLINK-20987: --- Summary: Upgrade Stateful Functions to use Flink 1.12 Key: FLINK-20987 URL: https://issues.apache.org/jira/browse/FLINK-20987 Project: Flink

[jira] [Created] (FLINK-20742) Skip deployment of StateFun example artifacts

Tzu-Li (Gordon) Tai created FLINK-20742: --- Summary: Skip deployment of StateFun example artifacts Key: FLINK-20742 URL: https://issues.apache.org/jira/browse/FLINK-20742 Project: Flink

[jira] [Created] (FLINK-20741) StateFun's DataStream interop SDK module is missing a valid NOTICE file

Tzu-Li (Gordon) Tai created FLINK-20741: --- Summary: StateFun's DataStream interop SDK module is missing a valid NOTICE file Key: FLINK-20741 URL: https://issues.apache.org/jira/browse/FLINK-20741

[jira] [Created] (FLINK-20689) Upgrade StateFun to Flink 1.11.3

Tzu-Li (Gordon) Tai created FLINK-20689: --- Summary: Upgrade StateFun to Flink 1.11.3 Key: FLINK-20689 URL: https://issues.apache.org/jira/browse/FLINK-20689 Project: Flink Issue Type:

[jira] [Created] (FLINK-20636) Require unaligned checkpoints to be disabled in StateFun applications

Tzu-Li (Gordon) Tai created FLINK-20636: --- Summary: Require unaligned checkpoints to be disabled in StateFun applications Key: FLINK-20636 URL: https://issues.apache.org/jira/browse/FLINK-20636

[jira] [Created] (FLINK-20574) Throttle number of remote invocation requests on startup or restores with large backlogs

Tzu-Li (Gordon) Tai created FLINK-20574: --- Summary: Throttle number of remote invocation requests on startup or restores with large backlogs Key: FLINK-20574 URL:

[jira] [Created] (FLINK-20336) RequestReplyFunction should not silently ignore UNRECOGNIZED state value mutations types

Tzu-Li (Gordon) Tai created FLINK-20336: --- Summary: RequestReplyFunction should not silently ignore UNRECOGNIZED state value mutations types Key: FLINK-20336 URL:

[jira] [Created] (FLINK-20335) Remove support for eager state specifications in module YAML definitions

Tzu-Li (Gordon) Tai created FLINK-20335: --- Summary: Remove support for eager state specifications in module YAML definitions Key: FLINK-20335 URL: https://issues.apache.org/jira/browse/FLINK-20335

[jira] [Created] (FLINK-20334) Introduce function endpoint path templating in module YAML specifications

Tzu-Li (Gordon) Tai created FLINK-20334: --- Summary: Introduce function endpoint path templating in module YAML specifications Key: FLINK-20334 URL: https://issues.apache.org/jira/browse/FLINK-20334

[jira] [Created] (FLINK-20268) Update Python SDK to implement new invocation protocol

Tzu-Li (Gordon) Tai created FLINK-20268: --- Summary: Update Python SDK to implement new invocation protocol Key: FLINK-20268 URL: https://issues.apache.org/jira/browse/FLINK-20268 Project: Flink

[jira] [Created] (FLINK-20265) Extend invocation protocol to allow functions to indicate incomplete state context

Tzu-Li (Gordon) Tai created FLINK-20265: --- Summary: Extend invocation protocol to allow functions to indicate incomplete state context Key: FLINK-20265 URL: https://issues.apache.org/jira/browse/FLINK-20265

[jira] [Created] (FLINK-20264) Zero-downtime / dynamic function upgrades in Stateful Functions

Tzu-Li (Gordon) Tai created FLINK-20264: --- Summary: Zero-downtime / dynamic function upgrades in Stateful Functions Key: FLINK-20264 URL: https://issues.apache.org/jira/browse/FLINK-20264

[jira] [Created] (FLINK-20189) Restored feedback events may be silently dropped if per key-group header bytes were not fully read

Tzu-Li (Gordon) Tai created FLINK-20189: --- Summary: Restored feedback events may be silently dropped if per key-group header bytes were not fully read Key: FLINK-20189 URL:

[jira] [Created] (FLINK-20182) Add JDK 11 build to StateFun's CI

Tzu-Li (Gordon) Tai created FLINK-20182: --- Summary: Add JDK 11 build to StateFun's CI Key: FLINK-20182 URL: https://issues.apache.org/jira/browse/FLINK-20182 Project: Flink Issue Type:

[jira] [Created] (FLINK-20161) Consider switching from Travis CI to Github Actions for flink-statefun's CI workflows

Tzu-Li (Gordon) Tai created FLINK-20161: --- Summary: Consider switching from Travis CI to Github Actions for flink-statefun's CI workflows Key: FLINK-20161 URL:

[jira] [Created] (FLINK-20085) Remove RemoteFunctionStateMigrator code paths from StateFun

Tzu-Li (Gordon) Tai created FLINK-20085: --- Summary: Remove RemoteFunctionStateMigrator code paths from StateFun Key: FLINK-20085 URL: https://issues.apache.org/jira/browse/FLINK-20085 Project:

[jira] [Created] (FLINK-19748) StateFun's UnboundedFeedbackLogger should call startNewKeyGroup for all assigned key groups

Tzu-Li (Gordon) Tai created FLINK-19748: --- Summary: StateFun's UnboundedFeedbackLogger should call startNewKeyGroup for all assigned key groups Key: FLINK-19748 URL:

[jira] [Created] (FLINK-19741) InternalTimeServiceManager fails to restore if there are other users of raw keyed state streams

Tzu-Li (Gordon) Tai created FLINK-19741: --- Summary: InternalTimeServiceManager fails to restore if there are other users of raw keyed state streams Key: FLINK-19741 URL:

[jira] [Created] (FLINK-19620) Merge StateFun's ExactlyOnceE2E and RemoteModuleE2E

Tzu-Li (Gordon) Tai created FLINK-19620: --- Summary: Merge StateFun's ExactlyOnceE2E and RemoteModuleE2E Key: FLINK-19620 URL: https://issues.apache.org/jira/browse/FLINK-19620 Project: Flink

[jira] [Created] (FLINK-19408) Update flink-statefun-docker release scripts for cross release Java 8 and 11

Tzu-Li (Gordon) Tai created FLINK-19408: --- Summary: Update flink-statefun-docker release scripts for cross release Java 8 and 11 Key: FLINK-19408 URL: https://issues.apache.org/jira/browse/FLINK-19408

[jira] [Created] (FLINK-19290) Add documentation for Stateful Function's Flink DataStream SDK

Tzu-Li (Gordon) Tai created FLINK-19290: --- Summary: Add documentation for Stateful Function's Flink DataStream SDK Key: FLINK-19290 URL: https://issues.apache.org/jira/browse/FLINK-19290

[jira] [Created] (FLINK-19256) Validate Stateful Functions configuration only where necessary

Tzu-Li (Gordon) Tai created FLINK-19256: --- Summary: Validate Stateful Functions configuration only where necessary Key: FLINK-19256 URL: https://issues.apache.org/jira/browse/FLINK-19256

[jira] [Created] (FLINK-19199) Add execution attempt ID to feedback channel keys

Tzu-Li (Gordon) Tai created FLINK-19199: --- Summary: Add execution attempt ID to feedback channel keys Key: FLINK-19199 URL: https://issues.apache.org/jira/browse/FLINK-19199 Project: Flink

[jira] [Created] (FLINK-19197) Add documentation for PersistedStateRegistry

Tzu-Li (Gordon) Tai created FLINK-19197: --- Summary: Add documentation for PersistedStateRegistry Key: FLINK-19197 URL: https://issues.apache.org/jira/browse/FLINK-19197 Project: Flink

[jira] [Created] (FLINK-19130) Expose backpressure metrics / logs for function dispatcher operator

Tzu-Li (Gordon) Tai created FLINK-19130: --- Summary: Expose backpressure metrics / logs for function dispatcher operator Key: FLINK-19130 URL: https://issues.apache.org/jira/browse/FLINK-19130

[jira] [Created] (FLINK-19107) Add basic checkpoint and recovery config keys to template flink-conf.yaml

Tzu-Li (Gordon) Tai created FLINK-19107: --- Summary: Add basic checkpoint and recovery config keys to template flink-conf.yaml Key: FLINK-19107 URL: https://issues.apache.org/jira/browse/FLINK-19107

[jira] [Created] (FLINK-19106) Add more timeout options for remote function specs

Tzu-Li (Gordon) Tai created FLINK-19106: --- Summary: Add more timeout options for remote function specs Key: FLINK-19106 URL: https://issues.apache.org/jira/browse/FLINK-19106 Project: Flink

[jira] [Created] (FLINK-19102) Make StateBinder a per-FunctionType entity

Tzu-Li (Gordon) Tai created FLINK-19102: --- Summary: Make StateBinder a per-FunctionType entity Key: FLINK-19102 URL: https://issues.apache.org/jira/browse/FLINK-19102 Project: Flink

[jira] [Created] (FLINK-19096) Simplify PersistedStateRegistry state registration methods

Tzu-Li (Gordon) Tai created FLINK-19096: --- Summary: Simplify PersistedStateRegistry state registration methods Key: FLINK-19096 URL: https://issues.apache.org/jira/browse/FLINK-19096 Project:

[jira] [Created] (FLINK-19095) Add expire mode for remote function state TTL

Tzu-Li (Gordon) Tai created FLINK-19095: --- Summary: Add expire mode for remote function state TTL Key: FLINK-19095 URL: https://issues.apache.org/jira/browse/FLINK-19095 Project: Flink

[jira] [Created] (FLINK-18340) Support directly providing bytes instead of a Protobuf messages when writing to Kafka / Kinesis with the Python SDK

Tzu-Li (Gordon) Tai created FLINK-18340: --- Summary: Support directly providing bytes instead of a Protobuf messages when writing to Kafka / Kinesis with the Python SDK Key: FLINK-18340 URL:

[jira] [Created] (FLINK-18316) Add a dynamic state registration primitive for Stateful Functions

Tzu-Li (Gordon) Tai created FLINK-18316: --- Summary: Add a dynamic state registration primitive for Stateful Functions Key: FLINK-18316 URL: https://issues.apache.org/jira/browse/FLINK-18316

[jira] [Created] (FLINK-18177) Document all YAML format versions for Stateful Functions

Tzu-Li (Gordon) Tai created FLINK-18177: --- Summary: Document all YAML format versions for Stateful Functions Key: FLINK-18177 URL: https://issues.apache.org/jira/browse/FLINK-18177 Project: Flink

[jira] [Created] (FLINK-18069) Scaladocs not building since inner Java interfaces cannot be recognized

Tzu-Li (Gordon) Tai created FLINK-18069: --- Summary: Scaladocs not building since inner Java interfaces cannot be recognized Key: FLINK-18069 URL: https://issues.apache.org/jira/browse/FLINK-18069

[jira] [Created] (FLINK-17997) Revert manual merging of AWS KPL's THIRD_PARTY_NOTICE files content in Stateful Functions distribution artifact

Tzu-Li (Gordon) Tai created FLINK-17997: --- Summary: Revert manual merging of AWS KPL's THIRD_PARTY_NOTICE files content in Stateful Functions distribution artifact Key: FLINK-17997 URL:

[jira] [Created] (FLINK-17963) Revert execution environment patching in StatefulFunctionsJob (FLINK-16926)

Tzu-Li (Gordon) Tai created FLINK-17963: --- Summary: Revert execution environment patching in StatefulFunctionsJob (FLINK-16926) Key: FLINK-17963 URL: https://issues.apache.org/jira/browse/FLINK-17963

[jira] [Created] (FLINK-17954) Do not multiplex remote function state into single PersistedTable

Tzu-Li (Gordon) Tai created FLINK-17954: --- Summary: Do not multiplex remote function state into single PersistedTable Key: FLINK-17954 URL: https://issues.apache.org/jira/browse/FLINK-17954

[jira] [Created] (FLINK-17875) Support state TTL for remote functions

Tzu-Li (Gordon) Tai created FLINK-17875: --- Summary: Support state TTL for remote functions Key: FLINK-17875 URL: https://issues.apache.org/jira/browse/FLINK-17875 Project: Flink Issue

[jira] [Created] (FLINK-17712) Upgrade Flink version to 1.10.1 in Stateful Functions

Tzu-Li (Gordon) Tai created FLINK-17712: --- Summary: Upgrade Flink version to 1.10.1 in Stateful Functions Key: FLINK-17712 URL: https://issues.apache.org/jira/browse/FLINK-17712 Project: Flink

[jira] [Created] (FLINK-17684) Run containerized end-to-end tests for all Travis builds

Tzu-Li (Gordon) Tai created FLINK-17684: --- Summary: Run containerized end-to-end tests for all Travis builds Key: FLINK-17684 URL: https://issues.apache.org/jira/browse/FLINK-17684 Project: Flink

[jira] [Created] (FLINK-17605) Consolidate flink.version in Stateful Functions POM files

Tzu-Li (Gordon) Tai created FLINK-17605: --- Summary: Consolidate flink.version in Stateful Functions POM files Key: FLINK-17605 URL: https://issues.apache.org/jira/browse/FLINK-17605 Project:

[jira] [Created] (FLINK-17520) Extend CompositeTypeSerializerSnapshot to allow composite serializers to signal migration based on outer configuration

Tzu-Li (Gordon) Tai created FLINK-17520: --- Summary: Extend CompositeTypeSerializerSnapshot to allow composite serializers to signal migration based on outer configuration Key: FLINK-17520 URL:

[jira] [Created] (FLINK-17519) Add Java State Bootstrapping E2E test for Stateful Functions

Tzu-Li (Gordon) Tai created FLINK-17519: --- Summary: Add Java State Bootstrapping E2E test for Stateful Functions Key: FLINK-17519 URL: https://issues.apache.org/jira/browse/FLINK-17519 Project:

[jira] [Created] (FLINK-17518) Add HTTP-based request reply protocol E2E test for Stateful Functions

Tzu-Li (Gordon) Tai created FLINK-17518: --- Summary: Add HTTP-based request reply protocol E2E test for Stateful Functions Key: FLINK-17518 URL: https://issues.apache.org/jira/browse/FLINK-17518

[jira] [Created] (FLINK-17517) Add failure recovery / exactly-once E2E for Stateful Functions

Tzu-Li (Gordon) Tai created FLINK-17517: --- Summary: Add failure recovery / exactly-once E2E for Stateful Functions Key: FLINK-17517 URL: https://issues.apache.org/jira/browse/FLINK-17517

[jira] [Created] (FLINK-17516) Add more end-to-end tests for Stateful Functions

Tzu-Li (Gordon) Tai created FLINK-17516: --- Summary: Add more end-to-end tests for Stateful Functions Key: FLINK-17516 URL: https://issues.apache.org/jira/browse/FLINK-17516 Project: Flink

[jira] [Created] (FLINK-17060) "{flink}" isn't being replaced by the Apache Flink trademark in Stateful Functions docs

Tzu-Li (Gordon) Tai created FLINK-17060: --- Summary: "{flink}" isn't being replaced by the Apache Flink trademark in Stateful Functions docs Key: FLINK-17060 URL:

[jira] [Created] (FLINK-16985) Specify job names for Stateful Functions examples

Tzu-Li (Gordon) Tai created FLINK-16985: --- Summary: Specify job names for Stateful Functions examples Key: FLINK-16985 URL: https://issues.apache.org/jira/browse/FLINK-16985 Project: Flink

[jira] [Created] (FLINK-16928) Switch back to new scheduler in Stateful Functions

Tzu-Li (Gordon) Tai created FLINK-16928: --- Summary: Switch back to new scheduler in Stateful Functions Key: FLINK-16928 URL: https://issues.apache.org/jira/browse/FLINK-16928 Project: Flink

[jira] [Created] (FLINK-16927) Stateful Function jobs fail to restore after losing task slots using the new Flink scheduler

Tzu-Li (Gordon) Tai created FLINK-16927: --- Summary: Stateful Function jobs fail to restore after losing task slots using the new Flink scheduler Key: FLINK-16927 URL:

[jira] [Created] (FLINK-16902) commons-codec dependency pulls in LICENSE.txt that should be excluded

Tzu-Li (Gordon) Tai created FLINK-16902: --- Summary: commons-codec dependency pulls in LICENSE.txt that should be excluded Key: FLINK-16902 URL: https://issues.apache.org/jira/browse/FLINK-16902

[jira] [Created] (FLINK-16901) Flink Kinesis connector NOTICE should have contents of AWS KPL's THIRD_PARTY_NOTICES file manually merged in

Tzu-Li (Gordon) Tai created FLINK-16901: --- Summary: Flink Kinesis connector NOTICE should have contents of AWS KPL's THIRD_PARTY_NOTICES file manually merged in Key: FLINK-16901 URL:

[jira] [Created] (FLINK-16900) Exclude NOTCE and LICENSE files of Kafka dependencies for statefun-flink-distribution

Tzu-Li (Gordon) Tai created FLINK-16900: --- Summary: Exclude NOTCE and LICENSE files of Kafka dependencies for statefun-flink-distribution Key: FLINK-16900 URL:

[jira] [Created] (FLINK-16880) Adapt Dockerfiles from flink-statefun to be added to flink-statefun-docker

Tzu-Li (Gordon) Tai created FLINK-16880: --- Summary: Adapt Dockerfiles from flink-statefun to be added to flink-statefun-docker Key: FLINK-16880 URL: https://issues.apache.org/jira/browse/FLINK-16880

[jira] [Created] (FLINK-16879) Disable the source-release-assembly execution goal when using the apache-release build profile

Tzu-Li (Gordon) Tai created FLINK-16879: --- Summary: Disable the source-release-assembly execution goal when using the apache-release build profile Key: FLINK-16879 URL:

[jira] [Created] (FLINK-16843) Python SDK distribution is missing LICENSE and NOTICE files

Tzu-Li (Gordon) Tai created FLINK-16843: --- Summary: Python SDK distribution is missing LICENSE and NOTICE files Key: FLINK-16843 URL: https://issues.apache.org/jira/browse/FLINK-16843 Project:

[jira] [Created] (FLINK-16842) Ridesharing example simulator built artifact is missing NOTICE / LICENSE for bundled dependencies

Tzu-Li (Gordon) Tai created FLINK-16842: --- Summary: Ridesharing example simulator built artifact is missing NOTICE / LICENSE for bundled dependencies Key: FLINK-16842 URL:

[jira] [Created] (FLINK-16841) Stateful Function artifacts jars should not bundle proto sources

Tzu-Li (Gordon) Tai created FLINK-16841: --- Summary: Stateful Function artifacts jars should not bundle proto sources Key: FLINK-16841 URL: https://issues.apache.org/jira/browse/FLINK-16841

[jira] [Created] (FLINK-16838) Stateful Functions Quickstart archetype Dockerfile should reference a specific version tag

Tzu-Li (Gordon) Tai created FLINK-16838: --- Summary: Stateful Functions Quickstart archetype Dockerfile should reference a specific version tag Key: FLINK-16838 URL:

[jira] [Created] (FLINK-16738) Add convenience Kinesis generic egress record builder to the Python SDK

Tzu-Li (Gordon) Tai created FLINK-16738: --- Summary: Add convenience Kinesis generic egress record builder to the Python SDK Key: FLINK-16738 URL: https://issues.apache.org/jira/browse/FLINK-16738

[jira] [Created] (FLINK-16706) Update Stateful Functions master branch version to 2.0-SNAPSHOT

Tzu-Li (Gordon) Tai created FLINK-16706: --- Summary: Update Stateful Functions master branch version to 2.0-SNAPSHOT Key: FLINK-16706 URL: https://issues.apache.org/jira/browse/FLINK-16706

[jira] [Created] (FLINK-16680) Add documentation for Stateful Function's State Bootstrapping API

Tzu-Li (Gordon) Tai created FLINK-16680: --- Summary: Add documentation for Stateful Function's State Bootstrapping API Key: FLINK-16680 URL: https://issues.apache.org/jira/browse/FLINK-16680

[jira] [Created] (FLINK-16569) Allow empty keys in Kafka egress messages for Statefun Python SDK

Tzu-Li (Gordon) Tai created FLINK-16569: --- Summary: Allow empty keys in Kafka egress messages for Statefun Python SDK Key: FLINK-16569 URL: https://issues.apache.org/jira/browse/FLINK-16569

[jira] [Created] (FLINK-16558) Reword Stateful Functions doc's tagline

Tzu-Li (Gordon) Tai created FLINK-16558: --- Summary: Reword Stateful Functions doc's tagline Key: FLINK-16558 URL: https://issues.apache.org/jira/browse/FLINK-16558 Project: Flink Issue

[jira] [Created] (FLINK-16557) Document YAML-ized Kafka egresses / ingresses in Stateful Functions documentation

Tzu-Li (Gordon) Tai created FLINK-16557: --- Summary: Document YAML-ized Kafka egresses / ingresses in Stateful Functions documentation Key: FLINK-16557 URL: https://issues.apache.org/jira/browse/FLINK-16557

[jira] [Created] (FLINK-16520) Move Kafka client properties resolution in KafkaSinkProvider to KafkaEgressBuilder

Tzu-Li (Gordon) Tai created FLINK-16520: --- Summary: Move Kafka client properties resolution in KafkaSinkProvider to KafkaEgressBuilder Key: FLINK-16520 URL: https://issues.apache.org/jira/browse/FLINK-16520

[jira] [Created] (FLINK-16518) Stateful Function's KafkaSinkProvider should use `setProperty` instead of `put` for resolving client properties

Tzu-Li (Gordon) Tai created FLINK-16518: --- Summary: Stateful Function's KafkaSinkProvider should use `setProperty` instead of `put` for resolving client properties Key: FLINK-16518 URL:

  1   2   3   4   >