[GitHub] [flink] QingdongZeng3 commented on pull request #13690: [FLINK-16595][YARN]support more HDFS nameServices in yarn mode when security enabled. Is…

2020-10-22 Thread GitBox
QingdongZeng3 commented on pull request #13690: URL: https://github.com/apache/flink/pull/13690#issuecomment-71485 @tillrohrmann @zentol Hi,contributors of YarnClusterDescriptor.java,would you help to review my code?Thanks!

[GitHub] [flink] JingsongLi commented on a change in pull request #13636: [FLINK-19641][hive] Optimize parallelism calculating of HiveTableSource by checking file number

2020-10-22 Thread GitBox
JingsongLi commented on a change in pull request #13636: URL: https://github.com/apache/flink/pull/13636#discussion_r510559354 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java ## @@ -210,19 +212,35 @@

[GitHub] [flink] flinkbot edited a comment on pull request #12647: [FLINK-18044][Connectors/Common] Add the subtask index information to the SourceReaderContext.

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #12647: URL: https://github.com/apache/flink/pull/12647#issuecomment-643898574 ## CI report: * dde8225437b4208d565a74e9a78c9398eea11025 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13739: [FLINK-19232][python] support iterating MapState and MapView

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13739: URL: https://github.com/apache/flink/pull/13739#issuecomment-714232634 ## CI report: * 844e71b94546c009d1e0e5ec7fccf841354f151e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13753: [FLINK-19765][flink-table-planner] refactor SqlToOperationConverter a…

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13753: URL: https://github.com/apache/flink/pull/13753#issuecomment-714862730 ## CI report: * b85f48049fd05f5c6da1cb91c6dfb4c6d201100c Azure:

[jira] [Updated] (FLINK-19755) flink cep docs exist looping match when coming to 17, 14 using AFTER MATCH SKIP TO LAST A 

2020-10-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19755: --- Labels: pull-request-available (was: ) > flink cep docs exist looping match when coming to

[GitHub] [flink] liuyongvs opened a new pull request #13754: [FLINK-19755][cep][docs] fix flink cep docs of looping matching bug.

2020-10-22 Thread GitBox
liuyongvs opened a new pull request #13754: URL: https://github.com/apache/flink/pull/13754 ## What is the purpose of the change * fix flink cep docs of looping matching bug* ## Does this pull request potentially affect one of the following parts: -

[GitHub] [flink] flinkbot commented on pull request #13754: [FLINK-19755][cep][docs] fix flink cep docs of looping matching bug.

2020-10-22 Thread GitBox
flinkbot commented on pull request #13754: URL: https://github.com/apache/flink/pull/13754#issuecomment-714871316 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-19776) cancel with savePoint throw Unrecognized field "status"

2020-10-22 Thread tonychan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tonychan updated FLINK-19776: - Attachment: (was: image-2020-10-23-10-56-13-197.png) > cancel with savePoint throw Unrecognized

[jira] [Updated] (FLINK-19776) cancel with savePoint throw Unrecognized field "status"

2020-10-22 Thread tonychan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tonychan updated FLINK-19776: - Attachment: (was: image-2020-10-23-10-56-44-838.png) > cancel with savePoint throw Unrecognized

[jira] [Updated] (FLINK-19776) cancel with savePoint throw Unrecognized field "status"

2020-10-22 Thread tonychan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tonychan updated FLINK-19776: - Attachment: (was: image-2020-10-23-10-57-50-418.png) > cancel with savePoint throw Unrecognized

[GitHub] [flink] flinkbot commented on pull request #13755: [FLINK-19700][k8s] Make Kubernetes Client in KubernetesResourceManagerDriver use io executor

2020-10-22 Thread GitBox
flinkbot commented on pull request #13755: URL: https://github.com/apache/flink/pull/13755#issuecomment-714876068 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] [Closed] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties

2020-10-22 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-19768. Resolution: Not A Problem > The shell "./yarn-session.sh " not use log4j-session.properties , it

[jira] [Updated] (FLINK-19776) cancel with savePoint throw Unrecognized field "status"

