[GitHub] [flink] gaoyunhaii commented on pull request #13249: [FLINK-14087][datastream] Clone the StreamPartitioner to avoid being shared at runtime.

2020-08-26 Thread GitBox
gaoyunhaii commented on pull request #13249: URL: https://github.com/apache/flink/pull/13249#issuecomment-681625841 From the failed tests, the current implementation has some problems in that the `StreamGraph` is using `AppClassLoader`, which could not load the classes in the users' code.

[jira] [Closed] (FLINK-19058) Dataset transformations document page error

2020-08-26 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-19058. Fix Version/s: 1.12.0 Resolution: Fixed Fixed in f9a5383f3e001ecf5fbe9499a75b0a8211

[jira] [Assigned] (FLINK-19058) Dataset transformations document page error

2020-08-26 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-19058: Assignee: Fin-chan > Dataset transformations document page error > --

[GitHub] [flink] dawidwys merged pull request #13259: [FLINK-19058][hotfix][doc] Dataset transformations document page error

2020-08-26 Thread GitBox
dawidwys merged pull request #13259: URL: https://github.com/apache/flink/pull/13259 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-benchmarks] pnowojski commented on pull request #2: [FLINK-19003][checkpointing] Add micro-benchmark for unaligned checkpoints

2020-08-26 Thread GitBox
pnowojski commented on pull request #2: URL: https://github.com/apache/flink-benchmarks/pull/2#issuecomment-681620966 Yes, sorry @xintongsong ! This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] flinkbot edited a comment on pull request #13259: [FLINK-19058][doc] Dataset transformations document page error

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13259: URL: https://github.com/apache/flink/pull/13259#issuecomment-681589995 ## CI report: * 0758e58366eeed2494f2e54ba4a931866a99ea80 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #13259: [FLINK-19058][doc] Dataset transformations document page error

2020-08-26 Thread GitBox
flinkbot commented on pull request #13259: URL: https://github.com/apache/flink/pull/13259#issuecomment-681589995 ## CI report: * 0758e58366eeed2494f2e54ba4a931866a99ea80 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink-web] Shawn-Hx opened a new pull request #372: [hotfix] Fix typo

2020-08-26 Thread GitBox
Shawn-Hx opened a new pull request #372: URL: https://github.com/apache/flink-web/pull/372 Fix typo: `commiter` --> `committer` This is an automated message from the Apache Git Service. To respond to the message, please lo

[jira] [Updated] (FLINK-16760) Support the yaml file submission for native Kubernetes integration

2020-08-26 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-16760: -- Parent: (was: FLINK-17709) Issue Type: New Feature (was: Sub-task) > Support the yaml fil

[jira] [Closed] (FLINK-15643) Support to start multiple Flink masters to achieve faster recovery

2020-08-26 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-15643. - Resolution: Duplicate > Support to start multiple Flink masters to achieve faster recovery > ---

[GitHub] [flink] flinkbot commented on pull request #13259: [FLINK-19058][doc] Dataset transformations document page error

2020-08-26 Thread GitBox
flinkbot commented on pull request #13259: URL: https://github.com/apache/flink/pull/13259#issuecomment-681577933 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Commented] (FLINK-17707) Support configuring replica of Deployment in ZooKeeper based HA setups

2020-08-26 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17185616#comment-17185616 ] Yang Wang commented on FLINK-17707: --- This is also useful for the native K8s HA support

[GitHub] [flink] Fin-chan opened a new pull request #13259: [FLINK-19058][doc] Dataset transformations document page error

2020-08-26 Thread GitBox
Fin-chan opened a new pull request #13259: URL: https://github.com/apache/flink/pull/13259 ## What is the purpose of the change Fix Dataset transformations document page error ## Brief change log "public void join(Tuple2 movie, Rating rating Collector> out)" change to

[jira] [Updated] (FLINK-19058) Dataset transformations document page error

2020-08-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19058: --- Labels: pull-request-available (was: ) > Dataset transformations document page error >

[GitHub] [flink] flinkbot edited a comment on pull request #13258: [FLINK-18899][yarn] Enrich the description of 'yarn.application-attempts'

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13258: URL: https://github.com/apache/flink/pull/13258#issuecomment-681539677 ## CI report: * 4e2929ebb85b81de4b47591e6bbc9f2ef8d851f5 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-19058) Dataset transformations document page error

