[jira] [Closed] (FLINK-5589) Tumbling group windows on batch tables do not consider object reuse

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-5589. --- Resolution: Not A Problem Should not be an issue in the Blink planner anymore. > Tumbling group

[GitHub] [flink] flinkbot edited a comment on pull request #15816: [FLINK-14393][webui] Add an option to enable/disable cancel job in we…

2021-04-29 Thread GitBox
flinkbot edited a comment on pull request #15816: URL: https://github.com/apache/flink/pull/15816#issuecomment-829848672 ## CI report: * a4de5d6f6c17c60e0289e275116c9a487d41bd3c Azure:

[jira] [Closed] (FLINK-4621) Improve decimal literals of SQL API

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-4621. --- Resolution: Won't Fix Blink planner has proper Decimal support. > Improve decimal literals of SQL

[jira] [Closed] (FLINK-11242) The predicate `'o_c_id === Null(Types.STRING)` not work in TableAPI

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-11242. -- Resolution: Not A Problem > The predicate `'o_c_id === Null(Types.STRING)` not work in TableAPI >

[jira] [Closed] (FLINK-4605) Add an expression that returns the return type of an expression

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-4605. --- Resolution: Fixed The Blink planner contains a `TYPE_OF` function. > Add an expression that returns

[GitHub] [flink] nlu90 commented on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

2021-04-29 Thread GitBox
nlu90 commented on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-829858384 @AHeise How is everything going on? Do you have some time for reviewing this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-19115) Null value fields cannot be ignored in ElasticSearch Sink

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-19115: - Component/s: Table SQL / Ecosystem > Null value fields cannot be ignored in ElasticSearch Sink

[jira] [Closed] (FLINK-13604) All kinds of problem when conversion from Logical type to DataType

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-13604. Resolution: Not A Problem Many issues have been coverted in the last months. I will close this

[GitHub] [flink-web] leonardBang commented on a change in pull request #436: Add Apache Flink release 1.13.0

2021-04-29 Thread GitBox
leonardBang commented on a change in pull request #436: URL: https://github.com/apache/flink-web/pull/436#discussion_r623627803 ## File path: _posts/2021-04-22-release-1.13.0.md ## @@ -0,0 +1,374 @@ +--- +layout: post +title: "Apache Flink 1.13.0 Release Announcement" +date:

[jira] [Closed] (FLINK-13578) Blink throws exception when using Types.INTERVAL_MILLIS in TableSource

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-13578. Resolution: Won't Fix FLIP-95 has reworked table sources and sink and such issues should be fixed

[jira] [Reopened] (FLINK-10568) Show correct time attributes when calling Table.getSchema()

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-10568: -- [~Leonard Xu] this is not entirely correct, it can still show false positives because only an

[jira] [Comment Edited] (FLINK-10568) Show correct time attributes when calling Table.getSchema()

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337097#comment-17337097 ] Timo Walther edited comment on FLINK-10568 at 4/30/21, 5:48 AM:

[jira] [Closed] (FLINK-8436) Allow implementing both RetractTableSink and BatchTableSink in one class

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-8436. --- Resolution: Won't Fix FLIP-95 reworked table source and sink interfaces in the Blink planner. >

[jira] [Closed] (FLINK-8535) Implement a basic set of table factories

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-8535. --- Resolution: Implemented > Implement a basic set of table factories >

[jira] [Commented] (FLINK-9966) Add a ORC table factory

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337094#comment-17337094 ] Timo Walther commented on FLINK-9966: - [~lzljs3620320] what is the current ORC story? Can we close

[jira] [Updated] (FLINK-9966) Add a ORC table factory

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9966: Parent: (was: FLINK-8535) Issue Type: Improvement (was: Sub-task) > Add a ORC table

[jira] [Closed] (FLINK-9651) Add a Kafka table source factory with Protobuf format support

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-9651. --- Resolution: Duplicate See FLINK-18202. > Add a Kafka table source factory with Protobuf format

[jira] [Closed] (FLINK-8536) Improve CSVTableSourceFactory to support all descriptor properties

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-8536. --- Resolution: Won't Fix Use CREATE TABLE DDL instead of descriptors in Blink planner. > Improve

[jira] [Commented] (FLINK-22535) Resource leak would happen if exception thrown during AbstractInvokable#restore of task life

2021-04-29 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337088#comment-17337088 ] Yun Gao commented on FLINK-22535: - Hi [~akalashnikov] sorry I think if there is always the re-thrown,