2020-10-22 Thread tonychan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tonychan updated FLINK-19776: - Attachment: image-2020-10-23-10-57-50-418.png Description: job running with yarn-per job mode

[jira] [Commented] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties

2020-10-22 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219428#comment-17219428 ] Xintong Song commented on FLINK-19768: -- [~YUJIANBO], I think this is not a bug.

[GitHub] [flink] flinkbot edited a comment on pull request #13739: [FLINK-19232][python] support iterating MapState and MapView

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13739: URL: https://github.com/apache/flink/pull/13739#issuecomment-714232634 ## CI report: * 844e71b94546c009d1e0e5ec7fccf841354f151e Azure:

[GitHub] [flink] flinkbot commented on pull request #13754: [FLINK-19755][cep][docs] fix flink cep docs of looping matching bug.

2020-10-22 Thread GitBox
flinkbot commented on pull request #13754: URL: https://github.com/apache/flink/pull/13754#issuecomment-714876169 ## CI report: * 3717c92c917638c1dbde99081f6aa890d723f39e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-19776) cancel with savePoint throw Unrecognized field "status"

2020-10-22 Thread tonychan (Jira)
tonychan created FLINK-19776: Summary: cancel with savePoint throw Unrecognized field "status" Key: FLINK-19776 URL: https://issues.apache.org/jira/browse/FLINK-19776 Project: Flink Issue

[jira] [Updated] (FLINK-19776) cancel with savePoint throw Unrecognized field "status"

2020-10-22 Thread tonychan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tonychan updated FLINK-19776: - Attachment: image-2020-10-23-10-58-32-976.png Description: job running with yarn-per job mode

[jira] [Comment Edited] (FLINK-19644) Support read specific partition of Hive table in temporal join

2020-10-22 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219021#comment-17219021 ] Leonard Xu edited comment on FLINK-19644 at 10/23/20, 3:11 AM: --- According

[jira] [Updated] (FLINK-19776) cancel with savePoint throw Unrecognized field "status"

2020-10-22 Thread tonychan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tonychan updated FLINK-19776: - Description: job running with yarn-per job mode,when i use cancel -s to stop  the job 

[jira] [Commented] (FLINK-19644) Support read specific partition of Hive table in temporal join

2020-10-22 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219439#comment-17219439 ] Leonard Xu commented on FLINK-19644: How about the Option?   "read.partition=latest-partition /

[GitHub] [flink] flinkbot edited a comment on pull request #13755: [FLINK-19700][k8s] Make Kubernetes Client in KubernetesResourceManagerDriver use io executor

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13755: URL: https://github.com/apache/flink/pull/13755#issuecomment-714883306 ## CI report: * e31a8a6b6e3c8628503b4534c2bdff345365c1e0 Azure:

[jira] [Comment Edited] (FLINK-19644) Support read specific partition of Hive table in temporal join

2020-10-22 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219439#comment-17219439 ] Leonard Xu edited comment on FLINK-19644 at 10/23/20, 3:48 AM: --- How about

[jira] [Comment Edited] (FLINK-19644) Support read specific partition of Hive table in temporal join

2020-10-22 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219439#comment-17219439 ] Leonard Xu edited comment on FLINK-19644 at 10/23/20, 3:49 AM: --- How about

[jira] [Comment Edited] (FLINK-19644) Support read specific partition of Hive table in temporal join

2020-10-22 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219439#comment-17219439 ] Leonard Xu edited comment on FLINK-19644 at 10/23/20, 3:48 AM: --- How about

[GitHub] [flink] gaoyunhaii commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

2020-10-22 Thread GitBox
gaoyunhaii commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r510579608 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PartitionedFileWriter.java ## @@ -0,0 +1,211 @@ +/* + *

[GitHub] [flink] flinkbot commented on pull request #13756: [FLINK-19770][python][test] Changed the PythonProgramOptionTest to be an ITCase.

2020-10-22 Thread GitBox
flinkbot commented on pull request #13756: URL: https://github.com/apache/flink/pull/13756#issuecomment-714895505 ## CI report: * d994782b0d8d72c5a59379643d6e588a02b333ad UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13744: [FLINK-19766][table-runtime] Introduce File streaming compaction operators

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13744: URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975 ## CI report: * 73d36420f9e131efb1ba70053b5ef315f79afd68 Azure:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

