[jira] [Created] (FLINK-37854) UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds

Jacky Lau created FLINK-37854: - Summary: UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds Key: FLINK-37854 URL: https://issues.apache.org/jira/browse/FLINK-37854 Project: Flink

Re: [ANNOUNCE] New Apache Flink PMC Member - Zakelly Lan

Congratulations, Zakelly! Best, JackyLau Shengkai Fang 于2025年4月2日周三 13:45写道： > Congratulations, Zakelly! > > Best, > Shengkai > > Yash Anand 于2025年4月2日周三 13:07写道： > > > Congratulations, Zakelly! > > > > On Wed, Apr 2, 2025 at 12:03 AM Sergey Nuyanzin > > wrote: > > > > > Congratulations, Zake

[jira] [Created] (FLINK-37591) Add Some PruneEmptyRules

Jacky Lau created FLINK-37591: - Summary: Add Some PruneEmptyRules Key: FLINK-37591 URL: https://issues.apache.org/jira/browse/FLINK-37591 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-37595) Add Join remove rules.

Jacky Lau created FLINK-37595: - Summary: Add Join remove rules. Key: FLINK-37595 URL: https://issues.apache.org/jira/browse/FLINK-37595 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-37593) Add some Reduce Expression Rules

Jacky Lau created FLINK-37593: - Summary: Add some Reduce Expression Rules Key: FLINK-37593 URL: https://issues.apache.org/jira/browse/FLINK-37593 Project: Flink Issue Type: Sub-task

Re: 回复：[ANNOUNCE] New Apache Flink Committer - Feng Jin

Congratulations! Best, Jacky Xuyang 于2025年2月21日周五 11:57写道： > Congratulations, Feng Jin ;)-- > > Best！ > Xuyang > > > > > > 在 2025-02-21 11:16:14，"Wei Zuo" <1015766...@qq.com.INVALID> 写道： > >Congratulations! > > > >Best, > >Zuo Wei > > > > > >-- 原始邮件 -- >

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

Congratulations, you deserve it. Best, Jacky yh z 于2025年2月20日周四 10:01写道： > Congratulations > > Best, > Ron > > Ron Liu 于2025年2月20日周四 09:56写道： > > > Congratulations, you deserve it. > > > > Best, > > Ron > > > > > > Lincoln Lee 于2025年2月20日周四 09:50写道： > > > > > Hi everyone, > > > > > > On behal

[jira] [Created] (FLINK-37009) Migrate PruneAggregateCallRule

Jacky Lau created FLINK-37009: - Summary: Migrate PruneAggregateCallRule Key: FLINK-37009 URL: https://issues.apache.org/jira/browse/FLINK-37009 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37002) Migrate DecomposeGroupingSetsRule

Jacky Lau created FLINK-37002: - Summary: Migrate DecomposeGroupingSetsRule Key: FLINK-37002 URL: https://issues.apache.org/jira/browse/FLINK-37002 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36992) Migrate SplitAggregateRule

Jacky Lau created FLINK-36992: - Summary: Migrate SplitAggregateRule Key: FLINK-36992 URL: https://issues.apache.org/jira/browse/FLINK-36992 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36988) Migrate LogicalCorrelateToJoinFromTemporalTableFunctionRule

Jacky Lau created FLINK-36988: - Summary: Migrate LogicalCorrelateToJoinFromTemporalTableFunctionRule Key: FLINK-36988 URL: https://issues.apache.org/jira/browse/FLINK-36988 Project: Flink Issue

[jira] [Created] (FLINK-36986) Migrate SplitRemoteConditionFromJoinRule

Jacky Lau created FLINK-36986: - Summary: Migrate SplitRemoteConditionFromJoinRule Key: FLINK-36986 URL: https://issues.apache.org/jira/browse/FLINK-36986 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36955) Migrate RewriteIntersectAllRule

Jacky Lau created FLINK-36955: - Summary: Migrate RewriteIntersectAllRule Key: FLINK-36955 URL: https://issues.apache.org/jira/browse/FLINK-36955 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36954) Migrate CalcRankTransposeRule

Jacky Lau created FLINK-36954: - Summary: Migrate CalcRankTransposeRule Key: FLINK-36954 URL: https://issues.apache.org/jira/browse/FLINK-36954 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36951) Migrate ProjectSemiAntiJoinTransposeRule

