[jira] [Updated] (FLINK-34477) support capture groups in REGEXP_REPLACE

2024-02-20 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-34477: --- Description: For example, I would expect this query {code:java} select REGEXP_REPLACE('ERR1,

[jira] [Updated] (FLINK-34477) support capture groups in REGEXP_REPLACE

2024-02-20 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-34477: --- Description: For example, I would expect this query {code:java} select REGEXP_REPLACE('ERR1,

[jira] [Created] (FLINK-34477) support capture groups in REGEXP_REPLACE

2024-02-20 Thread David Anderson (Jira)
David Anderson created FLINK-34477: -- Summary: support capture groups in REGEXP_REPLACE Key: FLINK-34477 URL: https://issues.apache.org/jira/browse/FLINK-34477 Project: Flink Issue Type: Impr

[jira] [Updated] (FLINK-34477) support capture groups in REGEXP_REPLACE

2024-02-20 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-34477: --- Affects Version/s: 1.18.1 > support capture groups in REGEXP_REPLACE > -

[jira] [Resolved] (FLINK-32099) create flink_data volume for operations playground

2023-05-15 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson resolved FLINK-32099. Fix Version/s: 1.17.1 Resolution: Implemented > create flink_data volume for operat

[jira] [Commented] (FLINK-32099) create flink_data volume for operations playground

2023-05-15 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722688#comment-17722688 ] David Anderson commented on FLINK-32099: fixed in playground master with d0ce3d8

[jira] [Created] (FLINK-32099) create flink_data volume for operations playground

2023-05-15 Thread David Anderson (Jira)
David Anderson created FLINK-32099: -- Summary: create flink_data volume for operations playground Key: FLINK-32099 URL: https://issues.apache.org/jira/browse/FLINK-32099 Project: Flink Issue

[jira] [Commented] (FLINK-31388) restart from savepoint fails with "userVisibleTail should not be larger than offset. This is a bug."

2023-03-09 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17698642#comment-17698642 ] David Anderson commented on FLINK-31388: [~fsk119] maybe you have an idea about

[jira] [Created] (FLINK-31388) restart from savepoint fails with "userVisibleTail should not be larger than offset. This is a bug."

2023-03-09 Thread David Anderson (Jira)
David Anderson created FLINK-31388: -- Summary: restart from savepoint fails with "userVisibleTail should not be larger than offset. This is a bug." Key: FLINK-31388 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Commented] (FLINK-31361) job created by sql-client can't authenticate to kafka, can't find org.apache.kafka.common.security.plain.PlainLoginModule

2023-03-07 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697645#comment-17697645 ] David Anderson commented on FLINK-31361: I'm using the sql-client to create the

[jira] [Created] (FLINK-31361) job created by sql-client can't authenticate to kafka, can't find org.apache.kafka.common.security.plain.PlainLoginModule

2023-03-07 Thread David Anderson (Jira)
David Anderson created FLINK-31361: -- Summary: job created by sql-client can't authenticate to kafka, can't find org.apache.kafka.common.security.plain.PlainLoginModule Key: FLINK-31361 URL: https://issues.apache.

[jira] [Resolved] (FLINK-30563) Update training exercises to use Flink 1.16

2023-02-03 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson resolved FLINK-30563. Resolution: Implemented Implemented with 412283a43682cdbef4dddf46257f18c6750787df > Upda

[jira] [Assigned] (FLINK-30563) Update training exercises to use Flink 1.16

2023-02-03 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-30563: -- Assignee: Yuxin Tan > Update training exercises to use Flink 1.16 > -

[jira] [Created] (FLINK-30563) Update training exercises to use Flink 1.16

2023-01-04 Thread David Anderson (Jira)
David Anderson created FLINK-30563: -- Summary: Update training exercises to use Flink 1.16 Key: FLINK-30563 URL: https://issues.apache.org/jira/browse/FLINK-30563 Project: Flink Issue Type: I

[jira] [Resolved] (FLINK-30439) Update playgrounds for 1.16

2023-01-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson resolved FLINK-30439. Resolution: Done > Update playgrounds for 1.16 > --- > >

[jira] [Resolved] (FLINK-30441) Update pyflink walkthrough playground for 1.16

2023-01-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson resolved FLINK-30441. Fix Version/s: 1.16.0 Resolution: Done Fixed in master and in release-1.16 via  4a

[jira] [Resolved] (FLINK-30442) Update table walkthrough playground for 1.16

2023-01-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson resolved FLINK-30442. Fix Version/s: 1.16.0 Release Note: The table walkthrough playground now supports M1-b

[jira] [Resolved] (FLINK-30440) Update operations playground for 1.16

2023-01-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson resolved FLINK-30440. Resolution: Done > Update operations playground for 1.16 > ---

[jira] [Commented] (FLINK-30440) Update operations playground for 1.16

2023-01-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17654548#comment-17654548 ] David Anderson commented on FLINK-30440: Fixed in master and release-1.16 via:

[jira] [Commented] (FLINK-30440) Update operations playground for 1.16

2023-01-02 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653629#comment-17653629 ] David Anderson commented on FLINK-30440: With these specific playground tasks, I

[jira] [Updated] (FLINK-30440) Update operations playground for 1.16

2023-01-02 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-30440: --- Fix Version/s: 1.16.0 > Update operations playground for 1.16 >

[jira] [Assigned] (FLINK-30442) Update table walkthrough playground for 1.16

2022-12-23 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-30442: -- Assignee: Gunnar Morling > Update table walkthrough playground for 1.16 > ---

[jira] [Assigned] (FLINK-30440) Update operations playground for 1.16

2022-12-23 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-30440: -- Assignee: Gunnar Morling (was: David Anderson) > Update operations playground for 1.

[jira] [Assigned] (FLINK-30441) Update pyflink walkthrough playground for 1.16

2022-12-23 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-30441: -- Assignee: Gunnar Morling > Update pyflink walkthrough playground for 1.16 > -

[jira] [Assigned] (FLINK-30440) Update operations playground for 1.16

2022-12-23 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-30440: -- Assignee: David Anderson > Update operations playground for 1.16 > --

[jira] [Updated] (FLINK-30439) Update playgrounds for 1.16

2022-12-16 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-30439: --- Labels: starter (was: ) > Update playgrounds for 1.16 > --- > >

[jira] [Updated] (FLINK-30439) Update playgrounds for 1.16

2022-12-16 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-30439: --- Description: All of the playgrounds should be updated for Flink 1.16. This should include r

[jira] [Created] (FLINK-30442) Update table walkthrough playground for 1.12

2022-12-16 Thread David Anderson (Jira)
David Anderson created FLINK-30442: -- Summary: Update table walkthrough playground for 1.12 Key: FLINK-30442 URL: https://issues.apache.org/jira/browse/FLINK-30442 Project: Flink Issue Type:

[jira] [Updated] (FLINK-30442) Update table walkthrough playground for 1.16

2022-12-16 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-30442: --- Summary: Update table walkthrough playground for 1.16 (was: Update table walkthrough playgr

[jira] [Created] (FLINK-30441) Update pyflink walkthrough playground for 1.16

2022-12-16 Thread David Anderson (Jira)
David Anderson created FLINK-30441: -- Summary: Update pyflink walkthrough playground for 1.16 Key: FLINK-30441 URL: https://issues.apache.org/jira/browse/FLINK-30441 Project: Flink Issue Type

[jira] [Created] (FLINK-30440) Update operations playground for 1.16

2022-12-16 Thread David Anderson (Jira)
David Anderson created FLINK-30440: -- Summary: Update operations playground for 1.16 Key: FLINK-30440 URL: https://issues.apache.org/jira/browse/FLINK-30440 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-30439) Update playgrounds for 1.16

2022-12-16 Thread David Anderson (Jira)
David Anderson created FLINK-30439: -- Summary: Update playgrounds for 1.16 Key: FLINK-30439 URL: https://issues.apache.org/jira/browse/FLINK-30439 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-27184) Optimize IntervalJoinOperator by using binary sorted state

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27184: --- Summary: Optimize IntervalJoinOperator by using binary sorted state (was: Optimize Interval

[jira] [Updated] (FLINK-27184) Optimize IntervalJoinOperator by using binary sorted state

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27184: --- Description: The performance of interval joins on RocksDB can be optimized by using binary s

[jira] [Updated] (FLINK-27182) Optimize RowTimeSortOperator by using binary sorted state

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27182: --- Summary: Optimize RowTimeSortOperator by using binary sorted state (was: Optimize RowTimeSo

[jira] [Updated] (FLINK-27183) Optimize CepOperator by using temporal state

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27183: --- Description: The performance of CEP on RocksDB can be significantly improved by having it us

[jira] [Updated] (FLINK-27183) Optimize CepOperator by using binary sorted state

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27183: --- Summary: Optimize CepOperator by using binary sorted state (was: Optimize CepOperator by us

[jira] [Updated] (FLINK-27182) Optimize RowTimeSortOperator by using binary sorted state

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27182: --- Description: The performance of the RowTimeSortOperator can be significantly improved by usi

[jira] [Updated] (FLINK-27181) Optimize TemporalRowTimeJoinOperator by using temporal state

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27181: --- Description: The throughput of the TemporalRowTimeJoinOperator can be significantly improved

[jira] [Updated] (FLINK-27181) Optimize TemporalRowTimeJoinOperator by using binary sorted state

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27181: --- Summary: Optimize TemporalRowTimeJoinOperator by using binary sorted state (was: Optimize T

[jira] [Closed] (FLINK-27179) Update training example to use temporal state

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson closed FLINK-27179. -- Resolution: Won't Do > Update training example to use temporal state > ---

[jira] [Updated] (FLINK-27180) Docs for binary sorted state

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27180: --- Description: Update [https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastre

[jira] [Updated] (FLINK-27180) Docs for binary sorted state

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27180: --- Summary: Docs for binary sorted state (was: Docs for temporal state) > Docs for binary sort

[jira] [Updated] (FLINK-27178) create examples that use binary sorted state

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27178: --- Summary: create examples that use binary sorted state (was: create examples that use tempor

[jira] [Updated] (FLINK-27178) create examples that use binary sorted state

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27178: --- Description: Add examples showing how to use binary sorted state. E.g., for custom windowing

[jira] [Updated] (FLINK-27177) Implement Binary Sorted State

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27177: --- Summary: Implement Binary Sorted State (was: Implement Temporal State) > Implement Binary S

[jira] [Updated] (FLINK-27177) Implement Binary Sorted State

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27177: --- Description: Following the plan in [FLIP-220|[https://cwiki.apache.org/confluence/x/Xo_FD]|h

[jira] [Updated] (FLINK-27176) FLIP-220: Binary Sorted State

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27176: --- Description: Task for implementing FLIP-220: Binary Sorted State: [https://cwiki.apache.org/

[jira] [Updated] (FLINK-27176) FLIP-220: Binary Sorted State

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27176: --- Release Note: Added BinarySortedState to optimize state accesses and updates used for sortin

[jira] [Updated] (FLINK-27176) FLIP-220: Binary Sorted State

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27176: --- Summary: FLIP-220: Binary Sorted State (was: FLIP-220: Temporal State) > FLIP-220: Binary S

[jira] [Assigned] (FLINK-27176) FLIP-220: Binary Sorted State

2022-12-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-27176: -- Assignee: David Anderson > FLIP-220: Binary Sorted State > --

[jira] [Commented] (FLINK-29494) ChangeLogNormalize operator causes unexpected firing of past windows after state restoration

2022-10-03 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612213#comment-17612213 ] David Anderson commented on FLINK-29494: [~twalthr] [~jingzhang] [~godfrey] This

[jira] [Resolved] (FLINK-27510) update playgrounds for Flink 1.15

2022-09-19 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson resolved FLINK-27510. Resolution: Implemented > update playgrounds for Flink 1.15 >

[jira] [Resolved] (FLINK-27513) Update table walkthrough playground for 1.15

2022-09-19 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson resolved FLINK-27513. Resolution: Implemented master:  677a4bb892f6eba990617a8ecc699b14b10e7b6a > Update table

[jira] [Updated] (FLINK-27510) update playgrounds for Flink 1.15

2022-09-19 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27510: --- Fix Version/s: 1.15.2 > update playgrounds for Flink 1.15 >

[jira] [Resolved] (FLINK-27512) Update pyflink walkthrough playground for 1.15

2022-09-19 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson resolved FLINK-27512. Resolution: Implemented master:  7d55cc567bb2c064f7ce49ff21faa9486bd3de65 > Update pyfli

[jira] [Resolved] (FLINK-27511) Update operations playground for 1.15

2022-09-19 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson resolved FLINK-27511. Resolution: Resolved master:  c173ab01f20ba1d168657e36cebd64c16238b1d1 > Update operatio

[jira] [Resolved] (FLINK-28937) Add doc for SqlGateway

2022-09-14 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson resolved FLINK-28937. Resolution: Duplicate > Add doc for SqlGateway > -- > >

[jira] [Assigned] (FLINK-27513) Update table walkthrough playground for 1.15

2022-09-14 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-27513: -- Assignee: Roy Michael > Update table walkthrough playground for 1.15 > --

[jira] [Assigned] (FLINK-27512) Update pyflink walkthrough playground for 1.15

2022-09-14 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-27512: -- Assignee: Roy Michael > Update pyflink walkthrough playground for 1.15 >

[jira] [Assigned] (FLINK-27511) Update operations playground for 1.15

2022-09-14 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-27511: -- Assignee: Roy Michael > Update operations playground for 1.15 > -

[jira] [Commented] (FLINK-27510) update playgrounds for Flink 1.15

2022-09-14 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17604756#comment-17604756 ] David Anderson commented on FLINK-27510: [~roy.m...@gmail.com] Thank you! I'm as

[jira] [Assigned] (FLINK-27510) update playgrounds for Flink 1.15

2022-09-14 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-27510: -- Assignee: Roy Michael > update playgrounds for Flink 1.15 > -

[jira] [Created] (FLINK-28975) withIdleness marks all streams from FLIP-27 sources as idle

2022-08-15 Thread David Anderson (Jira)
David Anderson created FLINK-28975: -- Summary: withIdleness marks all streams from FLIP-27 sources as idle Key: FLINK-28975 URL: https://issues.apache.org/jira/browse/FLINK-28975 Project: Flink

[jira] [Created] (FLINK-28754) document that Java 8 is required to build table store

2022-07-30 Thread David Anderson (Jira)
David Anderson created FLINK-28754: -- Summary: document that Java 8 is required to build table store Key: FLINK-28754 URL: https://issues.apache.org/jira/browse/FLINK-28754 Project: Flink Iss

[jira] [Commented] (FLINK-28060) Kafka Commit on checkpointing fails repeatedly after a broker restart

2022-07-26 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571628#comment-17571628 ] David Anderson commented on FLINK-28060: [~martijnvisser] [~renqs] [~mason6345]

[jira] [Updated] (FLINK-24392) Upgrade presto s3 fs implementation to Trino >= 348

2022-07-13 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-24392: --- Fix Version/s: (was: 1.15.0) > Upgrade presto s3 fs implementation to Trino >= 348 > ---

[jira] [Updated] (FLINK-24392) Upgrade presto s3 fs implementation to Trino >= 348

2022-07-13 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-24392: --- Fix Version/s: 1.16.0 > Upgrade presto s3 fs implementation to Trino >= 348 > --

[jira] [Updated] (FLINK-28019) Error in RetractableTopNFunction when retracting a stale record with state ttl enabled

2022-06-22 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-28019: --- Summary: Error in RetractableTopNFunction when retracting a stale record with state ttl enab

[jira] [Updated] (FLINK-27999) NoSuchMethodError when using Hive 3 dialect

2022-06-20 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27999: --- Fix Version/s: 1.15.1 (was: 1.15.2) > NoSuchMethodError when using Hi

[jira] [Updated] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots hang

2022-06-20 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-24960: --- Fix Version/s: 1.15.1 > YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobMa

[jira] [Updated] (FLINK-26993) CheckpointCoordinatorTest#testMinCheckpointPause

2022-06-20 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-26993: --- Fix Version/s: 1.15.1 (was: 1.15.2) > CheckpointCoordinatorTest#testM

[jira] [Updated] (FLINK-27881) The key(String) in PulsarMessageBuilder returns null

2022-06-20 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27881: --- Fix Version/s: 1.15.1 (was: 1.15.2) > The key(String) in PulsarMessag

[jira] [Updated] (FLINK-28019) Error occurred when retract a staled record when enable state ttl in RetractableTopNFunction

2022-06-20 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-28019: --- Fix Version/s: 1.15.1 (was: 1.15.2) > Error occurred when retract a s

[jira] [Updated] (FLINK-27776) Throw exception when UDAF used in sliding window does not implement merge method in PyFlink

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27776: --- Summary: Throw exception when UDAF used in sliding window does not implement merge method in

[jira] [Updated] (FLINK-26909) Allow setting parallelism to -1 from CLI

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-26909: --- Summary: Allow setting parallelism to -1 from CLI (was: Allow to set parallelism to be -1 f

[jira] [Updated] (FLINK-26788) AbstractDeserializationSchema should add cause when throwing a FlinkRuntimeException

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-26788: --- Summary: AbstractDeserializationSchema should add cause when throwing a FlinkRuntimeExceptio

[jira] [Updated] (FLINK-27955) PyFlink installation failure on Windows OS

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27955: --- Summary: PyFlink installation failure on Windows OS (was: Fix the problem of windows instal

[jira] [Updated] (FLINK-27890) SideOutputExample.java fails

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27890: --- Summary: SideOutputExample.java fails (was: bug of SideOutputExample.java) > SideOutputExam

[jira] [Updated] (FLINK-27910) FileSink not enforcing rolling policy if started from scratch

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27910: --- Summary: FileSink not enforcing rolling policy if started from scratch (was: FileSink not r

[jira] [Updated] (FLINK-27683) Insert into (column1, column2) Values(.....) fails with SQL hints

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27683: --- Summary: Insert into (column1, column2) Values(.) fails with SQL hints (was: Insert int

[jira] [Updated] (FLINK-27606) CompileException when using UDAF with merge() method

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27606: --- Summary: CompileException when using UDAF with merge() method (was: Fix CompileException wh

[jira] [Updated] (FLINK-27367) SQL CAST between INT and DATE is broken

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27367: --- Summary: SQL CAST between INT and DATE is broken (was: CAST between INT and DATE is broken)

[jira] [Updated] (FLINK-27420) Suspended SlotManager fails to re-register metrics when started again

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27420: --- Summary: Suspended SlotManager fails to re-register metrics when started again (was: Suspen

[jira] [Updated] (FLINK-27368) SQL CAST(' 1 ' as BIGINT) returns wrong result

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27368: --- Summary: SQL CAST(' 1 ' as BIGINT) returns wrong result (was: CAST(' 1 ' as BIGINT) returns

[jira] [Assigned] (FLINK-27041) KafkaSource in batch mode failing on 0 messages in any topic partition

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-27041: -- Assignee: Qingsheng Ren (was: David Anderson) > KafkaSource in batch mode failing on

[jira] [Updated] (FLINK-27041) KafkaSource in batch mode failing if any topic partition is empty

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27041: --- Summary: KafkaSource in batch mode failing if any topic partition is empty (was: KafkaSourc

[jira] [Assigned] (FLINK-27041) KafkaSource in batch mode failing on 0 messages in any topic partition

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-27041: -- Assignee: David Anderson (was: Qingsheng Ren) > KafkaSource in batch mode failing on

[jira] [Updated] (FLINK-26588) Translate the new SQL CAST documentation to Chinese

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-26588: --- Summary: Translate the new SQL CAST documentation to Chinese (was: Translate the new CAST d

[jira] [Updated] (FLINK-27079) Setup cron jobs

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27079: --- Fix Version/s: 1.15.2 (was: 1.15.1) > Setup cron jobs > -

[jira] [Updated] (FLINK-27082) Disable tests relying on non-writable directories

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27082: --- Fix Version/s: 1.15.2 (was: 1.15.1) > Disable tests relying on non-wr

[jira] [Updated] (FLINK-27080) Enable builds for pull requests

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27080: --- Fix Version/s: 1.15.2 (was: 1.15.1) > Enable builds for pull requests

[jira] [Updated] (FLINK-27077) Setup per-commit builds

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27077: --- Fix Version/s: 1.15.2 (was: 1.15.1) > Setup per-commit builds > -

[jira] [Updated] (FLINK-27075) Migrate CI from Azure to Github Actions

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27075: --- Fix Version/s: 1.15.2 (was: 1.15.1) > Migrate CI from Azure to Github

[jira] [Updated] (FLINK-27492) Flink table scala example does not including the scala-api jars

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27492: --- Fix Version/s: 1.15.2 (was: 1.15.1) > Flink table scala example does

[jira] [Comment Edited] (FLINK-28060) Kafka Commit on checkpointing fails repeatedly after a broker restart

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1727#comment-1727 ] David Anderson edited comment on FLINK-28060 at 6/17/22 10:33 AM:

[jira] [Commented] (FLINK-28060) Kafka Commit on checkpointing fails repeatedly after a broker restart

2022-06-17 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1727#comment-1727 ] David Anderson commented on FLINK-28060: It doesn't seem wise to upgrade the Kaf

[jira] [Commented] (FLINK-28060) Kafka Commit on checkpointing fails repeatedly after a broker restart

2022-06-16 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17554935#comment-17554935 ] David Anderson commented on FLINK-28060: Along the lines of what Chesnay mention

[jira] [Updated] (FLINK-27299) flink parsing parameter bug

2022-06-15 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27299: --- Fix Version/s: 1.16.0 (was: 1.15.1) > flink parsing parameter bug > -

[jira] [Updated] (FLINK-27865) Add guide and example for configuring SASL and SSL in Kafka SQL connector document

2022-06-15 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27865: --- Fix Version/s: 1.15.2 (was: 1.15.1) > Add guide and example for confi

  1   2   3   4   5   6   7   >