2020-10-22 Thread GitBox
gaoyunhaii commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r510581883 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PartitionSortedBuffer.java ## @@ -0,0 +1,390 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #13756: [FLINK-19770][python][test] Changed the PythonProgramOptionTest to be an ITCase.

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13756: URL: https://github.com/apache/flink/pull/13756#issuecomment-714895505 ## CI report: * d994782b0d8d72c5a59379643d6e588a02b333ad Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13744: [FLINK-19766][table-runtime] Introduce File streaming compaction operators

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13744: URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975 ## CI report: * d257594ae6a62374f9727f97dad3254ea7c25ef2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13754: [FLINK-19755][cep][docs] fix flink cep docs of looping matching bug.

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13754: URL: https://github.com/apache/flink/pull/13754#issuecomment-714876169 ## CI report: * 3717c92c917638c1dbde99081f6aa890d723f39e Azure:

[GitHub] [flink] twalthr commented on a change in pull request #13732: [FLINK-19275][connector-kafka] Support reading and writing Kafka meta… …data

2020-10-22 Thread GitBox
twalthr commented on a change in pull request #13732: URL: https://github.com/apache/flink/pull/13732#discussion_r510144202 ## File path: flink-core/src/main/java/org/apache/flink/types/Row.java ## @@ -274,4 +278,119 @@ public static Row join(Row first, Row... remainings) {

[GitHub] [flink] flinkbot edited a comment on pull request #13618: [FLINK-19274][table] Implement SupportsReadingMetadata and SupportsWritingMetadata for sources and sinks

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13618: URL: https://github.com/apache/flink/pull/13618#issuecomment-707809605 ## CI report: * ad4d51bd6104da7e25c51973aaef9b45056907a4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13636: [FLINK-19641][hive] Optimize parallelism calculating of HiveTableSource by checking file number

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13636: URL: https://github.com/apache/flink/pull/13636#issuecomment-708378225 ## CI report: * 9b46a6a32ef4964221948656f783d8248db7e60b Azure:

[GitHub] [flink] WeiZhong94 commented on pull request #13739: [FLINK-19232][python] support iterating MapState and MapView

2020-10-22 Thread GitBox
WeiZhong94 commented on pull request #13739: URL: https://github.com/apache/flink/pull/13739#issuecomment-714486868 @dianfu Thanks for your comments! I have updated this PR. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #13636: [FLINK-19641][hive] Optimize parallelism calculating of HiveTableSource by checking file number

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13636: URL: https://github.com/apache/flink/pull/13636#issuecomment-708378225 ## CI report: * 9b46a6a32ef4964221948656f783d8248db7e60b Azure:

[jira] [Commented] (FLINK-19644) Support read specific partition of Hive table in temporal join

2020-10-22 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219021#comment-17219021 ] Leonard Xu commented on FLINK-19644: According to my Investigation, a major user case is to load

[GitHub] [flink] flinkbot edited a comment on pull request #13706: [FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resolution en

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13706: URL: https://github.com/apache/flink/pull/13706#issuecomment-712871607 ## CI report: * 12f743654fc694b682b29faf2b82311a24914f73 Azure:

[GitHub] [flink] flinkbot commented on pull request #13748: [FLINK-19769][streaming] Reuse StreamRecord in SourceOutputWithWatermarks#collect

2020-10-22 Thread GitBox
flinkbot commented on pull request #13748: URL: https://github.com/apache/flink/pull/13748#issuecomment-714518838 ## CI report: * ab95658b962916b08339896aa8d922cadca20cc5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13696: [FLINK-19726][table] Implement new providers for blink planner

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13696: URL: https://github.com/apache/flink/pull/13696#issuecomment-712617122 ## CI report: * f2e5f3867663c020ec292722b63d5788b43fd3b2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13672: [FLINK-19660][docs][python] Translate page "table_environment.zh.md" into Chinese

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13672: URL: https://github.com/apache/flink/pull/13672#issuecomment-711107288 ## CI report: * 3f25a527ec7c3238365f0746323c02f0f35252cb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13677: Single task scheduler

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13677: URL: https://github.com/apache/flink/pull/13677#issuecomment-711161777 ## CI report: * b74b5ddf6a01dcb080cf5cf2e6773d919a6ecdec Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #13711: [FLINK-19721] [flink-runtime] Support exponential backoff retries in RpcGatewayRetriever