2020-08-26 Thread Fin-chan (Jira)
Fin-chan created FLINK-19058: Summary: Dataset transformations document page error Key: FLINK-19058 URL: https://issues.apache.org/jira/browse/FLINK-19058 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-19038) It doesn't support to call Table.limit() continuously

2020-08-26 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17185585#comment-17185585 ] Nicholas Jiang edited comment on FLINK-19038 at 8/27/20, 5:40 AM:

[jira] [Updated] (FLINK-13735) Support session window with blink planner in batch mode

2020-08-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13735: --- Fix Version/s: 1.12.0 > Support session window with blink planner in batch mode > --

[GitHub] [flink] flinkbot commented on pull request #13258: [FLINK-18899][yarn] Enrich the description of 'yarn.application-attempts'

2020-08-26 Thread GitBox
flinkbot commented on pull request #13258: URL: https://github.com/apache/flink/pull/13258#issuecomment-681539677 ## CI report: * 4e2929ebb85b81de4b47591e6bbc9f2ef8d851f5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] wangyang0918 opened a new pull request #13258: [FLINK-18899][yarn] Enrich the description of 'yarn.application-attempts'

2020-08-26 Thread GitBox
wangyang0918 opened a new pull request #13258: URL: https://github.com/apache/flink/pull/13258 ## What is the purpose of the change The reason why we leave the default value of `yarn.application-attempts` to none is to configure it based on the HA configuration. If the users

[jira] [Updated] (FLINK-18899) The property yarn.application-attempts default value is not none

2020-08-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18899: --- Labels: pull-request-available usability (was: usability) > The property yarn.application-a

[GitHub] [flink] flinkbot edited a comment on pull request #13257: [FLINK-18992][table] Fix Table API renameColumns method annotation error

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13257: URL: https://github.com/apache/flink/pull/13257#issuecomment-681380311 ## CI report: * dc11360c401c989a71311fb1dfb248ecf430c523 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #12880: URL: https://github.com/apache/flink/pull/12880#issuecomment-657437173 ## CI report: * 72e7dcb66f3a2c6eda4899d51ddd6420d2d5822b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] finchen-tencent removed a comment on pull request #13257: [FLINK-18992][table] Fix Table API renameColumns method annotation error

2020-08-26 Thread GitBox
finchen-tencent removed a comment on pull request #13257: URL: https://github.com/apache/flink/pull/13257#issuecomment-681394344 test This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] finchen-tencent commented on pull request #13257: [FLINK-18992][table] Fix Table API renameColumns method annotation error

2020-08-26 Thread GitBox
finchen-tencent commented on pull request #13257: URL: https://github.com/apache/flink/pull/13257#issuecomment-681394344 test This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot commented on pull request #13257: [FLINK-18992][table] Fix Table API renameColumns method annotation error

2020-08-26 Thread GitBox
flinkbot commented on pull request #13257: URL: https://github.com/apache/flink/pull/13257#issuecomment-681380311 ## CI report: * dc11360c401c989a71311fb1dfb248ecf430c523 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #12880: URL: https://github.com/apache/flink/pull/12880#issuecomment-657437173 ## CI report: * 72e7dcb66f3a2c6eda4899d51ddd6420d2d5822b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-18854) Translate the 'API Migration Guides' page of 'Application Development' into Chinese

2020-08-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18854. --- Fix Version/s: 1.12.0 Resolution: Fixed Implemented in master (1.12.0): 3ea9572c2f128a19cce798461aad4

[GitHub] [flink] wuchong merged pull request #13172: [FLINK-18854][docs-zh] Translate the 'API Migration Guides' page of 'Application Development' into Chinese

2020-08-26 Thread GitBox
wuchong merged pull request #13172: URL: https://github.com/apache/flink/pull/13172 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] wuchong commented on pull request #13172: [FLINK-18854][docs-zh] Translate the 'API Migration Guides' page of 'Application Development' into Chinese

2020-08-26 Thread GitBox
wuchong commented on pull request #13172: URL: https://github.com/apache/flink/pull/13172#issuecomment-681375252 Mering... This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-19048) support line format for table connector

