[jira] [Created] (FLINK-35532) Prevent Cross-Site Authentication (XSA) attacks on Flink dashboard

2024-06-05 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-35512) ArtifactFetchManagerTest unit tests fail

2024-06-03 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-35299) FlinkKinesisConsumer does not respect StreamInitialPosition for new Kinesis Stream when restoring from snapshot

2024-05-06 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-35299: --- Summary: FlinkKinesisConsumer does not respect StreamInitialPosition for new Kinesis Stream when restoring from snapshot Key: FLINK-35299 URL:

[jira] [Created] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-18 Thread Hong Liang Teoh (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

[jira] [Created] (FLINK-33259) flink-connector-aws should use/extend the common connector workflow

2023-10-12 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-33167) Run IT tests against Kinesalite if AWS credentials are not present

2023-09-28 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-33073) Implement end-to-end tests for the Kinesis Streams Sink

2023-09-11 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-33072) Implement end-to-end tests for AWS Kinesis Connectors

2023-09-11 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32703) [hotfix] flink-python POM has a typo for protobuf-java in shading config

2023-07-27 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32619) ConfigOptions to support fallback configuration

2023-07-18 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32537) Add compatibility annotation for REST API classes

2023-07-04 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32535) CheckpointingStatisticsHandler periodically returns NullArgumentException after job restarts

2023-07-04 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-32535: --- Summary: CheckpointingStatisticsHandler periodically returns NullArgumentException after job restarts Key: FLINK-32535 URL:

[jira] [Created] (FLINK-32499) Removing dependency of flink-connector-aws on a specific flink-shaded version

2023-06-30 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32488) Introduce configuration to control ExecutionGraph cache in REST API

2023-06-29 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-32469) Simplify the implementation of the checkpoint handlers

2023-06-28 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32324) Implement watermark alignment on KDS source

2023-06-13 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32229) Implement metrics and logging for Initial implementation

2023-05-31 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32218) Implement support for parent/child shard ordering

2023-05-30 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-32116) FlinkKinesisConsumer cannot stop-with-savepoint when configured with watermark assigner and watermark tracker

2023-05-17 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-32116: --- Summary: FlinkKinesisConsumer cannot stop-with-savepoint when configured with watermark assigner and watermark tracker Key: FLINK-32116 URL:

[jira] [Created] (FLINK-32097) Implement support for Kinesis aggregation

2023-05-15 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-31990) Use Flink Configuration to specify KDS Source configuration object

2023-05-03 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-31989) Update documentation

2023-05-03 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31988) Implement Python wrapper for new KDS source

2023-05-03 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31987) Implement Table API support

2023-05-03 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31986) Implement Integration test for FLIP-27 DataStreams API

2023-05-03 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31980) Implement support for EFO in new Source

2023-05-02 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-31942) Support Conditional Writes in DynamoDB connector

2023-04-25 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31922) Port over Kinesis Client configurations for retry and backoff

2023-04-24 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31813) Initial implementation of Kinesis Source using FLIP-27

2023-04-14 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31662) Migrate flink-connectors-aws to new structure

2023-03-29 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-20 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-31108) Use StreamARN for API calls in Kinesis Connector

2023-02-16 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30950) Remove flink-connector-aws-base from Flink main repo

2023-02-07 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30949) Sync flink-connector-aws-base from Flink main to flink-connector-aws

2023-02-07 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-30948) Remove flink-avro-glue-schema-registry and flink-json-glue-schema-registry from Flink main repo

2023-02-07 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-30947) Sync flink-avro-glue-schema-registry and flink-json-glue-schema-registry to flink-connector-aws

2023-02-07 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-30946) Sync master Avro GlueSchemaRegistry formats flink-connector-aws

2023-02-07 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30853) Make clear the public API for flink-avro

2023-01-31 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-30837) Remove dependency of MutableByteArrayInputStream from flink-avro-glue-schema-registry

2023-01-30 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30783) Add pull request template for AWS Connectors repo

2023-01-25 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30156) [FLIP-242] Blogpost about the customisable RateLimitingStrategy in the AsyncSinkBase

2022-11-22 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30098) Update DynamoDb Sink unit tests to JUnit 5

2022-11-19 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-30096) Rename DynamoDB config destinationTableName to tableName

2022-11-19 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-30092) Improve Table API experience for Flink DOUBLE type

2022-11-18 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-29909) Standardise connector package names

2022-11-05 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-29900) Implement Table API for DynamoDB Sink

2022-11-05 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-29683) Introduce config parser for AWS BackoffStrategy

2022-10-18 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-29574) Upgrade software.amazon.glue:schema-registry-common and software.amazon.glue:schema-registry-serde dependency from 1.1.8 to 1.1.14

2022-10-10 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-09-22 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-28978) [aws][connectors] Kinesis connector doesn't work for new AWS regions

2022-08-15 Thread Hong Liang Teoh (Jira)
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:

[jira] [Created] (FLINK-28487) Introduce configurable RateLimitingStrategy for Async Sink

2022-07-11 Thread Hong Liang Teoh (Jira)
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

[jira] [Created] (FLINK-19226) [Kinesis] [EFO] Connector reaches default max attempts for describeStream and describeStreamConsumer when parallelism is high

2020-09-14 Thread Hong Liang Teoh (Jira)
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: