[
https://issues.apache.org/jira/browse/FLINK-35751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17887464#comment-17887464
]
Jacky Lau commented on FLINK-35751:
---
hi [~snuyanzin] will you help review this?
> Mi
[ https://issues.apache.org/jira/browse/FLINK-35751 ]
Jacky Lau deleted comment on FLINK-35751:
---
was (Author: jackylau):
pr is here [https://github.com/apache/flink/pull/25014,] will you help review
this [~snuyanzin] ?
> Migrate SplitPythonCondi
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: Tabl
[
https://issues.apache.org/jira/browse/FLINK-36378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885189#comment-17885189
]
Jacky Lau commented on FLINK-36378:
---
hi [~twalthr] , will you have time to have a look
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
Is
[
https://issues.apache.org/jira/browse/FLINK-36358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau resolved FLINK-36358.
---
Resolution: Fixed
> to_timestamp result is not correct when the string precision is long than
> dat
[
https://issues.apache.org/jira/browse/FLINK-36358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau updated FLINK-36358:
--
Description:
tEnv.executeSql("select to_timestamp('2017-09-15 00:00:00.12345', '-MM-dd
HH:mm:ss.S
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
Proje
[
https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884184#comment-17884184
]
Jacky Lau commented on FLINK-34702:
---
i agree with [~lincoln.86xy] +1
Delay the rank/
[
https://issues.apache.org/jira/browse/FLINK-36089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau closed FLINK-36089.
-
Resolution: Fixed
> clean codegen print function
>
>
> Key:
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:
[
https://issues.apache.org/jira/browse/FLINK-35752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862772#comment-17862772
]
Jacky Lau commented on FLINK-35752:
---
pr is here [https://github.com/apache/flink/pull/
[
https://issues.apache.org/jira/browse/FLINK-35751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862771#comment-17862771
]
Jacky Lau edited comment on FLINK-35751 at 7/3/24 12:57 PM:
[
https://issues.apache.org/jira/browse/FLINK-35751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862771#comment-17862771
]
Jacky Lau commented on FLINK-35751:
---
pr is here [https://github.com/apache/flink/pull/
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: Table
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
[
https://issues.apache.org/jira/browse/FLINK-35075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837146#comment-17837146
]
Jacky Lau commented on FLINK-35075:
---
hi [~snuyanzin] will you help review this?
> Mig
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
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
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:
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
[ https://issues.apache.org/jira/browse/FLINK-34556 ]
Jacky Lau deleted comment on FLINK-34556:
---
was (Author: jackylau):
hi [~snuyanzin] will you also help review this pr ?
> Migrate EnumerableToLogicalTableScan
> ---
[
https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829374#comment-17829374
]
Jacky Lau edited comment on FLINK-34702 at 3/21/24 4:32 AM:
[
https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829374#comment-17829374
]
Jacky Lau edited comment on FLINK-34702 at 3/21/24 4:31 AM:
[
https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829374#comment-17829374
]
Jacky Lau commented on FLINK-34702:
---
When opting for Solution 3, it was found to be un
[
https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828590#comment-17828590
]
Jacky Lau commented on FLINK-34702:
---
we have three proposed solutions :
{*}Solution
[
https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau updated FLINK-34702:
--
Description:
{code:java}
@Test
def testSimpleFirstRowOnBuiltinProctime1(): Unit = {
val sqlQuery =
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: F
[
https://issues.apache.org/jira/browse/FLINK-34665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826981#comment-17826981
]
Jacky Lau edited comment on FLINK-34665 at 3/14/24 7:46 AM:
[
https://issues.apache.org/jira/browse/FLINK-34665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau updated FLINK-34665:
--
Issue Type: Improvement (was: Bug)
> Add streaming rule for union to Rand and it convert to StreamExe
[
https://issues.apache.org/jira/browse/FLINK-34665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826981#comment-17826981
]
Jacky Lau commented on FLINK-34665:
---
hi [~jark] [~xuyangzhong] what do you think?
> A
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
Projec
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-ta
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-tas
[
https://issues.apache.org/jira/browse/FLINK-34556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825486#comment-17825486
]
Jacky Lau commented on FLINK-34556:
---
hi [~snuyanzin] will you also help review this p
[
https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825260#comment-17825260
]
Jacky Lau commented on FLINK-31663:
---
[~Sergey Nuyanzin] ok. if the array_except and ar
[
https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825244#comment-17825244
]
Jacky Lau commented on FLINK-31663:
---
[~Sergey Nuyanzin] in Flink, array_contains retur
[
https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825131#comment-17825131
]
Jacky Lau commented on FLINK-31663:
---
hi [~snuyanzin] what is your opinion?
> Add ARRA
[
https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824699#comment-17824699
]
Jacky Lau commented on FLINK-31663:
---
[~dwysakowicz] Even though they are different fun
[
https://issues.apache.org/jira/browse/FLINK-34494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824687#comment-17824687
]
Jacky Lau commented on FLINK-34494:
---
hi [~dwysakowicz] will you help review this?
> M
[
https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824686#comment-17824686
]
Jacky Lau commented on FLINK-31663:
---
[~dwysakowicz] i see, thanks for your response.
[
https://issues.apache.org/jira/browse/FLINK-31663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824607#comment-17824607
]
Jacky Lau commented on FLINK-31663:
---
hi [~dwysakowicz] [~hanyuzheng] [~luoyuxia] , i f
[
https://issues.apache.org/jira/browse/FLINK-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824595#comment-17824595
]
Jacky Lau commented on FLINK-34156:
---
[~Sergey Nuyanzin]
If the community is short on
[
https://issues.apache.org/jira/browse/FLINK-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824594#comment-17824594
]
Jacky Lau commented on FLINK-34156:
---
[~Sergey Nuyanzin] I agree that these can be set
[
https://issues.apache.org/jira/browse/FLINK-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824380#comment-17824380
]
Jacky Lau commented on FLINK-34156:
---
[~Sergey Nuyanzin]
I've noticed that some Scala
[
https://issues.apache.org/jira/browse/FLINK-34616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau updated FLINK-34616:
--
Description:
our enviroment found lots of python-dist causing disk full.
the main resource is
constru
[
https://issues.apache.org/jira/browse/FLINK-34616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau updated FLINK-34616:
--
Description:
our enviroment found lots of python-dist causing disk full.
the main resource is
constru
[
https://issues.apache.org/jira/browse/FLINK-34616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau updated FLINK-34616:
--
Description:
our enviroment found lots of python-dist causing disk full.
the main resource is
constru
[
https://issues.apache.org/jira/browse/FLINK-34616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau updated FLINK-34616:
--
Attachment: image-2024-03-07-17-58-06-493.png
> python dist doesn't clean when open method construct r
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: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824266#comment-17824266
]
Jacky Lau commented on FLINK-34156:
---
hi [~Sergey Nuyanzin] Thanks for your summary.
A
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
Comp
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
Com
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
Comp
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
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
Comp
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
Compo
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
Comp
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
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
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
Compon
[
https://issues.apache.org/jira/browse/FLINK-34481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau closed FLINK-34481.
-
Release Note: merged f523b9d6191ecb584e36aa2aeffcd0659ce231f7
Resolution: Fixed
> Migrate SetOpRew
[
https://issues.apache.org/jira/browse/FLINK-34481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822434#comment-17822434
]
Jacky Lau commented on FLINK-34481:
---
Merged f523b9d6191ecb584e36aa2aeffcd0659ce231f7
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
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
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
Compo
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
Com
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
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
[
https://issues.apache.org/jira/browse/FLINK-34492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau updated FLINK-34492:
--
Description:
scala [[org.apache.calcite.rel.rules.CalcMergeRule]]
java {@link org.apache.calcite.
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:
[
https://issues.apache.org/jira/browse/FLINK-34481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau updated FLINK-34481:
--
Description:
we should Migrate SetOpRewriteUtil for
ReplaceMinusWithAntiJoinRule
ReplaceMinusWithAnt
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:
[
https://issues.apache.org/jira/browse/FLINK-33945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau closed FLINK-33945.
-
Resolution: Fixed
merged 060dcf8fc65e5fc3ade5b6037f7dfdc7919ba2b2
> Cleanup usage of deprecated
> org.
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:
[
https://issues.apache.org/jira/browse/FLINK-33948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau closed FLINK-33948.
-
Resolution: Fixed
merged c24e2c9a8c77406f0f4ca6b5b50e8d2b2ac5d811
> Cleanup usage of org.apache.flink.t
[
https://issues.apache.org/jira/browse/FLINK-33951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau updated FLINK-33951:
--
Issue Type: Improvement (was: Bug)
> should use aggCallNeedRetractions instead of needRetraction to c
[
https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808570#comment-17808570
]
Jacky Lau edited comment on FLINK-33950 at 1/19/24 9:25 AM:
[
https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808570#comment-17808570
]
Jacky Lau commented on FLINK-33950:
---
bellow is spark code
{code:java}
val useHash = Ag
[
https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808565#comment-17808565
]
Jacky Lau commented on FLINK-33950:
---
[~twalthr] yeap, but BinaryRowData's doesn't have
[
https://issues.apache.org/jira/browse/FLINK-33951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808557#comment-17808557
]
Jacky Lau commented on FLINK-33951:
---
[~martijnvisser] i change the description and ci
[
https://issues.apache.org/jira/browse/FLINK-33951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau updated FLINK-33951:
--
Description:
we check whether exists retract method using needRetraction which is operator
level. but
[
https://issues.apache.org/jira/browse/FLINK-33951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau updated FLINK-33951:
--
Description:
we check whether exists retract method using needRetraction which is operator
level. but
[
https://issues.apache.org/jira/browse/FLINK-33951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Lau updated FLINK-33951:
--
Description: we check whether exists retract method using
> should use aggCallNeedRetractions instead
[
https://issues.apache.org/jira/browse/FLINK-31691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808519#comment-17808519
]
Jacky Lau commented on FLINK-31691:
---
hi [~Sergey Nuyanzin] will you help to review thi
[
https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808439#comment-17808439
]
Jacky Lau commented on FLINK-33950:
---
hi [~twalthr] [~martijnvisser] [~dwysakowicz] w
[
https://issues.apache.org/jira/browse/FLINK-34156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808430#comment-17808430
]
Jacky Lau commented on FLINK-34156:
---
hi [~Sergey Nuyanzin] can I also help with this t
[
https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807008#comment-17807008
]
Jacky Lau commented on FLINK-33950:
---
hi [~martijnvisser] [~Zakelly] [~dwysakowicz] , i
[
https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804569#comment-17804569
]
Jacky Lau commented on FLINK-33950:
---
hi [~martijnvisser] what is your opinion?
> Upda
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:
[
https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803828#comment-17803828
]
Jacky Lau commented on FLINK-33950:
---
[~martijnvisser] I haven't specifically tested i
[
https://issues.apache.org/jira/browse/FLINK-33951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17801639#comment-17801639
]
Jacky Lau commented on FLINK-33951:
---
[~xuyangzhong] yeap, not a bug.However, this migh
[
https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17801120#comment-17801120
]
Jacky Lau commented on FLINK-33950:
---
hi [~martijnvisser] [~twalthr] the reason of th
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/
[
https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800726#comment-17800726
]
Jacky Lau commented on FLINK-33950:
---
hi [~twalthr] do you have time to help review it
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-t
[
https://issues.apache.org/jira/browse/FLINK-18809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800705#comment-17800705
]
Jacky Lau commented on FLINK-18809:
---
hi [~twalthr] why you don't use new type for Max
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
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:
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
1 - 100 of 145 matches
Mail list logo