2020-08-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17185588#comment-17185588 ] Jark Wu commented on FLINK-19048: - [~badqiu], let's move the discussion to FLINK-14356.

[jira] [Closed] (FLINK-19048) support line format for table connector

2020-08-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19048. --- Resolution: Duplicate > support line format for table connector > --- >

[GitHub] [flink-benchmarks] zhijiangW commented on pull request #2: [FLINK-19003][checkpointing] Add micro-benchmark for unaligned checkpoints

2020-08-26 Thread GitBox
zhijiangW commented on pull request #2: URL: https://github.com/apache/flink-benchmarks/pull/2#issuecomment-681363205 @xintongsong , I guess it is a mis-operation, ignore. :) This is an automated message from the Apache Git S

[GitHub] [flink-benchmarks] zhijiangW commented on a change in pull request #2: [FLINK-19003][checkpointing] Add micro-benchmark for unaligned checkpoints

2020-08-26 Thread GitBox
zhijiangW commented on a change in pull request #2: URL: https://github.com/apache/flink-benchmarks/pull/2#discussion_r478076502 ## File path: src/main/java/org/apache/flink/benchmark/UnalignedCheckpointTimeBenchmark.java ## @@ -42,17 +43,22 @@ import static java.util.concu

[GitHub] [flink] flinkbot commented on pull request #13257: [FLINK-18992][table] Fix Table API renameColumns method annotation error

2020-08-26 Thread GitBox
flinkbot commented on pull request #13257: URL: https://github.com/apache/flink/pull/13257#issuecomment-681356430 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] Fin-chan opened a new pull request #13257: [FLINK-18992][table] Fix Table API renameColumns method annotation error

2020-08-26 Thread GitBox
Fin-chan opened a new pull request #13257: URL: https://github.com/apache/flink/pull/13257 ## What is the purpose of the change Fix Table API renameColumns method annotation error ## Brief change log example:table.renameColumns($("a").as($("a1")) change to table.renameColumns(

[GitHub] [flink] Fin-chan closed pull request #13256: [FLINK-18992][table] Fix Table API renameColumns method annotation error

2020-08-26 Thread GitBox
Fin-chan closed pull request #13256: URL: https://github.com/apache/flink/pull/13256 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] finchen-tencent removed a comment on pull request #13222: batch-shuffle-interface-poc

2020-08-26 Thread GitBox
finchen-tencent removed a comment on pull request #13222: URL: https://github.com/apache/flink/pull/13222#issuecomment-681336371 test This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] finchen-tencent commented on pull request #13222: batch-shuffle-interface-poc

2020-08-26 Thread GitBox
finchen-tencent commented on pull request #13222: URL: https://github.com/apache/flink/pull/13222#issuecomment-681336371 test This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot commented on pull request #13256: [FLINK-18992][table] Fix Table API renameColumns method annotation error

2020-08-26 Thread GitBox
flinkbot commented on pull request #13256: URL: https://github.com/apache/flink/pull/13256#issuecomment-681330991 ## CI report: * 95e574854c6b5901778cf748ef1b4cd4ee4d8e0b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Comment Edited] (FLINK-19038) It doesn't support to call Table.limit() continuously

2020-08-26 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17185585#comment-17185585 ] Nicholas Jiang edited comment on FLINK-19038 at 8/27/20, 3:37 AM:

[jira] [Comment Edited] (FLINK-19038) It doesn't support to call Table.limit() continuously

2020-08-26 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17185585#comment-17185585 ] Nicholas Jiang edited comment on FLINK-19038 at 8/27/20, 3:37 AM:

[jira] [Commented] (FLINK-19038) It doesn't support to call Table.limit() continuously

2020-08-26 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17185585#comment-17185585 ] Nicholas Jiang commented on FLINK-19038: [~twalthr],[~dwysakowicz],   {code:jav

[GitHub] [flink] flinkbot commented on pull request #13256: [FLINK-18992][table] Fix Table API renameColumns method annotation error

2020-08-26 Thread GitBox
flinkbot commented on pull request #13256: URL: https://github.com/apache/flink/pull/13256#issuecomment-681322269 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] Fin-chan opened a new pull request #13256: [FLINK-18992][table] Fix Table API renameColumns method annotation error

2020-08-26 Thread GitBox
Fin-chan opened a new pull request #13256: URL: https://github.com/apache/flink/pull/13256 ## What is the purpose of the change Fix Table API renameColumns method annotation error ## Brief change log example:table.renameColumns($("a").as($("a1")) change to table.renameColumns(

[GitHub] [flink] Fin-chan closed pull request #13243: [FLINK-18992][table] Fix Table API renameColumns method annotation error

2020-08-26 Thread GitBox
Fin-chan closed pull request #13243: URL: https://github.com/apache/flink/pull/13243 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 #13255: [FLINK-18971] Support to mount kerberos conf as ConfigMap and Keytab …

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13255: URL: https://github.com/apache/flink/pull/13255#issuecomment-681311805 ## CI report: * d314aaa9e779d3177e50a91edbfe07baa64691dc Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] miklosgergely commented on pull request #13128: [FLINK-18795][hbase] Support for HBase 2

2020-08-26 Thread GitBox
miklosgergely commented on pull request #13128: URL: https://github.com/apache/flink/pull/13128#issuecomment-681316205 Modified the patch so that both HBase 1.4 and HBase 2.2 are supported, also having a project for their common parts. Also put the delegation token related modifications in

[GitHub] [flink] dianfu commented on a change in pull request #13193: [FLINK-18918][python][docs] Add dedicated connector documentation for Python Table API

2020-08-26 Thread GitBox
dianfu commented on a change in pull request #13193: URL: https://github.com/apache/flink/pull/13193#discussion_r477978848 ## File path: docs/dev/python/user-guide/table/python_table_api_connectors.zh.md ## @@ -0,0 +1,194 @@ +--- +title: "Connectors" +nav-parent_id: python_tabl

[GitHub] [flink] flinkbot commented on pull request #13255: [FLINK-18971] Support to mount kerberos conf as ConfigMap and Keytab …

2020-08-26 Thread GitBox
flinkbot commented on pull request #13255: URL: https://github.com/apache/flink/pull/13255#issuecomment-681311805 ## CI report: * d314aaa9e779d3177e50a91edbfe07baa64691dc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] dianfu commented on a change in pull request #13193: [FLINK-18918][python][docs] Add dedicated connector documentation for Python Table API

2020-08-26 Thread GitBox
dianfu commented on a change in pull request #13193: URL: https://github.com/apache/flink/pull/13193#discussion_r477948856 ## File path: docs/dev/python/user-guide/table/python_table_api_connectors.md ## @@ -0,0 +1,194 @@ +--- +title: "Connectors" +nav-parent_id: python_tableap

[GitHub] [flink] flinkbot commented on pull request #13255: [FLINK-18971] Support to mount kerberos conf as ConfigMap and Keytab …

2020-08-26 Thread GitBox
flinkbot commented on pull request #13255: URL: https://github.com/apache/flink/pull/13255#issuecomment-681309844 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-18971) Support to mount kerberos conf as ConfigMap and Keytab as Secrete

2020-08-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18971: --- Labels: pull-request-available (was: ) > Support to mount kerberos conf as ConfigMap and Ke

[GitHub] [flink] KarmaGYZ opened a new pull request #13255: [FLINK-18971] Support to mount kerberos conf as ConfigMap and Keytab …

2020-08-26 Thread GitBox
KarmaGYZ opened a new pull request #13255: URL: https://github.com/apache/flink/pull/13255 …as Secrete ## What is the purpose of the change Support to mount kerberos conf as ConfigMap and Keytab as Secrete ## Brief change log - Add "kubernetes.kerberos.krb

[GitHub] [flink] flinkbot edited a comment on pull request #13128: [FLINK-18795][hbase] Support for HBase 2

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13128: URL: https://github.com/apache/flink/pull/13128#issuecomment-672766836 ## CI report: * 313b80f4474455d7013b0852929b5a8458f391a1 UNKNOWN * ef0e2d93a502dd9b3050200b4a5b43f96f4e045b Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Closed] (FLINK-18720) Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

2020-08-26 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-18720. Resolution: Done Merged via * master: 31e9b3d494097313364cf8a37314cb7d28bc11b2 > Migrate Kubernet

[GitHub] [flink] xintongsong closed pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

2020-08-26 Thread GitBox
xintongsong closed pull request #13186: URL: https://github.com/apache/flink/pull/13186 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] xintongsong commented on pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

