Hong Liang Teoh created FLINK-38006:
---
Summary: Support Python for Flink AWS connectors in Flink 2.0
Key: FLINK-38006
URL: https://issues.apache.org/jira/browse/FLINK-38006
Project: Flink
Is
Hong Liang Teoh created FLINK-37565:
---
Summary: Connector python CI failing for JDK 8
Key: FLINK-37565
URL: https://issues.apache.org/jira/browse/FLINK-37565
Project: Flink
Issue Type: Bug
Hong Liang Teoh created FLINK-37514:
---
Summary: Display if incremental checkpoints are enabled on Flink
dashboard's checkpoints tab
Key: FLINK-37514
URL: https://issues.apache.org/jira/browse/FLINK-37514
Hong Liang Teoh created FLINK-37417:
---
Summary: Implement better exception message to explain why
KinesisSource doesn't support partial recovery
Key: FLINK-37417
URL: https://issues.apache.org/jira/browse/FLINK-3
Hong Liang Teoh created FLINK-37004:
---
Summary: Implement Multithreaded SourceReader
Key: FLINK-37004
URL: https://issues.apache.org/jira/browse/FLINK-37004
Project: Flink
Issue Type: Improv
Hong Liang Teoh created FLINK-36828:
---
Summary: Implement example for customers to perform KPL
Deaggregation
Key: FLINK-36828
URL: https://issues.apache.org/jira/browse/FLINK-36828
Project: Flink
Hong Liang Teoh created FLINK-36820:
---
Summary: SourceCoordinator#addSplitsBack() should not be called on
full failover
Key: FLINK-36820
URL: https://issues.apache.org/jira/browse/FLINK-36820
Project
Hong Liang Teoh created FLINK-36672:
---
Summary: Kinesis Table API for new KDS source should infer region
from streamARN
Key: FLINK-36672
URL: https://issues.apache.org/jira/browse/FLINK-36672
Project
Hong Liang Teoh created FLINK-36671:
---
Summary: Kinesis Table API for new KDS source does not support
metadata.
Key: FLINK-36671
URL: https://issues.apache.org/jira/browse/FLINK-36671
Project: Flink
Hong Liang Teoh created FLINK-36668:
---
Summary: Release flink-connector-aws v5.0.0
Key: FLINK-36668
URL: https://issues.apache.org/jira/browse/FLINK-36668
Project: Flink
Issue Type: Technica
Hong Liang Teoh created FLINK-3:
---
Summary: CI/CD should check NOTICE files for discrepancies.
Key: FLINK-3
URL: https://issues.apache.org/jira/browse/FLINK-3
Project: Flink
Issu
Hong Liang Teoh created FLINK-36612:
---
Summary: Flink TypeSerializer doesn't recognize valid POJO
getters/setters generated by Lombok
Key: FLINK-36612
URL: https://issues.apache.org/jira/browse/FLINK-36612
Hong Liang Teoh created FLINK-36571:
---
Summary: Flink dashboard does not show Busy / Backpressure
Key: FLINK-36571
URL: https://issues.apache.org/jira/browse/FLINK-36571
Project: Flink
Issu
Hong Liang Teoh created FLINK-36359:
---
Summary: IT case for DDB Streams connector
Key: FLINK-36359
URL: https://issues.apache.org/jira/browse/FLINK-36359
Project: Flink
Issue Type: Improveme
Hong Liang Teoh created FLINK-36357:
---
Summary: SDK retry for KDS connector
Key: FLINK-36357
URL: https://issues.apache.org/jira/browse/FLINK-36357
Project: Flink
Issue Type: Sub-task
Hong Liang Teoh created FLINK-36289:
---
Summary: Create Prometheus Flink connector release
Key: FLINK-36289
URL: https://issues.apache.org/jira/browse/FLINK-36289
Project: Flink
Issue Type: S
Hong Liang Teoh created FLINK-36288:
---
Summary: Set up architectural test
Key: FLINK-36288
URL: https://issues.apache.org/jira/browse/FLINK-36288
Project: Flink
Issue Type: Sub-task
Hong Liang Teoh created FLINK-36286:
---
Summary: Set up pull request template
Key: FLINK-36286
URL: https://issues.apache.org/jira/browse/FLINK-36286
Project: Flink
Issue Type: Sub-task
Hong Liang Teoh created FLINK-36205:
---
Summary: DDB Streams connector should be able to resolve the
stream ARN from given Table name
Key: FLINK-36205
URL: https://issues.apache.org/jira/browse/FLINK-36205
Hong Liang Teoh created FLINK-36187:
---
Summary: Reimplement UniformShardAssigner using Kinesis shard
hashes
Key: FLINK-36187
URL: https://issues.apache.org/jira/browse/FLINK-36187
Project: Flink
Hong Liang Teoh created FLINK-35989:
---
Summary: Document and log error on partially failed requests for
AWS sinks
Key: FLINK-35989
URL: https://issues.apache.org/jira/browse/FLINK-35989
Project: Flin
Hong Liang Teoh created FLINK-35532:
---
Summary: Prevent Cross-Site Authentication (XSA) attacks on Flink
dashboard
Key: FLINK-35532
URL: https://issues.apache.org/jira/browse/FLINK-35532
Project: Fli
Hong Liang Teoh created FLINK-35512:
---
Summary: ArtifactFetchManagerTest unit tests fail
Key: FLINK-35512
URL: https://issues.apache.org/jira/browse/FLINK-35512
Project: Flink
Issue Type: Te
Hong Liang Teoh created FLINK-35299:
---
Summary: FlinkKinesisConsumer does not respect
StreamInitialPosition for new Kinesis Stream when restoring from snapshot
Key: FLINK-35299
URL: https://issues.apache.org/jira
Hong Liang Teoh created FLINK-33872:
---
Summary: Checkpoint history does not display for completed jobs
Key: FLINK-33872
URL: https://issues.apache.org/jira/browse/FLINK-33872
Project: Flink
Hong Liang Teoh created FLINK-33259:
---
Summary: flink-connector-aws should use/extend the common
connector workflow
Key: FLINK-33259
URL: https://issues.apache.org/jira/browse/FLINK-33259
Project: Fl
Hong Liang Teoh created FLINK-33167:
---
Summary: Run IT tests against Kinesalite if AWS credentials are
not present
Key: FLINK-33167
URL: https://issues.apache.org/jira/browse/FLINK-33167
Project: Fli
Hong Liang Teoh created FLINK-33073:
---
Summary: Implement end-to-end tests for the Kinesis Streams Sink
Key: FLINK-33073
URL: https://issues.apache.org/jira/browse/FLINK-33073
Project: Flink
Hong Liang Teoh created FLINK-33072:
---
Summary: Implement end-to-end tests for AWS Kinesis Connectors
Key: FLINK-33072
URL: https://issues.apache.org/jira/browse/FLINK-33072
Project: Flink
I
Hong Liang Teoh created FLINK-32703:
---
Summary: [hotfix] flink-python POM has a typo for protobuf-java in
shading config
Key: FLINK-32703
URL: https://issues.apache.org/jira/browse/FLINK-32703
Projec
Hong Liang Teoh created FLINK-32619:
---
Summary: ConfigOptions to support fallback configuration
Key: FLINK-32619
URL: https://issues.apache.org/jira/browse/FLINK-32619
Project: Flink
Issue T
Hong Liang Teoh created FLINK-32537:
---
Summary: Add compatibility annotation for REST API classes
Key: FLINK-32537
URL: https://issues.apache.org/jira/browse/FLINK-32537
Project: Flink
Issue
Hong Liang Teoh created FLINK-32535:
---
Summary: CheckpointingStatisticsHandler periodically returns
NullArgumentException after job restarts
Key: FLINK-32535
URL: https://issues.apache.org/jira/browse/FLINK-32535
Hong Liang Teoh created FLINK-32499:
---
Summary: Removing dependency of flink-connector-aws on a specific
flink-shaded version
Key: FLINK-32499
URL: https://issues.apache.org/jira/browse/FLINK-32499
P
Hong Liang Teoh created FLINK-32488:
---
Summary: Introduce configuration to control ExecutionGraph cache
in REST API
Key: FLINK-32488
URL: https://issues.apache.org/jira/browse/FLINK-32488
Project: Fl
Hong Liang Teoh created FLINK-32469:
---
Summary: Simplify the implementation of the checkpoint handlers
Key: FLINK-32469
URL: https://issues.apache.org/jira/browse/FLINK-32469
Project: Flink
Hong Liang Teoh created FLINK-32324:
---
Summary: Implement watermark alignment on KDS source
Key: FLINK-32324
URL: https://issues.apache.org/jira/browse/FLINK-32324
Project: Flink
Issue Type:
Hong Liang Teoh created FLINK-32229:
---
Summary: Implement metrics and logging for Initial implementation
Key: FLINK-32229
URL: https://issues.apache.org/jira/browse/FLINK-32229
Project: Flink
Hong Liang Teoh created FLINK-32218:
---
Summary: Implement support for parent/child shard ordering
Key: FLINK-32218
URL: https://issues.apache.org/jira/browse/FLINK-32218
Project: Flink
Issue
Hong Liang Teoh created FLINK-32116:
---
Summary: FlinkKinesisConsumer cannot stop-with-savepoint when
configured with watermark assigner and watermark tracker
Key: FLINK-32116
URL: https://issues.apache.org/jira/b
Hong Liang Teoh created FLINK-32097:
---
Summary: Implement support for Kinesis aggregation
Key: FLINK-32097
URL: https://issues.apache.org/jira/browse/FLINK-32097
Project: Flink
Issue Type: S
Hong Liang Teoh created FLINK-31990:
---
Summary: Use Flink Configuration to specify KDS Source
configuration object
Key: FLINK-31990
URL: https://issues.apache.org/jira/browse/FLINK-31990
Project: Fli
Hong Liang Teoh created FLINK-31989:
---
Summary: Update documentation
Key: FLINK-31989
URL: https://issues.apache.org/jira/browse/FLINK-31989
Project: Flink
Issue Type: Sub-task
R
Hong Liang Teoh created FLINK-31988:
---
Summary: Implement Python wrapper for new KDS source
Key: FLINK-31988
URL: https://issues.apache.org/jira/browse/FLINK-31988
Project: Flink
Issue Type:
Hong Liang Teoh created FLINK-31987:
---
Summary: Implement Table API support
Key: FLINK-31987
URL: https://issues.apache.org/jira/browse/FLINK-31987
Project: Flink
Issue Type: Sub-task
Hong Liang Teoh created FLINK-31986:
---
Summary: Implement Integration test for FLIP-27 DataStreams API
Key: FLINK-31986
URL: https://issues.apache.org/jira/browse/FLINK-31986
Project: Flink
Hong Liang Teoh created FLINK-31980:
---
Summary: Implement support for EFO in new Source
Key: FLINK-31980
URL: https://issues.apache.org/jira/browse/FLINK-31980
Project: Flink
Issue Type: Sub
Hong Liang Teoh created FLINK-31942:
---
Summary: Support Conditional Writes in DynamoDB connector
Key: FLINK-31942
URL: https://issues.apache.org/jira/browse/FLINK-31942
Project: Flink
Issue
Hong Liang Teoh created FLINK-31922:
---
Summary: Port over Kinesis Client configurations for retry and
backoff
Key: FLINK-31922
URL: https://issues.apache.org/jira/browse/FLINK-31922
Project: Flink
Hong Liang Teoh created FLINK-31813:
---
Summary: Initial implementation of Kinesis Source using FLIP-27
Key: FLINK-31813
URL: https://issues.apache.org/jira/browse/FLINK-31813
Project: Flink
Hong Liang Teoh created FLINK-31662:
---
Summary: Migrate flink-connectors-aws to new structure
Key: FLINK-31662
URL: https://issues.apache.org/jira/browse/FLINK-31662
Project: Flink
Issue Typ
Hong Liang Teoh created FLINK-31159:
---
Summary: Release Testing: Verify FLINK-30583 Provide the flame
graph to the subtask level
Key: FLINK-31159
URL: https://issues.apache.org/jira/browse/FLINK-31159
Hong Liang Teoh created FLINK-31108:
---
Summary: Use StreamARN for API calls in Kinesis Connector
Key: FLINK-31108
URL: https://issues.apache.org/jira/browse/FLINK-31108
Project: Flink
Issue
Hong Liang Teoh created FLINK-30950:
---
Summary: Remove flink-connector-aws-base from Flink main repo
Key: FLINK-30950
URL: https://issues.apache.org/jira/browse/FLINK-30950
Project: Flink
Is
Hong Liang Teoh created FLINK-30949:
---
Summary: Sync flink-connector-aws-base from Flink main to
flink-connector-aws
Key: FLINK-30949
URL: https://issues.apache.org/jira/browse/FLINK-30949
Project: F
Hong Liang Teoh created FLINK-30948:
---
Summary: Remove flink-avro-glue-schema-registry and
flink-json-glue-schema-registry from Flink main repo
Key: FLINK-30948
URL: https://issues.apache.org/jira/browse/FLINK-30
Hong Liang Teoh created FLINK-30947:
---
Summary: Sync flink-avro-glue-schema-registry and
flink-json-glue-schema-registry to flink-connector-aws
Key: FLINK-30947
URL: https://issues.apache.org/jira/browse/FLINK-30
Hong Liang Teoh created FLINK-30946:
---
Summary: Sync master Avro GlueSchemaRegistry formats
flink-connector-aws
Key: FLINK-30946
URL: https://issues.apache.org/jira/browse/FLINK-30946
Project: Flink
Hong Liang Teoh created FLINK-30853:
---
Summary: Make clear the public API for flink-avro
Key: FLINK-30853
URL: https://issues.apache.org/jira/browse/FLINK-30853
Project: Flink
Issue Type: Te
Hong Liang Teoh created FLINK-30837:
---
Summary: Remove dependency of MutableByteArrayInputStream from
flink-avro-glue-schema-registry
Key: FLINK-30837
URL: https://issues.apache.org/jira/browse/FLINK-30837
Hong Liang Teoh created FLINK-30783:
---
Summary: Add pull request template for AWS Connectors repo
Key: FLINK-30783
URL: https://issues.apache.org/jira/browse/FLINK-30783
Project: Flink
Issue
Hong Liang Teoh created FLINK-30156:
---
Summary: [FLIP-242] Blogpost about the customisable
RateLimitingStrategy in the AsyncSinkBase
Key: FLINK-30156
URL: https://issues.apache.org/jira/browse/FLINK-30156
Hong Liang Teoh created FLINK-30098:
---
Summary: Update DynamoDb Sink unit tests to JUnit 5
Key: FLINK-30098
URL: https://issues.apache.org/jira/browse/FLINK-30098
Project: Flink
Issue Type:
Hong Liang Teoh created FLINK-30096:
---
Summary: Rename DynamoDB config destinationTableName to tableName
Key: FLINK-30096
URL: https://issues.apache.org/jira/browse/FLINK-30096
Project: Flink
Hong Liang Teoh created FLINK-30092:
---
Summary: Improve Table API experience for Flink DOUBLE type
Key: FLINK-30092
URL: https://issues.apache.org/jira/browse/FLINK-30092
Project: Flink
Issu
Hong Liang Teoh created FLINK-29909:
---
Summary: Standardise connector package names
Key: FLINK-29909
URL: https://issues.apache.org/jira/browse/FLINK-29909
Project: Flink
Issue Type: Sub-tas
Hong Liang Teoh created FLINK-29900:
---
Summary: Implement Table API for DynamoDB Sink
Key: FLINK-29900
URL: https://issues.apache.org/jira/browse/FLINK-29900
Project: Flink
Issue Type: Impro
Hong Liang Teoh created FLINK-29683:
---
Summary: Introduce config parser for AWS BackoffStrategy
Key: FLINK-29683
URL: https://issues.apache.org/jira/browse/FLINK-29683
Project: Flink
Issue T
Hong Liang Teoh created FLINK-29574:
---
Summary: Upgrade software.amazon.glue:schema-registry-common and
software.amazon.glue:schema-registry-serde dependency from 1.1.8 to 1.1.14
Key: FLINK-29574
URL: https://iss
Hong Liang Teoh created FLINK-29395:
---
Summary: [Kinesis][EFO] Issue using EFO consumer at timestamp with
empty shard
Key: FLINK-29395
URL: https://issues.apache.org/jira/browse/FLINK-29395
Project:
Hong Liang Teoh created FLINK-28978:
---
Summary: [aws][connectors] Kinesis connector doesn't work for new
AWS regions
Key: FLINK-28978
URL: https://issues.apache.org/jira/browse/FLINK-28978
Project: F
Hong Liang Teoh created FLINK-28487:
---
Summary: Introduce configurable RateLimitingStrategy for Async Sink
Key: FLINK-28487
URL: https://issues.apache.org/jira/browse/FLINK-28487
Project: Flink
Hong Liang Teoh created FLINK-19226:
---
Summary: [Kinesis] [EFO] Connector reaches default max attempts
for describeStream and describeStreamConsumer when parallelism is high
Key: FLINK-19226
URL: https://issues.a
73 matches
Mail list logo
