[jira] [Commented] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

2017-08-11 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123262#comment-16123262 ] Gábor Hermann commented on FLINK-3133: -- What's the status of this? We alr

[jira] [Commented] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

2017-08-22 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136684#comment-16136684 ] Gábor Hermann commented on FLINK-3133: -- [~aljoscha], [~kenmy] thanks for

[jira] [Commented] (FLINK-4947) Make all configuration possible via flink-conf.yaml and CLI.

2017-08-22 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136704#comment-16136704 ] Gábor Hermann commented on FLINK-4947: -- Would this make every configura

[jira] [Commented] (FLINK-4947) Make all configuration possible via flink-conf.yaml and CLI.

2017-08-23 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16138127#comment-16138127 ] Gábor Hermann commented on FLINK-4947: -- [~jgrier] Thanks for the clarificatio

[jira] [Commented] (FLINK-13836) Improve support of java.util.UUID for JDBCTypeUtil

2019-08-28 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917735#comment-16917735 ] François Lacombe commented on FLINK-13836: -- HI  [~jark] UUID is actual

[jira] [Created] (FLINK-13925) ClassLoader in BlobLibraryCacheManager is not using context class loader

2019-08-30 Thread Jira
Jan Lukavský created FLINK-13925: Summary: ClassLoader in BlobLibraryCacheManager is not using context class loader Key: FLINK-13925 URL: https://issues.apache.org/jira/browse/FLINK-13925 Project

[jira] [Created] (FLINK-13945) Vendor-repos Maven profile doesn't exist in flink-shaded

2019-09-03 Thread Jira
Elise Ramé created FLINK-13945: -- Summary: Vendor-repos Maven profile doesn't exist in flink-shaded Key: FLINK-13945 URL: https://issues.apache.org/jira/browse/FLINK-13945 Project: Flink

[jira] [Commented] (FLINK-13925) ClassLoader in BlobLibraryCacheManager is not using context class loader

2019-09-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16922242#comment-16922242 ] Jan Lukavský commented on FLINK-13925: -- Hi [~jark], it's fine, there s

[jira] [Assigned] (FLINK-13957) Redact passwords from dynamic properties on job submission

2019-09-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-13957: -- Assignee: Matyas Orhidi > Redact passwords from dynamic properties on job submiss

[jira] [Commented] (FLINK-13957) Redact passwords from dynamic properties on job submission

2019-09-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16922423#comment-16922423 ] Márton Balassi commented on FLINK-13957: Thanks for reporting the i

[jira] [Closed] (FLINK-13957) Redact passwords from dynamic properties logged on job submission

2019-09-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-13957. -- Resolution: Invalid The issue fortunately did not make it to the upstream implementation, was

[jira] [Updated] (FLINK-13957) Log dynamic properties on job submission