2020-08-26 Thread GitBox
xintongsong commented on pull request #13186: URL: https://github.com/apache/flink/pull/13186#issuecomment-681302816 Thanks all. I've created FLINK-19057 for tracking the `flinkClientConfig` issue. Merging this. This is a

[jira] [Closed] (FLINK-18917) Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the "Python API" -> "User Guide" -> "Table API" section

2020-08-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18917. --- Fix Version/s: 1.11.2 1.12.0 Resolution: Fixed master: 083933a9e03f1fee802e0f0efe1

[jira] [Commented] (FLINK-19057) Avoid usage of GlobalConfiguration in ResourceManager

2020-08-26 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17185550#comment-17185550 ] Xintong Song commented on FLINK-19057: -- cc [~trohrmann] [~fly_in_gis] > Avoid usag

[GitHub] [flink] dianfu closed pull request #13226: [FLINK-18917][doc][python] Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the "Python API" -> "User Guide"

2020-08-26 Thread GitBox
dianfu closed pull request #13226: URL: https://github.com/apache/flink/pull/13226 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 t

[jira] [Created] (FLINK-19057) Avoid usage of GlobalConfiguration in ResourceManager

2020-08-26 Thread Xintong Song (Jira)
Xintong Song created FLINK-19057: Summary: Avoid usage of GlobalConfiguration in ResourceManager Key: FLINK-19057 URL: https://issues.apache.org/jira/browse/FLINK-19057 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #13128: [FLINK-18795][hbase] Support for HBase 2

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13128: URL: https://github.com/apache/flink/pull/13128#issuecomment-672766836 ## CI report: * 50348849269d2b0edb7e811b9e5e13de45f686cd Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13251: [FLINK-14435] Added memory configuration to TaskManagers REST endpoint

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13251: URL: https://github.com/apache/flink/pull/13251#issuecomment-680904640 ## CI report: * 78fbaad055ce6f0c9bb59e37347793a08655bb69 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13128: [FLINK-18795][hbase] Support for HBase 2

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13128: URL: https://github.com/apache/flink/pull/13128#issuecomment-672766836 ## CI report: * 50348849269d2b0edb7e811b9e5e13de45f686cd Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wangyang0918 commented on pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

2020-08-26 Thread GitBox
wangyang0918 commented on pull request #13186: URL: https://github.com/apache/flink/pull/13186#issuecomment-681282597 It also makes sense to me for merging the PR first and leave the discussion about `GlobalConfiguration` and `flinkClientConfig ` in a separate ticket.

[GitHub] [flink] wangyang0918 commented on a change in pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

2020-08-26 Thread GitBox
wangyang0918 commented on a change in pull request #13186: URL: https://github.com/apache/flink/pull/13186#discussion_r477905760 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/AbstractResourceManagerDriver.java ## @@ -0,0 +1,76 @@ +/*

[jira] [Commented] (FLINK-18287) Correct the documentation of Python Table API in SQL pages

2020-08-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17185538#comment-17185538 ] Dian Fu commented on FLINK-18287: -  [~Fin-Chan] You are right. Thanks a lot!  > Correct

[jira] [Updated] (FLINK-18287) Correct the documentation of Python Table API in SQL pages

2020-08-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18287: Issue Type: Improvement (was: Bug) > Correct the documentation of Python Table API in SQL pages > ---

[GitHub] [flink] RocMarshal commented on a change in pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

2020-08-26 Thread GitBox
RocMarshal commented on a change in pull request #13225: URL: https://github.com/apache/flink/pull/13225#discussion_r477897780 ## File path: docs/dev/user_defined_functions.zh.md ## @@ -147,95 +142,75 @@ data.map (new RichMapFunction[String, Int] { -Rich functions provide

[jira] [Closed] (FLINK-18287) Correct the documentation of Python Table API in SQL pages

2020-08-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18287. --- Fix Version/s: (was: 1.11.2) (was: 1.12.0) Resolution: Fixed Merged to rel

[jira] [Updated] (FLINK-18287) Correct the documentation of Python Table API in SQL pages

2020-08-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18287: Affects Version/s: (was: 1.11.0) > Correct the documentation of Python Table API in SQL pages > --

[GitHub] [flink] dianfu commented on pull request #13253: [FLINK-18287][doc] Correct the documentation of Python Table API in SQL pages

