[jira] [Commented] (FLINK-15649) Support mounting volumes

2020-07-23 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163240#comment-17163240 ] Canbin Zheng commented on FLINK-15649: -- [~DaDaShen] Previously I don't think volume mounting is a

[jira] [Resolved] (FLINK-18559) Refactor tests for datastream / table collect

2020-07-23 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng resolved FLINK-18559. - Resolution: Done > Refactor tests for datastream / table collect >

[jira] [Resolved] (FLINK-18560) Introduce collect iterator with at least once semantics and exactly once semantics without fault tolerance

2020-07-23 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng resolved FLINK-18560. - Resolution: Implemented > Introduce collect iterator with at least once semantics and exactly

[GitHub] [flink] gaoyunhaii opened a new pull request #12965: [FLINK-18552][tests] Update migration tests in master to cover migration till release-1.11

2020-07-23 Thread GitBox
gaoyunhaii opened a new pull request #12965: URL: https://github.com/apache/flink/pull/12965 **This PR picks the #12876 to release-1.11** ## What is the purpose of the change This PR updates the following tests to cover migration till release-1.11 (including release-1.10 and

[jira] [Commented] (FLINK-10515) Improve tokenisation of program args passed as string

2020-07-23 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163245#comment-17163245 ] Andrey Zagrebin commented on FLINK-10515: - I think the problem is that Web UI has one field for

[jira] [Closed] (FLINK-16085) Translate "Joins in Continuous Queries" page of "Streaming Concepts" into Chinese

2020-07-23 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-16085. -- Fix Version/s: 1.12.0 Resolution: Fixed Merged in

[GitHub] [flink] fsk119 opened a new pull request #12966: [FLINK-17427][table sql/planner]Support SupportsPartitionPushDown in …

2020-07-23 Thread GitBox
fsk119 opened a new pull request #12966: URL: https://github.com/apache/flink/pull/12966 …planner. ## What is the purpose of the change *Support partition push down in planner.* ## Brief change log - *Implement rule to Support partition into table

[jira] [Updated] (FLINK-17427) Support SupportsPartitionPushDown in planner

2020-07-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17427: --- Labels: pull-request-available (was: ) > Support SupportsPartitionPushDown in planner >

[jira] [Comment Edited] (FLINK-18646) Managed memory released check can block RPC thread

2020-07-23 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163285#comment-17163285 ] Andrey Zagrebin edited comment on FLINK-18646 at 7/23/20, 7:37 AM: ---

[GitHub] [flink] flinkbot edited a comment on pull request #12919: [FLINK-16048][avro] Support read/write confluent schema registry avro…

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12919: URL: https://github.com/apache/flink/pull/12919#issuecomment-659928275 ## CI report: * d1e4ba7690be134e21d193fbc1cb01aa51aaeb9b Azure:

[jira] [Commented] (FLINK-18641) "Failure to finalize checkpoint" error in MasterTriggerRestoreHook

2020-07-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163425#comment-17163425 ] Piotr Nowojski commented on FLINK-18641: [~becket_qin] yes you are right that the problem was

[GitHub] [flink] flinkbot commented on pull request #12965: [FLINK-18552][tests] Update migration tests in master to cover migration till release-1.11

2020-07-23 Thread GitBox
flinkbot commented on pull request #12965: URL: https://github.com/apache/flink/pull/12965#issuecomment-662841389 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] [Updated] (FLINK-18552) Update migration tests in master to cover migration from release-1.11

2020-07-23 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-18552: Description: We should update the following tests to cover migration from release-1.11: *

[GitHub] [flink] liuyongvs commented on pull request #12964: [FLINK-17426][blink plannger] Dynamic Source supportsLimit pushdown