2019-09-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-13957: --- Summary: Log dynamic properties on job submission (was: Redact passwords from dynamic

[jira] [Reopened] (FLINK-13957) Log dynamic properties on job submission

2019-09-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reopened FLINK-13957: > Log dynamic properties on job submiss

[jira] [Issue Comment Deleted] (FLINK-13957) Log dynamic properties on job submission

2019-09-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-13957: --- Comment: was deleted (was: The issue fortunately did not make it to the upstream

[jira] [Updated] (FLINK-13957) Log dynamic properties on job submission

2019-09-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-13957: --- Description: This would let users understand their job submissions better, expected output

[jira] [Closed] (FLINK-13957) Log dynamic properties on job submission

2019-09-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-13957. -- Resolution: Implemented Implemented via 2ce6938. > Log dynamic properties on job submiss

[jira] [Commented] (FLINK-13836) Improve support of java.util.UUID for JDBCTypeUtil

2019-09-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935777#comment-16935777 ] François Lacombe commented on FLINK-13836: -- Hi [~jark] I don't under

[jira] [Created] (FLINK-14173) ANSI-style JOIN with Temporal Table Function fails

2019-09-23 Thread Jira
Benoît Paris created FLINK-14173: Summary: ANSI-style JOIN with Temporal Table Function fails Key: FLINK-14173 URL: https://issues.apache.org/jira/browse/FLINK-14173 Project: Flink Issue

[jira] [Comment Edited] (FLINK-14173) ANSI-style JOIN with Temporal Table Function fails

2019-09-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-14173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936597#comment-16936597 ] Benoît Paris edited comment on FLINK-14173 at 9/24/19 9:2

[jira] [Commented] (FLINK-14173) ANSI-style JOIN with Temporal Table Function fails

2019-09-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-14173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936597#comment-16936597 ] Benoît Paris commented on FLINK-14173: -- Hi [~jark]! I was so sure I used the

[jira] [Commented] (FLINK-13836) Improve support of java.util.UUID for JDBCTypeUtil

2019-09-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936915#comment-16936915 ] François Lacombe commented on FLINK-13836: -- Given problem isn't on

[jira] [Commented] (FLINK-14173) ANSI-style JOIN with Temporal Table Function fails

2019-09-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-14173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936942#comment-16936942 ] Benoît Paris commented on FLINK-14173: -- @[~lzljs3620320], ah I get it. The W

[jira] [Created] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side

2019-09-24 Thread Jira
Benoît Paris created FLINK-14200: Summary: Temporal Table Function Joins do not work on Tables (only TableSources) on the query side Key: FLINK-14200 URL: https://issues.apache.org/jira/browse/FLINK-14200

[jira] [Updated] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side

2019-09-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-14200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-14200: - Description: This only affects the Blink planner. The legacy planner works fine. With Orders

[jira] [Updated] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side

2019-09-24 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-14200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-14200: - Description: This only affects the Blink planner. The legacy planner works fine. With Orders

[jira] [Created] (FLINK-14297) Temporal Table Function Build Side does not accept a constant key

2019-09-30 Thread Jira
Benoît Paris created FLINK-14297: Summary: Temporal Table Function Build Side does not accept a constant key Key: FLINK-14297 URL: https://issues.apache.org/jira/browse/FLINK-14297 Project: Flink

[jira] [Updated] (FLINK-14297) Temporal Table Function Build Side does not accept a constant key

2019-09-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-14297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-14297: - Description: When defining a table that will be used as the build side on a Temporal Table

[jira] [Updated] (FLINK-14297) Temporal Table Function Build Side does not accept a constant key

2019-09-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-14297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-14297: - Description: When defining a table that will be used as the build side on a Temporal Table

[jira] [Updated] (FLINK-14297) Temporal Table Function Build Side does not accept a constant key

2019-09-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-14297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-14297: - Description: When defining a table that will be used as the build side on a Temporal Table

[jira] [Updated] (FLINK-14297) Temporal Table Function Build Side does not accept a constant key

2019-09-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-14297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-14297: - Description: When defining a table that will be used as the build side on a Temporal Table

[jira] [Updated] (FLINK-14297) Temporal Table Function Build Side does not accept a constant key

2019-09-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-14297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-14297: - Description: When defining a table that will be used as the build side on a Temporal Table

[jira] [Updated] (FLINK-14297) Temporal Table Function Build Side does not accept a constant key

2019-09-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-14297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-14297: - Description: When defining a table that will be used as the build side on a Temporal Table

[jira] [Commented] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side

2019-10-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-14200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950839#comment-16950839 ] Benoît Paris commented on FLINK-14200: -- [As mentioned in the mailing-list|

[jira] [Reopened] (FLINK-12461) Flink 1.8 not working with Scala 2.12.8

2019-05-15 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-12461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gaël Renoux reopened FLINK-12461: - If compiling with Scala 2.12.8 is not an option, we should at least update the documentation with

[jira] [Commented] (FLINK-12303) Scala 2.12 lambdas does not work in event classes inside streams.

2019-05-15 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-12303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16840509#comment-16840509 ] Matěj Novotný commented on FLINK-12303: --- [~aljoscha] I would say that You d

[jira] [Reopened] (FLINK-12303) Scala 2.12 lambdas does not work in event classes inside streams.

2019-05-15 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-12303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matěj Novotný reopened FLINK-12303: --- closed for incorrect reason > Scala 2.12 lambdas does not work in event classes inside stre

[jira] [Created] (FLINK-12532) Upgrade Avro to version 1.9.0

2019-05-16 Thread JIRA
Ismaël Mejía created FLINK-12532: Summary: Upgrade Avro to version 1.9.0 Key: FLINK-12532 URL: https://issues.apache.org/jira/browse/FLINK-12532 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-12303) Scala 2.12 lambdas does not work in event classes inside streams.

2019-05-16 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-12303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841408#comment-16841408 ] Matěj Novotný commented on FLINK-12303: --- [~aljoscha], thank you for showin

[jira] [Created] (FLINK-12782) Show formatted timestamp in Watermark Tab of JM Web UI

2019-06-07 Thread JIRA
Felix Wollschläger created FLINK-12782: -- Summary: Show formatted timestamp in Watermark Tab of JM Web UI Key: FLINK-12782 URL: https://issues.apache.org/jira/browse/FLINK-12782 Project: Flink

[jira] [Created] (FLINK-35564) The topic cannot be distributed on subtask when calculatePartitionOwner returns -1

2024-06-11 Thread Jira
中国无锡周良 created FLINK-35564: -- Summary: The topic cannot be distributed on subtask when calculatePartitionOwner returns -1 Key: FLINK-35564 URL: https://issues.apache.org/jira/browse/FLINK-35564 Project

[jira] [Closed] (FLINK-35116) Upgrade JOSDK dependency to 4.8.3

2024-06-11 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-35116. -- Resolution: Fixed Thanks [~mateczagany] ! Indeed. > Upgrade JOSDK dependency to 4.

[jira] [Created] (FLINK-35706) FLIP-463: Schema Definition in CREATE TABLE AS Statement

2024-06-26 Thread Jira
Sergio Peña created FLINK-35706: --- Summary: FLIP-463: Schema Definition in CREATE TABLE AS Statement Key: FLINK-35706 URL: https://issues.apache.org/jira/browse/FLINK-35706 Project: Flink Issue

[jira] [Created] (FLINK-35707) Allow column definition in CREATE TABLE AS (CTAS)

2024-06-26 Thread Jira
Sergio Peña created FLINK-35707: --- Summary: Allow column definition in CREATE TABLE AS (CTAS) Key: FLINK-35707 URL: https://issues.apache.org/jira/browse/FLINK-35707 Project: Flink Issue Type

[jira] [Created] (FLINK-35708) Allow defining a schema in REPLACE TABLE AS (RTAS)

2024-06-26 Thread Jira
Sergio Peña created FLINK-35708: --- Summary: Allow defining a schema in REPLACE TABLE AS (RTAS) Key: FLINK-35708 URL: https://issues.apache.org/jira/browse/FLINK-35708 Project: Flink Issue Type

[jira] [Created] (FLINK-35709) Allow reordering source column names in CTAS / RTAS

2024-06-26 Thread Jira
Sergio Peña created FLINK-35709: --- Summary: Allow reordering source column names in CTAS / RTAS Key: FLINK-35709 URL: https://issues.apache.org/jira/browse/FLINK-35709 Project: Flink Issue Type

[jira] [Created] (FLINK-35717) Allow DISTRIBUTED BY in CREATE TABLE AS (CTAS)

2024-06-27 Thread Jira
Sergio Peña created FLINK-35717: --- Summary: Allow DISTRIBUTED BY in CREATE TABLE AS (CTAS) Key: FLINK-35717 URL: https://issues.apache.org/jira/browse/FLINK-35717 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-35788) Deprecate old InputFormat and SinkFunction

2024-07-08 Thread Jira
João Boto created FLINK-35788: - Summary: Deprecate old InputFormat and SinkFunction Key: FLINK-35788 URL: https://issues.apache.org/jira/browse/FLINK-35788 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35789) Allow WATERMARK & PRIMARY KEY in CREATE TABLE AS (CTAS)

2024-07-08 Thread Jira
Sergio Peña created FLINK-35789: --- Summary: Allow WATERMARK & PRIMARY KEY in CREATE TABLE AS (CTAS) Key: FLINK-35789 URL: https://issues.apache.org/jira/browse/FLINK-35789 Project: Flink I

[jira] [Updated] (FLINK-35789) Allow defining watermarks & PRIMARY KEY in CREATE TABLE AS (CTAS)

2024-07-08 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergio Peña updated FLINK-35789: Summary: Allow defining watermarks & PRIMARY KEY in CREATE TABLE AS (CTAS) (was: Allow WATER

[jira] [Created] (FLINK-35790) Update docs for new schema definition in CTAS and RTAS

2024-07-08 Thread Jira
Sergio Peña created FLINK-35790: --- Summary: Update docs for new schema definition in CTAS and RTAS Key: FLINK-35790 URL: https://issues.apache.org/jira/browse/FLINK-35790 Project: Flink Issue

[jira] [Updated] (FLINK-35788) Deprecate old InputFormat and SinkFunction

2024-07-09 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto updated FLINK-35788: -- Description: Need to change TableApi to use new Source and Sink. After the change we can start

[jira] [Updated] (FLINK-35367) Reorganize sinks

2024-07-09 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto updated FLINK-35367: -- Description: Reorganize datastream sink (was: Reorganize datastream sink and source) > Reorgan

[jira] [Updated] (FLINK-35494) Reorganize sources

2024-07-09 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto updated FLINK-35494: -- Description: Reorganize datastream source > Reorganize sour

[jira] [Updated] (FLINK-35706) FLIP-463: Allow defining partition keys and table distribution in CREATE TABLE AS (CTAS)

2024-07-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergio Peña updated FLINK-35706: Summary: FLIP-463: Allow defining partition keys and table distribution in CREATE TABLE AS (CTAS

[jira] [Updated] (FLINK-35706) FLIP-463: Schema Definition in CREATE TABLE AS Statement

2024-07-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergio Peña updated FLINK-35706: Summary: FLIP-463: Schema Definition in CREATE TABLE AS Statement (was: FLIP-463: Allow defining

[jira] [Created] (FLINK-35809) Deploying Flink History Server and Flink SQL Gateway via Flink Operator.

2024-07-10 Thread Jira
钟洋洋 created FLINK-35809: --- Summary: Deploying Flink History Server and Flink SQL Gateway via Flink Operator. Key: FLINK-35809 URL: https://issues.apache.org/jira/browse/FLINK-35809 Project: Flink

[jira] [Commented] (FLINK-35081) CompileException when watermark definition contains coalesce and to_timestamp built-in functions

2024-07-17 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866732#comment-17866732 ] Grzegorz Kołakowski commented on FLINK-35081: - [~xuyangzhong] You are r

[jira] [Resolved] (FLINK-35081) CompileException when watermark definition contains coalesce and to_timestamp built-in functions

2024-07-17 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grzegorz Kołakowski resolved FLINK-35081. - Fix Version/s: 1.18.2 1.20.0 1.19.1

[jira] [Commented] (FLINK-35376) When flink submits the job by calling the rest api, the dependent jar package generated to the tmp is not removed

2024-07-18 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867143#comment-17867143 ] 中国无锡周良 commented on FLINK-35376: Will this differ from Flink's different d

[jira] [Created] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered

2024-07-19 Thread Jira
Grzegorz Kołakowski created FLINK-35869: --- Summary: Right side columns of temporal left join are always null when right side is filtered Key: FLINK-35869 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Updated] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered

2024-07-19 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grzegorz Kołakowski updated FLINK-35869: Description: Background: I have a stream of user information updates, but those

[jira] [Updated] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered

2024-07-19 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grzegorz Kołakowski updated FLINK-35869: Description: Background: I have a stream of user information updates, but those

[jira] [Updated] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered

2024-07-19 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grzegorz Kołakowski updated FLINK-35869: Description: Background: I have a stream of user information updates in Kafka

[jira] [Updated] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered

2024-07-19 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grzegorz Kołakowski updated FLINK-35869: Description: Background: I have a stream of user information updates in Kafka

[jira] [Updated] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered

2024-07-19 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grzegorz Kołakowski updated FLINK-35869: Description: Background: I have a stream of user information updates in Kafka

[jira] [Updated] (FLINK-35869) Right side columns of temporal left join are always null when right side is filtered

2024-07-19 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grzegorz Kołakowski updated FLINK-35869: Description: Background: I have a stream of user information updates in Kafka

[jira] [Created] (FLINK-35875) Flink cdc frequently encounters LabelAlreadyExists errors

2024-07-22 Thread Jira
牛一凡 created FLINK-35875: --- Summary: Flink cdc frequently encounters LabelAlreadyExists errors Key: FLINK-35875 URL: https://issues.apache.org/jira/browse/FLINK-35875 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34414) EXACTLY_ONCE guarantee doesn't work properly for Flink/Pulsar connector

2024-02-08 Thread Jira
Rafał Trójczak created FLINK-34414: -- Summary: EXACTLY_ONCE guarantee doesn't work properly for Flink/Pulsar connector Key: FLINK-34414 URL: https://issues.apache.org/jira/browse/FLINK-34414 Pr

[jira] [Commented] (FLINK-34414) EXACTLY_ONCE guarantee doesn't work properly for Flink/Pulsar connector

2024-02-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822063#comment-17822063 ] Rafał Trójczak commented on FLINK-34414: Hello All, I would like to ki

[jira] [Commented] (FLINK-33011) Operator deletes HA data unexpectedly

2023-10-19 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1209#comment-1209 ] Pedro Mázala commented on FLINK-33011: -- [~gyfora] Thank you for the fix :mu

[jira] [Assigned] (FLINK-32671) Document Externalized Declarative Resource Management

2023-10-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek reassigned FLINK-32671: - Assignee: David Morávek > Document Externalized Declarative Resource Managem

[jira] [Updated] (FLINK-32671) Document Externalized Declarative Resource Management

2023-10-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-32671: -- Fix Version/s: 1.18.0 > Document Externalized Declarative Resource Managem

[jira] [Commented] (FLINK-32671) Document Externalized Declarative Resource Management

2023-10-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17778838#comment-17778838 ] David Morávek commented on FLINK-32671: --- ma

[jira] [Commented] (FLINK-32671) Document Externalized Declarative Resource Management

2023-10-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17778840#comment-17778840 ] David Morávek commented on FLINK-32671: --- [~ConradJam] I've prepar

[jira] [Resolved] (FLINK-32671) Document Externalized Declarative Resource Management

2023-10-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek resolved FLINK-32671. --- Resolution: Fixed > Document Externalized Declarative Resource Managem

[jira] [Created] (FLINK-33357) add Apache Software License 2

2023-10-24 Thread Jira
蔡灿材 created FLINK-33357: --- Summary: add Apache Software License 2 Key: FLINK-33357 URL: https://issues.apache.org/jira/browse/FLINK-33357 Project: Flink Issue Type: Improvement Components

[jira] [Created] (FLINK-33378) Bump flink version on flink-connectors-jdbc

2023-10-27 Thread Jira
João Boto created FLINK-33378: - Summary: Bump flink version on flink-connectors-jdbc Key: FLINK-33378 URL: https://issues.apache.org/jira/browse/FLINK-33378 Project: Flink Issue Type

[jira] [Created] (FLINK-33393) flink document description error

2023-10-30 Thread Jira
蔡灿材 created FLINK-33393: --- Summary: flink document description error Key: FLINK-33393 URL: https://issues.apache.org/jira/browse/FLINK-33393 Project: Flink Issue Type: Improvement Components

[jira] [Updated] (FLINK-33393) flink document description error

2023-10-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 蔡灿材 updated FLINK-33393: Attachment: (was: 捕获.PNG) > flink document description er

[jira] [Updated] (FLINK-33393) flink document description error

2023-10-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 蔡灿材 updated FLINK-33393: Attachment: 捕获.PNG > flink document description error > > >

[jira] [Closed] (FLINK-33427) Mark new relocated autoscaler configs IGNORE in the operator

2023-11-02 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-33427. -- Resolution: Fixed [{{81a2d99}}|https://github.com/apache/flink-kubernetes-operator/commit

[jira] [Commented] (FLINK-25420) Port JDBC Source to new Source API (FLIP-27)

2023-11-06 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783286#comment-17783286 ] João Boto commented on FLINK-25420: --- Sounds good [~RocMarshal] > Port JDBC So

[jira] [Updated] (FLINK-33295) Separate SinkV2 and SinkV1Adapter tests

2023-11-08 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-33295: --- Fix Version/s: 1.19.0 > Separate SinkV2 and SinkV1Adapter te

[jira] [Closed] (FLINK-33295) Separate SinkV2 and SinkV1Adapter tests

2023-11-08 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-33295. -- Resolution: Implemented [{{92951a0}}|https://github.com/apache/flink/commit

[jira] [Created] (FLINK-33528) Externalize Python connector code

2023-11-12 Thread Jira
Márton Balassi created FLINK-33528: -- Summary: Externalize Python connector code Key: FLINK-33528 URL: https://issues.apache.org/jira/browse/FLINK-33528 Project: Flink Issue Type: Technical

[jira] [Closed] (FLINK-25857) Add committer metrics to track the status of committables

2023-11-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-25857. -- Fix Version/s: 1.19.0 Resolution: Implemented [{{c3a07f9}}|https://github.com/apache

[jira] [Commented] (FLINK-33528) Externalize Python connector code

2023-11-14 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785947#comment-17785947 ] Márton Balassi commented on FLINK-33528: [~pvary] is taking a stab a

[jira] [Assigned] (FLINK-33528) Externalize Python connector code

2023-11-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-33528: -- Assignee: Peter Vary > Externalize Python connector c

[jira] [Created] (FLINK-33556) Test infrastructure for externalized python code

2023-11-15 Thread Jira
Márton Balassi created FLINK-33556: -- Summary: Test infrastructure for externalized python code Key: FLINK-33556 URL: https://issues.apache.org/jira/browse/FLINK-33556 Project: Flink Issue

[jira] [Created] (FLINK-33557) Externalize Cassandra Python connector code

2023-11-15 Thread Jira
Márton Balassi created FLINK-33557: -- Summary: Externalize Cassandra Python connector code Key: FLINK-33557 URL: https://issues.apache.org/jira/browse/FLINK-33557 Project: Flink Issue Type

[jira] [Created] (FLINK-33558) Externalize Elasticsearch Python connector code

2023-11-15 Thread Jira
Márton Balassi created FLINK-33558: -- Summary: Externalize Elasticsearch Python connector code Key: FLINK-33558 URL: https://issues.apache.org/jira/browse/FLINK-33558 Project: Flink Issue

[jira] [Created] (FLINK-33559) Externalize Kafka Python connector code

2023-11-15 Thread Jira
Márton Balassi created FLINK-33559: -- Summary: Externalize Kafka Python connector code Key: FLINK-33559 URL: https://issues.apache.org/jira/browse/FLINK-33559 Project: Flink Issue Type: Sub

[jira] [Updated] (FLINK-33557) Externalize Cassandra Python connector code

2023-11-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-33557: --- Affects Version/s: 1.18.0 > Externalize Cassandra Python connector c

[jira] [Updated] (FLINK-33558) Externalize Elasticsearch Python connector code

2023-11-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-33558: --- Fix Version/s: 1.19.0 > Externalize Elasticsearch Python connector c

[jira] [Updated] (FLINK-33558) Externalize Elasticsearch Python connector code

2023-11-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-33558: --- Affects Version/s: 1.18.0 > Externalize Elasticsearch Python connector c

[jira] [Updated] (FLINK-33557) Externalize Cassandra Python connector code

2023-11-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-33557: --- Fix Version/s: 1.19.0 > Externalize Cassandra Python connector c

[jira] [Created] (FLINK-33560) Externalize Kinesis Python connector code

2023-11-15 Thread Jira
Márton Balassi created FLINK-33560: -- Summary: Externalize Kinesis Python connector code Key: FLINK-33560 URL: https://issues.apache.org/jira/browse/FLINK-33560 Project: Flink Issue Type

[jira] [Updated] (FLINK-33558) Externalize Elasticsearch Python connector code

2023-11-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-33558: --- Component/s: API / Python Connectors / ElasticSearch > External

[jira] [Updated] (FLINK-33557) Externalize Cassandra Python connector code

2023-11-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-33557: --- Component/s: API / Python Connectors / Cassandra > Externalize Cassan

[jira] [Updated] (FLINK-33559) Externalize Kafka Python connector code

2023-11-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-33559: --- Component/s: API / Python Connectors / Kafka > Externalize Kafka Pyt

<    1   2   3   4   5   6   7   8   9   10   >