2020-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #13711: URL: https://github.com/apache/flink/pull/13711#discussion_r510221384 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/retriever/impl/RpcGatewayRetriever.java ## @@ -42,24 +44,26 @@

[jira] [Created] (FLINK-19772) Add utility for retrying sync operations with exponential timeout

2020-10-22 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-19772: Summary: Add utility for retrying sync operations with exponential timeout Key: FLINK-19772 URL: https://issues.apache.org/jira/browse/FLINK-19772 Project:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

2020-10-22 Thread GitBox
gaoyunhaii commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r510256114 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PartitionSortedBuffer.java ## @@ -0,0 +1,390 @@ +/* + *

[jira] [Updated] (FLINK-19712) Pipelined region failover should skip restarting tasks in CREATED

2020-10-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19712: --- Labels: pull-request-available (was: ) > Pipelined region failover should skip restarting

[GitHub] [flink] azagrebin opened a new pull request #13749: [FLINK-19712][Coordination] Do not restart CREATED executions in RestartPipelinedRegionFailoverStrategy

2020-10-22 Thread GitBox
azagrebin opened a new pull request #13749: URL: https://github.com/apache/flink/pull/13749 ## What is the purpose of the change When a task fails and it is `RestartPipelinedRegionFailoverStrategy`, all tasks in the region of the failed task and in the downstream regions will be

[jira] [Updated] (FLINK-19770) PythonProgramOptionsTest requires package phase before execution

