[GitHub] [flink] flinkbot edited a comment on pull request #15776: [FLINK-22488][hotfix] Update SubtaskGatewayImpl to specify the cause of sendEvent() failure when triggering task failover

2021-04-29 Thread GitBox
flinkbot edited a comment on pull request #15776: URL: https://github.com/apache/flink/pull/15776#issuecomment-827352419 ## CI report: * 7abd504d29417b4f19677f289089d52a973b78f0 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-22510) ConfigurationUtils always serializes Duration to nanoseconds

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-22510. Fix Version/s: 1.14.0 Resolution: Fixed Fixed in 1.14.0: 89c6c03660a88a648bbd13b4e6696124fe

[GitHub] [flink] twalthr closed pull request #15809: [FLINK-22510][core] Format durations with highest unit

2021-04-29 Thread GitBox
twalthr closed pull request #15809: URL: https://github.com/apache/flink/pull/15809 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please

[jira] [Updated] (FLINK-18952) Add 10 minutes to DataStream API documentation

2021-04-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18952: Fix Version/s: (was: 1.13.0) 1.13.1 1.14.0 > Add 10 minutes to D

[jira] [Updated] (FLINK-22470) The root cause of the exception encountered during compiling the job was not exposed to users in certain cases

2021-04-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22470: Fix Version/s: (was: 1.13.0) 1.13.1 1.14.0 > The root cause of t

[jira] [Updated] (FLINK-22445) Add more examples of row-based operations in PyFlink doc

2021-04-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22445: Fix Version/s: (was: 1.13.0) 1.13.1 > Add more examples of row-based operations in

[jira] [Updated] (FLINK-20720) Add documentation for ProcessFunction in Python DataStream API

2021-04-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20720: Fix Version/s: (was: 1.13.0) 1.13.1 > Add documentation for ProcessFunction in Pyth

[jira] [Closed] (FLINK-12114) Try to perform UDF By Reflection

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-12114. Resolution: Not A Problem Should not be a problem with FLIP-65 functions. > Try to perform UDF By

[jira] [Updated] (FLINK-8183) Add native Avro type support to the Table API & SQL

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8183: Parent: FLINK-12251 Issue Type: Sub-task (was: New Feature) > Add native Avro type support

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

2021-04-29 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337132#comment-17337132 ] Arvid Heise commented on FLINK-17170: - Hi [~dannycranmer] , why do we need to have t

[jira] [Updated] (FLINK-8236) Allow to set the parallelism of table queries

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8236: Priority: Major (was: Minor) > Allow to set the parallelism of table queries > ---

[jira] [Resolved] (FLINK-11399) Parsing nested ROW()s in SQL

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

[jira] [Updated] (FLINK-11398) Add a dedicated phase to materialize time indicators for nodes produce updates

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

[GitHub] [flink] flinkbot edited a comment on pull request #15776: [FLINK-22488][hotfix] Update SubtaskGatewayImpl to specify the cause of sendEvent() failure when triggering task failover

2021-04-29 Thread GitBox
flinkbot edited a comment on pull request #15776: URL: https://github.com/apache/flink/pull/15776#issuecomment-827352419 ## CI report: * 7abd504d29417b4f19677f289089d52a973b78f0 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-17158) Watermark strategy property cannot be expressed in YAML

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-17158. Resolution: Won't Fix YAML will not be supported in future versions in favor of SQL scripts. > Wa

[jira] [Updated] (FLINK-11310) Convert predicates to IN or NOT_IN for Project

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

[jira] [Closed] (FLINK-8185) Make first level flattening optional for input and output

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-8185. --- Resolution: Not A Problem Blink planner adds a lot of implicits casts and conversion logic to make th

[jira] [Closed] (FLINK-8379) Improve type checking for DataView

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-8379. --- Resolution: Implemented Improved as part of FLIP-65. > Improve type checking for DataView >

[jira] [Updated] (FLINK-8179) Convert CharSequence to String when registering / converting a Table

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8179: Parent: FLINK-12251 Issue Type: Sub-task (was: Improvement) > Convert CharSequence to Stri

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

2021-04-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337124#comment-17337124 ] Leonard Xu commented on FLINK-10568: Thanks [~twalthr] for the explanation, I'm sorr

[jira] [Updated] (FLINK-8129) Add a union type

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