2020-08-26 Thread GitBox
dianfu commented on pull request #13253: URL: https://github.com/apache/flink/pull/13253#issuecomment-681270453 closed via ffcef94d9cfc152f9400d70c5ded736c6b839240 This is an automated message from the Apache Git Service. To

[GitHub] [flink-benchmarks] xintongsong commented on pull request #2: [FLINK-19003][checkpointing] Add micro-benchmark for unaligned checkpoints

2020-08-26 Thread GitBox
xintongsong commented on pull request #2: URL: https://github.com/apache/flink-benchmarks/pull/2#issuecomment-681270940 @pnowojski I assume you've assigned me as a reviewer by mis-operation? I'm completely not familiar with the background of this effort. --

[GitHub] [flink] dianfu closed pull request #13253: [FLINK-18287][doc] Correct the documentation of Python Table API in SQL pages

2020-08-26 Thread GitBox
dianfu closed pull request #13253: URL: https://github.com/apache/flink/pull/13253 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 t

[GitHub] [flink] dianfu edited a comment on pull request #13253: [FLINK-18287][doc] Correct the documentation of Python Table API in SQL pages

2020-08-26 Thread GitBox
dianfu edited a comment on pull request #13253: URL: https://github.com/apache/flink/pull/13253#issuecomment-681270453 Merged via ffcef94d9cfc152f9400d70c5ded736c6b839240 This is an automated message from the Apache Git Servi

[GitHub] [flink] RocMarshal edited a comment on pull request #13212: [FLINK-18973][docs-zh] Translate the 'History Server' page of 'Debugging & Monitoring' into Chinese

2020-08-26 Thread GitBox
RocMarshal edited a comment on pull request #13212: URL: https://github.com/apache/flink/pull/13212#issuecomment-680925909 @klion26 Thank you very much for your guidance and advices. I made some adjustments according to your suggestions. If you have free time, please have a look. Loo

[jira] [Commented] (FLINK-18287) Correct the documentation of Python Table API in SQL pages

2020-08-26 Thread Fin-Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17185534#comment-17185534 ] Fin-Chan commented on FLINK-18287: -- hello,i commit the pr and CI report success,please

[GitHub] [flink] wsry edited a comment on pull request #13239: [FLINK-19021][network] Various cleanups and refactorings of the ResultPartition

2020-08-26 Thread GitBox
wsry edited a comment on pull request #13239: URL: https://github.com/apache/flink/pull/13239#issuecomment-680884418 @StephanEwen Thanks for cleanups and refactorings. These are really nice changes. The code LGTM. Only two small questions: 1. Should we also remove ResultPartitionWriter#g

[jira] [Updated] (FLINK-19056) Investigate multipart upload performance regression

2020-08-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19056: - Description: When using Netty 4.1.50 the multipart upload of files is more than a 100 ti

[jira] [Updated] (FLINK-19056) Investigate multipart upload performance regression

2020-08-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19056: - Description: When using Netty 4.1.50 the multipart upload of files is more than a 100 ti

[jira] [Updated] (FLINK-19056) Investigate multipart upload performance regression

2020-08-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19056: - Description: When using Netty 4.1.50 the multipart upload of files is more than a 100 ti

[jira] [Created] (FLINK-19056) Investigate multipart upload performance regression

2020-08-26 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-19056: Summary: Investigate multipart upload performance regression Key: FLINK-19056 URL: https://issues.apache.org/jira/browse/FLINK-19056 Project: Flink I

[GitHub] [flink] walterddr commented on pull request #13163: [FLINK-16789][runtime] Support JMX RMI random port assign

2020-08-26 Thread GitBox
walterddr commented on pull request #13163: URL: https://github.com/apache/flink/pull/13163#issuecomment-681167412 closing this PR in favor of the solution proposed in discussion This is an automated message from the Apache G

[GitHub] [flink] walterddr closed pull request #13163: [FLINK-16789][runtime] Support JMX RMI random port assign

2020-08-26 Thread GitBox
walterddr closed pull request #13163: URL: https://github.com/apache/flink/pull/13163 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 t

