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

[ 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

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

[ 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

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

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:

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

[ 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

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-32099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722688#comment-17722688 ] David Anderson commented on FLINK-32099: fixed in playground master with

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

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."

[ https://issues.apache.org/jira/browse/FLINK-31388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698642#comment-17698642 ] David Anderson commented on FLINK-31388: [~fsk119] maybe you have an idea about this? > restart

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

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:

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

[ https://issues.apache.org/jira/browse/FLINK-31361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697645#comment-17697645 ] David Anderson commented on FLINK-31361: I'm using the sql-client to create the job. > job

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

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:

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

[ 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 >

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

[ 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

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:

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

[ 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

[ 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 

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

[ 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

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-30440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

[ https://issues.apache.org/jira/browse/FLINK-30440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653629#comment-17653629 ] David Anderson commented on FLINK-30440: With these specific playground tasks, I usually merge

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

[ 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

[ 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

[ 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

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

[ 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

[ 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

[ 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

[ 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

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

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

[ 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

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

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

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

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:

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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-27180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27180: --- Description: Update

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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:

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

[ 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

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

[ 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

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-29494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612213#comment-17612213 ] David Anderson commented on FLINK-29494: [~twalthr] [~jingzhang] [~godfrey] This is an

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

[ 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

[ 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

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

[ 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

[ 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

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

[ 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

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

[ 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

[ 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

[ 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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-27510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17604756#comment-17604756 ] David Anderson commented on FLINK-27510: [~roy.m...@gmail.com] Thank you! I'm assigning this

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

[ 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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571628#comment-17571628 ] David Anderson commented on FLINK-28060: [~martijnvisser] [~renqs] [~mason6345] Are we any

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

[ 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

[ 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

[ 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

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

[ 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

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

[ 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 >

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

[ 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) >

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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) >

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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:

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

[ 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)

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

[ 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

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

[ 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:

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

[ 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

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

[ 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

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

[ 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

[ 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

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

[ 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

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

[ 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

[ 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

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

[ 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

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

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

[ https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1727#comment-1727 ] David Anderson commented on FLINK-28060: It doesn't seem wise to upgrade the Kafka client from

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

[ https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554935#comment-17554935 ] David Anderson commented on FLINK-28060: Along the lines of what Chesnay mentioned, what would

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

[ 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

[ 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

  1   2   3   4   5   6   7   >