[GitHub] [flink] gaoyunhaii commented on pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

2020-11-12 Thread GitBox
gaoyunhaii commented on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-726586833 @kl0u Very thanks for opening the PR! I'll have a look and do the translation~ This is an automated message

[jira] [Commented] (FLINK-19852) Managed memory released check can block IterativeTask

2020-11-12 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231231#comment-17231231 ] Andrey Zagrebin commented on FLINK-19852: - UnsafeMemory usage has indeed become

[GitHub] [flink] flinkbot commented on pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

2020-11-12 Thread GitBox
flinkbot commented on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-726585261 ## CI report: * ffe1daf67c98e39f476f1f15279c77bbc83a1c98 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14060: [hotfix][doc] fix the usage example of datagen connector doc

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #14060: URL: https://github.com/apache/flink/pull/14060#issuecomment-726548680 ## CI report: * deb5686ae2485f1fd700e5f1e69e6bf8aa6e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14017: [FLINK-19859][document] Add document for the upsert-kafka connector

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #14017: URL: https://github.com/apache/flink/pull/14017#issuecomment-724665676 ## CI report: * 7dff1e172e3b99d819cfc1cbc1eedf71bea94626 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] rmetzger commented on pull request #14033: [FLINK-19979][e2e] Add sanity check after bash e2e tests for no leftovers

2020-11-12 Thread GitBox
rmetzger commented on pull request #14033: URL: https://github.com/apache/flink/pull/14033#issuecomment-726583118 Rebased to latest master to make sure e2e tests are still compliant. This is an automated message from the Apac

[GitHub] [flink] tzulitai commented on a change in pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

2020-11-12 Thread GitBox
tzulitai commented on a change in pull request #14042: URL: https://github.com/apache/flink/pull/14042#discussion_r522749182 ## File path: flink-core/src/main/java/org/apache/flink/core/io/PostVersionedIOReadableWritable.java ## @@ -62,16 +62,23 @@ public void write(DataOutput

[GitHub] [flink] tzulitai commented on a change in pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

2020-11-12 Thread GitBox
tzulitai commented on a change in pull request #14042: URL: https://github.com/apache/flink/pull/14042#discussion_r522749182 ## File path: flink-core/src/main/java/org/apache/flink/core/io/PostVersionedIOReadableWritable.java ## @@ -62,16 +62,23 @@ public void write(DataOutput

[GitHub] [flink] tzulitai commented on a change in pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

2020-11-12 Thread GitBox
tzulitai commented on a change in pull request #14042: URL: https://github.com/apache/flink/pull/14042#discussion_r522733565 ## File path: flink-core/src/main/java/org/apache/flink/core/io/PostVersionedIOReadableWritable.java ## @@ -62,16 +62,23 @@ public void write(DataOutput

[GitHub] [flink] flinkbot commented on pull request #14062: [FLINK-17470] Send sigkill to hanging processes in standalone scripts

2020-11-12 Thread GitBox
flinkbot commented on pull request #14062: URL: https://github.com/apache/flink/pull/14062#issuecomment-726579428 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-17470) Flink task executor process permanently hangs on `flink-daemon.sh stop`, deletes PID file

