[jira] [Commented] (FLINK-32608) Improve source reusing with projection push down

[ 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

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

[ 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

[jira] [Commented] (FLINK-32659) DB connection may leak if exception is thrown in JdbcOutputFormat#close

[ 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:

[jira] [Commented] (FLINK-32711) 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=17749412#comment-17749412 ] Aitozi commented on FLINK-32711: I pushed a fix for this, anyone can help review ? > Type mismatch when

[jira] [Updated] (FLINK-32711) Type mismatch when proctime function used as parameter

[ 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 >

[jira] [Commented] (FLINK-32711) 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

[jira] [Created] (FLINK-32711) Type mismatch when proctime function used as parameter

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:

[jira] [Created] (FLINK-32659) DB connection may leak if exception is thrown in JdbcOutputFormat#close

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

[jira] [Commented] (FLINK-32320) Same correlate can not be reused due to the different correlationId

[ 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

[jira] [Commented] (FLINK-32320) Same correlate can not be reused due to the different correlationId

[ 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

[jira] [Created] (FLINK-32320) Same correlate can not be reused due to the different correlationId

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

[jira] [Commented] (FLINK-31704) Pulsar docs should be pulled from dedicated branch

[ 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

[jira] [Commented] (FLINK-31704) Pulsar docs should be pulled from dedicated branch

[ 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

[jira] [Commented] (FLINK-32249) A Java string should be used instead of a Calcite NlsString to construct the table and column comment attributes of CatalogTable

[ 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>

[jira] [Commented] (FLINK-32246) javax.management.InstanceAlreadyExistsException

[ 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

[jira] [Commented] (FLINK-31828) List field in a POJO data stream results in table program compilation failure

[ 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

[jira] [Commented] (FLINK-31835) DataTypeHint don't support Row>

[ 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

[jira] [Commented] (FLINK-31835) DataTypeHint don't support Row>

[ 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

[jira] [Commented] (FLINK-31835) DataTypeHint don't support Row>

[ 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

[jira] [Commented] (FLINK-31835) DataTypeHint don't support Row>

[ 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

[jira] [Commented] (FLINK-31835) DataTypeHint don't support Row>

[ 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}}.

[jira] [Commented] (FLINK-31828) List field in a POJO data stream results in table program compilation failure

[ 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}

[jira] [Commented] (FLINK-31828) List field in a POJO data stream results in table program compilation failure

[ 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

[jira] [Commented] (FLINK-31828) List field in a POJO data stream results in table program compilation failure

[ 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

[jira] [Commented] (FLINK-31828) List field in a POJO data stream results in table program compilation failure

[ 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

[jira] [Comment Edited] (FLINK-29692) Support early/late fires for Windowing TVFs

[ 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

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

[ 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

[jira] [Commented] (FLINK-31755) ROW function can not work with RewriteIntersectAllRule

[ 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

[jira] [Commented] (FLINK-31774) Add document for delete and update statement

[ 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

[jira] [Commented] (FLINK-31790) Filesystem batch sink should also respect to the PartitionCommitPolicy

[ 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

[jira] [Created] (FLINK-31790) Filesystem batch sink should also respect to the PartitionCommitPolicy

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

[jira] [Commented] (FLINK-31787) Add the explicit ROW constructor to the system function doc

[ 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:

[jira] [Created] (FLINK-31787) Add the explicit ROW constructor to the system function doc

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:

[jira] [Commented] (FLINK-31344) Support to update nested columns in update statement

[ 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

[jira] [Commented] (FLINK-31533) CREATE TABLE AS SELECT should support to define partition

[ 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

[jira] (FLINK-31533) CREATE TABLE AS SELECT should support to define partition

[ 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  >

[jira] [Commented] (FLINK-31533) CREATE TABLE AS SELECT should support to define partition

[ 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

[jira] [Comment Edited] (FLINK-18027) ROW value constructor cannot deal with complex expressions

[ 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

[jira] [Commented] (FLINK-18027) ROW value constructor cannot deal with complex expressions

[ 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 

[jira] [Commented] (FLINK-18027) ROW value constructor cannot deal with complex expressions

[ 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

[jira] [Commented] (FLINK-31774) Add document for delete and update statement

[ 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

[jira] [Updated] (FLINK-31774) Add document for delete and update statement

[ 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

[jira] [Created] (FLINK-31774) Add document for delete and update statement

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

[jira] [Commented] (FLINK-31533) CREATE TABLE AS SELECT should support to define partition

[ 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

[jira] [Commented] (FLINK-18027) ROW value constructor cannot deal with complex expressions

[ 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

[jira] [Commented] (FLINK-31301) Unsupported nested columns in column list of insert statement

[ 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,

[jira] [Commented] (FLINK-31344) Support to update nested columns in update statement

[ 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

[jira] [Commented] (FLINK-31344) Support to update nested columns in update statement

[ 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.

[jira] [Updated] (FLINK-31755) ROW function can not work with RewriteIntersectAllRule

[ 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' =

[jira] [Created] (FLINK-31755) ROW function can not work with RewriteIntersectAllRule

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

[jira] [Commented] (FLINK-31301) Unsupported nested columns in column list of insert statement

[ 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

[jira] [Commented] (FLINK-31301) Unsupported nested columns in column list of insert statement

[ 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

[jira] [Commented] (FLINK-31550) Replace deprecated TableSchema with Schema in OperationConverterUtils

[ 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}}

[jira] [Commented] (FLINK-31507) Move execution logic of ShowOperation out from TableEnvironmentImpl

[ 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

[jira] [Updated] (FLINK-31497) Drop the deprecated CatalogViewImpl

[ 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

[jira] [Created] (FLINK-31497) Drop the deprecated CatalogViewImpl

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

[jira] [Updated] (FLINK-31426) Upgrade the deprecated UniqueConstraint to the new one

[ 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

[jira] [Created] (FLINK-31426) Upgrade the deprecated UniqueConstraint to the new one

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:

[jira] [Commented] (FLINK-31260) PushLocalHashAggIntoScanRule should also work with union RelNode

[ 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

[jira] [Created] (FLINK-31390) Optimize the FlinkChangelogModeInferenceProgram by avoiding unnecessary traversals.

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:

[jira] [Updated] (FLINK-31362) Upgrade to Calcite version to 1.33.0

[ 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

[jira] [Updated] (FLINK-31362) Upgrade to Calcite version to 1.33.0

[ 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

[jira] [Updated] (FLINK-31362) Upgrade to Calcite version to 1.33.0

[ 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)

[jira] [Updated] (FLINK-31362) 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

[jira] [Created] (FLINK-31362) Add document about how to use C-style escape strings

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:

[jira] [Commented] (FLINK-31296) Add JoinConditionEqualityTransferRule to stream optimizer

[ 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

[jira] [Created] (FLINK-31296) Add JoinConditionEqualityTransferRule to stream optimizer

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:

[jira] [Updated] (FLINK-31260) PushLocalHashAggIntoScanRule should also work with union RelNode

[ 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 >

[jira] [Created] (FLINK-31260) 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

[jira] [Commented] (FLINK-31205) do optimize for multi sink in a single relNode tree

[ 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]

[jira] [Commented] (FLINK-31205) do optimize for multi sink in a single relNode tree

[ 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

[jira] [Created] (FLINK-31205) do optimize for multi sink in a single relNode tree

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:

[jira] [Commented] (FLINK-30551) Add open method to PartitionCommitPolicy

[ 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

[jira] [Commented] (FLINK-31120) ConcurrentModificationException occurred in StringFunctionsITCase.test

[ 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:

[jira] [Commented] (FLINK-30570) RexNodeExtractor#isSupportedPartitionPredicate generates unexpected partition predicates

[ 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,

[jira] [Updated] (FLINK-30570) RexNodeExtractor#isSupportedPartitionPredicate generates unexpected partition predicates

[ 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

[jira] [Created] (FLINK-30570) RexNodeExtractor#isSupportedPartitionPredicate generates unexpected partition predicates

Aitozi created FLINK-30570: -- Summary: RexNodeExtractor#isSupportedPartitionPredicate generates unexpected partition predicates Key: FLINK-30570 URL: https://issues.apache.org/jira/browse/FLINK-30570

[jira] [Commented] (FLINK-30551) Add open method to PartitionCommitPolicy

[ 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

[jira] [Created] (FLINK-30551) Add open method to PartitionCommitPolicy

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

[jira] [Closed] (FLINK-29085) Add the name for test as hint for the current test case in BuiltInFunctionTestBase

[ 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

[jira] [Closed] (FLINK-29066) Reconsider the runtime property of the BuiltInFunctionDefinition

[ 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 >

[jira] [Commented] (FLINK-30198) Support AdaptiveBatchScheduler to set per-task size for reducer task

[ 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

[jira] [Commented] (FLINK-30242) Push localHashAggregate pass the union node

[ 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

[jira] [Updated] (FLINK-30242) 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-2.png > Push localHashAggregate pass the union node >

[jira] [Updated] (FLINK-30242) 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 >

[jira] [Updated] (FLINK-30242) 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 >

[jira] [Updated] (FLINK-30242) 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 >

[jira] [Commented] (FLINK-30242) 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,

[jira] [Created] (FLINK-30242) Push localHashAggregate pass the union node

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

[jira] [Commented] (FLINK-30198) Support AdaptiveBatchScheduler to set per-task size for reducer task

[ 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

[jira] [Updated] (FLINK-30198) Support AdaptiveBatchScheduler to set per-task size for reducer task

[ 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,

[jira] [Updated] (FLINK-30198) Support AdaptiveBatchScheduler to set per-task size for reducer task

[ 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,

[jira] [Created] (FLINK-30198) Support AdaptiveBatchScheduler to set per-task size for reducer task

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

[jira] [Commented] (FLINK-29585) Migrate TableSchema to Schema for Hive connector

[ 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

[jira] [Commented] (FLINK-25113) Cleanup from Parquet and Orc the partition key handling logic

[ 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

[jira] [Commented] (FLINK-30019) Remove the unused HiveTableFileInputFormat in hive connector

[ 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

[jira] [Created] (FLINK-30019) Remove the unused HiveTableFileInputFormat in hive connector

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

[jira] [Commented] (FLINK-25113) Cleanup from Parquet and Orc the partition key handling logic

[ 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

[jira] [Commented] (FLINK-25113) Cleanup from Parquet and Orc the partition key handling logic

[ 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 :)

[jira] [Commented] (FLINK-25113) Cleanup from Parquet and Orc the partition key handling logic

[ 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   2   3   4   5   6   7   8   9   >