Jacky Lau created FLINK-36951: - Summary: Migrate ProjectSemiAntiJoinTransposeRule Key: FLINK-36951 URL: https://issues.apache.org/jira/browse/FLINK-36951 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36950) Migrate WindowPropertiesRules

Jacky Lau created FLINK-36950: - Summary: Migrate WindowPropertiesRules Key: FLINK-36950 URL: https://issues.apache.org/jira/browse/FLINK-36950 Project: Flink Issue Type: Sub-task

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

Jacky Lau created FLINK-36911: - Summary: add more calcite rules to improve flink performance because calcite has upgrade Key: FLINK-36911 URL: https://issues.apache.org/jira/browse/FLINK-36911 Project

[jira] [Created] (FLINK-36848) FlinkLimit0RemoveRule can be replaced by PruneEmptyRules.SORT_FETCH_ZERO_INSTANCE because high version calcite has supported

Jacky Lau created FLINK-36848: - Summary: FlinkLimit0RemoveRule can be replaced by PruneEmptyRules.SORT_FETCH_ZERO_INSTANCE because high version calcite has supported Key: FLINK-36848 URL: https://issues.apache.org

[jira] [Created] (FLINK-36792) FlinkJoinPushExpressionsRule can be removed because high version calcite has fixed

Jacky Lau created FLINK-36792: - Summary: FlinkJoinPushExpressionsRule can be removed because high version calcite has fixed Key: FLINK-36792 URL: https://issues.apache.org/jira/browse/FLINK-36792 Project

[jira] [Created] (FLINK-36791) FlinkPruneEmptyRules can be removed because high version calcite has fixed

Jacky Lau created FLINK-36791: - Summary: FlinkPruneEmptyRules can be removed because high version calcite has fixed Key: FLINK-36791 URL: https://issues.apache.org/jira/browse/FLINK-36791 Project: Flink

[jira] [Created] (FLINK-36399) cast result is incorrect

Jacky Lau created FLINK-36399: - Summary: cast result is incorrect Key: FLINK-36399 URL: https://issues.apache.org/jira/browse/FLINK-36399 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal

Jacky Lau created FLINK-36378: - Summary: type extraction problem between java BigDecimal and sql decimal Key: FLINK-36378 URL: https://issues.apache.org/jira/browse/FLINK-36378 Project: Flink

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

Jacky Lau created FLINK-36358: - Summary: to_timestamp result is not correct when the string precision is long than date format Key: FLINK-36358 URL: https://issues.apache.org/jira/browse/FLINK-36358

[jira] [Created] (FLINK-36089) clean codegen print function

Jacky Lau created FLINK-36089: - Summary: clean codegen print function Key: FLINK-36089 URL: https://issues.apache.org/jira/browse/FLINK-36089 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-35752) Migrate PythonUtil

Jacky Lau created FLINK-35752: - Summary: Migrate PythonUtil Key: FLINK-35752 URL: https://issues.apache.org/jira/browse/FLINK-35752 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-35751) Migrate SplitPythonConditionFromCorrelateRule

Jacky Lau created FLINK-35751: - Summary: Migrate SplitPythonConditionFromCorrelateRule Key: FLINK-35751 URL: https://issues.apache.org/jira/browse/FLINK-35751 Project: Flink Issue Type: Sub-task

Re: [ANNOUNCE] New Apache Flink Committer - Zhongqiang Gong

Congratulations Zhongqiang! Best Regards Jacky Lau Yubin Li 于2024年6月18日周二 00:28写道： > Congratulations Zhongqiang! > > Best Regards > Yubin > > On Tue, Jun 18, 2024 at 12:21 AM Muhammet Orazov > wrote: > > > > Congratulations Zhongqiang! Well deserved! > > > > Best, > > Muhammet > > > > >

Re: [ANNOUNCE] New Apache Flink Committer - Hang Ruan

Congratulations Hang! Best Regards Jacky Lau Yubin Li 于2024年6月18日周二 00:36写道： > Congratulations Hang! > > Best Regards > Yubin > > On Tue, Jun 18, 2024 at 12:23 AM Muhammet Orazov > wrote: > > > > Congratulations Hang! Well deserved! > > > > Best, > > Muhammet >

Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui

Congratulations Rui, well deserved! Regards, Jacky Lau Jeyhun Karimov 于2024年6月11日 周二03:49写道： > Congratulations Rui, well deserved! > > Regards, > Jeyhun > > On Mon, Jun 10, 2024, 10:21 Ahmed Hamdy wrote: > > > Congratulations Rui! > > Best Regards > >

Re: [ANNOUNCE] New Apache Flink PMC Member - Lincoln Lee

Congratulations, Lincoln! Best, Jacky Lau Jinzhong Li 于2024年4月15日周一 15:45写道： > Congratulations, Lincoln! > > Best, > Jinzhong Li > > On Mon, Apr 15, 2024 at 2:56 PM Hangxiang Yu wrote: > > > Congratulations, Lincoln! > > > > On Mon, Apr 15,

Re: [ANNOUNCE] New Apache Flink PMC Member - Jing Ge

Congratulations, Jing! Best, Jacky Lau

[jira] [Created] (FLINK-35075) Migrate TwoStageOptimizedAggregateRule

Jacky Lau created FLINK-35075: - Summary: Migrate TwoStageOptimizedAggregateRule Key: FLINK-35075 URL: https://issues.apache.org/jira/browse/FLINK-35075 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35062) Migrate RewriteMultiJoinConditionRule

Jacky Lau created FLINK-35062: - Summary: Migrate RewriteMultiJoinConditionRule Key: FLINK-35062 URL: https://issues.apache.org/jira/browse/FLINK-35062 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35061) Migrate TemporalJoinUtil

Jacky Lau created FLINK-35061: - Summary: Migrate TemporalJoinUtil Key: FLINK-35061 URL: https://issues.apache.org/jira/browse/FLINK-35061 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-35054) Migrate TemporalJoinRewriteWithUniqueKeyRule

Jacky Lau created FLINK-35054: - Summary: Migrate TemporalJoinRewriteWithUniqueKeyRule Key: FLINK-35054 URL: https://issues.apache.org/jira/browse/FLINK-35054 Project: Flink Issue Type: Sub-task

Re: [ANNOUNCE] Apache Flink 1.19.0 released

Congratulations! Best, Jacky Lau Hongshun Wang 于2024年3月21日周四 10:32写道： > Congratulations! > > Best, > Hongshun > > On Tue, Mar 19, 2024 at 3:12 PM Shawn Huang wrote: > > > Congratulations! > > > > Best, > > Shawn Huang > > > > > &g

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

Jacky Lau created FLINK-34702: - Summary: Rank should not convert to StreamExecDuplicate when the input is not insert only Key: FLINK-34702 URL: https://issues.apache.org/jira/browse/FLINK-34702 Project

[jira] [Created] (FLINK-34665) Add streaming rule for union to Rand and it convert to StreamExecDeduplicate finally

Jacky Lau created FLINK-34665: - Summary: Add streaming rule for union to Rand and it convert to StreamExecDeduplicate finally Key: FLINK-34665 URL: https://issues.apache.org/jira/browse/FLINK-34665

[jira] [Created] (FLINK-34650) Migrate PushProjectIntoLegacyTableSourceScanRule

Jacky Lau created FLINK-34650: - Summary: Migrate PushProjectIntoLegacyTableSourceScanRule Key: FLINK-34650 URL: https://issues.apache.org/jira/browse/FLINK-34650 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-34649) Migrate PushFilterIntoLegacyTableSourceScanRule

Jacky Lau created FLINK-34649: - Summary: Migrate PushFilterIntoLegacyTableSourceScanRule Key: FLINK-34649 URL: https://issues.apache.org/jira/browse/FLINK-34649 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-34616) python dist doesn't clean when open method construct resource

Jacky Lau created FLINK-34616: - Summary: python dist doesn't clean when open method construct resource Key: FLINK-34616 URL: https://issues.apache.org/jira/browse/FLINK-34616 Project:

[jira] [Created] (FLINK-34612) Migrate StreamPhysicalValuesRule

Jacky Lau created FLINK-34612: - Summary: Migrate StreamPhysicalValuesRule Key: FLINK-34612 URL: https://issues.apache.org/jira/browse/FLINK-34612 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34611) Migrate StreamPhysicalUnionRule

Jacky Lau created FLINK-34611: - Summary: Migrate StreamPhysicalUnionRule Key: FLINK-34611 URL: https://issues.apache.org/jira/browse/FLINK-34611 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34609) Migrate BatchPhysicalScriptTransformRule

