[jira] [Commented] (FLINK-37005) Make StreamExecDeduplicate ouput insert only where possible

2025-01-06 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910331#comment-17910331 ] Jim Hughes commented on FLINK-37005: [~pnowojski], I like this idea! Could it make

[jira] [Assigned] (FLINK-36941) Fix Doc for DATE_FORMAT

2025-01-06 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-36941: -- Assignee: Yiyu Tian > Fix Doc for DATE_FORMAT > --- > > K

[jira] [Commented] (FLINK-36916) Unexpected error in type inference logic of function 'TYPEOF' for ROW

2024-12-17 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906454#comment-17906454 ] Jim Hughes commented on FLINK-36916: [~Sergey Nuyanzin] is there a ticket for that p

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

2024-12-16 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906203#comment-17906203 ] Jim Hughes commented on FLINK-12173: Hi [~lincoln.86xy], we have not done any benchm

[jira] [Assigned] (FLINK-36725) Add CompiledPlan annotations to BatchExecRuntimeFilter exec nodes

2024-12-12 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-36725: -- Assignee: (was: Jim Hughes) > Add CompiledPlan annotations to BatchExecRuntimeFilter exec

[jira] [Assigned] (FLINK-36862) Implement additional TO_TIMESTAMP_LTZ() functions

2024-12-06 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-36862: -- Assignee: Yiyu Tian > Implement additional TO_TIMESTAMP_LTZ() functions > ---

[jira] [Created] (FLINK-36802) Add CompiledPlan annotations to BatchExecSortMergeJoin

2024-11-26 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36802: -- Summary: Add CompiledPlan annotations to BatchExecSortMergeJoin Key: FLINK-36802 URL: https://issues.apache.org/jira/browse/FLINK-36802 Project: Flink Issue Type

[jira] [Updated] (FLINK-36718) Add CompiledPlan annotations to BatchExecLookupJoin

