[
https://issues.apache.org/jira/browse/FLINK-32608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753066#comment-17753066
]
Aitozi commented on FLINK-32608:
I think this issue is duplicated of
[
https://issues.apache.org/jira/browse/FLINK-32699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750530#comment-17750530
]
Aitozi commented on FLINK-32699:
Hi [~jackylau], sorry for not notice this ticket, I have opened another
[
https://issues.apache.org/jira/browse/FLINK-32659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749428#comment-17749428
]
Aitozi commented on FLINK-32659:
Can someone help review the fix:
[
https://issues.apache.org/jira/browse/FLINK-32711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749412#comment-17749412
]
Aitozi commented on FLINK-32711:
I pushed a fix for this, anyone can help review ?
> Type mismatch when
[
https://issues.apache.org/jira/browse/FLINK-32711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-32711:
---
Issue Type: Bug (was: Improvement)
> Type mismatch when proctime function used as parameter
>
[
https://issues.apache.org/jira/browse/FLINK-32711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748626#comment-17748626
]
Aitozi commented on FLINK-32711:
It's caused by the hard coded nullable result type of
Aitozi created FLINK-32711:
--
Summary: Type mismatch when proctime function used as parameter
Key: FLINK-32711
URL: https://issues.apache.org/jira/browse/FLINK-32711
Project: Flink
Issue Type:
Aitozi created FLINK-32659:
--
Summary: DB connection may leak if exception is thrown in
JdbcOutputFormat#close
Key: FLINK-32659
URL: https://issues.apache.org/jira/browse/FLINK-32659
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731832#comment-17731832
]
Aitozi commented on FLINK-32320:
[~libenchao] Thanks for your attention. I just made a quick fix on
[
https://issues.apache.org/jira/browse/FLINK-32320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731823#comment-17731823
]
Aitozi commented on FLINK-32320:
In production, multi sink job are very common, if the table from UDTF
Aitozi created FLINK-32320:
--
Summary: Same correlate can not be reused due to the different
correlationId
Key: FLINK-32320
URL: https://issues.apache.org/jira/browse/FLINK-32320
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730162#comment-17730162
]
Aitozi commented on FLINK-31704:
thanks, will try it.
> Pulsar docs should be pulled from dedicated
[
https://issues.apache.org/jira/browse/FLINK-31704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730133#comment-17730133
]
Aitozi commented on FLINK-31704:
Hi [~Weijie Guo] [~dannycranmer] I have a CI failed with missing branch
[
https://issues.apache.org/jira/browse/FLINK-32249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17729175#comment-17729175
]
Aitozi commented on FLINK-32249:
It does not reproduce in my local sql client
{code:java}
Flink SQL>
[
https://issues.apache.org/jira/browse/FLINK-32246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728658#comment-17728658
]
Aitozi commented on FLINK-32246:
where do you run this sql ? sql-client ? Can you provide a demo case to
[
https://issues.apache.org/jira/browse/FLINK-31828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725311#comment-17725311
]
Aitozi commented on FLINK-31828:
Any sql guys can help verify this fix ?
> List field in a POJO data
[
https://issues.apache.org/jira/browse/FLINK-31835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716538#comment-17716538
]
Aitozi commented on FLINK-31835:
[~jark] The PR have passed the CI and I think the current solution will
[
https://issues.apache.org/jira/browse/FLINK-31835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716209#comment-17716209
]
Aitozi commented on FLINK-31835:
Yes, the reason is shown above. I have pushed a PR to try to solve
[
https://issues.apache.org/jira/browse/FLINK-31835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715474#comment-17715474
]
Aitozi commented on FLINK-31835:
The first thought in my mind is that the conversion class for atomic
[
https://issues.apache.org/jira/browse/FLINK-31835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715466#comment-17715466
]
Aitozi commented on FLINK-31835:
When creating Array CollectionDataType it will use the array's element
[
https://issues.apache.org/jira/browse/FLINK-31835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715464#comment-17715464
]
Aitozi commented on FLINK-31835:
In this case, ARRAY will still maps to
{{ArrayObjectArrayConverter}}.
[
https://issues.apache.org/jira/browse/FLINK-31828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715451#comment-17715451
]
Aitozi commented on FLINK-31828:
Hi [~netvl] you could also work with this in your case.
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-31828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715403#comment-17715403
]
Aitozi commented on FLINK-31828:
[~twalthr] could help review this fix :) ? Since I see you help review
[
https://issues.apache.org/jira/browse/FLINK-31828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715356#comment-17715356
]
Aitozi commented on FLINK-31828:
I have pushed a fix for it. Before this fix the demo will fails with
[
https://issues.apache.org/jira/browse/FLINK-31828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715111#comment-17715111
]
Aitozi commented on FLINK-31828:
Hi [~netvl] Thanks for this detailed bug report.
I have reproduced
[
https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714815#comment-17714815
]
Aitozi edited comment on FLINK-29692 at 4/21/23 4:12 AM:
-
hi, sorry for jumping
[
https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714815#comment-17714815
]
Aitozi commented on FLINK-29692:
hi, sorry for jumping into this discussion. I want to share two
[
https://issues.apache.org/jira/browse/FLINK-31755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17713864#comment-17713864
]
Aitozi commented on FLINK-31755:
CC [~lincoln.86xy] [~snuyanzin]
> ROW function can not work with
[
https://issues.apache.org/jira/browse/FLINK-31774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712195#comment-17712195
]
Aitozi commented on FLINK-31774:
Hi [~luoyuxia] The pr is ready for review, please take a look when you
[
https://issues.apache.org/jira/browse/FLINK-31790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711683#comment-17711683
]
Aitozi commented on FLINK-31790:
CC [~luoyuxia]
> Filesystem batch sink should also respect to the
Aitozi created FLINK-31790:
--
Summary: Filesystem batch sink should also respect to the
PartitionCommitPolicy
Key: FLINK-31790
URL: https://issues.apache.org/jira/browse/FLINK-31790
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711427#comment-17711427
]
Aitozi commented on FLINK-31787:
see discussion in this ticket:
Aitozi created FLINK-31787:
--
Summary: Add the explicit ROW constructor to the system function
doc
Key: FLINK-31787
URL: https://issues.apache.org/jira/browse/FLINK-31787
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711306#comment-17711306
]
Aitozi commented on FLINK-31344:
[~luoyuxia] I have finished this ticket, could you help take a look
[
https://issues.apache.org/jira/browse/FLINK-31533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711265#comment-17711265
]
Aitozi commented on FLINK-31533:
After some trying, I find it's seems easy to support this feature. It
[ https://issues.apache.org/jira/browse/FLINK-31533 ]
Aitozi deleted comment on FLINK-31533:
was (Author: aitozi):
Yes, it's indeed need to revisit the parser of the ctas syntax. I will draw a
POC for this and open a discussion in dev mailing
>
[
https://issues.apache.org/jira/browse/FLINK-31533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711203#comment-17711203
]
Aitozi commented on FLINK-31533:
Yes, it's indeed need to revisit the parser of the ctas syntax. I will
[
https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711200#comment-17711200
]
Aitozi edited comment on FLINK-18027 at 4/12/23 5:43 AM:
-
The content is
[
https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711200#comment-17711200
]
Aitozi commented on FLINK-18027:
The content is modified
from
[
https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711040#comment-17711040
]
Aitozi commented on FLINK-18027:
[~libenchao] do you know why the explicit ROW construct is removed from
[
https://issues.apache.org/jira/browse/FLINK-31774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711033#comment-17711033
]
Aitozi commented on FLINK-31774:
I think we should add the description for this two statements similar
[
https://issues.apache.org/jira/browse/FLINK-31774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-31774:
---
Parent: FLINK-30648
Issue Type: Sub-task (was: Improvement)
> Add document for delete and update
Aitozi created FLINK-31774:
--
Summary: Add document for delete and update statement
Key: FLINK-31774
URL: https://issues.apache.org/jira/browse/FLINK-31774
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-31533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711002#comment-17711002
]
Aitozi commented on FLINK-31533:
[~luoyuxia] I think it's a useful feature, and I'd like to support
[
https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710866#comment-17710866
]
Aitozi commented on FLINK-18027:
Now calcite version is bundled to 1.29, the complex expression for row
[
https://issues.apache.org/jira/browse/FLINK-31301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710396#comment-17710396
]
Aitozi commented on FLINK-31301:
[~lincoln.86xy] , I opened PR for this, could you help review it,
[
https://issues.apache.org/jira/browse/FLINK-31344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710023#comment-17710023
]
Aitozi commented on FLINK-31344:
Thanks for your reply. Totally agree with you. I have basically
[
https://issues.apache.org/jira/browse/FLINK-31344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709961#comment-17709961
]
Aitozi commented on FLINK-31344:
Hi [~luoyuxia], when solving the FLINK-31301 I notice this ticket.
[
https://issues.apache.org/jira/browse/FLINK-31755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-31755:
---
Description:
Reproduce case:
{code:java}
create table row_sink (
`b` ROW
) with (
'connector' =
Aitozi created FLINK-31755:
--
Summary: ROW function can not work with RewriteIntersectAllRule
Key: FLINK-31755
URL: https://issues.apache.org/jira/browse/FLINK-31755
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-31301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708948#comment-17708948
]
Aitozi commented on FLINK-31301:
Hello [~lincoln.86xy], I want to contribute to this ticket and I have
[
https://issues.apache.org/jira/browse/FLINK-31301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708014#comment-17708014
]
Aitozi commented on FLINK-31301:
Hello [~lincoln.86xy], I'm interested in this ticket and spend some
[
https://issues.apache.org/jira/browse/FLINK-31550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17705828#comment-17705828
]
Aitozi commented on FLINK-31550:
Is this stale? {{OperationConverterUtils}} do not use {{TableSchema}}
[
https://issues.apache.org/jira/browse/FLINK-31507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702245#comment-17702245
]
Aitozi commented on FLINK-31507:
Hello, [~jark] May I help to do this refactor ?
> Move execution logic
[
https://issues.apache.org/jira/browse/FLINK-31497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-31497:
---
Parent: FLINK-21394
Issue Type: Sub-task (was: Technical Debt)
> Drop the deprecated
Aitozi created FLINK-31497:
--
Summary: Drop the deprecated CatalogViewImpl
Key: FLINK-31497
URL: https://issues.apache.org/jira/browse/FLINK-31497
Project: Flink
Issue Type: Technical Debt
[
https://issues.apache.org/jira/browse/FLINK-31426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-31426:
---
Parent: FLINK-29072
Issue Type: Sub-task (was: Technical Debt)
> Upgrade the deprecated
Aitozi created FLINK-31426:
--
Summary: Upgrade the deprecated UniqueConstraint to the new one
Key: FLINK-31426
URL: https://issues.apache.org/jira/browse/FLINK-31426
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698902#comment-17698902
]
Aitozi commented on FLINK-31260:
[~zhengyiweng] Thanks for your attention, I think the exchange in rule
Aitozi created FLINK-31390:
--
Summary: Optimize the FlinkChangelogModeInferenceProgram by
avoiding unnecessary traversals.
Key: FLINK-31390
URL: https://issues.apache.org/jira/browse/FLINK-31390
Project:
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-31362:
---
Description:
In Calcite 1.33.0, C-style escape strings have been supported. We could
leverage it to
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-31362:
---
Component/s: Table SQL / API
(was: Documentation)
> Upgrade to Calcite version to
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-31362:
---
Summary: Upgrade to Calcite version to 1.33.0 (was: Add document about how
to use C-style escape strings)
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-31362:
---
Description:
In Calcite 1.33.0, C-style escape strings have been supported. We should
outline its usage in
Aitozi created FLINK-31362:
--
Summary: Add document about how to use C-style escape strings
Key: FLINK-31362
URL: https://issues.apache.org/jira/browse/FLINK-31362
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695491#comment-17695491
]
Aitozi commented on FLINK-31296:
But this will affect the join key pair in the Join operator which may
Aitozi created FLINK-31296:
--
Summary: Add JoinConditionEqualityTransferRule to stream optimizer
Key: FLINK-31296
URL: https://issues.apache.org/jira/browse/FLINK-31296
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-31260:
---
Component/s: Table SQL / Planner
> PushLocalHashAggIntoScanRule should also work with union RelNode
>
Aitozi created FLINK-31260:
--
Summary: PushLocalHashAggIntoScanRule should also work with union
RelNode
Key: FLINK-31260
URL: https://issues.apache.org/jira/browse/FLINK-31260
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-31205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694386#comment-17694386
]
Aitozi commented on FLINK-31205:
looking forward to your opinion CC [~godfreyhe] [~twalthr] [~snuyanzin]
[
https://issues.apache.org/jira/browse/FLINK-31205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694372#comment-17694372
]
Aitozi commented on FLINK-31205:
After some research, I found that there are better choices than using a
Aitozi created FLINK-31205:
--
Summary: do optimize for multi sink in a single relNode tree
Key: FLINK-31205
URL: https://issues.apache.org/jira/browse/FLINK-31205
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-30551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691568#comment-17691568
]
Aitozi commented on FLINK-30551:
In my PR, only the table's with properties will be passed to the open
[
https://issues.apache.org/jira/browse/FLINK-31120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691082#comment-17691082
]
Aitozi commented on FLINK-31120:
Another instance:
[
https://issues.apache.org/jira/browse/FLINK-30570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656052#comment-17656052
]
Aitozi commented on FLINK-30570:
I opened a PR to solve this problem, looking forward to be reviewed,
[
https://issues.apache.org/jira/browse/FLINK-30570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-30570:
---
Description:
Currently, the condition {{where rand(1) < 0.0001}} will be recognized as a
partition
Aitozi created FLINK-30570:
--
Summary: RexNodeExtractor#isSupportedPartitionPredicate generates
unexpected partition predicates
Key: FLINK-30570
URL: https://issues.apache.org/jira/browse/FLINK-30570
[
https://issues.apache.org/jira/browse/FLINK-30551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17653949#comment-17653949
]
Aitozi commented on FLINK-30551:
cc [~gaoyunhaii] what do you think of this ?
> Add open method to
Aitozi created FLINK-30551:
--
Summary: Add open method to PartitionCommitPolicy
Key: FLINK-30551
URL: https://issues.apache.org/jira/browse/FLINK-30551
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-29085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi closed FLINK-29085.
--
Resolution: Won't Fix
> Add the name for test as hint for the current test case in
> BuiltInFunctionTestBase
[
https://issues.apache.org/jira/browse/FLINK-29066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi closed FLINK-29066.
--
Resolution: Won't Fix
> Reconsider the runtime property of the BuiltInFunctionDefinition
>
[
https://issues.apache.org/jira/browse/FLINK-30198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648099#comment-17648099
]
Aitozi commented on FLINK-30198:
Thanks, all guys, for your input. I agree that vertex-level tuning will
[
https://issues.apache.org/jira/browse/FLINK-30242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641636#comment-17641636
]
Aitozi commented on FLINK-30242:
> which scenario do you meet this problem?
I met this when we ran the
[
https://issues.apache.org/jira/browse/FLINK-30242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-30242:
---
Attachment: screenshot-2.png
> Push localHashAggregate pass the union node
>
[
https://issues.apache.org/jira/browse/FLINK-30242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-30242:
---
Attachment: (was: screenshot-1.png)
> Push localHashAggregate pass the union node
>
[
https://issues.apache.org/jira/browse/FLINK-30242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-30242:
---
Attachment: screenshot-1.png
> Push localHashAggregate pass the union node
>
[
https://issues.apache.org/jira/browse/FLINK-30242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-30242:
---
Attachment: screenshot-1.png
> Push localHashAggregate pass the union node
>
[
https://issues.apache.org/jira/browse/FLINK-30242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1764#comment-1764
]
Aitozi commented on FLINK-30242:
Hi [~Runking], Sorry I have not noticed that. If you have already done,
Aitozi created FLINK-30242:
--
Summary: Push localHashAggregate pass the union node
Key: FLINK-30242
URL: https://issues.apache.org/jira/browse/FLINK-30242
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-30198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638331#comment-17638331
]
Aitozi commented on FLINK-30198:
cc [~wanglijie] what do you think of this ?
> Support
[
https://issues.apache.org/jira/browse/FLINK-30198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-30198:
---
Description:
When we use AdaptiveBatchScheduler in our case, we found that it can work well
in most case,
[
https://issues.apache.org/jira/browse/FLINK-30198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-30198:
---
Description:
When we use AdaptiveBatchScheduler in our case, we found that it can work well
in most case,
Aitozi created FLINK-30198:
--
Summary: Support AdaptiveBatchScheduler to set per-task size for
reducer task
Key: FLINK-30198
URL: https://issues.apache.org/jira/browse/FLINK-30198
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634112#comment-17634112
]
Aitozi commented on FLINK-29585:
fyi, I'm trying to work on this now. I will ping you for review after I
[
https://issues.apache.org/jira/browse/FLINK-25113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17633829#comment-17633829
]
Aitozi commented on FLINK-25113:
Hi [~slinkydeveloper], [~luoyuxia] , [~lsy] I have push a
[
https://issues.apache.org/jira/browse/FLINK-30019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17633826#comment-17633826
]
Aitozi commented on FLINK-30019:
cc [~luoyuxia], [~lsy] can you help review this PR ?
> Remove the
Aitozi created FLINK-30019:
--
Summary: Remove the unused HiveTableFileInputFormat in hive
connector
Key: FLINK-30019
URL: https://issues.apache.org/jira/browse/FLINK-30019
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-25113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632146#comment-17632146
]
Aitozi commented on FLINK-25113:
When I try to work on this, I found that I can't simply break this to
[
https://issues.apache.org/jira/browse/FLINK-25113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631679#comment-17631679
]
Aitozi commented on FLINK-25113:
sorry for missing the ticket link :)
[
https://issues.apache.org/jira/browse/FLINK-25113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631632#comment-17631632
]
Aitozi commented on FLINK-25113:
hi [~slinkydeveloper], I created a preceding ticket to improve the hive
1 - 100 of 803 matches
Mail list logo