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

2021-04-30 Thread GitBox
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 #15772: [FLINK-21131][webui] Alignment timeout displayed in checkpoint config…

2021-04-30 Thread GitBox
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 #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

2021-04-30 Thread GitBox
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 edited a comment on pull request #15729: [FLINK-22234][runtime] Read savepoint before creating ExecutionGraph

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

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

2021-04-30 Thread GitBox
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

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

2021-04-30 Thread Piotr Nowojski (Jira)
[ 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

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

2021-04-30 Thread Timo Walther (Jira)
[ 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

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

2021-04-30 Thread ASF GitHub Bot (Jira)
[ 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…

2021-04-30 Thread GitBox
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 -

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

2021-04-30 Thread Jark Wu (Jira)
[ 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

2021-04-30 Thread Jark Wu (Jira)
[ 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] [Updated] (FLINK-21911) Support GREATEST and LEAST functions in SQL

2021-04-30 Thread Jark Wu (Jira)
[ 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

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

2021-04-30 Thread GitBox
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] [Closed] (FLINK-22522) BytesHashMap has many verbose logs

2021-04-30 Thread Jark Wu (Jira)
[ 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 merged pull request #15801: [FLINK-22522][table-runtime-blink] BytesHashMap prints many verbose INFO level logs

2021-04-30 Thread GitBox
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] [Closed] (FLINK-22524) Fix the incorrect Java groupBy clause in Table API docs

2021-04-30 Thread Jark Wu (Jira)
[ 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:

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

2021-04-30 Thread Jark Wu (Jira)
[ 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:

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

2021-04-30 Thread GitBox
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,

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

2021-04-30 Thread GitBox
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,

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

2021-04-30 Thread GitBox
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…

2021-04-30 Thread GitBox
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 #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

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

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

2021-04-30 Thread Piotr Nowojski (Jira)
[ 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

[jira] [Commented] (FLINK-21911) Support arithmetic MIN/MAX in SQL

2021-04-30 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337298#comment-17337298 ] Sergey Nuyanzin commented on FLINK-21911: - yes, i have a branch for these changes however still

[GitHub] [flink] flinkbot edited a comment on pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

2021-04-30 Thread GitBox
flinkbot edited a comment on pull request #15728: URL: https://github.com/apache/flink/pull/15728#issuecomment-824960796 ## CI report: * f03cc305d25f320b88bb7c7e457c384d4e02674c Azure:

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

2021-04-30 Thread GitBox
beyond1920 commented on a change in pull request #15760: URL: https://github.com/apache/flink/pull/15760#discussion_r623787382 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/state/WindowListState.java ## @@

[jira] [Commented] (FLINK-22534) Set delegation token's service name as credential alias

2021-04-30 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337289#comment-17337289 ] Matthias commented on FLINK-22534: -- Thanks [~zuston] for creating this ticket. Could you add more

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

2021-04-30 Thread GitBox
beyond1920 commented on a change in pull request #15760: URL: https://github.com/apache/flink/pull/15760#discussion_r623787382 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/state/WindowListState.java ## @@

[jira] [Assigned] (FLINK-22534) Set delegation token's service name as credential alias

2021-04-30 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-22534: Assignee: Junfan Zhang > Set delegation token's service name as credential alias >

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

2021-04-30 Thread GitBox
XComp commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r623782754 ## File path: flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java ## @@ -108,6 +108,20 @@ +

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

2021-04-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337283#comment-17337283 ] Jark Wu commented on FLINK-21949: - cc [~twalthr] > Support collect to array aggregate function >

[jira] [Updated] (FLINK-14364) Allow comments fail when not ignore parse errors in CsvRowDeserializationSchema

2021-04-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14364: Component/s: Table SQL / Ecosystem > Allow comments fail when not ignore parse errors in >

[jira] [Assigned] (FLINK-19647) Support the limit push down for the hbase connector

2021-04-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19647: --- Assignee: Lsw_aka_laplace > Support the limit push down for the hbase connector >

[jira] [Closed] (FLINK-11175) The sample code describing the Processing time used in TableSource is incorrect

2021-04-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-11175. --- Resolution: Fixed The documentation has been updated. > The sample code describing the Processing time

[jira] [Closed] (FLINK-13144) Add method takeAsList to Table

2021-04-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-13144. --- Resolution: Fixed This can be covered by {{Table#collect()}} or {{Table#print()}}. > Add method takeAsList

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

2021-04-30 Thread GitBox
tillrohrmann commented on a change in pull request #15817: URL: https://github.com/apache/flink/pull/15817#discussion_r623760515 ## File path: docs/layouts/shortcodes/generated/web_configuration.html ## @@ -50,6 +50,12 @@ Boolean Flag indicating

[jira] [Closed] (FLINK-11210) Enable auto state cleanup strategy for RANGE OVER

2021-04-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-11210. --- Resolution: Fixed Blink planner already supports this. > Enable auto state cleanup strategy for RANGE

[jira] [Closed] (FLINK-11188) Bounded over should not enable state retention time

2021-04-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-11188. --- Resolution: Fixed Blink planner already follows Fabian's conclusion: - OVER RANGE should automatically

[GitHub] [flink] tillrohrmann commented on a change in pull request #15812: remove slotpoolImpl

2021-04-30 Thread GitBox
tillrohrmann commented on a change in pull request #15812: URL: https://github.com/apache/flink/pull/15812#discussion_r623767811 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphRestartTest.java ## @@ -97,8 +103,10 @@ private

[jira] [Closed] (FLINK-11203) FunctionContext of AggregateFunction will not be initialized for window GroupBy

2021-04-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-11203. --- Resolution: Fixed We implemented a window operator for table in blink planner which supports to expose

[jira] [Closed] (FLINK-11139) stream non window join support state ttl

2021-04-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-11139. --- Resolution: Implemented This has been supported in blink planner. > stream non window join support state

[jira] [Closed] (FLINK-11118) Refactor and unify rowtime timestamp extractor interface

2021-04-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-8. --- Assignee: (was: vinoyang) Resolution: Won't Fix The descriptor API is deprecated and will be

[jira] [Resolved] (FLINK-9863) Add a built-in ingestion time TS extractor

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-9863. --- Resolution: Won't Fix The descriptor API is deprecated and will be refactored soon, it's recommend

[GitHub] [flink] flinkbot edited a comment on pull request #15819: [FLINK-22512][Hive] Fix issue that can't call current_timestamp with hive dialect for hive-3.1

2021-04-30 Thread GitBox
flinkbot edited a comment on pull request #15819: URL: https://github.com/apache/flink/pull/15819#issuecomment-829984795 ## CI report: * 4c52c0c429eb766f22ac20a71e0dcd80b28ff718 Azure:

[jira] [Resolved] (FLINK-9278) Allow restore savepoint with some SQL queries added/removed

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-9278. --- Fix Version/s: 1.13.0 Resolution: Fixed See the doc 

[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-30 Thread GitBox
flinkbot edited a comment on pull request #15776: URL: https://github.com/apache/flink/pull/15776#issuecomment-827352419 ## CI report: * 211c182159f208a7308092734b7001c314cc5116 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

2021-04-30 Thread GitBox
flinkbot edited a comment on pull request #15728: URL: https://github.com/apache/flink/pull/15728#issuecomment-824960796 ## CI report: * f03cc305d25f320b88bb7c7e457c384d4e02674c Azure:

[jira] [Commented] (FLINK-19647) Support the limit push down for the hbase connector

2021-04-30 Thread Lsw_aka_laplace (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337251#comment-17337251 ] Lsw_aka_laplace commented on FLINK-19647: -  Hi [~jark]  [~lirui],  I'm willing to doing this,

[jira] [Assigned] (FLINK-15376) support "CREATE TABLE AS" in Flink SQL

2021-04-30 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15376: -- Assignee: Danny Chen > support "CREATE TABLE AS" in Flink SQL >

[GitHub] [flink] flinkbot commented on pull request #15819: [FLINK-22512][Hive] Fix issue that can't call current_timestamp with hive dialect for hive-3.1

2021-04-30 Thread GitBox
flinkbot commented on pull request #15819: URL: https://github.com/apache/flink/pull/15819#issuecomment-829984795 ## CI report: * 4c52c0c429eb766f22ac20a71e0dcd80b28ff718 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

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

[jira] [Commented] (FLINK-15376) support "CREATE TABLE AS" in Flink SQL

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337246#comment-17337246 ] Leonard Xu commented on FLINK-15376: [~danny0405] Could you take a look this ticket? > support

[jira] [Commented] (FLINK-14364) Allow comments fail when not ignore parse errors in CsvRowDeserializationSchema

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337244#comment-17337244 ] Leonard Xu commented on FLINK-14364: [~lirui] could you take a look this one? it's should be a csv

[jira] [Updated] (FLINK-14364) Allow comments fail when not ignore parse errors in CsvRowDeserializationSchema

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14364: --- Component/s: (was: Table SQL / API) Formats (JSON, Avro, Parquet, ORC,

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

2021-04-30 Thread ChangjiGuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334641#comment-17334641 ] ChangjiGuo edited comment on FLINK-22497 at 4/30/21, 9:51 AM: -- Can someone

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

2021-04-30 Thread ChangjiGuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334641#comment-17334641 ] ChangjiGuo edited comment on FLINK-22497 at 4/30/21, 9:51 AM: -- Can someone

[jira] [Commented] (FLINK-11103) Set a default uncaught exception handler

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337240#comment-17337240 ] Till Rohrmann commented on FLINK-11103: --- I think so. But please double check for other {{main}}

[GitHub] [flink] flinkbot commented on pull request #15819: [FLINK-22512][Hive] Fix issue that can't call current_timestamp with hive dialect for hive-3.1

2021-04-30 Thread GitBox
flinkbot commented on pull request #15819: URL: https://github.com/apache/flink/pull/15819#issuecomment-829975472 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

[jira] [Commented] (FLINK-13773) Rework of the Expression Design

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337239#comment-17337239 ] Leonard Xu commented on FLINK-13773: [~lzljs3620320] Could you take a look these unfinished tasks?

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

2021-04-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22512: --- Labels: pull-request-available (was: ) > Can't call current_timestamp with hive dialect

[GitHub] [flink] luoyuxia opened a new pull request #15819: [FLINK-22512][Hive] Fix issue that can't call current_timestamp with hive dialect for hive-3.1

2021-04-30 Thread GitBox
luoyuxia opened a new pull request #15819: URL: https://github.com/apache/flink/pull/15819 … with hive dialect for hive-3.1 ## What is the purpose of the change * This pull request fixes the issue that can't call current_timestamp with hive dialect for hive-3.1 *

[jira] [Updated] (FLINK-13580) Add overload support for user defined function to blink-planner

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-13580: --- Fix Version/s: 1.11.0 > Add overload support for user defined function to blink-planner >

[jira] [Resolved] (FLINK-13731) flink sql support window with alignment

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-13731. Fix Version/s: 1.13.0 Resolution: Implemented Supported in FLINK-21714, the return value

[jira] [Commented] (FLINK-13580) Add overload support for user defined function to blink-planner

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337234#comment-17337234 ] Leonard Xu commented on FLINK-13580: Implemented in FLINK-15009 {code:java} @FunctionHint(output =

[jira] [Resolved] (FLINK-13580) Add overload support for user defined function to blink-planner

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-13580. Resolution: Implemented > Add overload support for user defined function to blink-planner >

[jira] [Closed] (FLINK-5621) Flink should provide a mechanism to prevent scheduling tasks on TaskManagers with operational issues

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5621. Resolution: Abandoned The issue has been abandoned. > Flink should provide a mechanism to prevent

[jira] [Updated] (FLINK-21979) Job can be restarted from the beginning after it reached a terminal state

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21979: -- Labels: (was: auto-deprioritized-critical) > Job can be restarted from the beginning after

[jira] [Updated] (FLINK-21979) Job can be restarted from the beginning after it reached a terminal state

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21979: -- Priority: Critical (was: Major) > Job can be restarted from the beginning after it reached a

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

2021-04-30 Thread GitBox
flinkbot commented on pull request #15818: URL: https://github.com/apache/flink/pull/15818#issuecomment-829970320 ## CI report: * 21c909a7845f93acf9aea096d6af4dc0da8d3403 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

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

[jira] [Updated] (FLINK-21928) DuplicateJobSubmissionException after JobManager failover

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21928: -- Labels: (was: auto-deprioritized-critical) > DuplicateJobSubmissionException after

[jira] [Updated] (FLINK-21928) DuplicateJobSubmissionException after JobManager failover

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21928: -- Priority: Critical (was: Major) > DuplicateJobSubmissionException after JobManager failover

[jira] [Closed] (FLINK-2197) Scala API is not working when using batch and streaming API in the same program

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2197. Resolution: Done {{DataSet}} API is being deprecated. > Scala API is not working when using batch

[jira] [Closed] (FLINK-8541) Mesos RM should recover from failover timeout

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8541. Resolution: Won't Do Mesos has been deprecated. > Mesos RM should recover from failover timeout >

[jira] [Commented] (FLINK-5763) Make savepoints self-contained and relocatable

2021-04-30 Thread Nicolaus Weidner (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337224#comment-17337224 ] Nicolaus Weidner commented on FLINK-5763: - [~sewen] [~klion26] We stumbled across this ticket

[jira] [Closed] (FLINK-5430) Bring documentation up to speed for current feature set

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5430. Resolution: Done All subtasks have been completed. > Bring documentation up to speed for current

[jira] [Closed] (FLINK-4568) Replace ActorGateway in WebRuntimeMonitor

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4568. Resolution: Not A Problem Not a problem anymore. > Replace ActorGateway in WebRuntimeMonitor >

[jira] [Closed] (FLINK-9612) Add option for minimal artifacts being pulled in Mesos

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9612. Resolution: Won't Do Mesos has been deprecated. > Add option for minimal artifacts being pulled

[jira] [Updated] (FLINK-20427) Remove CheckpointConfig.setPreferCheckpointForRecovery because it can lead to data loss

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20427: -- Labels: (was: auto-deprioritized-critical) > Remove

[jira] [Updated] (FLINK-20427) Remove CheckpointConfig.setPreferCheckpointForRecovery because it can lead to data loss

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20427: -- Priority: Critical (was: Major) > Remove CheckpointConfig.setPreferCheckpointForRecovery

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

2021-04-30 Thread GitBox
zuston edited a comment on pull request #15810: URL: https://github.com/apache/flink/pull/15810#issuecomment-829966066 @XComp Submit new one. -- 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

[GitHub] [flink] zuston commented on pull request #15810: [FLINK-22534] Set delegation token's service name as credential alias

2021-04-30 Thread GitBox
zuston commented on pull request #15810: URL: https://github.com/apache/flink/pull/15810#issuecomment-829966066 @XComp Sumit new one. -- 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

[jira] [Closed] (FLINK-10658) org.apache.flink.util.FlinkException: Releasing shared slot parent.

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10658. - Resolution: Not A Problem Not a problem anymore. > org.apache.flink.util.FlinkException:

[jira] [Closed] (FLINK-5064) Checkpoint messages are not scoped to the leader session ID

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5064. Resolution: Not A Problem Not a problem anymore. > Checkpoint messages are not scoped to the

[jira] [Updated] (FLINK-13052) Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-13052: --- Affects Version/s: (was: 1.8.0) > Supporting multi-topic when using >

[jira] [Updated] (FLINK-13052) Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-13052: --- Fix Version/s: 1.12.0 > Supporting multi-topic when using >

[jira] [Resolved] (FLINK-13052) Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-13052. Resolution: Implemented Implemented in FLINK-18449 > Supporting multi-topic when using >

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

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337209#comment-17337209 ] Leonard Xu commented on FLINK-12710: [~twalthr] Could we close this one as its all subtasks have

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

2021-04-30 Thread GitBox
flinkbot commented on pull request #15818: URL: https://github.com/apache/flink/pull/15818#issuecomment-829956288 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

[jira] [Commented] (FLINK-12562) Improve code in ExpandColumnFunctionsRule

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337207#comment-17337207 ] Leonard Xu commented on FLINK-12562: [~godfreyhe] Could you take over this one?  it's a code cleanup

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

2021-04-30 Thread GitBox
flinkbot commented on pull request #15817: URL: https://github.com/apache/flink/pull/15817#issuecomment-829959024 ## CI report: * 31f01fe2108f5e18f26f50e352d3ed353bd8ffc8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-12562) Improve code in ExpandColumnFunctionsRule

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

[jira] [Closed] (FLINK-8291) For security, Job Manager web UI should be accessed with username/password

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8291. Resolution: Won't Do > For security, Job Manager web UI should be accessed with username/password

[jira] [Updated] (FLINK-22540) Remove YAML environment file support in SQL Client

2021-04-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22540: Priority: Critical (was: Major) > Remove YAML environment file support in SQL Client >

[jira] [Closed] (FLINK-10643) Bubble execution: Resource aware job execution

2021-04-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10643. - Resolution: Abandoned Has been abandoned. > Bubble execution: Resource aware job execution >

[jira] [Commented] (FLINK-12243) Support generic table stats related operations in HiveCatalog

2021-04-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337203#comment-17337203 ] Leonard Xu commented on FLINK-12243: [~lirui] Could you take a look this ? > Support generic table

[jira] [Updated] (FLINK-22540) Remove YAML environment file support in SQL Client

2021-04-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22540: Description: As discussed in

[jira] [Updated] (FLINK-12243) Support generic table stats related operations in HiveCatalog

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

[jira] [Created] (FLINK-22540) Remove YAML environment file support in SQL Client

2021-04-30 Thread Jark Wu (Jira)
Jark Wu created FLINK-22540: --- Summary: Remove YAML environment file support in SQL Client Key: FLINK-22540 URL: https://issues.apache.org/jira/browse/FLINK-22540 Project: Flink Issue Type:

[jira] [Updated] (FLINK-22539) Restructure the Python dependency management documentation

2021-04-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22539: Description: Currently there is a dependency management page under both the Python Table API and Python

<    1   2   3   4   >