2024-11-26 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-36718: --- Summary: Add CompiledPlan annotations to BatchExecLookupJoin (was: Add CompiledPlan annotations to

[jira] [Commented] (FLINK-36167) testSinkDisorderChangeLog failed on AZP

2024-11-26 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17901284#comment-17901284 ] Jim Hughes commented on FLINK-36167: As a related failure, I saw this on a PR build,

[jira] [Assigned] (FLINK-36729) Add CompiledPlan annotations to BatchExecPythonCorrelate

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-36729: -- Assignee: (was: Jim Hughes) > Add CompiledPlan annotations to BatchExecPythonCorrelate >

[jira] [Assigned] (FLINK-36730) Add CompiledPlan annotations to BatchExecPythonGroupAggregate

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-36730: -- Assignee: (was: Jim Hughes) > Add CompiledPlan annotations to BatchExecPythonGroupAggrega

[jira] [Commented] (FLINK-36552) Fix Table API OVER window support in batch mode

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898409#comment-17898409 ] Jim Hughes commented on FLINK-36552: Does this relate to https://issues.apache.org/j

[jira] [Assigned] (FLINK-36731) Add CompiledPlan annotations to BatchExecPythonGroupWindowAggregate

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-36731: -- Assignee: (was: Jim Hughes) > Add CompiledPlan annotations to BatchExecPythonGroupWindowA

[jira] [Updated] (FLINK-35797) FLIP-456: CompiledPlan support for Batch Execution Mode

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-35797: --- Description: The CompiledPlan feature, introduced in FLIP-190: Support Version Upgrades for Table A

[jira] [Created] (FLINK-36731) Add CompiledPlan annotations to BatchExecPythonGroupWindowAggregate

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36731: -- Summary: Add CompiledPlan annotations to BatchExecPythonGroupWindowAggregate Key: FLINK-36731 URL: https://issues.apache.org/jira/browse/FLINK-36731 Project: Flink

[jira] [Updated] (FLINK-36728) Add CompiledPlan annotations to BatchExecPythonCalc

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-36728: --- Description: (was: In addition to the annotations, implement the BatchRestoreTest for this opera

[jira] [Assigned] (FLINK-36728) Add CompiledPlan annotations to BatchExecPythonCalc

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-36728: -- Assignee: (was: Jim Hughes) > Add CompiledPlan annotations to BatchExecPythonCalc > -

[jira] [Created] (FLINK-36732) Add CompiledPlan annotations to BatchExecPythonOverAggregate

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36732: -- Summary: Add CompiledPlan annotations to BatchExecPythonOverAggregate Key: FLINK-36732 URL: https://issues.apache.org/jira/browse/FLINK-36732 Project: Flink Iss

[jira] [Assigned] (FLINK-36732) Add CompiledPlan annotations to BatchExecPythonOverAggregate

2024-11-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-36732: -- Assignee: (was: Jim Hughes) > Add CompiledPlan annotations to BatchExecPythonOverAggregat

[jira] [Created] (FLINK-36729) Add CompiledPlan annotations to BatchExecPythonCorrelate

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36729: -- Summary: Add CompiledPlan annotations to BatchExecPythonCorrelate Key: FLINK-36729 URL: https://issues.apache.org/jira/browse/FLINK-36729 Project: Flink Issue Ty

[jira] [Created] (FLINK-36727) Add a completeness test to cover BatchExecNodes

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36727: -- Summary: Add a completeness test to cover BatchExecNodes Key: FLINK-36727 URL: https://issues.apache.org/jira/browse/FLINK-36727 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-36730) Add CompiledPlan annotations to BatchExecPythonGroupAggregate

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36730: -- Summary: Add CompiledPlan annotations to BatchExecPythonGroupAggregate Key: FLINK-36730 URL: https://issues.apache.org/jira/browse/FLINK-36730 Project: Flink Is

[jira] [Created] (FLINK-36728) Add CompiledPlan annotations to BatchExecPythonCalc

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36728: -- Summary: Add CompiledPlan annotations to BatchExecPythonCalc Key: FLINK-36728 URL: https://issues.apache.org/jira/browse/FLINK-36728 Project: Flink Issue Type: S

[jira] [Created] (FLINK-36726) Add CompiledPlan annotations to BatchExecInputAdapter

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36726: -- Summary: Add CompiledPlan annotations to BatchExecInputAdapter Key: FLINK-36726 URL: https://issues.apache.org/jira/browse/FLINK-36726 Project: Flink Issue Type:

[jira] [Created] (FLINK-36724) Add CompiledPlan annotations to BatchExecExecutionOrderEnforcer

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36724: -- Summary: Add CompiledPlan annotations to BatchExecExecutionOrderEnforcer Key: FLINK-36724 URL: https://issues.apache.org/jira/browse/FLINK-36724 Project: Flink

[jira] [Created] (FLINK-36725) Add CompiledPlan annotations to BatchExecRuntimeFilter exec nodes

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36725: -- Summary: Add CompiledPlan annotations to BatchExecRuntimeFilter exec nodes Key: FLINK-36725 URL: https://issues.apache.org/jira/browse/FLINK-36725 Project: Flink

[jira] [Created] (FLINK-36723) Add CompiledPlan annotations to BatchExecDynamicFilteringDataCollector

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36723: -- Summary: Add CompiledPlan annotations to BatchExecDynamicFilteringDataCollector Key: FLINK-36723 URL: https://issues.apache.org/jira/browse/FLINK-36723 Project: Flink

[jira] [Created] (FLINK-36721) Add CompiledPlan annotations to BatchExecHashWindowAggregate

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36721: -- Summary: Add CompiledPlan annotations to BatchExecHashWindowAggregate Key: FLINK-36721 URL: https://issues.apache.org/jira/browse/FLINK-36721 Project: Flink Iss

[jira] [Created] (FLINK-36722) Add CompiledPlan annotations to BatchExecSortWindowAggregate

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36722: -- Summary: Add CompiledPlan annotations to BatchExecSortWindowAggregate Key: FLINK-36722 URL: https://issues.apache.org/jira/browse/FLINK-36722 Project: Flink Iss

[jira] [Created] (FLINK-36720) Add CompiledPlan annotations to BatchExecWindowTableFunction

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36720: -- Summary: Add CompiledPlan annotations to BatchExecWindowTableFunction Key: FLINK-36720 URL: https://issues.apache.org/jira/browse/FLINK-36720 Project: Flink Iss

[jira] [Created] (FLINK-36718) Add CompiledPlan annotations to BatchExecLookupJoin and BatchExecSortMergeJoin

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36718: -- Summary: Add CompiledPlan annotations to BatchExecLookupJoin and BatchExecSortMergeJoin Key: FLINK-36718 URL: https://issues.apache.org/jira/browse/FLINK-36718 Project: F

[jira] [Created] (FLINK-36719) Add CompiledPlan annotations to BatchExecMultipleInput

2024-11-14 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36719: -- Summary: Add CompiledPlan annotations to BatchExecMultipleInput Key: FLINK-36719 URL: https://issues.apache.org/jira/browse/FLINK-36719 Project: Flink Issue Type

[jira] [Commented] (FLINK-36356) HadoopRecoverableWriterTest.testRecoverWithState due to IOException

2024-11-11 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897338#comment-17897338 ] Jim Hughes commented on FLINK-36356: Failed in a CI build here: https://dev.azure.c

[jira] [Commented] (FLINK-25802) OverWindow in batch mode failed

2024-11-08 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896817#comment-17896817 ] Jim Hughes commented on FLINK-25802: [~Runking] do you have a PR for this particular

[jira] [Commented] (FLINK-35792) Sorting by proctime does not work in rank

2024-11-08 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896681#comment-17896681 ] Jim Hughes commented on FLINK-35792: For more context, [~yiyutian] and I hit while s

[jira] [Commented] (FLINK-35792) Sorting by proctime does not work in rank

2024-11-07 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896540#comment-17896540 ] Jim Hughes commented on FLINK-35792: [~xuyangzhong] Sounds like between 3.1 and 3.2,

[jira] [Commented] (FLINK-35792) Sorting by proctime does not work in rank

2024-11-07 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896513#comment-17896513 ] Jim Hughes commented on FLINK-35792: Hi [~xuyangzhong], thank you for the context!

[jira] [Commented] (FLINK-35792) Sorting by proctime does not work in rank

2024-10-30 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894259#comment-17894259 ] Jim Hughes commented on FLINK-35792: [~xuyangzhong] I have been helping [~yiyutian]

[jira] [Commented] (FLINK-15333) Using FlinkCostFactory rather than RelOptCostImpl in blink planner

2024-10-01 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886280#comment-17886280 ] Jim Hughes commented on FLINK-15333: [~yiyutian] and I hit the issue recently and we

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

2024-09-23 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884050#comment-17884050 ] Jim Hughes commented on FLINK-12173: I think we should address https://issues.apache

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

2024-09-23 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883868#comment-17883868 ] Jim Hughes edited comment on FLINK-34702 at 9/23/24 12:53 PM:

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

2024-09-23 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883868#comment-17883868 ] Jim Hughes commented on FLINK-34702: Sergey, correct me if I'm wrong, but this appro

[jira] [Assigned] (FLINK-36330) Session Window TVFs with named parameters don't support column expansion

2024-09-19 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-36330: -- Assignee: Jim Hughes > Session Window TVFs with named parameters don't support column expansi

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

2024-09-06 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879983#comment-17879983 ] Jim Hughes commented on FLINK-34702: As a suggestion building on *Solution 1*, we co

[jira] [Created] (FLINK-36049) Add CompiledPlan annotations to BatchExecSortLimit

2024-08-13 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36049: -- Summary: Add CompiledPlan annotations to BatchExecSortLimit Key: FLINK-36049 URL: https://issues.apache.org/jira/browse/FLINK-36049 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-36048) Add CompiledPlan annotations to BatchExecRank

2024-08-13 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36048: -- Summary: Add CompiledPlan annotations to BatchExecRank Key: FLINK-36048 URL: https://issues.apache.org/jira/browse/FLINK-36048 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-36047) Add CompiledPlan annotations to BatchExecOverAggregate

2024-08-13 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36047: -- Summary: Add CompiledPlan annotations to BatchExecOverAggregate Key: FLINK-36047 URL: https://issues.apache.org/jira/browse/FLINK-36047 Project: Flink Issue Type

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

2024-08-09 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872447#comment-17872447 ] Jim Hughes commented on FLINK-12173: [~jark] This looks like a neat optimization. W

[jira] [Created] (FLINK-36003) Add CompiledPlan annotations to BatchExecExpand and BatchExecSortAggregate

2024-08-07 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36003: -- Summary: Add CompiledPlan annotations to BatchExecExpand and BatchExecSortAggregate Key: FLINK-36003 URL: https://issues.apache.org/jira/browse/FLINK-36003 Project: Flink

[jira] [Created] (FLINK-36002) Add CompiledPlan annotations to BatchExecMatch

2024-08-07 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-36002: -- Summary: Add CompiledPlan annotations to BatchExecMatch Key: FLINK-36002 URL: https://issues.apache.org/jira/browse/FLINK-36002 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-35944) Add CompiledPlan annotations to BatchExecUnion

2024-07-31 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35944: -- Summary: Add CompiledPlan annotations to BatchExecUnion Key: FLINK-35944 URL: https://issues.apache.org/jira/browse/FLINK-35944 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-35943) Add CompiledPlan annotations to BatchExecHashJoin and BatchExecNestedLoopJoin

2024-07-31 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35943: -- Summary: Add CompiledPlan annotations to BatchExecHashJoin and BatchExecNestedLoopJoin Key: FLINK-35943 URL: https://issues.apache.org/jira/browse/FLINK-35943 Project: Fl

[jira] [Updated] (FLINK-35942) Add CompiledPlan annotations to BatchExecCorrelate

2024-07-31 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-35942: --- Summary: Add CompiledPlan annotations to BatchExecCorrelate (was: Add CompiledPlan annotations to B

[jira] [Created] (FLINK-35942) Add CompiledPlan annotations to BatchExecSort

2024-07-31 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35942: -- Summary: Add CompiledPlan annotations to BatchExecSort Key: FLINK-35942 URL: https://issues.apache.org/jira/browse/FLINK-35942 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-35941) Add CompiledPlan annotations to BatchExecLimit

2024-07-31 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35941: -- Summary: Add CompiledPlan annotations to BatchExecLimit Key: FLINK-35941 URL: https://issues.apache.org/jira/browse/FLINK-35941 Project: Flink Issue Type: Sub-ta

[jira] [Updated] (FLINK-35934) Add CompiledPlan annotations to BatchExecValues

2024-07-30 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-35934: --- Description: In addition to the annotations, implement the BatchCompiledPlan test for this operator.

[jira] [Created] (FLINK-35934) Add CompiledPlan annotations to BatchExecValues

2024-07-30 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35934: -- Summary: Add CompiledPlan annotations to BatchExecValues Key: FLINK-35934 URL: https://issues.apache.org/jira/browse/FLINK-35934 Project: Flink Issue Type: Sub-t

[jira] [Updated] (FLINK-35923) Add CompiledPlan annotations to BatchExecSort

2024-07-30 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-35923: --- Description: In addition to the annotations, implement the BatchCompiledPlan test for this operator

[jira] [Created] (FLINK-35923) Add CompiledPlan annotations to BatchExecSort

2024-07-29 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35923: -- Summary: Add CompiledPlan annotations to BatchExecSort Key: FLINK-35923 URL: https://issues.apache.org/jira/browse/FLINK-35923 Project: Flink Issue Type: Sub-tas

[jira] [Resolved] (FLINK-35798) Implement a BatchRestoreTestBase

2024-07-29 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes resolved FLINK-35798. Fix Version/s: 2.0.0 Resolution: Fixed > Implement a BatchRestoreTestBase > ---

[jira] [Updated] (FLINK-35798) Implement a BatchRestoreTestBase

2024-07-29 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-35798: --- Description: * The goal of BatchRestoreTestBase has two goals: 1. Take TableTestPrograms and produce

[jira] [Updated] (FLINK-35798) Implement a BatchRestoreTestBase

2024-07-29 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-35798: --- Summary: Implement a BatchRestoreTestBase (was: Implement a BatchCompiledPlanTestBase) > Implement

[jira] [Commented] (FLINK-35798) Implement a BatchRestoreTestBase

2024-07-29 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869414#comment-17869414 ] Jim Hughes commented on FLINK-35798: This was implemented in https://github.com/apa

[jira] [Assigned] (FLINK-35799) Add CompiledPlan annotations to BatchExecCalc

2024-07-09 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-35799: -- Assignee: Jim Hughes > Add CompiledPlan annotations to BatchExecCalc > --

[jira] [Commented] (FLINK-35797) FLIP-456: CompiledPlan support for Batch Execution Mode

2024-07-09 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864427#comment-17864427 ] Jim Hughes commented on FLINK-35797: In terms of strategy, I'll be creating the init

[jira] [Assigned] (FLINK-35798) Implement a BatchCompiledPlanTestBase

2024-07-09 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-35798: -- Assignee: Jim Hughes > Implement a BatchCompiledPlanTestBase > --

[jira] [Created] (FLINK-35799) Add CompiledPlan annotations to BatchExecCalc

2024-07-09 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35799: -- Summary: Add CompiledPlan annotations to BatchExecCalc Key: FLINK-35799 URL: https://issues.apache.org/jira/browse/FLINK-35799 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-35798) Implement a BatchCompiledPlanTestBase

2024-07-09 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35798: -- Summary: Implement a BatchCompiledPlanTestBase Key: FLINK-35798 URL: https://issues.apache.org/jira/browse/FLINK-35798 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35797) FLIP-456: CompiledPlan support for Batch Execution Mode

2024-07-09 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35797: -- Summary: FLIP-456: CompiledPlan support for Batch Execution Mode Key: FLINK-35797 URL: https://issues.apache.org/jira/browse/FLINK-35797 Project: Flink Issue Typ

[jira] [Commented] (FLINK-33494) FLIP-376: Add DISTRIBUTED BY clause

2024-07-09 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864195#comment-17864195 ] Jim Hughes commented on FLINK-33494: Hi [~Weijie Guo], thank you! I thought we were

[jira] [Updated] (FLINK-33494) FLIP-376: Add DISTRIBUTED BY clause

2024-07-09 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-33494: --- Release Note: Many SQL vendors expose the concepts of Partitioning, Bucketing, and Clustering. Here

[jira] [Updated] (FLINK-33494) FLIP-376: Add DISTRIBUTED BY clause

2024-07-09 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-33494: --- Release Note: Many SQL vendors expose the concepts of Partitioning, Bucketing, and Clustering. We i

[jira] [Commented] (FLINK-33494) FLIP-376: Add DISTRIBUTED BY clause

2024-07-08 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863819#comment-17863819 ] Jim Hughes commented on FLINK-33494: Hi [~Weijie Guo] sorry to be slow to respond.

[jira] [Assigned] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause

2024-07-08 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-33497: -- Assignee: Arvid Heise (was: Tzu-Li (Gordon) Tai) > Update the Kafka connector to support DIS

[jira] [Commented] (FLINK-35608) Release Testing Instructions: Verify FLIP-376: Add DISTRIBUTED BY clause

2024-07-01 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861214#comment-17861214 ] Jim Hughes commented on FLINK-35608: I did the implementation for FLIP-376 / FLINK-3

[jira] [Assigned] (FLINK-33496) Expose DISTRIBUTED BY clause via parser

2024-06-28 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-33496: -- Assignee: Jim Hughes > Expose DISTRIBUTED BY clause via parser >

[jira] [Updated] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause

2024-06-28 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-33497: --- Parent: (was: FLINK-33494) Issue Type: New Feature (was: Sub-task) > Update the Kafka c

[jira] [Created] (FLINK-35725) Translate new DISTRIBUTED BY documentation into Chinese

2024-06-28 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35725: -- Summary: Translate new DISTRIBUTED BY documentation into Chinese Key: FLINK-35725 URL: https://issues.apache.org/jira/browse/FLINK-35725 Project: Flink Issue Typ

[jira] [Assigned] (FLINK-35585) Add documentation for distribution

2024-06-12 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-35585: -- Assignee: Jim Hughes > Add documentation for distribution > -

[jira] [Created] (FLINK-35585) Add documentation for distribution

2024-06-12 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-35585: -- Summary: Add documentation for distribution Key: FLINK-35585 URL: https://issues.apache.org/jira/browse/FLINK-35585 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-34513) GroupAggregateRestoreTest.testRestore fails

2024-03-25 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830640#comment-17830640 ] Jim Hughes commented on FLINK-34513: >From looking at this quickly, here are some no

[jira] [Assigned] (FLINK-33521) Implement restore tests for PythonCalc node

2024-03-25 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-33521: -- Assignee: (was: Jim Hughes) > Implement restore tests for PythonCalc node > -

[jira] [Commented] (FLINK-29107) Upgrade spotless version to improve spotless check efficiency

2024-01-30 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812488#comment-17812488 ] Jim Hughes commented on FLINK-29107: [~chesnay] Do you know if the IntelliJ plugin h

[jira] [Created] (FLINK-34173) Implement CatalogTable.Builder

2024-01-19 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-34173: -- Summary: Implement CatalogTable.Builder Key: FLINK-34173 URL: https://issues.apache.org/jira/browse/FLINK-34173 Project: Flink Issue Type: Sub-task R

[jira] [Assigned] (FLINK-34172) Add support for altering a distribution via ALTER TABLE

2024-01-19 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-34172: -- Assignee: Jim Hughes > Add support for altering a distribution via ALTER TABLE > ---

[jira] [Created] (FLINK-34172) Add support for altering a distribution via ALTER TABLE

2024-01-19 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-34172: -- Summary: Add support for altering a distribution via ALTER TABLE Key: FLINK-34172 URL: https://issues.apache.org/jira/browse/FLINK-34172 Project: Flink Issue Ty

[jira] [Updated] (FLINK-34067) Fix javacc warnings in flink-sql-parser

2024-01-11 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-34067: --- Description: While extending the Flink SQL parser, I noticed these two warnings: ``` [INFO] — javacc

[jira] [Created] (FLINK-34067) Fix javacc warnings in flink-sql-parser

2024-01-11 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-34067: -- Summary: Fix javacc warnings in flink-sql-parser Key: FLINK-34067 URL: https://issues.apache.org/jira/browse/FLINK-34067 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-34067) Fix javacc warnings in flink-sql-parser

2024-01-11 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-34067: --- Affects Version/s: 1.19.0 > Fix javacc warnings in flink-sql-parser > --

[jira] [Comment Edited] (FLINK-21224) Remove BatchExecExchange and StreamExecExchange, and replace their functionality with ExecEdge

2023-12-20 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799190#comment-17799190 ] Jim Hughes edited comment on FLINK-21224 at 12/20/23 10:08 PM: ---

[jira] [Commented] (FLINK-21224) Remove BatchExecExchange and StreamExecExchange, and replace their functionality with ExecEdge

2023-12-20 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799190#comment-17799190 ] Jim Hughes commented on FLINK-21224: As a note, if this node is used, it would need

[jira] [Closed] (FLINK-33918) Fix AsyncSinkWriterThrottlingTest test failure

2023-12-20 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes closed FLINK-33918. -- Resolution: Duplicate Duplicate of https://issues.apache.org/jira/browse/FLINK-31472 > Fix AsyncSinkW

[jira] [Commented] (FLINK-33918) Fix AsyncSinkWriterThrottlingTest test failure

2023-12-20 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799149#comment-17799149 ] Jim Hughes commented on FLINK-33918: Sorry for the duplicate! > Fix AsyncSinkWriter

[jira] [Updated] (FLINK-33918) Fix AsyncSinkWriterThrottlingTest test failure

2023-12-20 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-33918: --- Description: >From >[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=55700&v

[jira] [Commented] (FLINK-33918) Fix AsyncSinkWriterThrottlingTest test failure

2023-12-20 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799139#comment-17799139 ] Jim Hughes commented on FLINK-33918: [https://dev.azure.com/apache-flink/apache-flin

[jira] [Created] (FLINK-33918) Fix AsyncSinkWriterThrottlingTest test failure

2023-12-20 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-33918: -- Summary: Fix AsyncSinkWriterThrottlingTest test failure Key: FLINK-33918 URL: https://issues.apache.org/jira/browse/FLINK-33918 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-33877) CollectSinkFunctionTest.testConfiguredPortIsUsed fails due to BindException

2023-12-19 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798614#comment-17798614 ] Jim Hughes commented on FLINK-33877: https://dev.azure.com/apache-flink/apache-flink

[jira] [Commented] (FLINK-27756) Fix intermittently failing test in AsyncSinkWriterTest.checkLoggedSendTimesAreWithinBounds

2023-12-18 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798369#comment-17798369 ] Jim Hughes commented on FLINK-27756: https://dev.azure.com/apache-flink/apache-flink

[jira] [Commented] (FLINK-27756) Fix intermittently failing test in AsyncSinkWriterTest.checkLoggedSendTimesAreWithinBounds

2023-12-18 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798368#comment-17798368 ] Jim Hughes commented on FLINK-27756: https://dev.azure.com/apache-flink/apache-flink

[jira] [Commented] (FLINK-33756) Missing record with CUMULATE/HOP windows using an optimization

2023-12-14 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796949#comment-17796949 ] Jim Hughes commented on FLINK-33756: Hi [~jeyhunkarimov], I am not actively working

  1   2   >