[jira] [Closed] (FLINK-10965) suggest that change $resultTypeTerm to Object at org.apache.flink.table.codegen.calls.ScalarFunctionCallGen:104

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-10965. Resolution: Won't Fix Legacy planner is reaching end of life. > suggest that change $resultTypeTe

[jira] [Updated] (FLINK-7271) ExpressionReducer does not optimize string-to-time conversion

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

[jira] [Closed] (FLINK-6705) Check visibility of methods in Table API classes

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-6705. --- Resolution: Implemented TableEnvironment has been reimplemented in Java with proper interface abstra

[GitHub] [flink] lindong28 commented on pull request #15776: [FLINK-22488][hotfix] Update SubtaskGatewayImpl to specify the cause of sendEvent() failure when triggering task failover

2021-04-29 Thread GitBox
lindong28 commented on pull request #15776: URL: https://github.com/apache/flink/pull/15776#issuecomment-829863682 Thanks you @dawidwys and @StephanEwen for your review! The PR has been updated as suggested. -- This is an automated message from the Apache Git Service. To respond to the m

[jira] [Closed] (FLINK-6591) Extend functionality of final ConversionMapper

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-6591. --- Resolution: Won't Fix Blink planner doesn't use type information anymore. The casting also got smart

[jira] [Closed] (FLINK-6547) Improve toString methods of Table API expressions

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-6547. --- Resolution: Won't Fix Nowadays we validate Calcite plans instead in Blink planner. > Improve toStrin

[jira] [Updated] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-6114: Component/s: API / DataSet > Type checking fails with generics, even when concrete type of field is

[jira] [Closed] (FLINK-5986) Add forwarded field annotations to batch (window) aggregate operators

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-5986. --- Resolution: Won't Fix We don't rely on DataSet API anymore in Blink planner. > Add forwarded field a

[jira] [Closed] (FLINK-6077) Support In/Exists/Except/Any /Some/All for Stream SQL

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-6077. --- Resolution: Won't Fix This is issue is quite old. Many operators are supported in the Blink planner

[jira] [Closed] (FLINK-5429) Code generate types between operators in Table API

2021-04-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-5429. --- Resolution: Won't Fix Blink planner uses RowData and code generates e.g. structured types. > Code ge

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

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

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

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

[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&focusedCommentId=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. > Allo

[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&focusedCommentId=17337094#comment-17337094 ] Timo Walther commented on FLINK-9966: - [~lzljs3620320] what is the current ORC story?

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

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

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

[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&focusedCommentId=17337088#comment-17337088 ] Yun Gao commented on FLINK-22535: - Hi [~akalashnikov] sorry I think if there is always t

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

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

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

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

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

[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&focusedCommentId=17337083#comment-17337083 ] Timo Walther commented on FLINK-9717: - [~jark] this optimization is still valid for t

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

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

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

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

[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&focusedCommentId=17337082#comment-17337082 ] Timo Walther commented on FLINK-9716: - [~jark] this issue is still valid, correct? >

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

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

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

[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&focusedCommentId=17337079#comment-17337079 ] Timo Walther commented on FLINK-10211: -- [~Leonard Xu] this issue is still present i

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

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

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

[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&focusedCommentId=17337076#comment-17337076 ] fangyue commented on FLINK-14393: - [~trohrmann]  [~flink-jira-bot]  Hello, I have comple

[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&focusedCommentId=17337075#comment-17337075 ] Yuan Mei commented on FLINK-21317: -- cc [~AHeise] since he mentioned this might be inclu

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

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

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17337070#comment-17337070 ] Leonard Xu edited comment on FLINK-10847 at 4/30/21, 4:39 AM:

[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&focusedCommentId=17337069#comment-17337069 ] Leonard Xu commented on FLINK-10846: {code:java} Flink SQL> select 1 IS DISTINCT FRO

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

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

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

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

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

[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&focusedCommentId=17337060#comment-17337060 ] Leonard Xu commented on FLINK-10257: The bug still exists, cc [~lzljs3620320] {nofor

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

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

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

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

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

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

[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&focusedCommentId=17337052#comment-17337052 ] Leonard Xu edited comment on FLINK-9327 at 4/30/21, 3:58 AM: -

[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&focusedCommentId=17337051#comment-17337051 ] Jark Wu commented on FLINK-21949: - Thanks [~jiabao.sun], the {{collect_list}} and {{coll

  1   2   3   4   5   6   7   8   9   10   >