Ahmed Hamdy created FLINK-36651:
---
Summary: Fix CI tests for ElasticSearch Connector
Key: FLINK-36651
URL: https://issues.apache.org/jira/browse/FLINK-36651
Project: Flink
Issue Type: Bug
Ahmed Hamdy created FLINK-36080:
---
Summary: Add SQL Connector for SQS
Key: FLINK-36080
URL: https://issues.apache.org/jira/browse/FLINK-36080
Project: Flink
Issue Type: Sub-task
Repo
Ahmed Hamdy created FLINK-36079:
---
Summary: Add Documentation for SQS Table API connector
Key: FLINK-36079
URL: https://issues.apache.org/jira/browse/FLINK-36079
Project: Flink
Issue Type: Sub-t
Ahmed Hamdy created FLINK-36078:
---
Summary: Add Documentation for PubSubSink Table API connector
Key: FLINK-36078
URL: https://issues.apache.org/jira/browse/FLINK-36078
Project: Flink
Issue Type
Ahmed Hamdy created FLINK-36077:
---
Summary: Implement Table API support for PubSubSink V2
Key: FLINK-36077
URL: https://issues.apache.org/jira/browse/FLINK-36077
Project: Flink
Issue Type: Sub-t
Ahmed Hamdy created FLINK-36010:
---
Summary: Duplicate Job Submission returns Succeeded on single
execution even if Global state is FAILED
Key: FLINK-36010
URL: https://issues.apache.org/jira/browse/FLINK-36010
Ahmed Hamdy created FLINK-35779:
---
Summary: Update documentation for PubSubSinkV2
Key: FLINK-35779
URL: https://issues.apache.org/jira/browse/FLINK-35779
Project: Flink
Issue Type: Sub-task
Ahmed Hamdy created FLINK-35697:
---
Summary: Release Testing: Verify FLIP-451 Introduce timeout
configuration to AsyncSink
Key: FLINK-35697
URL: https://issues.apache.org/jira/browse/FLINK-35697
Project:
Ahmed Hamdy created FLINK-35548:
---
Summary: Add E2E tests for PubSubSinkV2
Key: FLINK-35548
URL: https://issues.apache.org/jira/browse/FLINK-35548
Project: Flink
Issue Type: Sub-task
Ahmed Hamdy created FLINK-35500:
---
Summary: DynamoDb SinkWriter fails to delete elements due to key
not found
Key: FLINK-35500
URL: https://issues.apache.org/jira/browse/FLINK-35500
Project: Flink
Ahmed Hamdy created FLINK-35454:
---
Summary: Connector ArchTests fails due to dependency on
fink.util.Preconditions
Key: FLINK-35454
URL: https://issues.apache.org/jira/browse/FLINK-35454
Project: Flink
Ahmed Hamdy created FLINK-35445:
---
Summary: Update Async Sink documentation for Timeout configuration
Key: FLINK-35445
URL: https://issues.apache.org/jira/browse/FLINK-35445
Project: Flink
Issu
Ahmed Hamdy created FLINK-35435:
---
Summary: [FLIP-451] Introduce timeout configuration to AsyncSink
Key: FLINK-35435
URL: https://issues.apache.org/jira/browse/FLINK-35435
Project: Flink
Issue T
Ahmed Hamdy created FLINK-35401:
---
Summary: Add SQS Table API support
Key: FLINK-35401
URL: https://issues.apache.org/jira/browse/FLINK-35401
Project: Flink
Issue Type: New Feature
Com
Ahmed Hamdy created FLINK-35322:
---
Summary: PubSub Connector Weekly build fails
Key: FLINK-35322
URL: https://issues.apache.org/jira/browse/FLINK-35322
Project: Flink
Issue Type: Bug
Ahmed Hamdy created FLINK-35320:
---
Summary: RabbitMQ Source fails to consume from quorum queues when
prefetch Count is set
Key: FLINK-35320
URL: https://issues.apache.org/jira/browse/FLINK-35320
Project:
Ahmed Hamdy created FLINK-35050:
---
Summary: Remove Lazy Initialization of DynamoDbBeanElementConverter
Key: FLINK-35050
URL: https://issues.apache.org/jira/browse/FLINK-35050
Project: Flink
Issu
Ahmed Hamdy created FLINK-35022:
---
Summary: Add TypeInformed Element Converter for DynamoDbSink
Key: FLINK-35022
URL: https://issues.apache.org/jira/browse/FLINK-35022
Project: Flink
Issue Type:
Ahmed Hamdy created FLINK-32063:
---
Summary: AWS CI mvn compile fails to cast objects to parent type.
Key: FLINK-32063
URL: https://issues.apache.org/jira/browse/FLINK-32063
Project: Flink
Issue
Ahmed Hamdy created FLINK-32007:
---
Summary: Implement Python Wrappers for DynamoDB Connector
Key: FLINK-32007
URL: https://issues.apache.org/jira/browse/FLINK-32007
Project: Flink
Issue Type: Ne
Ahmed Hamdy created FLINK-31998:
---
Summary: Flink Operator Deadlock on run job Failure
Key: FLINK-31998
URL: https://issues.apache.org/jira/browse/FLINK-31998
Project: Flink
Issue Type: Bug
Ahmed Hamdy created FLINK-31872:
---
Summary: CLONE - AsyncSinkWriter Performance regression due to
AIMD rate limiting strategy
Key: FLINK-31872
URL: https://issues.apache.org/jira/browse/FLINK-31872
Proje
Ahmed Hamdy created FLINK-31772:
---
Summary: AsyncSinkWriter Performance regression due to AIMD rate
limiting strategy
Key: FLINK-31772
URL: https://issues.apache.org/jira/browse/FLINK-31772
Project: Flin
Ahmed Hamdy created FLINK-28333:
---
Summary: GlueSchemaRegistryAvroKinesisITCase is being Ignored due
to `Access key not configured`
Key: FLINK-28333
URL: https://issues.apache.org/jira/browse/FLINK-28333
Ahmed Hamdy created FLINK-28332:
---
Summary: GlueSchemaRegistryJsonKinesisITCase is being Ignored due
to `Access key not configured`
Key: FLINK-28332
URL: https://issues.apache.org/jira/browse/FLINK-28332
Ahmed Hamdy created FLINK-27756:
---
Summary: Fix Intermittingly failing test in `AsyncSinkWriterTest`
Key: FLINK-27756
URL: https://issues.apache.org/jira/browse/FLINK-27756
Project: Flink
Issue
Ahmed Hamdy created FLINK-26398:
---
Summary: Add documentation for Kinesis Firehose table API.
Key: FLINK-26398
URL: https://issues.apache.org/jira/browse/FLINK-26398
Project: Flink
Issue Type: S
Ahmed Hamdy created FLINK-26397:
---
Summary: Chinese Translation - Add documentation for Kinesis
firehose Table Api
Key: FLINK-26397
URL: https://issues.apache.org/jira/browse/FLINK-26397
Project: Flink
Ahmed Hamdy created FLINK-26373:
---
Summary: Rename flink-connector-aws-kinesis-data-streams module to
flink-connector-aws-kinesis-streams
Key: FLINK-26373
URL: https://issues.apache.org/jira/browse/FLINK-26373
Ahmed Hamdy created FLINK-26310:
---
Summary: [FLIP-171] Add AsyncSinkWriterConfig class
Key: FLINK-26310
URL: https://issues.apache.org/jira/browse/FLINK-26310
Project: Flink
Issue Type: Improvem
Ahmed Hamdy created FLINK-26058:
---
Summary: KinesisDynamicTableFactory implements
DynamicSourceFactory but uses sink options
Key: FLINK-26058
URL: https://issues.apache.org/jira/browse/FLINK-26058
Projec
Ahmed Hamdy created FLINK-26057:
---
Summary: CLONE - [FLIP-171] Add SQL Client Uber jar for
KinesisDataStreams Sink.
Key: FLINK-26057
URL: https://issues.apache.org/jira/browse/FLINK-26057
Project: Flink
Ahmed Hamdy created FLINK-26056:
---
Summary: CLONE - [FLIP-171] KDS implementation of Async Sink Table
API
Key: FLINK-26056
URL: https://issues.apache.org/jira/browse/FLINK-26056
Project: Flink
Ahmed Hamdy created FLINK-25949:
---
Summary: [FLIP-171] Kinesis Firehose sink builder falls back to
wrong http protocol.
Key: FLINK-25949
URL: https://issues.apache.org/jira/browse/FLINK-25949
Project: Fl
Ahmed Hamdy created FLINK-25811:
---
Summary: Fix generic AsyncSinkWriter retrying requests in reverse
order
Key: FLINK-25811
URL: https://issues.apache.org/jira/browse/FLINK-25811
Project: Flink
Ahmed Hamdy created FLINK-25810:
---
Summary: [FLIP-171] Add Uber-jar for sql connector for
KinesisDataStreams.
Key: FLINK-25810
URL: https://issues.apache.org/jira/browse/FLINK-25810
Project: Flink
Ahmed Hamdy created FLINK-25734:
---
Summary: Chinese Translation - Update documentation for Kinesis
Table Api
Key: FLINK-25734
URL: https://issues.apache.org/jira/browse/FLINK-25734
Project: Flink
Ahmed Hamdy created FLINK-25733:
---
Summary: [FLIP-171] Create A migration guide for Kinesis Table API
connector
Key: FLINK-25733
URL: https://issues.apache.org/jira/browse/FLINK-25733
Project: Flink
Ahmed Hamdy created FLINK-25610:
---
Summary: [FLIP-171] Kinesis Firehose implementation of Async Sink
Table API
Key: FLINK-25610
URL: https://issues.apache.org/jira/browse/FLINK-25610
Project: Flink
39 matches
Mail list logo
