[
https://issues.apache.org/jira/browse/FLINK-33050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766757#comment-17766757
]
tartarus commented on FLINK-33050:
--
See https://issues.apache.org/jira/browse/FLINK-32787 for details
[
https://issues.apache.org/jira/browse/FLINK-32787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762380#comment-17762380
]
tartarus edited comment on FLINK-32787 at 9/6/23 1:10 PM:
--
[~hackergin] thanks
[
https://issues.apache.org/jira/browse/FLINK-32787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762380#comment-17762380
]
tartarus commented on FLINK-32787:
--
[~hackergin] thanks for verifying~
I think there are two issues
tartarus created FLINK-33050:
Summary: Prompts user to close when atomicity implementation is
not supported
Key: FLINK-33050
URL: https://issues.apache.org/jira/browse/FLINK-33050
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755822#comment-17755822
]
tartarus edited comment on FLINK-32791 at 8/18/23 7:00 AM:
---
Verified the Time
[
https://issues.apache.org/jira/browse/FLINK-32791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17755822#comment-17755822
]
tartarus commented on FLINK-32791:
--
Verified the RTAS with paimon catalog;
Write the data with the
[
https://issues.apache.org/jira/browse/FLINK-32791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tartarus updated FLINK-32791:
-
Attachment: image-2023-08-18-14-56-19-198.png
> Release Testing: Verify FLIP-308: Support Time Travel
>
[
https://issues.apache.org/jira/browse/FLINK-32791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tartarus updated FLINK-32791:
-
Attachment: image-2023-08-18-14-55-18-883.png
> Release Testing: Verify FLIP-308: Support Time Travel
>
[
https://issues.apache.org/jira/browse/FLINK-32791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tartarus updated FLINK-32791:
-
Attachment: image-2023-08-18-14-55-55-817.png
> Release Testing: Verify FLIP-308: Support Time Travel
>
tartarus created FLINK-32581:
Summary: Add document for atomic CTAS
Key: FLINK-32581
URL: https://issues.apache.org/jira/browse/FLINK-32581
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-32349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tartarus updated FLINK-32349:
-
Parent: FLINK-32580
Issue Type: Sub-task (was: New Feature)
> Support atomic for CREATE TABLE
tartarus created FLINK-32580:
Summary: FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS)
Key: FLINK-32580
URL: https://issues.apache.org/jira/browse/FLINK-32580
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17738555#comment-17738555
]
tartarus commented on FLINK-31655:
--
Hi [~pnowojski] thank you for your reply.
I currently tend to use
[
https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17738549#comment-17738549
]
tartarus commented on FLINK-31655:
--
Hi [~wangm92] Thank you for sharing, your solution sounds similar
[
https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17738546#comment-17738546
]
tartarus commented on FLINK-31655:
--
hi [~fanrui] thank you for your reply, I will answer your concerns
[
https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733425#comment-17733425
]
tartarus edited comment on FLINK-31655 at 6/16/23 9:37 AM:
---
[~fanrui] Thank
[
https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733425#comment-17733425
]
tartarus edited comment on FLINK-31655 at 6/16/23 9:36 AM:
---
[~fanrui] Thank
[
https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733425#comment-17733425
]
tartarus commented on FLINK-31655:
--
[~fanrui] Thank you very much for sharing your solution!
[
https://issues.apache.org/jira/browse/FLINK-28460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732998#comment-17732998
]
tartarus commented on FLINK-28460:
--
Resolved in FLIP-305, for details see
tartarus created FLINK-32349:
Summary: Support atomic for CREATE TABLE AS SELECT(CTAS) statement
Key: FLINK-32349
URL: https://issues.apache.org/jira/browse/FLINK-32349
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712168#comment-17712168
]
tartarus commented on FLINK-31655:
--
[~akalash] [~pnowojski] [~pltbkd] Thank you very much for your
[
https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711663#comment-17711663
]
tartarus commented on FLINK-31655:
--
Hi [~akalash] thanks for your reminder!
In our company, adaptive
tartarus created FLINK-31721:
Summary: Move JobStatusHook to flink-core module
Key: FLINK-31721
URL: https://issues.apache.org/jira/browse/FLINK-31721
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17707138#comment-17707138
]
tartarus commented on FLINK-31655:
--
Hi [~gaoyunhaii] [~fanrui]
Thanks for your suggestions, I will
[
https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706287#comment-17706287
]
tartarus commented on FLINK-31655:
--
cc [~zhuzh]
> Adaptive Channel selection for partitioner
>
[
https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706281#comment-17706281
]
tartarus commented on FLINK-31655:
--
[~gaoyunhaii] [~fanrui] Please take a look at this issue, after
tartarus created FLINK-31655:
Summary: Adaptive Channel selection for partitioner
Key: FLINK-31655
URL: https://issues.apache.org/jira/browse/FLINK-31655
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-30640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676509#comment-17676509
]
tartarus commented on FLINK-30640:
--
It looks like ctas didn't execute successfully.
Will retrying with
[
https://issues.apache.org/jira/browse/FLINK-29219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17605152#comment-17605152
]
tartarus commented on FLINK-29219:
--
[~renqs] This problem has been located because sql-client does not
[
https://issues.apache.org/jira/browse/FLINK-29219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17601658#comment-17601658
]
tartarus edited comment on FLINK-29219 at 9/8/22 6:21 AM:
--
[~renqs] Thank you
[
https://issues.apache.org/jira/browse/FLINK-29219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17601658#comment-17601658
]
tartarus commented on FLINK-29219:
--
[~renqs] Thank you very much for your feedback on this issue!
I
[
https://issues.apache.org/jira/browse/FLINK-28965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579809#comment-17579809
]
tartarus commented on FLINK-28965:
--
[~luoyuxia] thank for you raise this issue, I will fix it soon!
tartarus created FLINK-28770:
Summary: CREATE TABLE AS SELECT supports explain
Key: FLINK-28770
URL: https://issues.apache.org/jira/browse/FLINK-28770
Project: Flink
Issue Type: Sub-task
tartarus created FLINK-28720:
Summary: Add Hive partition when flink has no data to write
Key: FLINK-28720
URL: https://issues.apache.org/jira/browse/FLINK-28720
Project: Flink
Issue Type:
tartarus created FLINK-28463:
Summary: Flink SQL syntax support CREATE TABLE AS SELECT(CTAS)
Key: FLINK-28463
URL: https://issues.apache.org/jira/browse/FLINK-28463
Project: Flink
Issue Type:
tartarus created FLINK-28462:
Summary: Table API support CREATE TABLE AS SELECT(CTAS)
Key: FLINK-28462
URL: https://issues.apache.org/jira/browse/FLINK-28462
Project: Flink
Issue Type: Sub-task
tartarus created FLINK-28460:
Summary: Flink SQL supports atomic CREATE TABLE AS SELECT(CTAS)
Key: FLINK-28460
URL: https://issues.apache.org/jira/browse/FLINK-28460
Project: Flink
Issue Type:
tartarus created FLINK-28459:
Summary: Flink SQL supports non-atomic CREATE TABLE AS SELECT(CTAS)
Key: FLINK-28459
URL: https://issues.apache.org/jira/browse/FLINK-28459
Project: Flink
Issue
tartarus created FLINK-28457:
Summary: Flink add JobStatusHook support
Key: FLINK-28457
URL: https://issues.apache.org/jira/browse/FLINK-28457
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-26942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564156#comment-17564156
]
tartarus commented on FLINK-26942:
--
[~waywtdcc] Thanks for the suggestion about the [with [no] data]
tartarus created FLINK-28343:
Summary: Hive dialect fails using union map type
Key: FLINK-28343
URL: https://issues.apache.org/jira/browse/FLINK-28343
Project: Flink
Issue Type: Sub-task
tartarus created FLINK-28342:
Summary: Flink batch support for Hive StorageHandlers
Key: FLINK-28342
URL: https://issues.apache.org/jira/browse/FLINK-28342
Project: Flink
Issue Type: Sub-task
tartarus created FLINK-28235:
Summary: Min aggregate function support type: ''ARRAY''.
Key: FLINK-28235
URL: https://issues.apache.org/jira/browse/FLINK-28235
Project: Flink
Issue Type: Sub-task
tartarus created FLINK-28158:
Summary: Flink supports all modes of Hive UDAF (PARTIAL1,
PARTIAL2, FINAL, COMPLETE)
Key: FLINK-28158
URL: https://issues.apache.org/jira/browse/FLINK-28158
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552530#comment-17552530
]
tartarus commented on FLINK-27603:
--
Thanks for your work!
I think the reload function is the habit of
[
https://issues.apache.org/jira/browse/FLINK-27677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17539180#comment-17539180
]
tartarus commented on FLINK-27677:
--
[~wangyang0918] thank you for your reply!
The scenarios of k8s
[
https://issues.apache.org/jira/browse/FLINK-27677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17538656#comment-17538656
]
tartarus commented on FLINK-27677:
--
[~tison] I think the behavior of this configuration on k8s and
tartarus created FLINK-27677:
Summary: Kubernetes reuse rest.bind-port, but do not support a
range of ports
Key: FLINK-27677
URL: https://issues.apache.org/jira/browse/FLINK-27677
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tartarus updated FLINK-27450:
-
Description:
If we use jdk11 to run Hive related jobs, there will be a problem that the Hive
[
https://issues.apache.org/jira/browse/FLINK-27450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529814#comment-17529814
]
tartarus commented on FLINK-27450:
--
[~jark] please assign to me, I will create a pr to fix it.
> [JDK
tartarus created FLINK-27450:
Summary: [JDK 11] Hive SessionState can't be initialized due to
classloader problem
Key: FLINK-27450
URL: https://issues.apache.org/jira/browse/FLINK-27450
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528738#comment-17528738
]
tartarus commented on FLINK-27379:
--
[~luoyuxia] thanks for your reply. you are so efficient!
>
[
https://issues.apache.org/jira/browse/FLINK-27387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528737#comment-17528737
]
tartarus commented on FLINK-27387:
--
[~luoyuxia] This is really good news, Looking forward to using it
[
https://issues.apache.org/jira/browse/FLINK-27391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528736#comment-17528736
]
tartarus commented on FLINK-27391:
--
[~luoyuxia] thanks for your reply.
I think we should support
[
https://issues.apache.org/jira/browse/FLINK-27386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528034#comment-17528034
]
tartarus commented on FLINK-27386:
--
[~luoyuxia] thanks for your reply, idea will add jvm parameter
tartarus created FLINK-27391:
Summary: Support Hive bucket table
Key: FLINK-27391
URL: https://issues.apache.org/jira/browse/FLINK-27391
Project: Flink
Issue Type: Sub-task
Affects Versions:
tartarus created FLINK-27387:
Summary: Support Insert Multi-Table
Key: FLINK-27387
URL: https://issues.apache.org/jira/browse/FLINK-27387
Project: Flink
Issue Type: Sub-task
tartarus created FLINK-27386:
Summary: throw NPE if multi MAPJOIN hint union all
Key: FLINK-27386
URL: https://issues.apache.org/jira/browse/FLINK-27386
Project: Flink
Issue Type: Sub-task
tartarus created FLINK-27385:
Summary: Field #1: values VARCHAR(2147483647) ARRAY does not exist
for expression index($0, 0)
Key: FLINK-27385
URL: https://issues.apache.org/jira/browse/FLINK-27385
tartarus created FLINK-27380:
Summary: Failed to get Hive result type from
org.apache.hadoop.hive.ql.udf.generic.GenericUDAFPercentileApprox
Key: FLINK-27380
URL: https://issues.apache.org/jira/browse/FLINK-27380
tartarus created FLINK-27379:
Summary: CodeGenException: Unable to find common type of
Key: FLINK-27379
URL: https://issues.apache.org/jira/browse/FLINK-27379
Project: Flink
Issue Type: Sub-task
tartarus created FLINK-27378:
Summary: Unexpected rexnode : org.apache.calcite.rex.RexFieldAccess
Key: FLINK-27378
URL: https://issues.apache.org/jira/browse/FLINK-27378
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-27305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524208#comment-17524208
]
tartarus commented on FLINK-27305:
--
[~luoyuxia] thanks for your remind.
It seems that
tartarus created FLINK-27305:
Summary: Hive Dialect support implicit conversion
Key: FLINK-27305
URL: https://issues.apache.org/jira/browse/FLINK-27305
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-27304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524142#comment-17524142
]
tartarus commented on FLINK-27304:
--
Looks like it is caused by the hive binary type,
sample array>
tartarus created FLINK-27304:
Summary: Flink doesn't support Hive primitive type void yet
Key: FLINK-27304
URL: https://issues.apache.org/jira/browse/FLINK-27304
Project: Flink
Issue Type:
tartarus created FLINK-27296:
Summary: CalcOperator CodeGenException: Boolean expression type
expected
Key: FLINK-27296
URL: https://issues.apache.org/jira/browse/FLINK-27296
Project: Flink
tartarus created FLINK-26942:
Summary: Support SELECT clause in CREATE TABLE(CTAS)
Key: FLINK-26942
URL: https://issues.apache.org/jira/browse/FLINK-26942
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-25605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513804#comment-17513804
]
tartarus commented on FLINK-25605:
--
[~jingzhang] Please assign this issue to me and I'll try to fix
[
https://issues.apache.org/jira/browse/FLINK-26460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tartarus updated FLINK-26460:
-
Description:
{code:java}
CREATE TABLE zm_test (
`a` BIGINT,
`m` MAP
);
{code}
if we insert into
[
https://issues.apache.org/jira/browse/FLINK-26460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500583#comment-17500583
]
tartarus commented on FLINK-26460:
--
[~jark] please assign it to me, thanks
> Fix Unsupported type
tartarus created FLINK-26460:
Summary: Fix Unsupported type when convertTypeToSpec: MAP
Key: FLINK-26460
URL: https://issues.apache.org/jira/browse/FLINK-26460
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-25240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457101#comment-17457101
]
tartarus commented on FLINK-25240:
--
2.15.0 may not be the best choice, the community has released
[
https://issues.apache.org/jira/browse/FLINK-25258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457089#comment-17457089
]
tartarus commented on FLINK-25258:
--
[
https://issues.apache.org/jira/browse/FLINK-25258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457082#comment-17457082
]
tartarus commented on FLINK-25258:
--
[~jingzhang] Please assign this issue to me, thank you
It is
[
https://issues.apache.org/jira/browse/FLINK-20416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456122#comment-17456122
]
tartarus commented on FLINK-20416:
--
[~shared_ptr] Excuse me, I found that this jira hasn't been updated
[
https://issues.apache.org/jira/browse/FLINK-25204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454424#comment-17454424
]
tartarus commented on FLINK-25204:
--
[~jark] Please assign to me , thanks
> Spell one more as in the
tartarus created FLINK-25204:
Summary: Spell one more as in the DataStream interval join docs
Key: FLINK-25204
URL: https://issues.apache.org/jira/browse/FLINK-25204
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-24761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tartarus updated FLINK-24761:
-
Description:
{color:#4c9aff}PartitionPruner{color} compile code use
[
https://issues.apache.org/jira/browse/FLINK-24761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tartarus updated FLINK-24761:
-
Description:
{color:#4c9aff}PartitionPruner{color} compile code use
[
https://issues.apache.org/jira/browse/FLINK-24761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438532#comment-17438532
]
tartarus commented on FLINK-24761:
--
[~jark] Please assign this jira to me, thanks
> Fix
tartarus created FLINK-24761:
Summary: Fix PartitionPruner code gen compile fail
Key: FLINK-24761
URL: https://issues.apache.org/jira/browse/FLINK-24761
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-23715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397050#comment-17397050
]
tartarus commented on FLINK-23715:
--
[~ruili] Please assign this issue to me, thanks
> Support for
tartarus created FLINK-23715:
Summary: Support for reading fields that do not exist in Parquet
files
Key: FLINK-23715
URL: https://issues.apache.org/jira/browse/FLINK-23715
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-23531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tartarus updated FLINK-23531:
-
Summary: Allow skip all change log for row-time deduplicate mini-batch
(was: Allow skip everytime
[
https://issues.apache.org/jira/browse/FLINK-23531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tartarus updated FLINK-23531:
-
Description:
current we keep all change log for row-time deduplicate mini-batch,
we need buffer all
[
https://issues.apache.org/jira/browse/FLINK-23531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17389248#comment-17389248
]
tartarus commented on FLINK-23531:
--
[~jark] please assign to me, thanks
> Allow skip everytime change
tartarus created FLINK-23531:
Summary: Allow skip everytime change log for row-time deduplicate
mini-batch
Key: FLINK-23531
URL: https://issues.apache.org/jira/browse/FLINK-23531
Project: Flink
tartarus created FLINK-23425:
Summary: The impact of cpu cores on test results for
StreamingJobGraphGeneratorTest#testSlotSharingResourceConfigurationWithDefaultSlotSharingGroup
Key: FLINK-23425
URL:
[
https://issues.apache.org/jira/browse/FLINK-20518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17368686#comment-17368686
]
tartarus commented on FLINK-20518:
--
[~chesnay] Do you think the parameters are decoded on the server
[
https://issues.apache.org/jira/browse/FLINK-23134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17368662#comment-17368662
]
tartarus commented on FLINK-23134:
--
[~trohrmann] Do you think this is ok?
Please assign this issue to
tartarus created FLINK-23134:
Summary: add URL decode for metric rest
Key: FLINK-23134
URL: https://issues.apache.org/jira/browse/FLINK-23134
Project: Flink
Issue Type: Bug
Components:
tartarus created FLINK-22716:
Summary: Add metrics watermarkAlignedChannelNum
Key: FLINK-22716
URL: https://issues.apache.org/jira/browse/FLINK-22716
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-22455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332416#comment-17332416
]
tartarus commented on FLINK-22455:
--
[~joemoe] I use 1.13.0 ,but I think this problem has existed for a
tartarus created FLINK-22455:
Summary: FlinkRelBuilder#windowAggregate will throw
ClassCastException when function reuse
Key: FLINK-22455
URL: https://issues.apache.org/jira/browse/FLINK-22455
Project:
tartarus created FLINK-22412:
Summary: SplitAggregateRule support optimization of aggregate
function reuse
Key: FLINK-22412
URL: https://issues.apache.org/jira/browse/FLINK-22412
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tartarus updated FLINK-21923:
-
Labels: pull-request-available (was: pull-request-available stale-assigned)
> SplitAggregateRule will
[
https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315334#comment-17315334
]
tartarus commented on FLINK-21923:
--
`LogicalTableAggregate` does not have a `PartialFinalType` member
[
https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tartarus updated FLINK-21923:
-
Description:
SplitAggregateRule optimizes one-layer aggregation to two-layer aggregation to
improve
[
https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tartarus updated FLINK-21923:
-
Description:
SplitAggregateRule optimizes one-layer aggregation to two-layer aggregation to
improve
1 - 100 of 151 matches
Mail list logo