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

[ 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

[ 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

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

[ 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] [Updated] (FLINK-22445) Add more examples of row-based operations in PyFlink doc

[ 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-22470) The root cause of the exception encountered during compiling the job was not exposed to users in certain cases

[ 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

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

[ 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

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

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

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

[ 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

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

[ 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

[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

flinkbot edited a comment on pull request #15776: URL: https://github.com/apache/flink/pull/15776#issuecomment-827352419 ## CI report: * 7abd504d29417b4f19677f289089d52a973b78f0 Azure:

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

[ 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

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

[ 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

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

[ 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

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

[ 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

[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

flinkbot edited a comment on pull request #15776: URL: https://github.com/apache/flink/pull/15776#issuecomment-827352419 ## CI report: * 7abd504d29417b4f19677f289089d52a973b78f0 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337141#comment-17337141 ] Till Rohrmann commented on FLINK-10644: --- Thanks a lot for sharing the details of the speculative

[GitHub] [flink] dianfu commented on a change in pull request #15813: [FLINK-22519][flink-python] support tar.gz python archives

dianfu commented on a change in pull request #15813: URL: https://github.com/apache/flink/pull/15813#discussion_r623649930 ## File path: flink-python/src/main/java/org/apache/flink/python/util/TarGzUtils.java ## @@ -0,0 +1,69 @@ +package org.apache.flink.python.util; +

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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-8236) Allow to set the parallelism of table queries

[ 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] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337132#comment-17337132 ] Arvid Heise commented on FLINK-17170: - Hi [~dannycranmer] , why do we need to have this{{

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

[ 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

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

[ 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

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

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,

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337143#comment-17337143 ] Till Rohrmann commented on FLINK-10644: --- This is really helpful input [~wind_ljy]. Thanks for

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

[ https://issues.apache.org/jira/browse/FLINK-10568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337124#comment-17337124 ] Leonard Xu commented on FLINK-10568: Thanks [~twalthr] for the explanation, I'm sorry that I closed

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

[ 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

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

[ 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] [Closed] (FLINK-17158) Watermark strategy property cannot be expressed in YAML

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

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

[ 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

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

flinkbot edited a comment on pull request #15780: URL: https://github.com/apache/flink/pull/15780#issuecomment-827444976 ## CI report: * 859149a5224d05589dcae87b7a384b7c223fce17 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337299#comment-17337299 ] Piotr Nowojski commented on FLINK-17170: I also think sources shouldn't be doing blocking waits

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

flinkbot edited a comment on pull request #15817: URL: https://github.com/apache/flink/pull/15817#issuecomment-829959024 ## CI report: * 31f01fe2108f5e18f26f50e352d3ed353bd8ffc8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15818: [FLINK-22539][python][docs] Restructure the Python dependency management documentation

flinkbot edited a comment on pull request #15818: URL: https://github.com/apache/flink/pull/15818#issuecomment-829970320 ## CI report: * 21c909a7845f93acf9aea096d6af4dc0da8d3403 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

flinkbot edited a comment on pull request #15760: URL: https://github.com/apache/flink/pull/15760#issuecomment-826500326 ## CI report: * e7a99f5f45e9acb529b903d7823735f3158756fc Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-22535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22535: --- Labels: pull-request-available (was: ) > Resource leak would happen if exception thrown

[GitHub] [flink] akalash opened a new pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

akalash opened a new pull request #15820: URL: https://github.com/apache/flink/pull/15820 … fail during the restore ## What is the purpose of the change *PR allows to release resources when the task fail during the restore* ## Brief change log -

[GitHub] [flink] zuston commented on pull request #15131: [FLINK-21700][security] Add an option to disable credential retrieval on a secure cluster

zuston commented on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-830039192 @XComp Thanks for your review. All done. -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #15729: [FLINK-22234][runtime] Read savepoint before creating ExecutionGraph

flinkbot edited a comment on pull request #15729: URL: https://github.com/apache/flink/pull/15729#issuecomment-825360063 ## CI report: * 4bb1185d7bbe8c7719ea4de375c3dc4cbd8810ba Azure:

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

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 #15656: [FLINK-22233][Table SQL / API]Modified the spelling error of word "constant" in source code

flinkbot edited a comment on pull request #15656: URL: https://github.com/apache/flink/pull/15656#issuecomment-822135263 ## CI report: * 6358c33368746cf2c93463ab423f5c9ff11b641b Azure:

[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=17337346#comment-17337346 ] Jark Wu commented on FLINK-18027: - What about {{STRUCT(...)}} ? This is also a well-known word and Spark

[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=17337350#comment-17337350 ] Timo Walther commented on FLINK-18027: -- I would keep the naming consistent with our existing data

[jira] [Commented] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-22509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337368#comment-17337368 ] Robert Metzger commented on FLINK-22509: Closing as a duplicate of FLINK-19916. > ./bin/flink

[jira] [Closed] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-22509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-22509. -- Resolution: Duplicate > ./bin/flink run -m yarn-cluster -d submission leads to

[jira] [Updated] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21914: --- Component/s: Deployment / YARN > Trying to access closed classloader >

[jira] [Updated] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21914: --- Component/s: (was: Deployment / YARN) Connectors / Hive > Trying to

[jira] [Updated] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19916: --- Affects Version/s: 1.12.2 > Hadoop3 ShutdownHookManager visit closed ClassLoader >

[jira] [Commented] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337377#comment-17337377 ] Robert Metzger commented on FLINK-19916: I've reset the priority to Major since multiple tickets

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

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 #15817: [FLINK-14393][webui] Add an option to enable/disable cancel job in we…

flinkbot edited a comment on pull request #15817: URL: https://github.com/apache/flink/pull/15817#issuecomment-829959024 ## CI report: * 31f01fe2108f5e18f26f50e352d3ed353bd8ffc8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15818: [FLINK-22539][python][docs] Restructure the Python dependency management documentation

flinkbot edited a comment on pull request #15818: URL: https://github.com/apache/flink/pull/15818#issuecomment-829970320 ## CI report: * d44f98b523a36e71a1f265768f4ea55a3aeb28ff Azure:

[jira] [Closed] (FLINK-22524) Fix the incorrect Java groupBy clause in Table API docs

[ https://issues.apache.org/jira/browse/FLINK-22524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22524. --- Fix Version/s: 1.13.1 1.14.0 Resolution: Fixed Fixed in - master:

[GitHub] [flink] wuchong merged pull request #15801: [FLINK-22522][table-runtime-blink] BytesHashMap prints many verbose INFO level logs

wuchong merged pull request #15801: URL: https://github.com/apache/flink/pull/15801 -- 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,

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

[ https://issues.apache.org/jira/browse/FLINK-22535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-22535: -- Assignee: Anton Kalashnikov > Resource leak would happen if exception thrown during

[GitHub] [flink] flinkbot edited a comment on pull request #15131: [FLINK-21700][security] Add an option to disable credential retrieval on a secure cluster

flinkbot edited a comment on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-794957907 ## CI report: * 60812bb2804fd21d56a47a23ca4b42a04300f1c0 Azure:

[GitHub] [flink] lirui-apache commented on a change in pull request #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

lirui-apache commented on a change in pull request #15712: URL: https://github.com/apache/flink/pull/15712#discussion_r623836414 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java ## @@ -531,6

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

[ https://issues.apache.org/jira/browse/FLINK-21949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337348#comment-17337348 ] Jark Wu commented on FLINK-21949: - The only concern of ARRAY_AGG from my side is it sounds similar to

[GitHub] [flink] flinkbot edited a comment on pull request #15656: [FLINK-22233][Table SQL / API]Modified the spelling error of word "constant" in source code

flinkbot edited a comment on pull request #15656: URL: https://github.com/apache/flink/pull/15656#issuecomment-822135263 ## CI report: * 6358c33368746cf2c93463ab423f5c9ff11b641b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

flinkbot edited a comment on pull request #15820: URL: https://github.com/apache/flink/pull/15820#issuecomment-830052015 ## CI report: * c548fc5c79450d898eebc1c6523be98472fe1cdd Azure:

[jira] [Commented] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337367#comment-17337367 ] Robert Metzger commented on FLINK-19916: Where did you see this exception? I found the same

[jira] [Commented] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337371#comment-17337371 ] Robert Metzger commented on FLINK-21914: This is a known issue, reported here FLINK-22509 and

[GitHub] [flink] wuchong merged pull request #15582: [FLINK-22250] flink sql parser module ParserResource.properties lack createSystemFunctionOnlySupportTemporary describe message.

wuchong merged pull request #15582: URL: https://github.com/apache/flink/pull/15582 -- 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,

[jira] [Closed] (FLINK-22522) BytesHashMap has many verbose logs

[ https://issues.apache.org/jira/browse/FLINK-22522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22522. --- Resolution: Fixed Fixed in - master: bf40fa5b8cd5b3a8876f37ab4aa7bf06e8b9f666 - release-1.13:

[GitHub] [flink] wuchong commented on a change in pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

wuchong commented on a change in pull request #15768: URL: https://github.com/apache/flink/pull/15768#discussion_r623809217 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/functions/CallFunctionITCase.java ## @@ -0,0 +1,98 @@

[jira] [Updated] (FLINK-21911) Support GREATEST and LEAST functions in SQL

[ https://issues.apache.org/jira/browse/FLINK-21911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21911: Summary: Support GREATEST and LEAST functions in SQL (was: Support arithmetic MIN/MAX in SQL) > Support

[jira] [Commented] (FLINK-21911) Support GREATEST and LEAST functions in SQL

[ https://issues.apache.org/jira/browse/FLINK-21911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337314#comment-17337314 ] Jark Wu commented on FLINK-21911: - Assigned to you [~Sergey Nuyanzin]. > Support GREATEST and LEAST

[jira] [Assigned] (FLINK-21911) Support GREATEST and LEAST functions in SQL

[ https://issues.apache.org/jira/browse/FLINK-21911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21911: --- Assignee: Sergey Nuyanzin > Support GREATEST and LEAST functions in SQL >

[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=17337323#comment-17337323 ] Timo Walther commented on FLINK-18027: -- [~jark] what do you think about introducing a new built-in

[GitHub] [flink] gaoyunhaii commented on a change in pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

gaoyunhaii commented on a change in pull request #15820: URL: https://github.com/apache/flink/pull/15820#discussion_r623824848 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -530,6 +532,10 @@ protected Counter

[GitHub] [flink] flinkbot commented on pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

flinkbot commented on pull request #15820: URL: https://github.com/apache/flink/pull/15820#issuecomment-830052015 ## CI report: * c548fc5c79450d898eebc1c6523be98472fe1cdd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] pnowojski commented on a change in pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

pnowojski commented on a change in pull request #15820: URL: https://github.com/apache/flink/pull/15820#discussion_r623819184 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java ## @@ -1619,6 +1616,34 @@ public void

[jira] [Commented] (FLINK-22014) Flink JobManager failed to restart after failure in kubernetes HA setup

[ https://issues.apache.org/jira/browse/FLINK-22014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337369#comment-17337369 ] Till Rohrmann commented on FLINK-22014: --- I couldn't really find anything suspicious in the logs.

[jira] [Updated] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21914: --- Component/s: (was: API / Core) Deployment / YARN > Trying to access

[GitHub] [flink] wuchong merged pull request #15802: [FLINK-22524][docs] Fix the incorrect Java groupBy clause in Table API docs

wuchong merged pull request #15802: URL: https://github.com/apache/flink/pull/15802 -- 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,

[jira] [Closed] (FLINK-22250) flink-sql-parser model Class ParserResource lack ParserResource.properties

[ https://issues.apache.org/jira/browse/FLINK-22250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22250. --- Fix Version/s: 1.13.1 Assignee: WeiNan Zhao Resolution: Fixed Fixed in - master:

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

[ https://issues.apache.org/jira/browse/FLINK-21949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337315#comment-17337315 ] Timo Walther commented on FLINK-21949: -- +1 for ARRAY_AGG. We don't need to support all SQL standard

[GitHub] [flink] flinkbot edited a comment on pull request #15818: [FLINK-22539][python][docs] Restructure the Python dependency management documentation

flinkbot edited a comment on pull request #15818: URL: https://github.com/apache/flink/pull/15818#issuecomment-829970320 ## CI report: * 21c909a7845f93acf9aea096d6af4dc0da8d3403 Azure:

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

flinkbot edited a comment on pull request #15817: URL: https://github.com/apache/flink/pull/15817#issuecomment-829959024 ## CI report: * 31f01fe2108f5e18f26f50e352d3ed353bd8ffc8 Azure:

[jira] [Closed] (FLINK-12710) Unify built-in and user-defined functions in the API modules

[ https://issues.apache.org/jira/browse/FLINK-12710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-12710. Resolution: Implemented Implemented as part of FLINK-20522. > Unify built-in and user-defined

[GitHub] [flink] flinkbot edited a comment on pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

flinkbot edited a comment on pull request #15760: URL: https://github.com/apache/flink/pull/15760#issuecomment-826500326 ## CI report: * e7a99f5f45e9acb529b903d7823735f3158756fc Azure:

[GitHub] [flink] flinkbot commented on pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

flinkbot commented on pull request #15820: URL: https://github.com/apache/flink/pull/15820#issuecomment-830041840 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] flinkbot edited a comment on pull request #15772: [FLINK-21131][webui] Alignment timeout displayed in checkpoint config…

flinkbot edited a comment on pull request #15772: URL: https://github.com/apache/flink/pull/15772#issuecomment-827092251 ## CI report: * 619e2d1c4f49a9dc40723ca4bb2ffd56cb846c33 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15131: [FLINK-21700][security] Add an option to disable credential retrieval on a secure cluster

flinkbot edited a comment on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-794957907 ## CI report: * 60812bb2804fd21d56a47a23ca4b42a04300f1c0 Azure:

[jira] [Commented] (FLINK-22139) Flink Jobmanager & Task Manger logs are not writing to the logs files

[ https://issues.apache.org/jira/browse/FLINK-22139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337366#comment-17337366 ] Till Rohrmann commented on FLINK-22139: --- [~bhagi__R] I've tested to deploy

[jira] [Commented] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337375#comment-17337375 ] Robert Metzger commented on FLINK-21914: Just deploying on YARN doesn't cause the exceptions on

[jira] [Commented] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337376#comment-17337376 ] Robert Metzger commented on FLINK-21914: I would like to close this ticket and track the

[jira] [Closed] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21914. -- Resolution: Duplicate > Trying to access closed classloader >

[jira] [Updated] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19916: --- Priority: Major (was: Minor) > Hadoop3 ShutdownHookManager visit closed ClassLoader >

[GitHub] [flink] tillrohrmann commented on pull request #14172: [FLINK-19545][e2e] Add e2e test for native Kubernetes HA

tillrohrmann commented on pull request #14172: URL: https://github.com/apache/flink/pull/14172#issuecomment-830086650 Also, it seems that the test does not fully clean up the `minikube` cluster and Docker. Not sure whether this is due to my local setup or not. -- This is an automated

[jira] [Commented] (FLINK-22234) Read savepoint before creating ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-22234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337149#comment-17337149 ] Nicholas Jiang commented on FLINK-22234: [~trohrmann], [~chesnay], the behavior that read

[GitHub] [flink] akalash commented on pull request #15772: [FLINK-21131][webui] Alignment timeout displayed in checkpoint config…

akalash commented on pull request #15772: URL: https://github.com/apache/flink/pull/15772#issuecomment-829909189 @flinkbot run azure -- 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

[GitHub] [flink] JingsongLi commented on a change in pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

JingsongLi commented on a change in pull request #15760: URL: https://github.com/apache/flink/pull/15760#discussion_r623689841 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/window/WindowJoinOperator.java ## @@

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

[ https://issues.apache.org/jira/browse/FLINK-9716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-9716: --- Component/s: (was: Table SQL / Planner) Table SQL / API > Support scans from temporal

[jira] [Updated] (FLINK-22538) How to check sql is right before to execute across API

[ https://issues.apache.org/jira/browse/FLINK-22538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ranqiqiang updated FLINK-22538: --- Summary: How to check sql is right before to execute across API (was: How to check sql is right

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

[ https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337176#comment-17337176 ] Jark Wu commented on FLINK-9717: [~twalthr], yes. > Flush state of one side of the join if other side is

  1   2   3   4   >