2020-07-23 Thread GitBox
liuyongvs commented on pull request #12964: URL: https://github.com/apache/flink/pull/12964#issuecomment-662851070 Hi @godfreyhe @wuchong ,it is here, thanks for your review. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #12955: [FLINK-18632][table-planner-blink] Assign row kind from input to outp…

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12955: URL: https://github.com/apache/flink/pull/12955#issuecomment-662294282 ## CI report: * 72d503c5afb9de060729cb9eab7cc9da2c4f2da1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12864: [FLINK-18487][table] Datagen and Blackhole factory omits unrecognized properties silently

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12864: URL: https://github.com/apache/flink/pull/12864#issuecomment-656503840 ## CI report: * dc885404cf1343b8316b8574208a2ed9f862673e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12934: [FLINK-18616][table sql/api]Add SHOW CURRENT DDLs

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12934: URL: https://github.com/apache/flink/pull/12934#issuecomment-660853561 ## CI report: * c3a5fb2c03a80e2d1a447a23923ce5c6c977c389 Azure:

[jira] [Assigned] (FLINK-18683) Support @DataTypeHint for TableFunction output types

2020-07-23 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-18683: Assignee: Timo Walther > Support @DataTypeHint for TableFunction output types >

[GitHub] [flink] twalthr opened a new pull request #12967: [FLINK-15803][table] Use AggregateInfo as the single source of types

2020-07-23 Thread GitBox
twalthr opened a new pull request #12967: URL: https://github.com/apache/flink/pull/12967 ## What is the purpose of the change This refactors a lot of the code generation around aggregate functions. It does this for better code maintainability and in particular for having a single

[jira] [Commented] (FLINK-18641) "Failure to finalize checkpoint" error in MasterTriggerRestoreHook

2020-07-23 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163267#comment-17163267 ] Jiangjie Qin commented on FLINK-18641: -- [~pnowojski] [~SleePy] There are actually more problems

[jira] [Commented] (FLINK-18568) Add Support for Azure Data Lake Store Gen 2 in Streaming File Sink

2020-07-23 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163284#comment-17163284 ] Robert Metzger commented on FLINK-18568: Thanks a lot for opening this ticket. I'm not a

[jira] [Assigned] (FLINK-18680) Improve RecordsWithSplitIds API

2020-07-23 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-18680: Assignee: Jiangjie Qin > Improve RecordsWithSplitIds API >

[jira] [Created] (FLINK-18680) Improve RecordsWithSplitIds API

2020-07-23 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-18680: Summary: Improve RecordsWithSplitIds API Key: FLINK-18680 URL: https://issues.apache.org/jira/browse/FLINK-18680 Project: Flink Issue Type: Sub-task

[GitHub] [flink-web] rmetzger commented on pull request #361: Catalogs blogpost

2020-07-23 Thread GitBox
rmetzger commented on pull request #361: URL: https://github.com/apache/flink-web/pull/361#issuecomment-662867251 +1 to merge. This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] twalthr closed pull request #12961: [FLINK-18672][docs] Fix Scala table UDF examples

2020-07-23 Thread GitBox
twalthr closed pull request #12961: URL: https://github.com/apache/flink/pull/12961 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

[GitHub] [flink] twalthr closed pull request #12959: [FLINK-15803][table] Unify validation for all kinds of UDFs

2020-07-23 Thread GitBox
twalthr closed pull request #12959: URL: https://github.com/apache/flink/pull/12959 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

[jira] [Closed] (FLINK-18398) ElasticSearch unavailibility causes TM shutdown

2020-07-23 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18398. Resolution: Won't Fix I'm closing this for now since it seems to be caused by

[jira] [Updated] (FLINK-18682) Vector orc reader cannot read Hive 2.0.0 table

2020-07-23 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-18682: --- Description: Trying to read a Hive 2.0.0 ORC table fails with: {noformat} Caused by:

[jira] [Comment Edited] (FLINK-18438) TaskManager start failed