[GitHub] [flink] flinkbot edited a comment on pull request #13254: Simplify if else logic

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13254: URL: https://github.com/apache/flink/pull/13254#issuecomment-681057344 ## CI report: * 922b30daaeff6e961d8c018bb37c7ec9f8e2d261 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13251: [FLINK-14435] Added memory configuration to TaskManagers REST endpoint

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13251: URL: https://github.com/apache/flink/pull/13251#issuecomment-680904640 ## CI report: * 9e6fc0926eacd9d4ffa4241d4ace28be2c518b59 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13251: [FLINK-14435] Added memory configuration to TaskManagers REST endpoint

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13251: URL: https://github.com/apache/flink/pull/13251#issuecomment-680904640 ## CI report: * 9e6fc0926eacd9d4ffa4241d4ace28be2c518b59 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13249: [FLINK-14087][datastream] Clone the StreamPartitioner to avoid being shared at runtime.

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13249: URL: https://github.com/apache/flink/pull/13249#issuecomment-680775587 ## CI report: * 6e53b34cb612e02e808008a6792c16fb60ac64e6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] rkhachatryan commented on a change in pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

2020-08-26 Thread GitBox
rkhachatryan commented on a change in pull request #13209: URL: https://github.com/apache/flink/pull/13209#discussion_r477546527 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java ## @@ -609,6 +609,33 @@ pu

[GitHub] [flink] rkhachatryan commented on a change in pull request #13209: [FLINK-18832][datastream] Add compatible check for blocking partition with buffer timeout

2020-08-26 Thread GitBox
rkhachatryan commented on a change in pull request #13209: URL: https://github.com/apache/flink/pull/13209#discussion_r477537338 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java ## @@ -285,11 +285,7 @@ public Strea

[jira] [Updated] (FLINK-19053) Flink Kafka Connector Dependency Error

2020-08-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19053: - Description: >From the Flink doucumention >URL:[https://ci.apache.org/projects/flink/fl

[jira] [Updated] (FLINK-19053) Flink Kafka Connector Dependency Error

2020-08-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19053: - Environment: (was: Flink V1.11.0 or Flink V1.11.1) > Flink Kafka Connector Dependenc

[GitHub] [flink] flinkbot edited a comment on pull request #13243: [FLINK-18992][table] Fix Table API renameColumns method annotation error

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13243: URL: https://github.com/apache/flink/pull/13243#issuecomment-680489296 ## CI report: * 5b0dd73014d5cb429a4d47b4b9127e6991c8edd0 UNKNOWN * 1846564d9ee97fc20d6e1e1fe5146744abcd6dff Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] rkhachatryan commented on a change in pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

2020-08-26 Thread GitBox
rkhachatryan commented on a change in pull request #13234: URL: https://github.com/apache/flink/pull/13234#discussion_r477498178 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java ## @@ -208,19 +206,100 @@ public Operat

[GitHub] [flink] rkhachatryan commented on a change in pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

2020-08-26 Thread GitBox
rkhachatryan commented on a change in pull request #13234: URL: https://github.com/apache/flink/pull/13234#discussion_r477487377 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputChainingOutput.java ## @@ -0,0 +1,138 @@ +/*

[GitHub] [flink] flinkbot edited a comment on pull request #13249: [FLINK-14087][datastream] Clone the StreamPartitioner to avoid being shared at runtime.

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13249: URL: https://github.com/apache/flink/pull/13249#issuecomment-680775587 ## CI report: * 6e53b34cb612e02e808008a6792c16fb60ac64e6 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13254: Simplify if else logic

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13254: URL: https://github.com/apache/flink/pull/13254#issuecomment-681057344 ## CI report: * 922b30daaeff6e961d8c018bb37c7ec9f8e2d261 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #13254: Simplify if else logic

2020-08-26 Thread GitBox
flinkbot commented on pull request #13254: URL: https://github.com/apache/flink/pull/13254#issuecomment-681057344 ## CI report: * 922b30daaeff6e961d8c018bb37c7ec9f8e2d261 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13249: [FLINK-14087][datastream] Clone the StreamPartitioner to avoid being shared at runtime.

2020-08-26 Thread GitBox
flinkbot edited a comment on pull request #13249: URL: https://github.com/apache/flink/pull/13249#issuecomment-680775587 ## CI report: * 6e53b34cb612e02e808008a6792c16fb60ac64e6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

  1   2   3   >