Jacky Lau created FLINK-34609: - Summary: Migrate BatchPhysicalScriptTransformRule Key: FLINK-34609 URL: https://issues.apache.org/jira/browse/FLINK-34609 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34610) Migrate StreamPhysicalLimitRule

Jacky Lau created FLINK-34610: - Summary: Migrate StreamPhysicalLimitRule Key: FLINK-34610 URL: https://issues.apache.org/jira/browse/FLINK-34610 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34608) Migrate BatchPhysicalValuesRule

Jacky Lau created FLINK-34608: - Summary: Migrate BatchPhysicalValuesRule Key: FLINK-34608 URL: https://issues.apache.org/jira/browse/FLINK-34608 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34607) Migrate BatchPhysicalUnionRule

Jacky Lau created FLINK-34607: - Summary: Migrate BatchPhysicalUnionRule Key: FLINK-34607 URL: https://issues.apache.org/jira/browse/FLINK-34607 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34606) Migrate BatchPhysicalExpandRule

Jacky Lau created FLINK-34606: - Summary: Migrate BatchPhysicalExpandRule Key: FLINK-34606 URL: https://issues.apache.org/jira/browse/FLINK-34606 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34605) Migrate BatchPhysicalDistributionRule

Jacky Lau created FLINK-34605: - Summary: Migrate BatchPhysicalDistributionRule Key: FLINK-34605 URL: https://issues.apache.org/jira/browse/FLINK-34605 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34603) Migrate BatchPhysicalBoundedStreamScanRule

Jacky Lau created FLINK-34603: - Summary: Migrate BatchPhysicalBoundedStreamScanRule Key: FLINK-34603 URL: https://issues.apache.org/jira/browse/FLINK-34603 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34604) Migrate BatchPhysicalCalcRule

Jacky Lau created FLINK-34604: - Summary: Migrate BatchPhysicalCalcRule Key: FLINK-34604 URL: https://issues.apache.org/jira/browse/FLINK-34604 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34556) Migrate EnumerableToLogicalTableScan

Jacky Lau created FLINK-34556: - Summary: Migrate EnumerableToLogicalTableScan Key: FLINK-34556 URL: https://issues.apache.org/jira/browse/FLINK-34556 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34555) Migrate JoinConditionTypeCoerceRule

Jacky Lau created FLINK-34555: - Summary: Migrate JoinConditionTypeCoerceRule Key: FLINK-34555 URL: https://issues.apache.org/jira/browse/FLINK-34555 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34505) Migrate WindowGroupReorderRule

Jacky Lau created FLINK-34505: - Summary: Migrate WindowGroupReorderRule Key: FLINK-34505 URL: https://issues.apache.org/jira/browse/FLINK-34505 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34503) Migrate JoinDeriveNullFilterRule

Jacky Lau created FLINK-34503: - Summary: Migrate JoinDeriveNullFilterRule Key: FLINK-34503 URL: https://issues.apache.org/jira/browse/FLINK-34503 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34494) Migrate ReplaceIntersectWithSemiJoinRule

Jacky Lau created FLINK-34494: - Summary: Migrate ReplaceIntersectWithSemiJoinRule Key: FLINK-34494 URL: https://issues.apache.org/jira/browse/FLINK-34494 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34493) Migrate ReplaceMinusWithAntiJoinRule

Jacky Lau created FLINK-34493: - Summary: Migrate ReplaceMinusWithAntiJoinRule Key: FLINK-34493 URL: https://issues.apache.org/jira/browse/FLINK-34493 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34492) fix scala style comment link when migrate scala to java

Jacky Lau created FLINK-34492: - Summary: fix scala style comment link when migrate scala to java Key: FLINK-34492 URL: https://issues.apache.org/jira/browse/FLINK-34492 Project: Flink Issue Type

[jira] [Created] (FLINK-34481) Migrate SetOpRewriteUtil

Jacky Lau created FLINK-34481: - Summary: Migrate SetOpRewriteUtil Key: FLINK-34481 URL: https://issues.apache.org/jira/browse/FLINK-34481 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-34473) Migrate FlinkPruneEmptyRules