2020-07-23 Thread JohnSiro (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163351#comment-17163351 ] JohnSiro edited comment on FLINK-18438 at 7/23/20, 9:08 AM: hi [~JohnSiro], 

[jira] [Comment Edited] (FLINK-18438) TaskManager start failed

2020-07-23 Thread JohnSiro (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163351#comment-17163351 ] JohnSiro edited comment on FLINK-18438 at 7/23/20, 9:09 AM: hi [~JohnSiro], 

[GitHub] [flink] zentol commented on pull request #12847: [FLINK-18521][release] Add script for creating snapshot branch

2020-07-23 Thread GitBox
zentol commented on pull request #12847: URL: https://github.com/apache/flink/pull/12847#issuecomment-662919235 Actually, none of the fields are supposed to contain `-SNAPSHOT`, as seen in the release-1.10 branch / release guide. So you use the script as is without specifying anything

[jira] [Created] (FLINK-18683) Support @DataTypeHint for TableFunction output types

2020-07-23 Thread Fabian Hueske (Jira)
Fabian Hueske created FLINK-18683: - Summary: Support @DataTypeHint for TableFunction output types Key: FLINK-18683 URL: https://issues.apache.org/jira/browse/FLINK-18683 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #12965: [FLINK-18552][tests] Update migration tests in master to cover migration till release-1.11

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12965: URL: https://github.com/apache/flink/pull/12965#issuecomment-662850124 ## CI report: * 5366de911c86f37b837e8ebf2367d6d9ae5e5905 Azure:

[GitHub] [flink] JingsongLi merged pull request #12721: [hotfix] Fix the table document errors

2020-07-23 Thread GitBox
JingsongLi merged pull request #12721: URL: https://github.com/apache/flink/pull/12721 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

[GitHub] [flink] rmetzger closed pull request #12420: [FLINK-16085][docs] Translate "Joins in Continuous Queries" page of "Streaming Concepts" into Chinese

2020-07-23 Thread GitBox
rmetzger closed pull request #12420: URL: https://github.com/apache/flink/pull/12420 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

[jira] [Assigned] (FLINK-18562) Add Support for Azure Data Lake Store Gen 2 in Flink File System

2020-07-23 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-18562: -- Assignee: Israel Ekpo > Add Support for Azure Data Lake Store Gen 2 in Flink File

[jira] [Commented] (FLINK-18562) Add Support for Azure Data Lake Store Gen 2 in Flink File System

2020-07-23 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163282#comment-17163282 ] Robert Metzger commented on FLINK-18562: Thanks a lot for opening this ticket! I like the idea

[jira] [Closed] (FLINK-18672) Fix Scala code examples for UDF type inference annotations

2020-07-23 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-18672. Fix Version/s: 1.11.2 1.12.0 Resolution: Fixed Fixed in 1.12.0:

[GitHub] [flink] flinkbot edited a comment on pull request #12919: [FLINK-16048][avro] Support read/write confluent schema registry avro…

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12919: URL: https://github.com/apache/flink/pull/12919#issuecomment-659928275 ## CI report: * 8984f0fbb7914ce69763e0a2b7afb869621bdd0d Azure:

[GitHub] [flink-web] dawidwys closed pull request #361: Catalogs blogpost

2020-07-23 Thread GitBox
dawidwys closed pull request #361: URL: https://github.com/apache/flink-web/pull/361 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

[GitHub] [flink-web] dawidwys commented on pull request #361: Catalogs blogpost

2020-07-23 Thread GitBox
dawidwys commented on pull request #361: URL: https://github.com/apache/flink-web/pull/361#issuecomment-662881791 Closed with dce4b86552b30e5d5e1490d131d27bbe7432ed72 This is an automated message from the Apache Git Service.

[GitHub] [flink-web] dawidwys commented on pull request #361: Catalogs blogpost

2020-07-23 Thread GitBox
dawidwys commented on pull request #361: URL: https://github.com/apache/flink-web/pull/361#issuecomment-662881908 Thank you all for the help with the post! This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] xintongsong commented on a change in pull request #12958: [FLINK-18625][runtime] Maintain redundant taskmanagers to speed up failover

2020-07-23 Thread GitBox
xintongsong commented on a change in pull request #12958: URL: https://github.com/apache/flink/pull/12958#discussion_r459236877 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ResourceManagerOptions.java ## @@ -67,6 +67,12 @@ "for

[jira] [Commented] (FLINK-18478) AvroDeserializationSchema does not work with types generated by avrohugger

2020-07-23 Thread Georg Heiler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163347#comment-17163347 ] Georg Heiler commented on FLINK-18478: -- Great! I can confirm that the initial reflection-based

[GitHub] [flink] JingsongLi commented on a change in pull request #12864: [FLINK-18487][table] Datagen and Blackhole factory omits unrecognized properties silently

2020-07-23 Thread GitBox
JingsongLi commented on a change in pull request #12864: URL: https://github.com/apache/flink/pull/12864#discussion_r459326556 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/DataGenTableSourceFactory.java ## @@ -94,128

[GitHub] [flink] zentol merged pull request #12948: [FLINK-18533][coordination] Tolerate pending deployments being reported

2020-07-23 Thread GitBox
zentol merged pull request #12948: URL: https://github.com/apache/flink/pull/12948 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

[GitHub] [flink] flinkbot edited a comment on pull request #12964: [FLINK-17426][blink plannger] Dynamic Source supportsLimit pushdown

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12964: URL: https://github.com/apache/flink/pull/12964#issuecomment-662793989 ## CI report: * 984b8a182e5a5cc64a9e1957710e9b9fd4768a56 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [WIP] [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * 3a528934242821e9233575a843673e020c060dda Azure:

[GitHub] [flink] eogramow commented on pull request #12791: [FLINK-18362][FLINK-13838][yarn] Add yarn.ship-archives to support LocalResourceType.ARCHIVE

2020-07-23 Thread GitBox
eogramow commented on pull request #12791: URL: https://github.com/apache/flink/pull/12791#issuecomment-662866887 @kl0u The unit test was added in YARNITCase. Could I get your review about it? This is an automated message

[jira] [Comment Edited] (FLINK-15649) Support mounting volumes

2020-07-23 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163318#comment-17163318 ] Andrey Zagrebin edited comment on FLINK-15649 at 7/23/20, 8:19 AM: --- I

[jira] [Commented] (FLINK-18641) "Failure to finalize checkpoint" error in MasterTriggerRestoreHook

2020-07-23 Thread Biao Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163341#comment-17163341 ] Biao Liu commented on FLINK-18641: -- Ah, sorry [~pnowojski], I forgot this change is not submitted to

[jira] [Closed] (FLINK-18549) flink 1.11 can not commit partition automatically

2020-07-23 Thread Jun Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Zhang closed FLINK-18549. - Release Note: my hadoop version is 2.6-cdh 5.8 , I upgrade it to hadoop 3.1.2 ,it is successed

[GitHub] [flink] pnowojski commented on pull request #12960: [FLINK-18671][docs] Update upgrade compatibility table for 1.11.0

2020-07-23 Thread GitBox
pnowojski commented on pull request #12960: URL: https://github.com/apache/flink/pull/12960#issuecomment-662893423 Thanks for the review. Yes, the table looks good in the html version. Columns are getting a bit narrow, but I think it's still ok - for a next version we will need to

[jira] [Commented] (FLINK-18641) "Failure to finalize checkpoint" error in MasterTriggerRestoreHook

2020-07-23 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163359#comment-17163359 ] Jiangjie Qin commented on FLINK-18641: -- [~SleePy] Right, the master hooks with

[GitHub] [flink] JingsongLi commented on a change in pull request #12864: [FLINK-18487][table] Datagen and Blackhole factory omits unrecognized properties silently

2020-07-23 Thread GitBox
JingsongLi commented on a change in pull request #12864: URL: https://github.com/apache/flink/pull/12864#discussion_r459326425 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/DataGenTableSourceFactory.java ## @@ -94,128

[GitHub] [flink] kl0u commented on pull request #12791: [FLINK-18362][FLINK-13838][yarn] Add yarn.ship-archives to support LocalResourceType.ARCHIVE

2020-07-23 Thread GitBox
kl0u commented on pull request #12791: URL: https://github.com/apache/flink/pull/12791#issuecomment-662916896 Thanks @eogramow , I will have a look today. This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] zentol commented on pull request #12847: [FLINK-18521][release] Add script for creating snapshot branch

2020-07-23 Thread GitBox
zentol commented on pull request #12847: URL: https://github.com/apache/flink/pull/12847#issuecomment-662916913 > I guess you would use this script rather with RELEASE_VERSION=1.12-SNAPSHOT instead of RELEASE_VERSION=1.12.0? That's a good point; I'll adjust it to use

[GitHub] [flink] flinkbot edited a comment on pull request #12934: [FLINK-18616][table sql/api]Add SHOW CURRENT DDLs

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12934: URL: https://github.com/apache/flink/pull/12934#issuecomment-660853561 ## CI report: * c3a5fb2c03a80e2d1a447a23923ce5c6c977c389 Azure:

[jira] [Comment Edited] (FLINK-15649) Support mounting volumes

2020-07-23 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163400#comment-17163400 ] Canbin Zheng edited comment on FLINK-15649 at 7/23/20, 10:14 AM: - Hi

[GitHub] [flink] flinkbot edited a comment on pull request #12864: [FLINK-18487][table] Datagen and Blackhole factory omits unrecognized properties silently

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12864: URL: https://github.com/apache/flink/pull/12864#issuecomment-656503840 ## CI report: * dc885404cf1343b8316b8574208a2ed9f862673e Azure:

[jira] [Commented] (FLINK-15649) Support mounting volumes

2020-07-23 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163400#comment-17163400 ] Canbin Zheng commented on FLINK-15649: -- Hi [~azagrebin] ??I briefly looked into the PR. It looks

[GitHub] [flink] nielsbasjes commented on pull request #12846: [FLINK-18448][pubsub] Update Google Cloud PubSub dependencies

2020-07-23 Thread GitBox
nielsbasjes commented on pull request #12846: URL: https://github.com/apache/flink/pull/12846#issuecomment-662940858 As it is now (i.e. the libraries-bom issue resolved) I do not think any documentation changes are needed. @rmetzger Do you agree?

[jira] [Commented] (FLINK-18262) PyFlink end-to-end test stalls

2020-07-23 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163265#comment-17163265 ] Robert Metzger commented on FLINK-18262: Thanks a lot for your comment. I agree that we should

[GitHub] [flink] flinkbot edited a comment on pull request #12957: [FLINK-18500][table] Make the legacy planner exception more clear whe…

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12957: URL: https://github.com/apache/flink/pull/12957#issuecomment-662341125 ## CI report: * 6142f8bf5f9e4e146da83e7bea9977359fe7f60f Azure:

[GitHub] [flink] flinkbot commented on pull request #12965: [FLINK-18552][tests] Update migration tests in master to cover migration till release-1.11

2020-07-23 Thread GitBox
flinkbot commented on pull request #12965: URL: https://github.com/apache/flink/pull/12965#issuecomment-662850124 ## CI report: * 5366de911c86f37b837e8ebf2367d6d9ae5e5905 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #12966: [FLINK-17427][table sql/planner]Support SupportsPartitionPushDown in …

2020-07-23 Thread GitBox
flinkbot commented on pull request #12966: URL: https://github.com/apache/flink/pull/12966#issuecomment-662853203 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-15649) Support mounting volumes

2020-07-23 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163318#comment-17163318 ] Andrey Zagrebin commented on FLINK-15649: - I agree that mounting volumes is very useful to do

[jira] [Created] (FLINK-18682) Vector orc reader cannot read Hive 2.0.0 table

2020-07-23 Thread Rui Li (Jira)
Rui Li created FLINK-18682: -- Summary: Vector orc reader cannot read Hive 2.0.0 table Key: FLINK-18682 URL: https://issues.apache.org/jira/browse/FLINK-18682 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-18682) Vector orc reader cannot read Hive 2.0.0 table

2020-07-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163380#comment-17163380 ] Jingsong Lee commented on FLINK-18682: -- What do you mean about trying to read a Hive 2.0.0 ORC

[GitHub] [flink] JingsongLi commented on a change in pull request #12864: [FLINK-18487][table] Datagen and Blackhole factory omits unrecognized properties silently

2020-07-23 Thread GitBox
JingsongLi commented on a change in pull request #12864: URL: https://github.com/apache/flink/pull/12864#discussion_r459326425 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/DataGenTableSourceFactory.java ## @@ -94,128

[GitHub] [flink] flinkbot commented on pull request #12967: [FLINK-15803][table] Use AggregateInfo as the single source of types

2020-07-23 Thread GitBox
flinkbot commented on pull request #12967: URL: https://github.com/apache/flink/pull/12967#issuecomment-662934046 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 commented on pull request #12967: [FLINK-15803][table] Use AggregateInfo as the single source of types

2020-07-23 Thread GitBox
flinkbot commented on pull request #12967: URL: https://github.com/apache/flink/pull/12967#issuecomment-662943223 ## CI report: * 3c0ded80d54651920a993ac2d0ee8d92c8480abf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] rmetzger commented on pull request #12420: [FLINK-16085][docs] Translate "Joins in Continuous Queries" page of "Streaming Concepts" into Chinese

2020-07-23 Thread GitBox
rmetzger commented on pull request #12420: URL: https://github.com/apache/flink/pull/12420#issuecomment-662843164 Thanks for the review & contribution. I will merge the PR now. This is an automated message from the Apache

[jira] [Comment Edited] (FLINK-18646) Managed memory released check can block RPC thread

2020-07-23 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163285#comment-17163285 ] Andrey Zagrebin edited comment on FLINK-18646 at 7/23/20, 7:33 AM: ---

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [WIP] [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * db1412f0ca469ea1b9f8cc3b7dcc78d1b60762cf Azure:

[GitHub] [flink] flinkbot commented on pull request #12966: [FLINK-17427][table sql/planner]Support SupportsPartitionPushDown in …

2020-07-23 Thread GitBox
flinkbot commented on pull request #12966: URL: https://github.com/apache/flink/pull/12966#issuecomment-662861328 ## CI report: * 0f19df4d1fcbb4093b69d772628b67b81ebb443a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-18681) The jar package version conflict causes the task to continue to increase and grab resources

2020-07-23 Thread wangtaiyang (Jira)
wangtaiyang created FLINK-18681: --- Summary: The jar package version conflict causes the task to continue to increase and grab resources Key: FLINK-18681 URL: https://issues.apache.org/jira/browse/FLINK-18681

[jira] [Commented] (FLINK-15803) Expose the new type inference for aggregate functions

2020-07-23 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163357#comment-17163357 ] Timo Walther commented on FLINK-15803: -- We will split this change into multiple PR due to the large

[jira] [Commented] (FLINK-15803) Expose the new type inference for aggregate functions

2020-07-23 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163358#comment-17163358 ] Timo Walther commented on FLINK-15803: -- Fixed in 1.12.0: {code}

[GitHub] [flink] flinkbot edited a comment on pull request #10768: [FLINK-15012][checkpoint] Introduce shutdown to CheckpointStorageCoordinatorView to clean up checkpoint directory.

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #10768: URL: https://github.com/apache/flink/pull/10768#issuecomment-570915760 ## CI report: * 31d15b255ff5bb329c16e1f1afac36b5ff06d4d8 UNKNOWN * e0cfa1cc05a2f8310bf325f7949417c8c95dfc07 Travis:

[jira] [Assigned] (FLINK-18581) Cannot find GC cleaner with java version previous jdk8u72(-b01)

2020-07-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-18581: - Assignee: Andrey Zagrebin > Cannot find GC cleaner with java version previous

[jira] [Updated] (FLINK-18686) Getting the emit time when `table.exec.emit.early-fire.enabled` is true

2020-07-23 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-18686: - Component/s: Table SQL / Planner Fix Version/s: 1.12.0 Affects Version/s:

[jira] [Created] (FLINK-18686) Getting the emit time when `table.exec.emit.early-fire.enabled` is true

2020-07-23 Thread hailong wang (Jira)
hailong wang created FLINK-18686: Summary: Getting the emit time when `table.exec.emit.early-fire.enabled` is true Key: FLINK-18686 URL: https://issues.apache.org/jira/browse/FLINK-18686 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #12920: [FLINK-18536][kinesis] Adding enhanced fan-out related configurations.

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12920: URL: https://github.com/apache/flink/pull/12920#issuecomment-659996635 ## CI report: * 68304c8bc1e5ccae037269302bd4c15ea41dc7a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12850: [FLINK-18483][kinesis] Test coverage improvements for FlinkKinesisConsumer/ShardConsumer

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12850: URL: https://github.com/apache/flink/pull/12850#issuecomment-655383993 ## CI report: * d2297eb49d52eb26e753feb4d61331d26dc2ed62 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12919: [FLINK-16048][avro] Support read/write confluent schema registry avro…

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12919: URL: https://github.com/apache/flink/pull/12919#issuecomment-659928275 ## CI report: * d1e4ba7690be134e21d193fbc1cb01aa51aaeb9b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12916: [FLINK-11547][flink-connector-kinesis] Fix JsonMappingException in DynamoDBStreamsSchema

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12916: URL: https://github.com/apache/flink/pull/12916#issuecomment-659762134 ## CI report: * f5c161b9cbf0df4cbf0e9f9efd08d1b5b3edb47e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12881: [FLINK-18512][kinesis] Introducing RecordPublisher. Refactor ShardConsumer to use PollingRecordPublisher

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12881: URL: https://github.com/apache/flink/pull/12881#issuecomment-657437295 ## CI report: * b8e47e8baef39de33c2336533426b4fa6d07dc66 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12729: [FLINK-10195][connectors/rabbitmq] Allow setting QoS

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12729: URL: https://github.com/apache/flink/pull/12729#issuecomment-647037124 ## CI report: * 790ebc88d93408cba281d3836ea24e6f6bc4a866 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12944: [FLINK-18513][Kinesis] Add AWS SDK v2.x dependency and KinesisProxyV2

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12944: URL: https://github.com/apache/flink/pull/12944#issuecomment-661736413 ## CI report: * e754d55a091b78c3647c47b227edb0b7870f0c09 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12312: [FLINK-15507][state backends] Activate local recovery by default

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12312: URL: https://github.com/apache/flink/pull/12312#issuecomment-633384542 ## CI report: * 0593cfda3ac278603f23e95f2ac07ec1cd20f3a7 Azure:

[GitHub] [flink] dannycranmer commented on a change in pull request #12944: [FLINK-18513][Kinesis] Add AWS SDK v2.x dependency and KinesisProxyV2

2020-07-23 Thread GitBox
dannycranmer commented on a change in pull request #12944: URL: https://github.com/apache/flink/pull/12944#discussion_r459474390 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AwsV2Util.java ## @@ -0,0

[jira] [Updated] (FLINK-18421) Elasticsearch (v6.3.1) sink end-to-end test instable

2020-07-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18421: --- Fix Version/s: 1.11.2 > Elasticsearch (v6.3.1) sink end-to-end test instable >

[jira] [Updated] (FLINK-18421) Elasticsearch (v6.3.1) sink end-to-end test instable

2020-07-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18421: --- Affects Version/s: 1.11.1 > Elasticsearch (v6.3.1) sink end-to-end test instable >

[jira] [Reopened] (FLINK-18552) Update migration tests in master to cover migration from release-1.11

2020-07-23 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reopened FLINK-18552: - > Update migration tests in master to cover migration from release-1.11 >

[jira] [Commented] (FLINK-18646) Managed memory released check can block RPC thread

2020-07-23 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163285#comment-17163285 ] Andrey Zagrebin commented on FLINK-18646: - {quote}do you know how the high number of GC calls

[jira] [Updated] (FLINK-18680) Improve RecordsWithSplitIds API

2020-07-23 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-18680: - Fix Version/s: 1.12.0 > Improve RecordsWithSplitIds API > --- > >

[GitHub] [flink] flinkbot edited a comment on pull request #12965: [FLINK-18552][tests] Update migration tests in master to cover migration till release-1.11

2020-07-23 Thread GitBox
flinkbot edited a comment on pull request #12965: URL: https://github.com/apache/flink/pull/12965#issuecomment-662850124 ## CI report: * 5366de911c86f37b837e8ebf2367d6d9ae5e5905 Azure:

[jira] [Commented] (FLINK-18675) Checkpoint not maintaining minimum pause duration between checkpoints

2020-07-23 Thread Ravi Bhushan Ratnakar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163289#comment-17163289 ] Ravi Bhushan Ratnakar commented on FLINK-18675: --- [~klion26] from the attached screenshot,

[GitHub] [flink] danny0405 commented on a change in pull request #12919: [FLINK-16048][avro] Support read/write confluent schema registry avro…

2020-07-23 Thread GitBox
danny0405 commented on a change in pull request #12919: URL: https://github.com/apache/flink/pull/12919#discussion_r459273734 ## File path: flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/RegistryAvroRowDataSeDeSchemaTest.java ## @@ -0,0 +1,129 @@ +/* + *

  1   2   3   4   >