Tzu-Li (Gordon) Tai created FLINK-13093:
---
Summary: Provide an easy way to modify max parallelism using the
State Processor API
Key: FLINK-13093
URL: https://issues.apache.org/jira/browse/FLINK-13093
Tzu-Li (Gordon) Tai created FLINK-13094:
---
Summary: Provide an easy way to read / bootstrap timers using the
State Processor API
Key: FLINK-13094
URL: https://issues.apache.org/jira/browse/FLINK-13094
Tzu-Li (Gordon) Tai created FLINK-13095:
---
Summary: Provide an easy way to read / bootstrap window state
using the State Processor API
Key: FLINK-13095
URL: https://issues.apache.org/jira/browse/FLINK-13095
Tzu-Li (Gordon) Tai created FLINK-13483:
---
Summary: PrestoS3FileSystemITCase.testDirectoryListing fails on
Travis
Key: FLINK-13483
URL: https://issues.apache.org/jira/browse/FLINK-13483
Project:
Tzu-Li (Gordon) Tai created FLINK-13484:
---
Summary: ConnectedComponents end-to-end test instable with
NoResourceAvailableException
Key: FLINK-13484
URL: https://issues.apache.org/jira/browse/FLINK-13484
Tzu-Li (Gordon) Tai created FLINK-13486:
---
Summary:
AsyncDataStreamITCase.testOrderedWaitUsingAnonymousFunction instable on Travis
Key: FLINK-13486
URL: https://issues.apache.org/jira/browse/FLINK-13486
Tzu-Li (Gordon) Tai created FLINK-13487:
---
Summary:
TaskExecutorPartitionLifecycleTest.testPartitionReleaseAfterReleaseCall failed
on Travis
Key: FLINK-13487
URL: https://issues.apache.org/jira/browse/FLINK-
Tzu-Li (Gordon) Tai created FLINK-13488:
---
Summary: flink-python fails to build on Travis due to
PackagesNotFoundError
Key: FLINK-13488
URL: https://issues.apache.org/jira/browse/FLINK-13488
Proj
Tzu-Li (Gordon) Tai created FLINK-13489:
---
Summary: Heavy deployment end-to-end test fails on Travis with TM
heartbeat timeout
Key: FLINK-13489
URL: https://issues.apache.org/jira/browse/FLINK-13489
Tzu-Li (Gordon) Tai created FLINK-13712:
---
Summary: Add 1.9.0 release notes to documentation
Key: FLINK-13712
URL: https://issues.apache.org/jira/browse/FLINK-13712
Project: Flink
Issue
Tzu-Li (Gordon) Tai created FLINK-13720:
---
Summary: Include asm-commons in flink-shaded-asm
Key: FLINK-13720
URL: https://issues.apache.org/jira/browse/FLINK-13720
Project: Flink
Issue T
Tzu-Li (Gordon) Tai created FLINK-13847:
---
Summary: Update release scripts to also update docs/_config.yml
Key: FLINK-13847
URL: https://issues.apache.org/jira/browse/FLINK-13847
Project: Flink
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
Projec
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: https://issues.apa
Tzu-Li (Gordon) Tai created FLINK-15930:
---
Summary: Setup Stateful Function's Spotless plugin to check
Javadoc violations to comply with Maven Javadoc plugin
Key: FLINK-15930
URL: https://issues.apache.org/ji
Tzu-Li (Gordon) Tai created FLINK-15931:
---
Summary: Add utility scripts / tooling for releasing Stateful
Functions
Key: FLINK-15931
URL: https://issues.apache.org/jira/browse/FLINK-15931
Project:
Tzu-Li (Gordon) Tai created FLINK-15945:
---
Summary: Remove MULTIPLEX_FLINK_STATE config from Stateful
Functions
Key: FLINK-15945
URL: https://issues.apache.org/jira/browse/FLINK-15945
Project: Fl
Tzu-Li (Gordon) Tai created FLINK-15957:
---
Summary: Document the release process for Stateful Functions in
the community wiki
Key: FLINK-15957
URL: https://issues.apache.org/jira/browse/FLINK-15957
Tzu-Li (Gordon) Tai created FLINK-15969:
---
Summary: Do not multiplex both PersistedValue and PersistedTable
with a single MapState state handle
Key: FLINK-15969
URL: https://issues.apache.org/jira/browse/FLIN
Tzu-Li (Gordon) Tai created FLINK-16112:
---
Summary: KafkaDeserializationSchema#isEndOfStream is ill-defined
Key: FLINK-16112
URL: https://issues.apache.org/jira/browse/FLINK-16112
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-16124:
---
Summary: Add a AWS Kinesis Stateful Functions Ingress
Key: FLINK-16124
URL: https://issues.apache.org/jira/browse/FLINK-16124
Project: Flink
Is
Tzu-Li (Gordon) Tai created FLINK-16159:
---
Summary: Add simple end-to-end test for Stateful Functions
Key: FLINK-16159
URL: https://issues.apache.org/jira/browse/FLINK-16159
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-16254:
---
Summary: Support -p/--parallelism option for
StatefulFunctionsClusterEntryPoint
Key: FLINK-16254
URL: https://issues.apache.org/jira/browse/FLINK-16254
Tzu-Li (Gordon) Tai created FLINK-16272:
---
Summary: Move Stateful Functions end-to-end test framework classes
to common module
Key: FLINK-16272
URL: https://issues.apache.org/jira/browse/FLINK-16272
Tzu-Li (Gordon) Tai created FLINK-16274:
---
Summary: Add typed builder methods for setting dynamic
configuration on StatefulFunctionsAppContainers
Key: FLINK-16274
URL: https://issues.apache.org/jira/browse/FL
Tzu-Li (Gordon) Tai created FLINK-16310:
---
Summary: Javadoc of AppendingState.get() contradicts with behavior
of UserFacingListState
Key: FLINK-16310
URL: https://issues.apache.org/jira/browse/FLINK-16310
Tzu-Li (Gordon) Tai created FLINK-16311:
---
Summary: PersistedAppendingBuffer state primitive has incorrect
contracts for view() method
Key: FLINK-16311
URL: https://issues.apache.org/jira/browse/FLINK-16311
Tzu-Li (Gordon) Tai created FLINK-16312:
---
Summary: Stateful Function's HttpFunction falls into endless loop
resending 0-sized batch requests
Key: FLINK-16312
URL: https://issues.apache.org/jira/browse/FLINK-
Tzu-Li (Gordon) Tai created FLINK-16326:
---
Summary: Eagerly validate strictly required Flink configurations
for Stateful Functions
Key: FLINK-16326
URL: https://issues.apache.org/jira/browse/FLINK-16326
Tzu-Li (Gordon) Tai created FLINK-16395:
---
Summary: Mention OkHttp in NOTICE file of
statefun-flink-distribution
Key: FLINK-16395
URL: https://issues.apache.org/jira/browse/FLINK-16395
Project: F
Tzu-Li (Gordon) Tai created FLINK-16396:
---
Summary: Support binding Kafka egresses with YAML-ized modules
Key: FLINK-16396
URL: https://issues.apache.org/jira/browse/FLINK-16396
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-16398:
---
Summary: Rename Protobuf Kafka Ingress / Routable Kafka Ingress
type identifier strings
Key: FLINK-16398
URL: https://issues.apache.org/jira/browse/FLINK-16398
Tzu-Li (Gordon) Tai created FLINK-16507:
---
Summary: "update_branch_version" should also update the version in
Stateful Function's Python SDK setup.py file
Key: FLINK-16507
URL: https://issues.apache.org/jira/
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: https://issues.apache.
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
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
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
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
Proje
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
Proje
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
Project
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
Tzu-Li (Gordon) Tai created FLINK-16838:
---
Summary: Stateful Functions Quickstart archetype Dockerfile should
reference a specific version tag
Key: FLINK-16838
URL: https://issues.apache.org/jira/browse/FLINK
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
Projec
Tzu-Li (Gordon) Tai created FLINK-16842:
---
Summary: Ridesharing example simulator built artifact is missing
NOTICE / LICENSE for bundled dependencies
Key: FLINK-16842
URL: https://issues.apache.org/jira/brows
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: Fl
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: https://issues.apache.org/jira/browse/F
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
Tzu-Li (Gordon) Tai created FLINK-16900:
---
Summary: Exclude NOTCE and LICENSE files of Kafka dependencies for
statefun-flink-distribution
Key: FLINK-16900
URL: https://issues.apache.org/jira/browse/FLINK-1690
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: https://issues.apache.org
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
P
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: https://issues.apache.org/jira/browse/FLI
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
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
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: https://issues.apache.org/jira/browse/FLINK-17
Tzu-Li (Gordon) Tai created FLINK-15729:
---
Summary: Table planner dependency instructions for executing in
IDE is vague
Key: FLINK-15729
URL: https://issues.apache.org/jira/browse/FLINK-15729
Pro
Tzu-Li (Gordon) Tai created FLINK-15769:
---
Summary: Allow configuring offset startup positions for Stateful
Functions Kafka Ingress
Key: FLINK-15769
URL: https://issues.apache.org/jira/browse/FLINK-15769
Tzu-Li (Gordon) Tai created FLINK-15770:
---
Summary: Stateful Functions State Processor module artifact id is
not named correctly
Key: FLINK-15770
URL: https://issues.apache.org/jira/browse/FLINK-15770
Tzu-Li (Gordon) Tai created FLINK-15818:
---
Summary: Add Kafka ingress startup position config to YAML support
Key: FLINK-15818
URL: https://issues.apache.org/jira/browse/FLINK-15818
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-15819:
---
Summary: Add more StateFun Kafka ingress features that are already
available in FlinkKafkaConsumer
Key: FLINK-15819
URL: https://issues.apache.org/jira/browse/FLINK-
Tzu-Li (Gordon) Tai created FLINK-15820:
---
Summary: Allow disabling / enabling auto offset committing to
Kafka in StateFun Kafka ingress
Key: FLINK-15820
URL: https://issues.apache.org/jira/browse/FLINK-15820
Tzu-Li (Gordon) Tai created FLINK-15821:
---
Summary: Allow configuring Kafka partition / topic discovery in
StateFun Kafka ingress
Key: FLINK-15821
URL: https://issues.apache.org/jira/browse/FLINK-15821
Tzu-Li (Gordon) Tai created FLINK-15839:
---
Summary: Revisit Stateful Functions KafkaIngressBuilder properties
resolution logic
Key: FLINK-15839
URL: https://issues.apache.org/jira/browse/FLINK-15839
Tzu-Li (Gordon) Tai created FLINK-15842:
---
Summary: Building Stateful Functions with JDK 11 fails due to
outdated Spotbugs version
Key: FLINK-15842
URL: https://issues.apache.org/jira/browse/FLINK-15842
Tzu-Li (Gordon) Tai created FLINK-15850:
---
Summary: Setup CI for Stateful Functions with Azure Pipelines
Key: FLINK-15850
URL: https://issues.apache.org/jira/browse/FLINK-15850
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-15851:
---
Summary: JDK 8 and 11 CI build pipeline for Stateful Functions
with Azure Pipelines
Key: FLINK-15851
URL: https://issues.apache.org/jira/browse/FLINK-15851
Tzu-Li (Gordon) Tai created FLINK-15874:
---
Summary: Setup Travis cron job for Stateful Functions
documentation build
Key: FLINK-15874
URL: https://issues.apache.org/jira/browse/FLINK-15874
Projec
Tzu-Li (Gordon) Tai created FLINK-15898:
---
Summary: Make Stateful Functions release-ready
Key: FLINK-15898
URL: https://issues.apache.org/jira/browse/FLINK-15898
Project: Flink
Issue Typ
Tzu-Li (Gordon) Tai created FLINK-15899:
---
Summary: Stateful Functions root POM should use the ASF parent POM
Key: FLINK-15899
URL: https://issues.apache.org/jira/browse/FLINK-15899
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-15910:
---
Summary: Add NOTICE files for Stateful Functions
Key: FLINK-15910
URL: https://issues.apache.org/jira/browse/FLINK-15910
Project: Flink
Issue T
Tzu-Li (Gordon) Tai created FLINK-9303:
--
Summary: Unassign partitions from Kafka client if partitions
become unavailable
Key: FLINK-9303
URL: https://issues.apache.org/jira/browse/FLINK-9303
Proj
Tzu-Li (Gordon) Tai created FLINK-9320:
--
Summary: Update `test-ha.sh` end-to-end test to use general
purpose DataStream job
Key: FLINK-9320
URL: https://issues.apache.org/jira/browse/FLINK-9320
P
Tzu-Li (Gordon) Tai created FLINK-9322:
--
Summary: Add exception throwing map function that simulates
failures to the general purpose DataStream job
Key: FLINK-9322
URL: https://issues.apache.org/jira/browse/F
Tzu-Li (Gordon) Tai created FLINK-9376:
--
Summary: Allow upgrading to incompatible state serializers (state
schema evolution)
Key: FLINK-9376
URL: https://issues.apache.org/jira/browse/FLINK-9376
Tzu-Li (Gordon) Tai created FLINK-9377:
--
Summary: Remove writing serializers as part of the checkpoint meta
information
Key: FLINK-9377
URL: https://issues.apache.org/jira/browse/FLINK-9377
Proje
Tzu-Li (Gordon) Tai created FLINK-9394:
--
Summary: Let externalized checkpoint resume e2e also test rescaling
Key: FLINK-9394
URL: https://issues.apache.org/jira/browse/FLINK-9394
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-9569:
--
Summary: Confusing construction of AvroSerializers for generic
records
Key: FLINK-9569
URL: https://issues.apache.org/jira/browse/FLINK-9569
Project: Flin
Tzu-Li (Gordon) Tai created FLINK-9574:
--
Summary: Add a dedicated documentation page for state evolution
Key: FLINK-9574
URL: https://issues.apache.org/jira/browse/FLINK-9574
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-9595:
--
Summary: Add instructions to docs about ceased support of KPL
version used in Kinesis connector
Key: FLINK-9595
URL: https://issues.apache.org/jira/browse/FLINK-9595
Tzu-Li (Gordon) Tai created FLINK-9608:
--
Summary: Add test base for TypeSerializer snapshotting / restore /
migration to be used by all Flink serializers
Key: FLINK-9608
URL: https://issues.apache.org/jira/br
Tzu-Li (Gordon) Tai created FLINK-9808:
--
Summary: Implement state conversion procedure in state backends
Key: FLINK-9808
URL: https://issues.apache.org/jira/browse/FLINK-9808
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-9885:
--
Summary: End-to-end test: Elasticsearch 6.x connector
Key: FLINK-9885
URL: https://issues.apache.org/jira/browse/FLINK-9885
Project: Flink
Issue
Tzu-Li (Gordon) Tai created FLINK-10015:
---
Summary: Use Elasticsearch's ESIntegTestCase to rework 5.x and
6.x's ITCases
Key: FLINK-10015
URL: https://issues.apache.org/jira/browse/FLINK-10015
Pro
Tzu-Li (Gordon) Tai created FLINK-10492:
---
Summary: Document generic support for configuring AwsKinesisClient
in the Kinesis Consumer
Key: FLINK-10492
URL: https://issues.apache.org/jira/browse/FLINK-10492
Tzu-Li (Gordon) Tai created FLINK-10679:
---
Summary: Let
TypeSerializerSchemaCompatibility.resolveSchemaCompatibility() be the entry
point for compatibility checks in framework code
Key: FLINK-10679
URL: http
Tzu-Li (Gordon) Tai created FLINK-10708:
---
Summary: Implement a SerializerMigrationTestBase
Key: FLINK-10708
URL: https://issues.apache.org/jira/browse/FLINK-10708
Project: Flink
Issue T
Tzu-Li (Gordon) Tai created FLINK-10709:
---
Summary: Remove NS generic parameter from
TypeSerializerSchemaCompatibility
Key: FLINK-10709
URL: https://issues.apache.org/jira/browse/FLINK-10709
Proj
Tzu-Li (Gordon) Tai created FLINK-10710:
---
Summary: Implement new CompositeSerializerSnapshot
Key: FLINK-10710
URL: https://issues.apache.org/jira/browse/FLINK-10710
Project: Flink
Issue
Tzu-Li (Gordon) Tai created FLINK-10716:
---
Summary: Upgrade ListSerializer / ArrayListSerializer for state
evolution
Key: FLINK-10716
URL: https://issues.apache.org/jira/browse/FLINK-10716
Projec
Tzu-Li (Gordon) Tai created FLINK-10717:
---
Summary: Introduce SimpleSerializerSnapshot as replacement for
ParameterlessTypeSerializerConfig
Key: FLINK-10717
URL: https://issues.apache.org/jira/browse/FLINK-10
Tzu-Li (Gordon) Tai created FLINK-10723:
---
Summary: Upgrade MapSerializer for state evolution
Key: FLINK-10723
URL: https://issues.apache.org/jira/browse/FLINK-10723
Project: Flink
Issue
Tzu-Li (Gordon) Tai created FLINK-10776:
---
Summary: Update migration tests for Flink 1.7
Key: FLINK-10776
URL: https://issues.apache.org/jira/browse/FLINK-10776
Project: Flink
Issue Type
Tzu-Li (Gordon) Tai created FLINK-10777:
---
Summary: Update TypeSerializerSnapshotMigrationITCase for Flink 1.7
Key: FLINK-10777
URL: https://issues.apache.org/jira/browse/FLINK-10777
Project: Flin
Tzu-Li (Gordon) Tai created FLINK-10778:
---
Summary: Update TypeSerializerSnapshotMigrationTestBase and
subclasses for 1.7
Key: FLINK-10778
URL: https://issues.apache.org/jira/browse/FLINK-10778
P
Tzu-Li (Gordon) Tai created FLINK-10779:
---
Summary: Update Java / Scala StatefulJobSavepointMigrationITCase
for 1.7
Key: FLINK-10779
URL: https://issues.apache.org/jira/browse/FLINK-10779
Project
Tzu-Li (Gordon) Tai created FLINK-10780:
---
Summary: Update Java / Scala
StatefulJobWBroadcastStateMigrationITCase for 1.7
Key: FLINK-10780
URL: https://issues.apache.org/jira/browse/FLINK-10780
P
Tzu-Li (Gordon) Tai created FLINK-10781:
---
Summary: Update BucketingSinkMigrationTest for Flink 1.7
Key: FLINK-10781
URL: https://issues.apache.org/jira/browse/FLINK-10781
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-10782:
---
Summary: Update AbstractKeyedOperatorRestoreTestBase for 1.7
Key: FLINK-10782
URL: https://issues.apache.org/jira/browse/FLINK-10782
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-10783:
---
Summary: Update WindowOperatorMigrationTest for 1.7
Key: FLINK-10783
URL: https://issues.apache.org/jira/browse/FLINK-10783
Project: Flink
Issu
Tzu-Li (Gordon) Tai created FLINK-10784:
---
Summary: Update FlinkKafkaConsumerBaseMigrationTest for 1.7
Key: FLINK-10784
URL: https://issues.apache.org/jira/browse/FLINK-10784
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-10785:
---
Summary: Update FlinkKinesisConsumerMigrationTest for 1.7
Key: FLINK-10785
URL: https://issues.apache.org/jira/browse/FLINK-10785
Project: Flink
1 - 100 of 384 matches
Mail list logo