Jacky Lau created FLINK-34473: - Summary: Migrate FlinkPruneEmptyRules Key: FLINK-34473 URL: https://issues.apache.org/jira/browse/FLINK-34473 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-34033) flink json supports raw type

Jacky Lau created FLINK-34033: - Summary: flink json supports raw type Key: FLINK-34033 URL: https://issues.apache.org/jira/browse/FLINK-34033 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-33951) should use aggCallNeedRetractions instead of needRetraction to check retract method, orelse throw not implement retract method

Jacky Lau created FLINK-33951: - Summary: should use aggCallNeedRetractions instead of needRetraction to check retract method, orelse throw not implement retract method Key: FLINK-33951 URL: https://issues.apache.org

[jira] [Created] (FLINK-33950) Update max aggregate functions to new type system

Jacky Lau created FLINK-33950: - Summary: Update max aggregate functions to new type system Key: FLINK-33950 URL: https://issues.apache.org/jira/browse/FLINK-33950 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-33948) Cleanup usage of org.apache.flink.table.api.dataview.MapView#MapView

Jacky Lau created FLINK-33948: - Summary: Cleanup usage of org.apache.flink.table.api.dataview.MapView#MapView Key: FLINK-33948 URL: https://issues.apache.org/jira/browse/FLINK-33948 Project: Flink

[jira] [Created] (FLINK-33945) Cleanup usage of deprecated org.apache.flink.table.api.dataview.ListView#ListView

Jacky Lau created FLINK-33945: - Summary: Cleanup usage of deprecated org.apache.flink.table.api.dataview.ListView#ListView Key: FLINK-33945 URL: https://issues.apache.org/jira/browse/FLINK-33945 Project

[jira] [Created] (FLINK-33896) Implement restore tests for Correlate node

Jacky Lau created FLINK-33896: - Summary: Implement restore tests for Correlate node Key: FLINK-33896 URL: https://issues.apache.org/jira/browse/FLINK-33896 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33895) Implement restore tests for PythonGroupWindowAggregate node

Jacky Lau created FLINK-33895: - Summary: Implement restore tests for PythonGroupWindowAggregate node Key: FLINK-33895 URL: https://issues.apache.org/jira/browse/FLINK-33895 Project: Flink Issue

[jira] [Created] (FLINK-33894) Implement restore tests for PythonGroupAggregate node

Jacky Lau created FLINK-33894: - Summary: Implement restore tests for PythonGroupAggregate node Key: FLINK-33894 URL: https://issues.apache.org/jira/browse/FLINK-33894 Project: Flink Issue Type

[jira] [Created] (FLINK-33893) Implement restore tests for PythonCorrelate node

Jacky Lau created FLINK-33893: - Summary: Implement restore tests for PythonCorrelate node Key: FLINK-33893 URL: https://issues.apache.org/jira/browse/FLINK-33893 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-33781) Cleanup usage of deprecated org.apache.flink.table.api.TableConfig#ctor()

Jacky Lau created FLINK-33781: - Summary: Cleanup usage of deprecated org.apache.flink.table.api.TableConfig#ctor() Key: FLINK-33781 URL: https://issues.apache.org/jira/browse/FLINK-33781 Project: Flink

[jira] [Created] (FLINK-33779) Cleanup usage of deprecated BaseExpressions#cast(TypeInformation)

Jacky Lau created FLINK-33779: - Summary: Cleanup usage of deprecated BaseExpressions#cast(TypeInformation) Key: FLINK-33779 URL: https://issues.apache.org/jira/browse/FLINK-33779 Project: Flink

[jira] [Created] (FLINK-33778) Cleanup usage of deprecated TableConfig#setIdleStateRetentionTime(Time, Time)

Jacky Lau created FLINK-33778: - Summary: Cleanup usage of deprecated TableConfig#setIdleStateRetentionTime(Time, Time) Key: FLINK-33778 URL: https://issues.apache.org/jira/browse/FLINK-33778 Project

[jira] [Created] (FLINK-33546) Implement type inference for order(asc/desc) function

Jacky Lau created FLINK-33546: - Summary: Implement type inference for order(asc/desc) function Key: FLINK-33546 URL: https://issues.apache.org/jira/browse/FLINK-33546 Project: Flink Issue Type

[jira] [Created] (FLINK-33518) Implement restore tests for WatermarkAssigner node