2020-11-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17470: --- Labels: pull-request-available (was: ) > Flink task executor process permanently hangs on `

[GitHub] [flink] rmetzger opened a new pull request #14062: [FLINK-17470] Send sigkill to hanging processes in standalone scripts

2020-11-12 Thread GitBox
rmetzger opened a new pull request #14062: URL: https://github.com/apache/flink/pull/14062 ## What is the purpose of the change There are situations where Flink's `JvmShutdownSafeguard` is unable to halt the JVM (if the JVM get's stuck during shutdown) ## Brief change log

[GitHub] [flink] flinkbot commented on pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

2020-11-12 Thread GitBox
flinkbot commented on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-726577316 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] kl0u commented on pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

2020-11-12 Thread GitBox
kl0u commented on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-726577016 @guoweiM and @gaoyunhaii could you help reviewing this and also translating it to Chinese? This is an automated me

[GitHub] [flink] kl0u opened a new pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

2020-11-12 Thread GitBox
kl0u opened a new pull request #14061: URL: https://github.com/apache/flink/pull/14061 ## What is the purpose of the change Adds documentation and improves class javadocs about the newly-introduced `FileSink`. ## Brief change log Adds a new page in the documentation.

[jira] [Updated] (FLINK-20141) Add documentation about the FileSink

2020-11-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20141: --- Labels: pull-request-available (was: ) > Add documentation about the FileSink > ---

[GitHub] [flink] tzulitai commented on a change in pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

2020-11-12 Thread GitBox
tzulitai commented on a change in pull request #14042: URL: https://github.com/apache/flink/pull/14042#discussion_r522733565 ## File path: flink-core/src/main/java/org/apache/flink/core/io/PostVersionedIOReadableWritable.java ## @@ -62,16 +62,23 @@ public void write(DataOutput

[GitHub] [flink] flinkbot edited a comment on pull request #13920: [FLINK-19743] Add metric definitions in FLIP-33 and report some of them by default.

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #13920: URL: https://github.com/apache/flink/pull/13920#issuecomment-721560528 ## CI report: * be28afd47c3de21d873d81c1d5e64ea3fc0ad81b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tzulitai commented on a change in pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

2020-11-12 Thread GitBox
tzulitai commented on a change in pull request #14042: URL: https://github.com/apache/flink/pull/14042#discussion_r522715078 ## File path: flink-core/src/test/java/org/apache/flink/core/io/PostVersionedIOReadableWritableTest.java ## @@ -35,52 +36,92 @@ @Test

[GitHub] [flink] flinkbot edited a comment on pull request #14059: [FLINK-20102][docs][hbase] Update HBase connector documentation for H…

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #14059: URL: https://github.com/apache/flink/pull/14059#issuecomment-726515875 ## CI report: * 3c9c8ddd6a5eed1c4fb5951c1b516e8d9073a24f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13920: [FLINK-19743] Add metric definitions in FLIP-33 and report some of them by default.

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #13920: URL: https://github.com/apache/flink/pull/13920#issuecomment-721560528 ## CI report: * be28afd47c3de21d873d81c1d5e64ea3fc0ad81b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-20136) Test all other aspects of new features added in PyFlink

2020-11-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20136. --- Resolution: Done Test the following in Python Table API: - TableResult.collect - Expression DSL - Mix use of

[jira] [Created] (FLINK-20141) Add documentation about the FileSink

2020-11-12 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-20141: -- Summary: Add documentation about the FileSink Key: FLINK-20141 URL: https://issues.apache.org/jira/browse/FLINK-20141 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-12130) Apply command line options to configuration before installing security modules

2020-11-12 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231204#comment-17231204 ] Victor Wong commented on FLINK-12130: - [~lingyaKK][~zhouqi] Very sorry, I haven't wo

[GitHub] [flink] flinkbot edited a comment on pull request #14060: [hotfix][doc] fix the usage example of datagen connector doc

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

[GitHub] [flink] flinkbot edited a comment on pull request #14017: [FLINK-19859][document] Add document for the upsert-kafka connector

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

[GitHub] [flink] SteNicholas commented on pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-11-12 Thread GitBox
SteNicholas commented on pull request #14028: URL: https://github.com/apache/flink/pull/14028#issuecomment-726555110 > Thanks a lot @SteNicholas. Feel free to take the commit and integrate it in your PR :) @kl0u Thanks for you better implementation commit. I have integrated into my

[GitHub] [flink] tzulitai commented on a change in pull request #14034: [FLINK-20088][kinesis] Fix issue encountered when Polling consumer using timestamp with empty shard

2020-11-12 Thread GitBox
tzulitai commented on a change in pull request #14034: URL: https://github.com/apache/flink/pull/14034#discussion_r522678744 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/polling/PollingRecordPubl

[jira] [Assigned] (FLINK-20114) Test Kafka Source based on the new Source API 

2020-11-12 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-20114: Assignee: Jiangjie Qin > Test Kafka Source based on the new Source API  > ---

[GitHub] [flink] flinkbot commented on pull request #14060: [hotfix][doc] fix the usage example of datagen connector doc

2020-11-12 Thread GitBox
flinkbot commented on pull request #14060: URL: https://github.com/apache/flink/pull/14060#issuecomment-726548680 ## CI report: * deb5686ae2485f1fd700e5f1e69e6bf8aa6e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14059: [FLINK-20102][docs][hbase] Update HBase connector documentation for H…

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #14059: URL: https://github.com/apache/flink/pull/14059#issuecomment-726515875 ## CI report: * cae4504a8c2921193aabd5b97e69ddd5c6368a9b Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #14017: [FLINK-19859][document] Add document for the upsert-kafka connector

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

[jira] [Commented] (FLINK-12130) Apply command line options to configuration before installing security modules

2020-11-12 Thread lingyajia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231191#comment-17231191 ] lingyajia commented on FLINK-12130: --- Is there any progress on this issue recently ? fl

[GitHub] [flink-web] klion26 commented on pull request #269: [FLINK-13680] Translate "Common Rules" page into Chinese

2020-11-12 Thread GitBox
klion26 commented on pull request #269: URL: https://github.com/apache/flink-web/pull/269#issuecomment-726540503 @ClownfishYang could you please clean the git history by getting rid of the git merge commit(you can use `git rebase` instead), after that I can have a look. thanks. -

[jira] [Updated] (FLINK-13680) Translate "Code Style - Common Rules" page into Chinese

2020-11-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13680: --- Labels: pull-request-available (was: ) > Translate "Code Style - Common Rules" page into Ch

[jira] [Assigned] (FLINK-20123) Test native support of PyFlink on Kubernetes

2020-11-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20123: --- Assignee: Shuiqiang Chen > Test native support of PyFlink on Kubernetes > -

[GitHub] [flink] flinkbot commented on pull request #14060: [hotfix][doc] fix the usage example of datagen connector doc

2020-11-12 Thread GitBox
flinkbot commented on pull request #14060: URL: https://github.com/apache/flink/pull/14060#issuecomment-726540279 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] HuangXingBo opened a new pull request #14060: [hotfix][doc] fix the usage example of datagen connector doc

2020-11-12 Thread GitBox
HuangXingBo opened a new pull request #14060: URL: https://github.com/apache/flink/pull/14060 ## What is the purpose of the change *This pull request will fix the usage example of datagen connector doc* ## Does this pull request potentially affect one of the following parts:

[jira] [Created] (FLINK-20140) Add documentation of TableResult.collect for Python Table API

2020-11-12 Thread Dian Fu (Jira)
Dian Fu created FLINK-20140: --- Summary: Add documentation of TableResult.collect for Python Table API Key: FLINK-20140 URL: https://issues.apache.org/jira/browse/FLINK-20140 Project: Flink Issue Ty

[GitHub] [flink] flinkbot edited a comment on pull request #14059: [FLINK-20102][docs][hbase] Update HBase connector documentation for H…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14059: [FLINK-20102][docs][hbase] Update HBase connector documentation for H…

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

[GitHub] [flink] flinkbot commented on pull request #14059: [FLINK-20102][docs][hbase] Update HBase connector documentation for H…

2020-11-12 Thread GitBox
flinkbot commented on pull request #14059: URL: https://github.com/apache/flink/pull/14059#issuecomment-726515875 ## CI report: * cae4504a8c2921193aabd5b97e69ddd5c6368a9b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14032: [FLINK-19863][tests] check embedded zookeeper status when start/close hbase resource

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #14032: URL: https://github.com/apache/flink/pull/14032#issuecomment-725359904 ## CI report: * c8c08d9411dbf6e733fcc0f84cb04c0b9127769b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14059: [FLINK-20102][docs][hbase] Update HBase connector documentation for H…

2020-11-12 Thread GitBox
flinkbot commented on pull request #14059: URL: https://github.com/apache/flink/pull/14059#issuecomment-726504112 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] flinkbot edited a comment on pull request #14058: [FLINK-20139][dispatcher] Enrich logs when MiniDispatcher shutting down

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #14058: URL: https://github.com/apache/flink/pull/14058#issuecomment-726497597 ## CI report: * 7bf1538a0647dcf49515cbae50c28f7fe28918d0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14032: [FLINK-19863][tests] check embedded zookeeper status when start/close hbase resource

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #14032: URL: https://github.com/apache/flink/pull/14032#issuecomment-725359904 ## CI report: * c8c08d9411dbf6e733fcc0f84cb04c0b9127769b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20102) Update HBase connector documentation for HBase 2.x supporting

2020-11-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20102: --- Labels: pull-request-available (was: ) > Update HBase connector documentation for HBase 2.x

[GitHub] [flink] wangxlong opened a new pull request #14059: [FLINK-20102][docs][hbase] Update HBase connector documentation for H…

2020-11-12 Thread GitBox
wangxlong opened a new pull request #14059: URL: https://github.com/apache/flink/pull/14059 ## What is the purpose of the change Update HBase connector documentation for HBase 2.x supporting ## Brief change log *(for example:)* - *The TaskInfo is stored in t

[GitHub] [flink] flinkbot commented on pull request #14058: [FLINK-20139][dispatcher] Enrich logs when MiniDispatcher shutting down

2020-11-12 Thread GitBox
flinkbot commented on pull request #14058: URL: https://github.com/apache/flink/pull/14058#issuecomment-726497597 ## CI report: * 7bf1538a0647dcf49515cbae50c28f7fe28918d0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #14058: [FLINK-20139][dispatcher] Enrich logs when MiniDispatcher shutting down

2020-11-12 Thread GitBox
flinkbot commented on pull request #14058: URL: https://github.com/apache/flink/pull/14058#issuecomment-726492068 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-20139) Enrich logs when MiniDispatcher shutting down

2020-11-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20139: --- Labels: pull-request-available (was: ) > Enrich logs when MiniDispatcher shutting down > --

[GitHub] [flink] TisonKun opened a new pull request #14058: [FLINK-20139][dispatcher] Enrich logs when MiniDispatcher shutting down

2020-11-12 Thread GitBox
TisonKun opened a new pull request #14058: URL: https://github.com/apache/flink/pull/14058 ## What is the purpose of the change From [discuss](https://lists.apache.org/x/thread.html/rd0061c9181d938780f0d447f8170f2d7f1e4608c5fc31f0e6884574c@%3Cuser-zh.flink.apache.org%3E) in user-zh

[jira] [Closed] (FLINK-18715) add cpu usage metric of jobmanager/taskmanager

2020-11-12 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wgcn closed FLINK-18715. Resolution: Won't Do > add cpu usage metric of jobmanager/taskmanager > ---

[jira] [Created] (FLINK-20139) Enrich logs when MiniDispatcher shutting down

2020-11-12 Thread Zili Chen (Jira)
Zili Chen created FLINK-20139: - Summary: Enrich logs when MiniDispatcher shutting down Key: FLINK-20139 URL: https://issues.apache.org/jira/browse/FLINK-20139 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

2020-11-12 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231130#comment-17231130 ] wgcn commented on FLINK-20138: -- hi~ [~trohrmann] please have a look at this issue > Flink

[jira] [Updated] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

2020-11-12 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wgcn updated FLINK-20138: - Description: our flink jobs run on Yarn Perjob Mode. We stoped some nodemanger machines ,and AMs of the m

[jira] [Updated] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

2020-11-12 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wgcn updated FLINK-20138: - Description: our flink jobs run on Yarn Perjob Mode. We stoped some nodemanger machines ,and AMs of the m

[jira] [Updated] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

2020-11-12 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wgcn updated FLINK-20138: - Description: our flink jobs run on Yarn Perjob Mode. We stoped some nodemanger machines ,and AMs of the m

[jira] [Updated] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

2020-11-12 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wgcn updated FLINK-20138: - Attachment: jobmanager.log > Flink Job can not recover due to timeout of requiring slots when flink > jobmanag

[jira] [Updated] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

2020-11-12 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wgcn updated FLINK-20138: - Attachment: 2820F7EE-85F9-441D-95D5-8163FB6267DF.png > Flink Job can not recover due to timeout of requiring sl

[jira] [Created] (FLINK-20138) Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted

2020-11-12 Thread wgcn (Jira)
wgcn created FLINK-20138: Summary: Flink Job can not recover due to timeout of requiring slots when flink jobmanager restarted Key: FLINK-20138 URL: https://issues.apache.org/jira/browse/FLINK-20138 Project:

[GitHub] [flink] sjwiesman commented on pull request #14006: [FLINK-19546][doc] Add documentation for native Kubernetes HA

2020-11-12 Thread GitBox
sjwiesman commented on pull request #14006: URL: https://github.com/apache/flink/pull/14006#issuecomment-726478193 @wangyang0918 could you please just add a sentence that explicitly states it works for both standalone and native resource manager. It wasn’t obvious to me. After that +1 to m

[GitHub] [flink] wangyang0918 commented on pull request #14006: [FLINK-19546][doc] Add documentation for native Kubernetes HA

2020-11-12 Thread GitBox
wangyang0918 commented on pull request #14006: URL: https://github.com/apache/flink/pull/14006#issuecomment-726475387 @sjwiesman Thanks for raising up this question. Before writing the documentation, I have verified that the Kubernetes HA service could work both for standalone and native

[GitHub] [flink] sjwiesman commented on pull request #14017: [FLINK-19859][document] Add document for the upsert-kafka connector

2020-11-12 Thread GitBox
sjwiesman commented on pull request #14017: URL: https://github.com/apache/flink/pull/14017#issuecomment-726474622 @fsk119 I just merged in #14036 which adds an autogenerated downloads page for sql connectors. Please rebase your PR and make two changes to your docs: 1) Please add u

[GitHub] [flink] sjwiesman commented on pull request #14049: [FLINK-20043][kinesis] Add flink-sql-connector-kinesis package

2020-11-12 Thread GitBox
sjwiesman commented on pull request #14049: URL: https://github.com/apache/flink/pull/14049#issuecomment-726474208 @dannycranmer I just merged in #14036 which adds an autogenerated downloads page for sql connectors. Please rebase your PR and make two changes to your docs: 1) Please

[jira] [Closed] (FLINK-20093) Create a download page for all optional sql client components

2020-11-12 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-20093. Resolution: Fixed > Create a download page for all optional sql client components > --

[jira] [Commented] (FLINK-20093) Create a download page for all optional sql client components

2020-11-12 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231119#comment-17231119 ] Seth Wiesman commented on FLINK-20093: -- fixed in master: d20a9d5dc9ed2cfddeec9ebe81

[GitHub] [flink] sjwiesman closed pull request #14036: [FLINK-20093] Create a download page for all optional sql client components

2020-11-12 Thread GitBox
sjwiesman closed pull request #14036: URL: https://github.com/apache/flink/pull/14036 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

[jira] [Commented] (FLINK-17159) ES6 ElasticsearchSinkITCase unstable

2020-11-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231114#comment-17231114 ] Dian Fu commented on FLINK-17159: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Assigned] (FLINK-20133) Test Pandas UDAF

2020-11-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20133: --- Assignee: Huang Xingbo > Test Pandas UDAF > > > Key: FLINK-20133 >

[GitHub] [flink] sjwiesman commented on pull request #14036: [FLINK-20093] Create a download page for all optional sql client components

2020-11-12 Thread GitBox
sjwiesman commented on pull request #14036: URL: https://github.com/apache/flink/pull/14036#issuecomment-726470234 Merging this so #14017 and #14049 can use it . This is an automated message from the Apache Git Service. To re

[jira] [Updated] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

2020-11-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20013: Fix Version/s: 1.11.3 > BoundedBlockingSubpartition may leak network buffer if task is failed or > cancel

[jira] [Assigned] (FLINK-20137) User cannot obtain the timestamp of current processing element in the ProcessFunction of Python DataStream API

2020-11-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20137: --- Assignee: Shuiqiang Chen > User cannot obtain the timestamp of current processing element in the >

[jira] [Commented] (FLINK-20133) Test Pandas UDAF

2020-11-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231110#comment-17231110 ] Dian Fu commented on FLINK-20133: - [~hxbks2ks] Thanks a lot~ > Test Pandas UDAF > -

[jira] [Updated] (FLINK-20137) User cannot obtain the timestamp of current processing element in the ProcessFunction of Python DataStream API

2020-11-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20137: Affects Version/s: 1.12.0 > User cannot obtain the timestamp of current processing element in the > Proce

[jira] [Comment Edited] (FLINK-20113) Test K8s High Availability Service

2020-11-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231080#comment-17231080 ] Guowei Ma edited comment on FLINK-20113 at 11/13/20, 2:16 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #14056: [FLINK-19940][task] Improve naming of multi-input transformation

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #14056: URL: https://github.com/apache/flink/pull/14056#issuecomment-726300254 ## CI report: * 4fe64a8f89ec60d1ba0cab944d23f88693d366d4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-statefun] klion26 commented on pull request #131: [FLINK-18968] Translate README.md to Chinese

2020-11-12 Thread GitBox
klion26 commented on pull request #131: URL: https://github.com/apache/flink-statefun/pull/131#issuecomment-726460039 @wangzzu Do you want to take over this? This is an automated message from the Apache Git Service. To respon

[jira] [Created] (FLINK-20137) User cannot obtain the timestamp of current processing element in the ProcessFunction of Python DataStream API

2020-11-12 Thread Shuiqiang Chen (Jira)
Shuiqiang Chen created FLINK-20137: -- Summary: User cannot obtain the timestamp of current processing element in the ProcessFunction of Python DataStream API Key: FLINK-20137 URL: https://issues.apache.org/jira/br

[jira] [Commented] (FLINK-20133) Test Pandas UDAF

2020-11-12 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231093#comment-17231093 ] Huang Xingbo commented on FLINK-20133: -- [~dian.fu] Thanks a lot for creating this i

[jira] [Created] (FLINK-20136) Test all other aspects of new features added in PyFlink

2020-11-12 Thread Dian Fu (Jira)
Dian Fu created FLINK-20136: --- Summary: Test all other aspects of new features added in PyFlink Key: FLINK-20136 URL: https://issues.apache.org/jira/browse/FLINK-20136 Project: Flink Issue Type: Tas

[jira] [Commented] (FLINK-20135) Test Python DataStream API

2020-11-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231087#comment-17231087 ] Dian Fu commented on FLINK-20135: - [~csq] Could you help to take this issue? > Test Pyt

[jira] [Commented] (FLINK-20133) Test Pandas UDAF

2020-11-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231085#comment-17231085 ] Dian Fu commented on FLINK-20133: - [~hxbks2ks] Could you help to take this issue? > Tes

[jira] [Commented] (FLINK-20134) Test non-vectorized Python UDAF

2020-11-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231086#comment-17231086 ] Dian Fu commented on FLINK-20134: - [~zhongwei] Could you help to take this issue? > Tes

[jira] [Created] (FLINK-20135) Test Python DataStream API

2020-11-12 Thread Dian Fu (Jira)
Dian Fu created FLINK-20135: --- Summary: Test Python DataStream API Key: FLINK-20135 URL: https://issues.apache.org/jira/browse/FLINK-20135 Project: Flink Issue Type: Task Components: API /

[jira] [Created] (FLINK-20134) Test non-vectorized Python UDAF

2020-11-12 Thread Dian Fu (Jira)
Dian Fu created FLINK-20134: --- Summary: Test non-vectorized Python UDAF Key: FLINK-20134 URL: https://issues.apache.org/jira/browse/FLINK-20134 Project: Flink Issue Type: Task Components:

[jira] [Created] (FLINK-20133) Test Pandas UDAF

2020-11-12 Thread Dian Fu (Jira)
Dian Fu created FLINK-20133: --- Summary: Test Pandas UDAF Key: FLINK-20133 URL: https://issues.apache.org/jira/browse/FLINK-20133 Project: Flink Issue Type: Task Components: API / Python

[jira] [Commented] (FLINK-20113) Test K8s High Availability Service

2020-11-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231080#comment-17231080 ] Guowei Ma commented on FLINK-20113: --- Could assign this task to me. I can work for this

[jira] [Created] (FLINK-20132) Test PyFlink new features

2020-11-12 Thread Dian Fu (Jira)
Dian Fu created FLINK-20132: --- Summary: Test PyFlink new features Key: FLINK-20132 URL: https://issues.apache.org/jira/browse/FLINK-20132 Project: Flink Issue Type: Sub-task Components: AP

[GitHub] [flink] sjwiesman edited a comment on pull request #14006: [FLINK-19546][doc] Add documentation for native Kubernetes HA

2020-11-12 Thread GitBox
sjwiesman edited a comment on pull request #14006: URL: https://github.com/apache/flink/pull/14006#issuecomment-726250727 Hmm, ok @tillrohrmann and @wangyang0918 I will defer to the two of you. I read the docs right now as being ambiguous as to whether or not k8s ha works with standalone c

[GitHub] [flink] flinkbot edited a comment on pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-726354432 ## CI report: * 86f96719e726d0225aa7201bb43f7c315aa74eea Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14056: [FLINK-19940][task] Improve naming of multi-input transformation

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #14056: URL: https://github.com/apache/flink/pull/14056#issuecomment-726300254 ## CI report: * d3f1b13bab3ae6fe2f50e27d61bd61f8726a1ea5 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #14055: [FLINK-19816] Make job state cleanup dependent on final job result

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #14055: URL: https://github.com/apache/flink/pull/14055#issuecomment-726241233 ## CI report: * e36baa9601903824a0eacc303720ecd943969883 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14051: [FLINK-20107][network] Make InputChannel.statePersister immutable

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #14051: URL: https://github.com/apache/flink/pull/14051#issuecomment-726175036 ## CI report: * 932afb33fec9d29d35c0b29c3e3b4424c0db9210 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-20092) [Java 11] Multi-thread Flink compilation not working

2020-11-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231017#comment-17231017 ] Chesnay Schepler commented on FLINK-20092: -- This is an issue in the shade-plugi

[GitHub] [flink] HuangZhenQiu commented on pull request #13994: [FLINK-20054][formats] Fix ParquetInputFormat 3 level List handling

2020-11-12 Thread GitBox
HuangZhenQiu commented on pull request #13994: URL: https://github.com/apache/flink/pull/13994#issuecomment-726389172 @JingsongLi Thanks. No hurry. This is an automated message from the Apache Git Service. To respond to t

[GitHub] [flink] flinkbot edited a comment on pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-726354432 ## CI report: * 86f96719e726d0225aa7201bb43f7c315aa74eea Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14052: [FLINK-20030][network] Rewrite RemoteInputChannel#getInflightBuffersUnsafe to use sequence numbers

2020-11-12 Thread GitBox
flinkbot edited a comment on pull request #14052: URL: https://github.com/apache/flink/pull/14052#issuecomment-726216034 ## CI report: * 14e0929bf9cebd4db7c60c5928d71e631fb4ad47 UNKNOWN * 0d6c68e97c1c6d23ca2870932db0cdfeddebcafd Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-11-12 Thread GitBox
flinkbot commented on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-726354432 ## CI report: * 86f96719e726d0225aa7201bb43f7c315aa74eea UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14056: [FLINK-19940][task] Improve naming of multi-input transformation

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

  1   2   3   4   5   >