2020-10-22 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19770: - Summary: PythonProgramOptionsTest requires package phase before execution (was: mvn

[jira] [Updated] (FLINK-19770) mvn clean verify - testConfigurePythonExecution failing

2020-10-22 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19770: - Priority: Minor (was: Major) > mvn clean verify - testConfigurePythonExecution failing

[jira] [Updated] (FLINK-19770) mvn clean verify - testConfigurePythonExecution failing

2020-10-22 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19770: - Component/s: (was: Build System) Tests API /

[GitHub] [flink] flinkbot edited a comment on pull request #13618: [FLINK-19274][table] Implement SupportsReadingMetadata and SupportsWritingMetadata for sources and sinks

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13618: URL: https://github.com/apache/flink/pull/13618#issuecomment-707809605 ## CI report: * ad4d51bd6104da7e25c51973aaef9b45056907a4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13706: [FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resolution en

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13706: URL: https://github.com/apache/flink/pull/13706#issuecomment-712871607 ## CI report: * 12f743654fc694b682b29faf2b82311a24914f73 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13739: [FLINK-19232][python] support iterating MapState and MapView

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13739: URL: https://github.com/apache/flink/pull/13739#issuecomment-714232634 ## CI report: * 9f75014b48308eb93937e11fcd8f4da80de12bd4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13735: URL: https://github.com/apache/flink/pull/13735#issuecomment-714048414 ## CI report: * ee73393a13c999be626f7b8b98a170be88a093d9 Azure:

[GitHub] [flink] rmetzger commented on pull request #13208: [FLINK-18676] [FileSystem] Bump s3 aws version

2020-10-22 Thread GitBox
rmetzger commented on pull request #13208: URL: https://github.com/apache/flink/pull/13208#issuecomment-714536738 Okay, I will indeed take over this PR. I'm closing this one in favor of a new one. This is an automated

[jira] [Assigned] (FLINK-18676) Update version of aws to support use of default constructor of "WebIdentityTokenCredentialsProvider"

2020-10-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-18676: -- Assignee: Robert Metzger > Update version of aws to support use of default

[GitHub] [flink] rmetzger closed pull request #13208: [FLINK-18676] [FileSystem] Bump s3 aws version

2020-10-22 Thread GitBox
rmetzger closed pull request #13208: URL: https://github.com/apache/flink/pull/13208 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] wuchong commented on a change in pull request #13732: [FLINK-19275][connector-kafka] Support reading and writing Kafka meta… …data

2020-10-22 Thread GitBox
wuchong commented on a change in pull request #13732: URL: https://github.com/apache/flink/pull/13732#discussion_r510230194 ## File path: flink-core/src/main/java/org/apache/flink/types/Row.java ## @@ -274,4 +278,119 @@ public static Row join(Row first, Row... remainings) {

[GitHub] [flink] wuchong commented on a change in pull request #13732: [FLINK-19275][connector-kafka] Support reading and writing Kafka meta… …data

2020-10-22 Thread GitBox
wuchong commented on a change in pull request #13732: URL: https://github.com/apache/flink/pull/13732#discussion_r510231299 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java ## @@

[GitHub] [flink] curcur edited a comment on pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

2020-10-22 Thread GitBox
curcur edited a comment on pull request #13648: URL: https://github.com/apache/flink/pull/13648#issuecomment-714599452 Thanks, @rkhachatryan for clarifying the problem! I agree there is a problem if a downstream task continuously fails multiple times, or an orphan task execution may

[GitHub] [flink] curcur edited a comment on pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

2020-10-22 Thread GitBox
curcur edited a comment on pull request #13648: URL: https://github.com/apache/flink/pull/13648#issuecomment-714599452 Thanks, @rkhachatryan for clarifying the problem! I agree there is a problem if a downstream task continuously fails multiple times, or an orphan task execution may

[GitHub] [flink] curcur commented on pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

2020-10-22 Thread GitBox
curcur commented on pull request #13648: URL: https://github.com/apache/flink/pull/13648#issuecomment-714599452 Thanks, @rkhachatryan for clarifying the problem! I agree there is a problem if a downstream task continuously fails multiple times, or an orphan task execution may exist for

[jira] [Commented] (FLINK-19770) mvn clean verify - testConfigurePythonExecution failing

2020-10-22 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219006#comment-17219006 ] Chesnay Schepler commented on FLINK-19770: -- Essentially we just have to change the class name

[jira] [Updated] (FLINK-19770) mvn clean verify - testConfigurePythonExecution failing

2020-10-22 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19770: - Fix Version/s: 1.11.3 1.12.0 > mvn clean verify -

[jira] [Updated] (FLINK-19770) mvn clean verify - testConfigurePythonExecution failing

2020-10-22 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19770: - Labels: starter (was: ) > mvn clean verify - testConfigurePythonExecution failing >

[jira] [Commented] (FLINK-10241) Reduce performance/stability impact of latency metrics

2020-10-22 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219005#comment-17219005 ] Chesnay Schepler commented on FLINK-10241: -- There are currently no further plans on improving

[jira] [Commented] (FLINK-19746) Why delete support for "as" function

2020-10-22 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219011#comment-17219011 ] Timo Walther commented on FLINK-19746: -- [~appleyuchi] {{tEnv.createTemporaryView("Orders",

[GitHub] [flink] flinkbot edited a comment on pull request #13745: [FLINK-19767] Add AbstractSlotPoolFactory

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13745: URL: https://github.com/apache/flink/pull/13745#issuecomment-714370772 ## CI report: * c6f0ef39c65468a7f613e31bac530b148d36a9d4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13741: [FLINK-19680][checkpointing] Announce timeoutable CheckpointBarriers

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13741: URL: https://github.com/apache/flink/pull/13741#issuecomment-714295796 ## CI report: * 8a68242a90fd180fcd0b4b4c60b5e1e49136c00f Azure:

[GitHub] [flink] StephanEwen commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

2020-10-22 Thread GitBox
StephanEwen commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r510200867 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PartitionSortedBuffer.java ## @@ -0,0 +1,390 @@ +/* + *

[GitHub] [flink] flinkbot commented on pull request #13750: [FLINK-19394][docs-zh] Translate the 'Monitoring Checkpointing' page of 'Debugging & Monitoring' into Chinese

2020-10-22 Thread GitBox
flinkbot commented on pull request #13750: URL: https://github.com/apache/flink/pull/13750#issuecomment-714547252 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] wuchong commented on a change in pull request #13732: [FLINK-19275][connector-kafka] Support reading and writing Kafka meta… …data

2020-10-22 Thread GitBox
wuchong commented on a change in pull request #13732: URL: https://github.com/apache/flink/pull/13732#discussion_r510233222 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java ## @@

[GitHub] [flink] flinkbot commented on pull request #13751: [FLINK-19772] Add FutureUtils#retryWithExponentialDelay

2020-10-22 Thread GitBox
flinkbot commented on pull request #13751: URL: https://github.com/apache/flink/pull/13751#issuecomment-714564736 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] wangjian2019 commented on pull request #13377: [FLINK-18592] bugfix for StreamingFileSink

2020-10-22 Thread GitBox
wangjian2019 commented on pull request #13377: URL: https://github.com/apache/flink/pull/13377#issuecomment-714570667 sorry for my late reply due to no notification of email. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #13618: [FLINK-19274][table] Implement SupportsReadingMetadata and SupportsWritingMetadata for sources and sinks

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13618: URL: https://github.com/apache/flink/pull/13618#issuecomment-707809605 ## CI report: * 4922a794b8792bcd5877ac7d08fc8c1bb82108aa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13706: [FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse resolution en

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13706: URL: https://github.com/apache/flink/pull/13706#issuecomment-712871607 ## CI report: * 12f743654fc694b682b29faf2b82311a24914f73 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13736: [FLINK-19654][python][e2e] Reduce pyflink e2e test parallelism

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13736: URL: https://github.com/apache/flink/pull/13736#issuecomment-714183394 ## CI report: * 111ec785929a0742b46ea98408f585aa03314b1d Azure:

[jira] [Created] (FLINK-19773) Exponential backoff restart strategy

2020-10-22 Thread Levi Ramsey (Jira)
Levi Ramsey created FLINK-19773: --- Summary: Exponential backoff restart strategy Key: FLINK-19773 URL: https://issues.apache.org/jira/browse/FLINK-19773 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #13750: [FLINK-19394][docs-zh] Translate the 'Monitoring Checkpointing' page of 'Debugging & Monitoring' into Chinese

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13750: URL: https://github.com/apache/flink/pull/13750#issuecomment-714567487 ## CI report: * 1ec411ddcfd58a0ab5f22c7ebe5433439b217d27 Azure:

[GitHub] [flink] flinkbot commented on pull request #13751: [FLINK-19772] Add FutureUtils#retryWithExponentialDelay

2020-10-22 Thread GitBox
flinkbot commented on pull request #13751: URL: https://github.com/apache/flink/pull/13751#issuecomment-714582964 ## CI report: * 1c418284a3319ec579755635cff60dd7dfc94ffe UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Closed] (FLINK-19746) Why delete support for "as" function

2020-10-22 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-19746. Resolution: Won't Fix I hope it is ok if I close this issue for now. Such questions rather belong

[GitHub] [flink] flinkbot edited a comment on pull request #13486: [FLINK-19334][docs-zh] Translate page `Streaming File Sink` of `ORC format` into Chinese

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13486: URL: https://github.com/apache/flink/pull/13486#issuecomment-699479597 ## CI report: * 61dd9a2f629470dafc3f3494822bfab938bb9bdf Azure:

[jira] [Updated] (FLINK-19394) Translate the 'Monitoring Checkpointing' page of 'Debugging & Monitoring' into Chinese

2020-10-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19394: --- Labels: Translation documentation pull-request-available translation translation-zh (was:

[GitHub] [flink] RocMarshal opened a new pull request #13750: [FLINK-19394][docs-zh] Translate the 'Monitoring Checkpointing' page of 'Debugging & Monitoring' into Chinese

2020-10-22 Thread GitBox
RocMarshal opened a new pull request #13750: URL: https://github.com/apache/flink/pull/13750 ## What is the purpose of the change *Translate the 'Monitoring Checkpointing' page of 'Debugging & Monitoring' into Chinese* ## Brief change log *Translate the

[jira] [Closed] (FLINK-19767) Add AbstractSlotPoolFactory

2020-10-22 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-19767. Resolution: Fixed master: 78b3f2e7d5d0a5a4d341587951b2dc54a5ef427b > Add

[GitHub] [flink] zentol merged pull request #13745: [FLINK-19767] Add AbstractSlotPoolFactory

2020-10-22 Thread GitBox
zentol merged pull request #13745: URL: https://github.com/apache/flink/pull/13745 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 #13735: [FLINK-19533][checkpoint] Add channel state reassignment for unaligned checkpoints.

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13735: URL: https://github.com/apache/flink/pull/13735#issuecomment-714048414 ## CI report: * c20d917f5ac0c8c3d932d0c0ba1ca1c7535c0b47 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13746: [FLINK-19675][python] Fix PythonCalcExpandProjectRule to handle cases when the calc node contains WHERE clause, composite fields acce

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13746: URL: https://github.com/apache/flink/pull/13746#issuecomment-714469108 ## CI report: * 9becc81983d757b76614749a96a14a94f14aa7d6 Azure:

[GitHub] [flink] flinkbot commented on pull request #13749: [FLINK-19712][Coordination] Do not restart CREATED executions in RestartPipelinedRegionFailoverStrategy

2020-10-22 Thread GitBox
flinkbot commented on pull request #13749: URL: https://github.com/apache/flink/pull/13749#issuecomment-714491588 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-19771) NullPointerException when accessing null array from postgres in JDBC Connector

2020-10-22 Thread Dylan Forciea (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dylan Forciea updated FLINK-19771: -- Description: When trying to utilize the JDBC Connector for Postgres, I tried to read in a

[jira] [Reopened] (FLINK-10241) Reduce performance/stability impact of latency metrics

2020-10-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-10241: > Reduce performance/stability impact of latency metrics >

[jira] [Closed] (FLINK-10241) Reduce performance/stability impact of latency metrics

2020-10-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-10241. -- Fix Version/s: (was: 1.12.0) Resolution: Won't Fix > Reduce performance/stability

[GitHub] [flink] flinkbot edited a comment on pull request #13672: [FLINK-19660][docs][python] Translate page "table_environment.zh.md" into Chinese

2020-10-22 Thread GitBox
flinkbot edited a comment on pull request #13672: URL: https://github.com/apache/flink/pull/13672#issuecomment-711107288 ## CI report: * 3f25a527ec7c3238365f0746323c02f0f35252cb Azure:

[jira] [Created] (FLINK-19771) NullPointerException when accessing null array from postgres in JDBC Connector

2020-10-22 Thread Dylan Forciea (Jira)
Dylan Forciea created FLINK-19771: - Summary: NullPointerException when accessing null array from postgres in JDBC Connector Key: FLINK-19771 URL: https://issues.apache.org/jira/browse/FLINK-19771

[GitHub] [flink] flinkbot commented on pull request #13747: [FLINK-19662][runtime] Exposing the JobManager's memory configuration through /jobmanager/config

2020-10-22 Thread GitBox
flinkbot commented on pull request #13747: URL: https://github.com/apache/flink/pull/13747#issuecomment-714516971 ## CI report: * 1dc2d0a4b8283574e961ae64b4e206a32cf6e2be UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13749: [FLINK-19712][Coordination] Do not restart CREATED executions in RestartPipelinedRegionFailoverStrategy

2020-10-22 Thread GitBox
flinkbot commented on pull request #13749: URL: https://github.com/apache/flink/pull/13749#issuecomment-714539634 ## CI report: * e35da3721be8a766e339dec86cf858cde021e690 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] tillrohrmann commented on a change in pull request #13706: [FLINK-19677][runtime] Make JobManager lazily resolve hostname of TaskManager and provide an option to turn off reverse reso

2020-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #13706: URL: https://github.com/apache/flink/pull/13706#discussion_r510234486 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerLocationTest.java ## @@ -198,4 +199,18 @@ public void

[jira] [Updated] (FLINK-19772) Add utility for retrying async operations with exponential timeout

2020-10-22 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19772: - Summary: Add utility for retrying async operations with exponential timeout (was: Add

<    1   2   3   4   5   >