Jacky Lau created FLINK-33518: - Summary: Implement restore tests for WatermarkAssigner node Key: FLINK-33518 URL: https://issues.apache.org/jira/browse/FLINK-33518 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-33517) Implement restore tests for Value node

Jacky Lau created FLINK-33517: - Summary: Implement restore tests for Value node Key: FLINK-33517 URL: https://issues.apache.org/jira/browse/FLINK-33517 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32721) agg supports char type

Jacky Lau created FLINK-32721: - Summary: agg supports char type Key: FLINK-32721 URL: https://issues.apache.org/jira/browse/FLINK-32721 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-32699) select typeof(proctime()); throw exception in sql-client

Jacky Lau created FLINK-32699: - Summary: select typeof(proctime()); throw exception in sql-client Key: FLINK-32699 URL: https://issues.apache.org/jira/browse/FLINK-32699 Project: Flink Issue

[jira] [Created] (FLINK-32641) json format supports pojo type

Jacky Lau created FLINK-32641: - Summary: json format supports pojo type Key: FLINK-32641 URL: https://issues.apache.org/jira/browse/FLINK-32641 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-32530) array_position semantic should align with array_contains instead of spark

Jacky Lau created FLINK-32530: - Summary: array_position semantic should align with array_contains instead of spark Key: FLINK-32530 URL: https://issues.apache.org/jira/browse/FLINK-32530 Project: Flink

[jira] [Created] (FLINK-32498) array_max return type should always nullable

Jacky Lau created FLINK-32498: - Summary: array_max return type should always nullable Key: FLINK-32498 URL: https://issues.apache.org/jira/browse/FLINK-32498 Project: Flink Issue Type

Re: Re: [VOTE] FLIP-302: Support TRUNCATE TABLE statement in batch mode

+1 (no-binding) Best, Jacky Lau Jingsong Li 于2023年4月18日周二 11:57写道： > +1 > > On Tue, Apr 18, 2023 at 9:39 AM Aitozi wrote: > > > > +1 > > > > Best, > > Aitozi > > > > ron 于2023年4月18日周二 09:18写道： > > > > > > +1 > > >

Re: [DISCUSS] Add support for Apache Arrow format

Hi I also think arrow format will be useful when reading/writing with message queue. Arrow defines a language-independent columnar memory format for flat and hierarchical data, organized for efficient analytic operations on modern hardware like CPUs and GPUs. The Arrow memory format also sup

Re: [ANNOUNCE] Kafka Connector Code Removal from apache/flink:main branch and code freezing

Hi Gordon. https://issues.apache.org/jira/browse/FLINK-31006, which is also a critical bug in kafka. it will not exit after all partitions consumed when jobmanager failover in pipeline mode running unbounded source. and i talked with @PatrickRen offline, don't have

Re: [VOTE] FLIP-293: Introduce Flink Jdbc Driver For Sql Gateway

+1 (non-binding) it will make integrate with other tools convenient, like beeline/tableau Best Regards, Jacky Lau Ran Tao 于2023年3月15日周三 13:11写道： > It's a very nice improvement. > > +1 (non-binding) > > Best Regards, > Ran Tao > > > Shammon FY 于2023年3月13日周一 13:

Re: [VOTE] FLIP-300: Add targetColumns to DynamicTableSink#Context to solve the null overwrite problem of partial-insert

+1 (non-binding) Best, Jacky Jingsong Li 于2023年3月14日周二 17:17写道： > +1 binding > > On Tue, Mar 14, 2023 at 10:54 AM Samrat Deb wrote: > > > > +1 (non binding) > > Thanks for driving it . > > > > Bests, > > Samrat > > > > On Tue, 14 Mar 2023 at 7:41 AM, Jark Wu wrote: > > > > > +1 (binding) > >

Re: [DISCUSS] FLIP-300: Add targetColumns to DynamicTableSink#Context to solve the null overwrite problem of partial-insert

Thanks for bringing this up. this is a good feature. but i have two questions: 1. if the two insert into with same columns, the result is not nondeterminism. will it check in planner and throw exception 2. some sink connectors can not supports it like queue such as kafka compacted topic. will also

Re: [VOTE] FLIP-297: Improve Auxiliary Sql Statements

Thanks Ran. +1 (non-binding) Regards, Jacky Lau Ran Tao 于2023年3月6日周一 19:32写道： > Hi Everyone, > > > I want to start the vote on FLIP-297: Improve Auxiliary Sql Statements [1]. > The FLIP was discussed in this thread [2]. > > > The goal of the FLIP is to improve flink