[jira] [Closed] (FLINK-9965) Support schema derivation in Avro table format factory

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-9965. --- Resolution: Won't Fix FLIP-95 table source and sink support schema derivation in Blink planner. >

[jira] [Closed] (FLINK-9984) Add a byte array table format factory

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-9984. --- Resolution: Won't Fix Use the RAW format in the Blink planner. > Add a byte array table format

[jira] [Closed] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-8953. --- Resolution: Won't Fix FLIP-95 sources don't require the field computer anymore. > Resolve

[jira] [Closed] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-9712. --- Resolution: Implemented All subtasks have been implemented. FLINK-9717 and FLINK-9716 have been

[GitHub] [flink] flinkbot commented on pull request #15816: [FLINK-14393][webui] Add an option to enable/disable cancel job in we…

2021-04-29 Thread GitBox
flinkbot commented on pull request #15816: URL: https://github.com/apache/flink/pull/15816#issuecomment-829848672 ## CI report: * a4de5d6f6c17c60e0289e275116c9a487d41bd3c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-9717) Flush state of one side of the join if other side is bounded

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337083#comment-17337083 ] Timo Walther commented on FLINK-9717: - [~jark] this optimization is still valid for the Blink

[jira] [Updated] (FLINK-9717) Flush state of one side of the join if other side is bounded

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9717: Parent: (was: FLINK-9712) Issue Type: Improvement (was: Sub-task) > Flush state of

[jira] [Updated] (FLINK-9717) Flush state of one side of the join if other side is bounded

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9717: Component/s: (was: Table SQL / Legacy Planner) Table SQL / Planner > Flush

[jira] [Updated] (FLINK-9716) Support scans from temporal table

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9716: Component/s: (was: Table SQL / Legacy Planner) Table SQL / Planner > Support

[jira] [Updated] (FLINK-9716) Support scans from temporal table

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9716: Summary: Support scans from temporal table (was: Support scans from table version function) >

[jira] [Commented] (FLINK-9716) Support scans from temporal table

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337082#comment-17337082 ] Timo Walther commented on FLINK-9716: - [~jark] this issue is still valid, correct? > Support scans

[jira] [Updated] (FLINK-9716) Support scans from temporal table

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9716: Description: Given a temporal table of {{Rates}} this should work:   {code:java} SELECT * FROM

[jira] [Updated] (FLINK-9716) Support scans from table version function

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9716: Parent: (was: FLINK-9712) Issue Type: New Feature (was: Sub-task) > Support scans

[jira] [Closed] (FLINK-9870) Support field mapping and time attributes for table sinks

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-9870. --- Resolution: Won't Fix FLIP-95 reworked the table source and sink interfaces. This issue is not

[jira] [Commented] (FLINK-10211) Time indicators are not correctly materialized for LogicalJoin

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337079#comment-17337079 ] Timo Walther commented on FLINK-10211: -- [~Leonard Xu] this issue is still present in the Blink

[jira] [Updated] (FLINK-10210) Time indicators are not always materialised for LogicalCorrelate

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10210: - Component/s: (was: Table SQL / Legacy Planner) Table SQL / Planner > Time

[jira] [Updated] (FLINK-10211) Time indicators are not correctly materialized for LogicalJoin

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10211: - Component/s: (was: Table SQL / Legacy Planner) Table SQL / Planner

[jira] [Closed] (FLINK-10290) Conversion error in StreamScan and BatchScan

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-10290. Resolution: Won't Fix Legacy planner will not be maintained anymore. TypeInformation is not used

[jira] [Closed] (FLINK-10553) Unified sink and source table name in SQL statement

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-10553. Resolution: Won't Fix Legacy planner will not be maintained anymore. Blink planner supports

[jira] [Commented] (FLINK-14393) add an option to enable/disable cancel job in web ui

