[jira] [Closed] (FLINK-37051) Cross-team verification for FLINK-36369

[ https://issues.apache.org/jira/browse/FLINK-37051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-37051. --- Resolution: Fixed This change has been covered by ut&it, doesn't need additional cross-team testing

[jira] [Closed] (FLINK-37172) Add logs in all existing async state ops to check if they are under async state when running

[ https://issues.apache.org/jira/browse/FLINK-37172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-37172. --- Assignee: xuyang Resolution: Fixed Fixed in master: 4a5238c020961efaa8f84dc1f414aa69fec49e32

[jira] [Closed] (FLINK-36837) Introduce RowTimeDeduplicateFunction with Async State API

[ https://issues.apache.org/jira/browse/FLINK-36837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36837. --- Resolution: Fixed Fixed in master: 26d342601a545293b6d9f447a033c0559ba86d14 > Introduce RowTimeDedu

[jira] [Closed] (FLINK-36927) Introduce slicing & one stage Window Aggregate with Async State API

[ https://issues.apache.org/jira/browse/FLINK-36927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36927. --- Resolution: Fixed Fixed in master: 8134e33dee9b064682a8953bf8c9b8fb32abdf8e > Introduce slicing & o

[jira] [Closed] (FLINK-36926) Introduce Window Join Operator with Async State API

[ https://issues.apache.org/jira/browse/FLINK-36926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36926. --- Resolution: Fixed Fixed in master: 8ada0ba123e99a408e7bafc8bcf90057d38d20b7 > Introduce Window Join

[jira] [Closed] (FLINK-36831) Introduce AppendOnlyTopNFunction in Rank with Async State API

[ https://issues.apache.org/jira/browse/FLINK-36831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36831. --- Resolution: Fixed Fixed in master: 29edd60f85a38a3286a8c6da2f6400affb04ce6f > Introduce AppendOnlyT

[jira] [Assigned] (FLINK-37116) Add release notes for all breaking changes in 2.0.0

[ https://issues.apache.org/jira/browse/FLINK-37116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-37116: --- Assignee: xuyang > Add release notes for all breaking changes in 2.0.0 > --

[jira] [Created] (FLINK-37116) Add release notes for all breaking changes in 2.0.0

lincoln lee created FLINK-37116: --- Summary: Add release notes for all breaking changes in 2.0.0 Key: FLINK-37116 URL: https://issues.apache.org/jira/browse/FLINK-37116 Project: Flink Issue Type:

[jira] [Closed] (FLINK-36825) Introduce FastTop1Function in Rank with Async State API

[ https://issues.apache.org/jira/browse/FLINK-36825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36825. --- Resolution: Fixed fixed in master: f4212d8b10936ef8cc548397e0370143388c04d3 > Introduce FastTop1Fun

[jira] [Commented] (FLINK-37097) Remove Hive connector from core Flink

[ https://issues.apache.org/jira/browse/FLINK-37097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912326#comment-17912326 ] lincoln lee commented on FLINK-37097: - [~luoyuxia] [~Sergey Nuyanzin] Thank you both

[jira] [Comment Edited] (FLINK-37097) Remove Hive connector from core Flink

[ https://issues.apache.org/jira/browse/FLINK-37097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911962#comment-17911962 ] lincoln lee edited comment on FLINK-37097 at 1/10/25 1:24 PM:

[jira] [Commented] (FLINK-37097) Remove Hive connector from core Flink

[ https://issues.apache.org/jira/browse/FLINK-37097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911962#comment-17911962 ] lincoln lee commented on FLINK-37097: - [~davidradl] We're hoping to see this happen

[jira] [Commented] (FLINK-37097) Remove

[ https://issues.apache.org/jira/browse/FLINK-37097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911944#comment-17911944 ] lincoln lee commented on FLINK-37097: - [~Sergey Nuyanzin] We were just discussing th

[jira] [Closed] (FLINK-36773) Introduce new Group Agg Operator with Async State API

[ https://issues.apache.org/jira/browse/FLINK-36773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36773. --- Resolution: Fixed fixed in master: bceca90aa7c492a15e5a0e3021586b1891ffec5d > Introduce new Group A

[jira] [Closed] (FLINK-36171) Remove APIs about ManagedTable

[ https://issues.apache.org/jira/browse/FLINK-36171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36171. --- Resolution: Fixed fixed in master: c13815fe141127678d46fd6bc08a41c73b82884c > Remove APIs about Man

[jira] [Closed] (FLINK-36481) Remove deprecated method `TableDescriptor#forManaged`

[ https://issues.apache.org/jira/browse/FLINK-36481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36481. --- Assignee: xuyang Resolution: Fixed fixed in master: de40a756e2e1764eaf0a7ff117ac45132d4ac316

[jira] [Assigned] (FLINK-36837) Introduce RowTimeDeduplicateFunction with Async State API

[ https://issues.apache.org/jira/browse/FLINK-36837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-36837: --- Assignee: xuyang > Introduce RowTimeDeduplicateFunction with Async State API >

[jira] [Assigned] (FLINK-36926) Introduce Window Join Operator with Async State API

[ https://issues.apache.org/jira/browse/FLINK-36926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-36926: --- Assignee: xuyang > Introduce Window Join Operator with Async State API > --

[jira] [Assigned] (FLINK-36927) Introduce slicing & one stage Window Aggregate with Async State API

[ https://issues.apache.org/jira/browse/FLINK-36927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-36927: --- Assignee: xuyang > Introduce slicing & one stage Window Aggregate with Async State API > --

[jira] [Commented] (FLINK-12173) Optimize "SELECT DISTINCT" into Deduplicate with keep first row

[ https://issues.apache.org/jira/browse/FLINK-12173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906590#comment-17906590 ] lincoln lee commented on FLINK-12173: - [~jhughes] For performance testing, the harne

[jira] [Closed] (FLINK-33921) Cleanup deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig

[ https://issues.apache.org/jira/browse/FLINK-33921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-33921. --- Resolution: Fixed fixed in master: 6248fd4fd61a0d76f1b6160abff19fdfdc0f4c63 > Cleanup deprecated Id

[jira] [Commented] (FLINK-36911) add more calcite rules to improve flink performance because calcite has upgrade

[ https://issues.apache.org/jira/browse/FLINK-36911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906237#comment-17906237 ] lincoln lee commented on FLINK-36911: - [~jackylau] Thank you for focusing on this pa

[jira] [Updated] (FLINK-12173) Optimize "SELECT DISTINCT" into Deduplicate with keep first row

[ https://issues.apache.org/jira/browse/FLINK-12173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-12173: Issue Type: Improvement (was: New Feature) > Optimize "SELECT DISTINCT" into Deduplicate with kee

[jira] [Commented] (FLINK-12173) Optimize "SELECT DISTINCT" into Deduplicate with keep first row

[ https://issues.apache.org/jira/browse/FLINK-12173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906076#comment-17906076 ] lincoln lee commented on FLINK-12173: - Thanks [~yiyutian] for your contribution! I

[jira] [Commented] (FLINK-35887) Null Pointer Exception in TypeExtractor.isRecord when trying to provide type info for interface

[ https://issues.apache.org/jira/browse/FLINK-35887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906068#comment-17906068 ] lincoln lee commented on FLINK-35887: - Fixed in 1.19: 5c9c45c45d77e3b609108cc69eac1

[jira] [Commented] (FLINK-35887) Null Pointer Exception in TypeExtractor.isRecord when trying to provide type info for interface

[ https://issues.apache.org/jira/browse/FLINK-35887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905951#comment-17905951 ] lincoln lee commented on FLINK-35887: - [~guoweijie] Thanks for looking into this! I

[jira] [Updated] (FLINK-35887) Null Pointer Exception in TypeExtractor.isRecord when trying to provide type info for interface

[ https://issues.apache.org/jira/browse/FLINK-35887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-35887: Fix Version/s: 1.19.2 1.20.1 > Null Pointer Exception in TypeExtractor.isRecord

[jira] [Commented] (FLINK-35887) Null Pointer Exception in TypeExtractor.isRecord when trying to provide type info for interface

[ https://issues.apache.org/jira/browse/FLINK-35887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905096#comment-17905096 ] lincoln lee commented on FLINK-35887: - Because the need to port to lower versions is

[jira] [Assigned] (FLINK-36773) Introduce new Group Agg Operator with Async State API

[ https://issues.apache.org/jira/browse/FLINK-36773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-36773: --- Assignee: xuyang (was: Yang Xu) > Introduce new Group Agg Operator with Async State API >

[jira] [Assigned] (FLINK-36773) Introduce new Group Agg Operator with Async State API

[ https://issues.apache.org/jira/browse/FLINK-36773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-36773: --- Assignee: Yang Xu > Introduce new Group Agg Operator with Async State API > ---

[jira] [Updated] (FLINK-36654) Decimal divide Integer reports Null pointer exception

[ https://issues.apache.org/jira/browse/FLINK-36654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-36654: Fix Version/s: 1.20.1 > Decimal divide Integer reports Null pointer exception > --

[jira] [Updated] (FLINK-36654) Decimal divide Integer reports Null pointer exception

[ https://issues.apache.org/jira/browse/FLINK-36654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-36654: Affects Version/s: 1.20.0 > Decimal divide Integer reports Null pointer exception > --

[jira] [Closed] (FLINK-36654) Decimal divide Integer reports Null pointer exception

[ https://issues.apache.org/jira/browse/FLINK-36654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36654. --- Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: bd6f292ad7fc75e1285ca6987a16422c98083

[jira] [Assigned] (FLINK-36654) Decimal divide Integer reports Null pointer exception

[ https://issues.apache.org/jira/browse/FLINK-36654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-36654: --- Assignee: Shuai Xu > Decimal divide Integer reports Null pointer exception > --

[jira] [Closed] (FLINK-36662) Incorrect constant pull up when group keys in aggregate are NULL

[ https://issues.apache.org/jira/browse/FLINK-36662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36662. --- Resolution: Fixed Fixed in master: 10692791c9ed1ebc039ebcd12667c04f95abc440 > Incorrect constant pu

[jira] [Updated] (FLINK-36662) Incorrect constant pull up when group keys in aggregate are NULL

[ https://issues.apache.org/jira/browse/FLINK-36662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-36662: Description: Currently, for the following case: {code:java} val groupingSetsQuery = """ |SELECT |

[jira] [Updated] (FLINK-36662) Incorrect constant pull up when group keys in aggregate are NULL

[ https://issues.apache.org/jira/browse/FLINK-36662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-36662: Description: Currently, for the following case: {code:java} val groupingSetsQuery = """ |SELECT |

[jira] [Created] (FLINK-36662) Incorrect constant pull up when group keys in aggregate are NULL

lincoln lee created FLINK-36662: --- Summary: Incorrect constant pull up when group keys in aggregate are NULL Key: FLINK-36662 URL: https://issues.apache.org/jira/browse/FLINK-36662 Project: Flink

[jira] [Commented] (FLINK-33748) Remove legacy TableSource/TableSink API in 2.0

[ https://issues.apache.org/jira/browse/FLINK-33748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887507#comment-17887507 ] lincoln lee commented on FLINK-33748: - Split into two-steps: 1st, package moving wa

[jira] [Updated] (FLINK-33748) Remove legacy TableSource/TableSink API in 2.0

[ https://issues.apache.org/jira/browse/FLINK-33748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33748: Fix Version/s: (was: 2.0-preview) > Remove legacy TableSource/TableSink API in 2.0 > -

[jira] [Closed] (FLINK-36369) Move deprecated user-visible classes in table modules to the legacy package to make it easier to delete them later

[ https://issues.apache.org/jira/browse/FLINK-36369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36369. --- Assignee: xuyang Resolution: Fixed fixed in master: 10037e39b5cbcdbf292d769bcaceb912abf6782c

[jira] [Closed] (FLINK-34702) Rank should not convert to StreamExecDuplicate when the input is not insert only

[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34702. --- Fix Version/s: 2.0-preview (was: 2.0.0) Resolution: Fixed fixed in mas

[jira] [Closed] (FLINK-36273) Remove deprecated Table/SQL configuration in 2.0

[ https://issues.apache.org/jira/browse/FLINK-36273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36273. --- Assignee: xuyang Resolution: Fixed Fixed in master: 733a56682bcceabab6625b621547538c6d993976

[jira] [Assigned] (FLINK-34702) Rank should not convert to StreamExecDuplicate when the input is not insert only

[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34702: --- Assignee: lincoln lee > Rank should not convert to StreamExecDuplicate when the input is no

[jira] [Closed] (FLINK-36358) to_timestamp result is not correct when the string precision is long than date format

[ https://issues.apache.org/jira/browse/FLINK-36358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36358. --- Fixed in master: 74b9a480317b3b2d93bf6953ba8934dedab1375f > to_timestamp result is not correct when the

[jira] [Assigned] (FLINK-36358) to_timestamp result is not correct when the string precision is long than date format

[ https://issues.apache.org/jira/browse/FLINK-36358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-36358: --- Assignee: Jacky Lau > to_timestamp result is not correct when the string precision is long

[jira] [Closed] (FLINK-36327) Remove the dependencies of the flink-scala and flink-streaming-scala modules from the table module.

[ https://issues.apache.org/jira/browse/FLINK-36327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36327. --- Assignee: xuyang Resolution: Fixed fixed in master: 7a06c3ba00ef0840ad59707cece2b9d3fcbd2409

[jira] [Closed] (FLINK-36248) Introduce new Join Operator with Async State API

[ https://issues.apache.org/jira/browse/FLINK-36248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36248. --- Resolution: Fixed Fixed in master: 5a63c56ca0b38ebae9fc475708917c35a4168844 > Introduce new Join Op

[jira] [Commented] (FLINK-29739) [FLIP-265] Deprecate and remove Scala API support

[ https://issues.apache.org/jira/browse/FLINK-29739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884193#comment-17884193 ] lincoln lee commented on FLINK-29739: - Thanks [~xuyangzhong] for your inputs and har

[jira] [Created] (FLINK-36354) Enable FORSTDB_BACKEND in async releated tests

lincoln lee created FLINK-36354: --- Summary: Enable FORSTDB_BACKEND in async releated tests Key: FLINK-36354 URL: https://issues.apache.org/jira/browse/FLINK-36354 Project: Flink Issue Type: Sub-

[jira] [Commented] (FLINK-34702) Rank should not convert to StreamExecDuplicate when the input is not insert only

[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884085#comment-17884085 ] lincoln lee commented on FLINK-34702: - [~AlexeyLV] Don't worry about losing any perf

[jira] [Commented] (FLINK-34702) Rank should not convert to StreamExecDuplicate when the input is not insert only

[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884084#comment-17884084 ] lincoln lee commented on FLINK-34702: - A draft pr was created: #25380. If we agree t

[jira] [Commented] (FLINK-34702) Rank should not convert to StreamExecDuplicate when the input is not insert only

[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883911#comment-17883911 ] lincoln lee commented on FLINK-34702: - Thank you guys bringing this up again! First

[jira] [Closed] (FLINK-36284) StreamTableEnvironment#toDataStream(Table table, Class targetClass) is not suitable for setting targetClass as a class generated by Avro.

[ https://issues.apache.org/jira/browse/FLINK-36284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36284. --- Assignee: xuyang Resolution: Fixed Fixed in master: 1cd9110f858a809ea640a23e872303be02015db9

[jira] [Closed] (FLINK-36283) The new PERCENTILE function doesn't follow user function first behavior when it encounters a user function with same name

[ https://issues.apache.org/jira/browse/FLINK-36283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36283. --- Fix Version/s: 2.0-preview (was: 2.0.0) Resolution: Fixed Fixed in mas

[jira] [Updated] (FLINK-36283) The new PERCENTILE function doesn't follow user function first behavior when it encounters a user function with same name

[ https://issues.apache.org/jira/browse/FLINK-36283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-36283: Issue Type: Bug (was: Improvement) > The new PERCENTILE function doesn't follow user function fir

[jira] [Created] (FLINK-36283) The new PERCENTILE function doesn't follow user function first behavior when it encounters a user function with same name

lincoln lee created FLINK-36283: --- Summary: The new PERCENTILE function doesn't follow user function first behavior when it encounters a user function with same name Key: FLINK-36283 URL: https://issues.apache.org/ji

[jira] [Commented] (FLINK-29739) [FLIP-265] Deprecate and remove Scala API support

[ https://issues.apache.org/jira/browse/FLINK-29739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881486#comment-17881486 ] lincoln lee commented on FLINK-29739: - We've been working on code cleanup for the de

[jira] [Closed] (FLINK-36230) REGEXP_EXTRACT Python Table API fails

[ https://issues.apache.org/jira/browse/FLINK-36230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36230. --- Fix Version/s: 2.0-preview Assignee: Dylan He Resolution: Fixed fixed in master: 8c6

[jira] [Closed] (FLINK-35827) Equality bewteen a row field and a row constant is wrong in SQL

[ https://issues.apache.org/jira/browse/FLINK-35827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-35827. --- Fix Version/s: 2.0-preview Assignee: xuyang Resolution: Fixed fixed in master: 54b0d

[jira] [Closed] (FLINK-36142) Remove TestTableSourceWithTime and its subclasses to prepare to remove TableEnvironmentInternal#registerTableSourceInternal

[ https://issues.apache.org/jira/browse/FLINK-36142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36142. --- Resolution: Fixed fixed in master: 8b8e695188114c7087d3a9ed83fc9f2ee2776339 > Remove TestTableSourc

[jira] [Closed] (FLINK-36123) Add PERCENTILE function

[ https://issues.apache.org/jira/browse/FLINK-36123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36123. --- Assignee: Dylan He Resolution: Fixed fixed in master: c749a1b61c9c154f32cb877b96274804a950bfd0

[jira] [Updated] (FLINK-36123) Add PERCENTILE function

[ https://issues.apache.org/jira/browse/FLINK-36123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-36123: Fix Version/s: 2.0-preview > Add PERCENTILE function > --- > >

[jira] [Created] (FLINK-36214) Error log when building flink-cdc-pipeline-udf-examples from source code

lincoln lee created FLINK-36214: --- Summary: Error log when building flink-cdc-pipeline-udf-examples from source code Key: FLINK-36214 URL: https://issues.apache.org/jira/browse/FLINK-36214 Project: Flink

[jira] [Closed] (FLINK-35988) Reduce the number of state queries in the AppendOnlyFirstNFunction.

[ https://issues.apache.org/jira/browse/FLINK-35988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-35988. --- Resolution: Fixed Fixed in master: d9931c8af05d0f1f721be9fe920690fe122507ad > Reduce the number of

[jira] [Updated] (FLINK-35988) Reduce the number of state queries in the AppendOnlyFirstNFunction.

[ https://issues.apache.org/jira/browse/FLINK-35988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-35988: Issue Type: Improvement (was: New Feature) > Reduce the number of state queries in the AppendOnly

[jira] [Updated] (FLINK-35988) Reduce the number of state queries in the AppendOnlyFirstNFunction.

[ https://issues.apache.org/jira/browse/FLINK-35988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-35988: Fix Version/s: 2.0.0 > Reduce the number of state queries in the AppendOnlyFirstNFunction. > -

[jira] [Assigned] (FLINK-35988) Reduce the number of state queries in the AppendOnlyFirstNFunction.

[ https://issues.apache.org/jira/browse/FLINK-35988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-35988: --- Assignee: luolei > Reduce the number of state queries in the AppendOnlyFirstNFunction. > --

[jira] [Assigned] (FLINK-36157) FLIP-473 Introduce New SQL Operators Based on Asynchronous State APIs

[ https://issues.apache.org/jira/browse/FLINK-36157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-36157: --- Assignee: xuyang > FLIP-473 Introduce New SQL Operators Based on Asynchronous State APIs >

[jira] [Closed] (FLINK-35964) Add STARTSWITH function

[ https://issues.apache.org/jira/browse/FLINK-35964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-35964. --- Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: 4c14c763ca0f9c71d642953228b364dce3eb3

[jira] [Closed] (FLINK-35965) Add ENDSWITH function

[ https://issues.apache.org/jira/browse/FLINK-35965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-35965. --- Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: 5bbdbb2889268e879b6aa06d2cdab02fd6154

[jira] [Assigned] (FLINK-35965) Add ENDSWITH function

[ https://issues.apache.org/jira/browse/FLINK-35965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-35965: --- Assignee: Dylan He > Add ENDSWITH function > - > > Key:

[jira] [Assigned] (FLINK-35964) Add STARTSWITH function

[ https://issues.apache.org/jira/browse/FLINK-35964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-35964: --- Assignee: Dylan He > Add STARTSWITH function > --- > >

[jira] [Closed] (FLINK-36100) Support ESCAPE in built-in function LIKE formally

[ https://issues.apache.org/jira/browse/FLINK-36100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36100. --- Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: ae4eb7dc3ae399659e52da39f7ac74242aaca

[jira] [Updated] (FLINK-36100) Support ESCAPE in built-in function LIKE formally

[ https://issues.apache.org/jira/browse/FLINK-36100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-36100: Affects Version/s: 1.19.1 1.20.0 > Support ESCAPE in built-in function LIKE

[jira] [Commented] (FLINK-36149) Support cleaning up expired states to prevent the continuous increase of states and add RocksDB state cleanup configuration.

[ https://issues.apache.org/jira/browse/FLINK-36149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876663#comment-17876663 ] lincoln lee commented on FLINK-36149: - [~lexluo09] Thanks for reporting this! It see

[jira] [Assigned] (FLINK-36100) Support ESCAPE in built-in function LIKE formally

[ https://issues.apache.org/jira/browse/FLINK-36100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-36100: --- Assignee: Dylan He > Support ESCAPE in built-in function LIKE formally > --

[jira] [Assigned] (FLINK-36136) Remove TableSource & TableSink impl and utils, docs and etc.

[ https://issues.apache.org/jira/browse/FLINK-36136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-36136: --- Assignee: xuyang > Remove TableSource & TableSink impl and utils, docs and etc. > -

[jira] [Assigned] (FLINK-36135) Remove the TableSource and TableSink ecosystem APIs like TableFactory, DefinedFieldMapping, FilterableTableSource, etc.

[ https://issues.apache.org/jira/browse/FLINK-36135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-36135: --- Assignee: xuyang > Remove the TableSource and TableSink ecosystem APIs like TableFactory,

[jira] [Assigned] (FLINK-36133) Remove subclass implementations of TableSource and TableSink, along with their corresponding Factory classes.

[ https://issues.apache.org/jira/browse/FLINK-36133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-36133: --- Assignee: xuyang > Remove subclass implementations of TableSource and TableSink, along with

[jira] [Assigned] (FLINK-36134) Remove the classes associated with TableSource and TableSink as part of the optimization process.

[ https://issues.apache.org/jira/browse/FLINK-36134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-36134: --- Assignee: xuyang > Remove the classes associated with TableSource and TableSink as part of

[jira] [Assigned] (FLINK-36132) Remove codes that references TableSource and TableSink directly at the API level.

[ https://issues.apache.org/jira/browse/FLINK-36132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-36132: --- Assignee: xuyang > Remove codes that references TableSource and TableSink directly at the A

[jira] [Closed] (FLINK-35932) Add REGEXP_COUNT function

[ https://issues.apache.org/jira/browse/FLINK-35932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-35932. --- Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: 8189bba195326d899a9830d3a19b50cafa092

[jira] [Closed] (FLINK-35962) Add REGEXP_INSTR function

[ https://issues.apache.org/jira/browse/FLINK-35962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-35962. --- Fix Version/s: 2.0.0 Assignee: Dylan He Resolution: Fixed Fixed in master: cbbb1cd17

[jira] [Closed] (FLINK-35931) Add REGEXP_EXTRACT_ALL function

[ https://issues.apache.org/jira/browse/FLINK-35931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-35931. --- Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: 7fa4ebad057bca765b661a553f4ccc2df7861

[jira] [Closed] (FLINK-35963) Add REGEXP_SUBSTR function

[ https://issues.apache.org/jira/browse/FLINK-35963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-35963. --- Fix Version/s: 2.0.0 Assignee: Dylan He Resolution: Fixed Fixed in master: e8c1d1b9d

[jira] [Closed] (FLINK-36095) KeyedLookupJoinWrapper should shuffle by input upsertKey instead of join key to avoid changelog disordering

[ https://issues.apache.org/jira/browse/FLINK-36095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36095. --- Resolution: Fixed fixed in master: 624bc5001c831d3d04a5680c03910c634a0c988b > KeyedLookupJoinWrappe

[jira] [Assigned] (FLINK-33748) Remove legacy TableSource/TableSink API in 2.0

[ https://issues.apache.org/jira/browse/FLINK-33748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-33748: --- Assignee: xuyang > Remove legacy TableSource/TableSink API in 2.0 > ---

[jira] [Commented] (FLINK-33748) Remove legacy TableSource/TableSink API in 2.0

[ https://issues.apache.org/jira/browse/FLINK-33748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875157#comment-17875157 ] lincoln lee commented on FLINK-33748: - [~xuyangzhong] thanks for volunteering！Assign

[jira] [Created] (FLINK-36095) KeyedLookupJoinWrapper should shuffle by input upsertKey instead of join key to avoid changelog disordering

lincoln lee created FLINK-36095: --- Summary: KeyedLookupJoinWrapper should shuffle by input upsertKey instead of join key to avoid changelog disordering Key: FLINK-36095 URL: https://issues.apache.org/jira/browse/FLIN

[jira] [Closed] (FLINK-35997) Incomplete Table API & Python API of built-in function LTRIM & RTRIM

[ https://issues.apache.org/jira/browse/FLINK-35997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-35997. --- Assignee: Dylan He Resolution: Fixed Fixed in master: 500d274265d100e4fe091e27fa1d96cebd812c2d

[jira] [Closed] (FLINK-35993) Add UNHEX function

[ https://issues.apache.org/jira/browse/FLINK-35993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-35993. --- Resolution: Fixed Fixed in master: 215ad96248c989405177704a8eb63c6ff3215792 > Add UNHEX function >

[jira] [Updated] (FLINK-35993) Add UNHEX function

[ https://issues.apache.org/jira/browse/FLINK-35993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-35993: Fix Version/s: 2.0.0 > Add UNHEX function > -- > > Key: FLINK-3599

[jira] [Closed] (FLINK-35920) Add PRINTF function

[ https://issues.apache.org/jira/browse/FLINK-35920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-35920. --- Resolution: Fixed Fixed in master: a91085ebdbcaf7784f9af78f6f4f40079f310399 > Add PRINTF function >

[jira] [Closed] (FLINK-35935) CREATE TABLE AS doesn't work with LIMIT

[ https://issues.apache.org/jira/browse/FLINK-35935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-35935. --- Resolution: Fixed > CREATE TABLE AS doesn't work with LIMIT > --

[jira] [Comment Edited] (FLINK-35935) CREATE TABLE AS doesn't work with LIMIT

[ https://issues.apache.org/jira/browse/FLINK-35935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873763#comment-17873763 ] lincoln lee edited comment on FLINK-35935 at 8/15/24 11:24 AM: ---

[jira] [Commented] (FLINK-35935) CREATE TABLE AS doesn't work with LIMIT

[ https://issues.apache.org/jira/browse/FLINK-35935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873762#comment-17873762 ] lincoln lee commented on FLINK-35935: - [~xuyangzhong] Could you also backport this f

[jira] [Commented] (FLINK-35935) CREATE TABLE AS doesn't work with LIMIT

[ https://issues.apache.org/jira/browse/FLINK-35935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873763#comment-17873763 ] lincoln lee commented on FLINK-35935: - Fixed in master: 729b8b81a77ba6c32711216b88a1

[jira] [Updated] (FLINK-35935) CREATE TABLE AS doesn't work with LIMIT

[ https://issues.apache.org/jira/browse/FLINK-35935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-35935: Fix Version/s: 2.0.0 1.19.2 1.20.1 > CREATE TABLE AS doesn't

[jira] [Assigned] (FLINK-35993) Add UNHEX function

[ https://issues.apache.org/jira/browse/FLINK-35993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-35993: --- Assignee: Dylan He > Add UNHEX function > -- > > Key: FLINK

  1   2   3   4   5   6   7   8   9   10   >