Re: [DISCUSS] FLIP-297: Improve Auxiliary Sql Statements

Hi Ran: Thanks for driving the FLIP. the google doc looks really good. it is important to improve user interactive experience. +1 to support this feature. Jing Ge 于2023年2月23日周四 00:51写道： > Hi Ran, > > Thanks for driving the FLIP. It looks overall good. Would you like to add > a description of us

RE: Re: [DISCUSS ] add --jars to support users dependencies jars.

hi Martijn: Some platform users may not package all the jars to the fat jars, spark also has - jars for dependencies https://stackoverflow.com/questions/29099115/spark-submit-add-multiple-jars-in-classpath On 2022/10/27 06:48:52 Martijn Visser wrote: > Hi Jacky Lau, > > Since you&#x

[DISCUSS ] add --jars to support users dependencies jars.

Hi guys: I'd like to initiate a discussion about adding command-line arguments to support user-dependent jar packages. Currently flink supports user's main jars through -jarfile or without setting this , the flink client will treat the first argument after that as the user master jar package when

[DISCUSS ] add --jars to support users dependencies jars.

Hi guys: I'd like to initiate a discussion about adding command-line arguments to support user-dependent jar packages. Currently flink supports user's main jars through -jarfile or without setting this , the flink client will treat the first argument after that as the user master jar package when

[DISCUSS ] add --jars to support users dependencies jars.

Hi guys: I'd like to initiate a discussion about adding command-line arguments to support user-dependent jar packages. Currently flink supports user's main jars through -jarfile or without setting this , the flink client will treat the first argument after that as the user master jar package when

Re: [DISCUSS ] HybridSouce Table & Sql api timeline

I am interested in this, can you share your DDL first? At the same time, there is no standard to describe hybrid Source DDL. I also hope that the community can discuss together and share their ideas. Ran Tao 于2022年5月7日周六 11:59写道： > HybridSource is a good feature, but now release version did not

Re: Re: [ANNOUNCE] New Flink PMC member: Yang Wang

Congrats Yang and well Deserved! Best, Jacky Lau Yun Gao 于2022年5月7日周六 10:44写道： > Congratulations Yang! > > Best, > Yun Gao > > > > --Original Mail -- > Sender:David Morávek > Send Date:Sat May 7 01:05:41 2022 > Recipients:

RE: Re: [DISCUSS] FLIP-213: TaskManager's Flame Graphs

eature, as we also experienced browser crashes on >>> existing operator-level flame graphs >>> >>> Best, >>> Echo Lee >>> >>>> 在 2022年1月24日，下午6:16，David Morávek 写道： >>>> >>>> Hi Jacky, >>>> >>>&

RE: Re: [DISCUSS] FLIP-213: TaskManager's Flame Graphs

eature, as we also experienced browser crashes on >>> existing operator-level flame graphs >>> >>> Best, >>> Echo Lee >>> >>>> 在 2022年1月24日，下午6:16，David Morávek 写道： >>>> >>>> Hi Jacky, >>>> >>>&

RE: Re: [DISCUSS] FLIP-213: TaskManager's Flame Graphs

t; This is an expected feature, as we also experienced browser crashes on > > > existing operator-level flame graphs > > > > > > Best, > > > Echo Lee > > > > > > > 在 2022年1月24日，下午6:16，David Morávek 写道： > > > > > > > >

RE: Re: [DISCUSS] FLIP-213: TaskManager's Flame Graphs

s the correct one [1]. > > > > > > [1] > > > > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-213%3A+TaskManager%27s+Flame+Graphs > > > > > > Best, > > > D. > > > > > >> On Mon, Jan 24, 2022 at 9:48 AM Jacky L

[DISCUSS] FLIP-213: TaskManager's Flame Graphs

at the FLIP wiki area is not fully done since i don't konw whether it will accept by flink community.     Feel free to add your thoughts to make this feature better! i am looking forward  to all your response. Thanks too much! Best Jacky Lau

[DISCUSS] flink authorization supports

dd interface for authorization. And users can implement it by themself.could the flink conmunity add some interfaces or have some future work to support authorization Cheers, Jacky Lau -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

  1   2   >