[jira] [Created] (FLINK-36975) Invalid ConfigOption for "aws.credentials.provider.role.provider" in AWSConfigOptions

2024-12-27 Thread Mohsen Rezaei (Jira)
Mohsen Rezaei created FLINK-36975: - Summary: Invalid ConfigOption for "aws.credentials.provider.role.provider" in AWSConfigOptions Key: FLINK-36975 URL: https://issues.apache.org/jira/browse/F

[jira] [Created] (FLINK-36713) NoSuchMethodError: PostgresConnection with PostgresIncrementalSource ar runtime

2024-11-13 Thread Mohsen Rezaei (Jira)
Mohsen Rezaei created FLINK-36713: - Summary: NoSuchMethodError: PostgresConnection with PostgresIncrementalSource ar runtime Key: FLINK-36713 URL: https://issues.apache.org/jira/browse/FLINK-36713

[jira] [Created] (FLINK-33487) Add the new Snowflake connector to supported list

2023-11-08 Thread Mohsen Rezaei (Jira)
Mohsen Rezaei created FLINK-33487: - Summary: Add the new Snowflake connector to supported list Key: FLINK-33487 URL: https://issues.apache.org/jira/browse/FLINK-33487 Project: Flink Issue

Re: [DISCUSS] FLINK-32737: At-least-once sink connector for Snowflake

2023-11-07 Thread Mohsen Rezaei
This is now available as an open-source project: https://github.com/deltastreaminc/flink-connector-snowflake The first version, {{1.0.7-1.17}} is published on the Maven Central. On Tue, Aug 8, 2023 at 10:56 PM Mohsen Rezaei wrote: > Hi all, > > I'm in the process of writing a

[DISCUSS] FLINK-32737: At-least-once sink connector for Snowflake

2023-08-08 Thread Mohsen Rezaei
Hi all, I'm in the process of writing a Snowflake sink connector much like the one described in FLINK-32737 [1], and I was interested in contributing the code back to Flink. I'm hoping to eventually add exactly-once semantics as described by the Snowflake documentation [2], and I'm looking forwar

[jira] [Created] (FLINK-32737) Add support for Snowflake sink connector

2023-08-02 Thread Mohsen Rezaei (Jira)
Mohsen Rezaei created FLINK-32737: - Summary: Add support for Snowflake sink connector Key: FLINK-32737 URL: https://issues.apache.org/jira/browse/FLINK-32737 Project: Flink Issue Type: New

[jira] [Created] (FLINK-31760) COALESCE() with NULL arguments throws error

2023-04-10 Thread Mohsen Rezaei (Jira)
Mohsen Rezaei created FLINK-31760: - Summary: COALESCE() with NULL arguments throws error Key: FLINK-31760 URL: https://issues.apache.org/jira/browse/FLINK-31760 Project: Flink Issue Type

[jira] [Created] (FLINK-31661) Add parity between `ROW` value function and it's type declaration

2023-03-29 Thread Mohsen Rezaei (Jira)
Mohsen Rezaei created FLINK-31661: - Summary: Add parity between `ROW` value function and it's type declaration Key: FLINK-31661 URL: https://issues.apache.org/jira/browse/FLINK-31661 Project:

Fwd: [FLINK-30596] Duplicate jobs on /run with the same jobId

2023-02-09 Thread Mohsen Rezaei
rt it back to 1.16.2 and 1.15.4 to close the loop on the issue for the last three major releases: https://github.com/apache/flink/pull/21849 Cheers, Mohsen Rezaei -- Forwarded message ----- From: Mohsen Rezaei Date: Sat, Jan 21, 2023 at 5:58 PM Subject: Duplicate jobs on /run with the

[jira] [Created] (FLINK-30596) Multiple POST /jars/:jarid/run requests with the same jobId, runs duplicate jobs

2023-01-06 Thread Mohsen Rezaei (Jira)
Mohsen Rezaei created FLINK-30596: - Summary: Multiple POST /jars/:jarid/run requests with the same jobId, runs duplicate jobs Key: FLINK-30596 URL: https://issues.apache.org/jira/browse/FLINK-30596