2021-04-29 Thread fangyue (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337076#comment-17337076 ] fangyue commented on FLINK-14393: - [~trohrmann]  [~flink-jira-bot]  Hello, I have completed the

[jira] [Commented] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

2021-04-29 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337075#comment-17337075 ] Yuan Mei commented on FLINK-21317: -- cc [~AHeise] since he mentioned this might be included within the

[GitHub] [flink] flinkbot commented on pull request #15816: [FLINK-14393][webui] Add an option to enable/disable cancel job in we…

2021-04-29 Thread GitBox
flinkbot commented on pull request #15816: URL: https://github.com/apache/flink/pull/15816#issuecomment-829843537 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] fangyuefy opened a new pull request #15816: [FLINK-14393][webui] Add an option to enable/disable cancel job in we…

2021-04-29 Thread GitBox
fangyuefy opened a new pull request #15816: URL: https://github.com/apache/flink/pull/15816 …b ui ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

[GitHub] [flink] flinkbot edited a comment on pull request #15789: [FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources

2021-04-29 Thread GitBox
flinkbot edited a comment on pull request #15789: URL: https://github.com/apache/flink/pull/15789#issuecomment-827996694 ## CI report: * 4c5180310bf76e96f2665bf53531eccb1fa86421 UNKNOWN * f87ee85814873dee4ed181eee11df9a6758a916e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

2021-04-29 Thread GitBox
flinkbot edited a comment on pull request #15712: URL: https://github.com/apache/flink/pull/15712#issuecomment-824189664 ## CI report: * 8256b986bcfce17787558b17bba6c2c6a9be24c2 Azure:

[jira] [Comment Edited] (FLINK-10847) Add support for IS NOT DISTINCT FROM in code generator

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337070#comment-17337070 ] Leonard Xu edited comment on FLINK-10847 at 4/30/21, 4:39 AM: -- {noformat}

[jira] [Resolved] (FLINK-10847) Add support for IS NOT DISTINCT FROM in code generator

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-10847. Resolution: Implemented {noformat} Flink SQL> select 1 IS DISTINCT FROM 2; +++ | op |

[jira] [Commented] (FLINK-10846) Add support for IS DISTINCT FROM in code generator

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337069#comment-17337069 ] Leonard Xu commented on FLINK-10846: {code:java} Flink SQL> select 1 IS DISTINCT FROM 1;

[jira] [Resolved] (FLINK-10846) Add support for IS DISTINCT FROM in code generator

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-10846. Resolution: Implemented > Add support for IS DISTINCT FROM in code generator >

[jira] [Updated] (FLINK-10257) Incorrect CHAR type support in Flink SQL and Table API

2021-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-10257: Component/s: (was: Table SQL / Runtime) Table SQL / API > Incorrect CHAR type

[jira] [Closed] (FLINK-15574) DataType to LogicalType conversion issue

2021-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-15574. --- Resolution: Cannot Reproduce The legacy {{TableSource}} does have some type problems when working with

[jira] [Updated] (FLINK-10553) Unified sink and source table name in SQL statement

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-10553: --- Component/s: (was: Table SQL / API) Table SQL / Legacy Planner > Unified sink

[jira] [Updated] (FLINK-10290) Conversion error in StreamScan and BatchScan

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-10290: --- Component/s: (was: Table SQL / API) Table SQL / Legacy Planner > Conversion

[jira] [Updated] (FLINK-10257) Incorrect CHAR type support in Flink SQL and Table API

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-10257: --- Component/s: (was: Table SQL / API) Table SQL / Runtime > Incorrect CHAR type

[jira] [Commented] (FLINK-10257) Incorrect CHAR type support in Flink SQL and Table API

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337060#comment-17337060 ] Leonard Xu commented on FLINK-10257: The bug still exists, cc [~lzljs3620320] {noformat} Flink SQL>

[jira] [Resolved] (FLINK-10231) Add a view SQL DDL

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-10231. Resolution: Implemented Has been supported in  FLINK-17105 > Add a view SQL DDL >

[jira] [Updated] (FLINK-10211) Time indicators are not correctly materialized for LogicalJoin

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-10211: --- Component/s: (was: Table SQL / API) > Time indicators are not correctly materialized for

[jira] [Updated] (FLINK-10210) Time indicators are not always materialised for LogicalCorrelate

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-10210: --- Component/s: (was: Table SQL / API) Table SQL / Legacy Planner > Time

[jira] [Resolved] (FLINK-10049) Correctly handle NULL arguments in SQL built-in functions

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-10049. Resolution: Implemented {noformat} Flink SQL> select abs(cast(null as int));

[GitHub] [flink] flinkbot edited a comment on pull request #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

2021-04-29 Thread GitBox
flinkbot edited a comment on pull request #15712: URL: https://github.com/apache/flink/pull/15712#issuecomment-824189664 ## CI report: * 8256b986bcfce17787558b17bba6c2c6a9be24c2 Azure:

[jira] [Resolved] (FLINK-10143) date_format throws CodeGenException

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-10143. Resolution: Won't Fix > date_format throws CodeGenException > ---

[jira] [Updated] (FLINK-9870) Support field mapping and time attributes for table sinks

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-9870: -- Component/s: (was: Table SQL / API) Table SQL / Legacy Planner > Support field

[jira] [Updated] (FLINK-22497) When using DefaultRollingPolicy in StreamingFileSink, the file will be finished delayed

2021-04-29 Thread ChangjiGuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangjiGuo updated FLINK-22497: --- Description: I had a doubt when testing StreamingFileSink: The default 60s rolling interval in

[jira] [Updated] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-9712: -- Component/s: (was: Table SQL / API) Table SQL / Legacy Planner > Support

[jira] [Updated] (FLINK-9716) Support scans from table version function

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-9716: -- Component/s: (was: Table SQL / API) Table SQL / Legacy Planner > Support scans

[jira] [Updated] (FLINK-9625) Enrich the error information to user

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-9625: -- Component/s: (was: Table SQL / API) Table SQL / Legacy Planner > Enrich the error

[jira] [Updated] (FLINK-9422) Dedicated DISTINCT operator for streaming tables with time attributes

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-9422: -- Component/s: (was: Table SQL / API) Table SQL / Legacy Planner > Dedicated

[jira] [Comment Edited] (FLINK-9327) Support explicit ROW value constructor in Flink SQL

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337052#comment-17337052 ] Leonard Xu edited comment on FLINK-9327 at 4/30/21, 3:58 AM: - Has supported

[jira] [Resolved] (FLINK-9327) Support explicit ROW value constructor in Flink SQL

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-9327. --- Resolution: Implemented {code:java} Flink SQL> SELECT ROW(1,2);

[jira] [Commented] (FLINK-21949) Support collect to array aggregate function

2021-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337051#comment-17337051 ] Jark Wu commented on FLINK-21949: - Thanks [~jiabao.sun], the {{collect_list}} and {{collect_set}} sounds

[jira] [Resolved] (FLINK-9502) Use generic parameter search for user-define functions when argument contains Object type

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-9502. --- Resolution: Duplicate > Use generic parameter search for user-define functions when argument

[jira] [Resolved] (FLINK-9501) Allow Object or Wildcard type in user-define functions as parameter types but not result types

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-9501. --- Resolution: Duplicate > Allow Object or Wildcard type in user-define functions as parameter types

[jira] [Resolved] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-9294. --- Resolution: Duplicate > Improve type inference for UDFs with composite parameter or result type >

[jira] [Commented] (FLINK-22484) Buit-in functions for collections

2021-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337050#comment-17337050 ] Jark Wu commented on FLINK-22484: - It seems all the proposed functions in this design doc are scalar

[jira] [Resolved] (FLINK-9484) Improve generic type inference for User-Defined Functions

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-9484. --- Resolution: Duplicate > Improve generic type inference for User-Defined Functions >

[jira] [Comment Edited] (FLINK-9484) Improve generic type inference for User-Defined Functions

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337049#comment-17337049 ] Leonard Xu edited comment on FLINK-9484 at 4/30/21, 3:52 AM: - I found this

[GitHub] [flink] flinkbot edited a comment on pull request #15815: [FLINK-22505][core] Limit the scale of Resource to 8

2021-04-29 Thread GitBox
flinkbot edited a comment on pull request #15815: URL: https://github.com/apache/flink/pull/15815#issuecomment-829766154 ## CI report: * f2de2280df7cae4f35be54255bfc3db2094f8114 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15810: [FLINK-22534] Set delegation token's service name as credential alias

2021-04-29 Thread GitBox
flinkbot edited a comment on pull request #15810: URL: https://github.com/apache/flink/pull/15810#issuecomment-829273230 ## CI report: * 297941c6f59acd7708c33addf0a1121aeb9d0b6e Azure:

[jira] [Assigned] (FLINK-22512) Can't call current_timestamp with hive dialect for hive-3.1

2021-04-29 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-22512: -- Assignee: 罗宇侠 (was: Rui Li) > Can't call current_timestamp with hive dialect for hive-3.1 >

[jira] [Commented] (FLINK-9484) Improve generic type inference for User-Defined Functions

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337049#comment-17337049 ] Leonard Xu commented on FLINK-9484: --- I found this improvement has been implemented in FLIP-65, I close

[jira] [Assigned] (FLINK-22512) Can't call current_timestamp with hive dialect for hive-3.1

2021-04-29 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-22512: -- Assignee: Rui Li > Can't call current_timestamp with hive dialect for hive-3.1 >

[jira] [Updated] (FLINK-21025) SQLClientHBaseITCase fails when untarring HBase

2021-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21025: Component/s: (was: Table SQL / Client) Table SQL / Ecosystem > SQLClientHBaseITCase

[jira] [Closed] (FLINK-9161) Support STRUCT syntax to create named STRUCT in SQL

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-9161. - Resolution: Implemented you can use ROW which also supported nested type  {code:java} Flink SQL> SELECT

[jira] [Closed] (FLINK-16422) Cannot use [catalog].[db].table with Hive catalog

2021-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16422. --- Resolution: Not A Problem > Cannot use [catalog].[db].table with Hive catalog >

[jira] [Closed] (FLINK-17137) Support mini batch for WindowOperator in blink planner

2021-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17137. --- Resolution: Implemented Mini-batch has been supported for window aggregation in the 1.13. > Support mini

[jira] [Updated] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-8953: -- Component/s: (was: Table SQL / API) Table SQL / Legacy Planner > Resolve

[jira] [Updated] (FLINK-8951) Support OVER windows PARTITION BY (rounded) timestamp

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-8951: -- Component/s: (was: Table SQL / API) Table SQL / Legacy Planner > Support OVER

[jira] [Updated] (FLINK-8566) Replace retract/insert of same record for state retention timer resets

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-8566: -- Component/s: (was: Table SQL / API) Table SQL / Legacy Planner > Replace

[jira] [Updated] (FLINK-8535) Implement a basic set of table factories

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-8535: -- Component/s: (was: Table SQL / API) Table SQL / Legacy Planner > Implement a

[jira] [Updated] (FLINK-11838) Create RecoverableWriter for GCS

2021-04-29 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-11838: - Labels: pull-request-available usability (was: pull-request-available stale-assigned

[jira] [Updated] (FLINK-8436) Allow implementing both RetractTableSink and BatchTableSink in one class

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-8436: -- Component/s: (was: Table SQL / API) Table SQL / Legacy Planner > Allow

[jira] [Commented] (FLINK-10644) Batch Job: Speculative execution

2021-04-29 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337040#comment-17337040 ] Jiayi Liao commented on FLINK-10644: Yes. We also implement our own speculation in ByteDance. This

[GitHub] [flink] flinkbot commented on pull request #15815: [FLINK-22505][core] Limit the scale of Resource to 8

2021-04-29 Thread GitBox
flinkbot commented on pull request #15815: URL: https://github.com/apache/flink/pull/15815#issuecomment-829766154 ## CI report: * f2de2280df7cae4f35be54255bfc3db2094f8114 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15813: [FLINK-22519][flink-python] support tar.gz python archives

2021-04-29 Thread GitBox
flinkbot edited a comment on pull request #15813: URL: https://github.com/apache/flink/pull/15813#issuecomment-829753030 ## CI report: * ec561cde67f5ddd7c215003cec5b9bdcbe53fcf7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15810: [FLINK-22534] Set delegation token's service name as credential alias

2021-04-29 Thread GitBox
flinkbot edited a comment on pull request #15810: URL: https://github.com/apache/flink/pull/15810#issuecomment-829273230 ## CI report: * 297941c6f59acd7708c33addf0a1121aeb9d0b6e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15780: [FLINK-22487][python] Support `print` to print logs in PyFlink

2021-04-29 Thread GitBox
flinkbot edited a comment on pull request #15780: URL: https://github.com/apache/flink/pull/15780#issuecomment-827444976 ## CI report: * aee5d1e284ded16ee52297f10af2e59d59e8ebb5 Azure:

[jira] [Updated] (FLINK-20484) Improve hive temporal table exception

2021-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20484: Component/s: (was: Table SQL / API) Connectors / Hive > Improve hive temporal table

[jira] [Updated] (FLINK-22271) FlinkSQL Read Hive(parquet file) field does not exist

2021-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22271: Component/s: (was: Table SQL / API) Connectors / Hive > FlinkSQL Read Hive(parquet

[jira] [Updated] (FLINK-19204) Improve warning during a Table.execute()

2021-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19204: Component/s: (was: Table SQL / API) Table SQL / Runtime > Improve warning during a

[jira] [Updated] (FLINK-19271) wrong HOP_PROCTIME output when materialize proctime

2021-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19271: Component/s: Table SQL / Runtime Table SQL / Planner > wrong HOP_PROCTIME output when

[jira] [Updated] (FLINK-20255) Nested decorrelate failed

2021-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20255: Component/s: (was: Table SQL / API) Table SQL / Planner > Nested decorrelate failed

  1   2   3   4   5   6   7   8   9   10   >