[jira] [Assigned] (FLINK-20168) Translate page 'Flink Architecture' into Chinese

2020-11-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20168: --- Assignee: CaoZhen > Translate page 'Flink Architecture' into Chinese >

[GitHub] [flink] flinkbot edited a comment on pull request #14020: [FLINK-20078][coordination] Factor out an ExecutionGraph factory method for DefaultExecutionTopology

2020-11-15 Thread GitBox
flinkbot edited a comment on pull request #14020: URL: https://github.com/apache/flink/pull/14020#issuecomment-724735089 ## CI report: * bb25d7f6325759f7400ae0b5728d41d478784659 UNKNOWN * c7df499afee4829fd30823f277597e04de20a8f2 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

2020-11-15 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232595#comment-17232595 ] Yuan Mei commented on FLINK-17726: -- Double checked with [~nicholasjiang], he said he wo

[GitHub] [flink] flinkbot edited a comment on pull request #13991: [FLINK-19983][network] Remove wrong state checking in SortMergeSubpartitionReader

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

[jira] [Commented] (FLINK-20098) Don't add flink-connector-files to flink-dist

2020-11-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232593#comment-17232593 ] Jark Wu commented on FLINK-20098: - If we want to solve the "provided" problem, then we m

[jira] [Comment Edited] (FLINK-20098) Don't add flink-connector-files to flink-dist

2020-11-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232593#comment-17232593 ] Jark Wu edited comment on FLINK-20098 at 11/16/20, 7:53 AM:

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

2020-11-15 Thread GitBox
wangyang0918 commented on a change in pull request #14006: URL: https://github.com/apache/flink/pull/14006#discussion_r523933632 ## File path: docs/ops/jobmanager_high_availability.md ## @@ -215,6 +215,76 @@ Starting zookeeper daemon on host localhost. $ bin/yarn-session.

[jira] [Commented] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

2020-11-15 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232590#comment-17232590 ] Kostas Kloudas commented on FLINK-20143: Thanks [~fly_in_gis], feel free to ping

[GitHub] [flink] flinkbot edited a comment on pull request #14075: [FLINK-20163][docs-zh] Translate page "raw format" into Chinese

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

[jira] [Commented] (FLINK-20168) Translate page 'Flink Architecture' into Chinese

2020-11-15 Thread CaoZhen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232589#comment-17232589 ] CaoZhen commented on FLINK-20168: - Hi [~jark], I want to translate this document. Can yo

[GitHub] [flink] wsry commented on pull request #13991: [FLINK-19983][network] Remove wrong state checking in SortMergeSubpartitionReader

2020-11-15 Thread GitBox
wsry commented on pull request #13991: URL: https://github.com/apache/flink/pull/13991#issuecomment-727793009 @AHeise Thanks for your review and comments. Your concern is reasonable. I have updated my fix. For current bounded partition, only Netty thread can release or poll the subpa

[jira] [Commented] (FLINK-20145) Streaming job fails with IllegalStateException: Should only poll priority events

2020-11-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232587#comment-17232587 ] Robert Metzger commented on FLINK-20145: Thanks a lot for addressing this so qui

[jira] [Created] (FLINK-20168) Translate page 'Flink Architecture' into Chinese

2020-11-15 Thread CaoZhen (Jira)
CaoZhen created FLINK-20168: --- Summary: Translate page 'Flink Architecture' into Chinese Key: FLINK-20168 URL: https://issues.apache.org/jira/browse/FLINK-20168 Project: Flink Issue Type: Improvemen

[jira] [Closed] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout."

2020-11-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-20149. -- Resolution: Fixed I reverted https://issues.apache.org/jira/browse/FLINK-20098 and reopened th

[GitHub] [flink] flinkbot edited a comment on pull request #13900: [FLINK-19949][csv] Unescape CSV format line delimiter character

2020-11-15 Thread GitBox
flinkbot edited a comment on pull request #13900: URL: https://github.com/apache/flink/pull/13900#issuecomment-720989833 ## CI report: * d9e47451664a976692e4e6110bbffa2842f2ae7a UNKNOWN * c9a24a3ac861addff4a26ffa47cffd38db7427ae Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Comment Edited] (FLINK-20098) Don't add flink-connector-files to flink-dist

2020-11-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232585#comment-17232585 ] Robert Metzger edited comment on FLINK-20098 at 11/16/20, 7:27 AM: ---

[jira] [Reopened] (FLINK-20098) Don't add flink-connector-files to flink-dist

2020-11-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-20098: Reverted f3f5e316622255b86f416ba5eb1c283562732823 See: https://issues.apache.org/jira/browse/

[jira] [Commented] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout."

2020-11-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232583#comment-17232583 ] Robert Metzger commented on FLINK-20149: Thanks for looking into it. I will reve

[GitHub] [flink] AHeise merged pull request #14073: [FLINK-20145][task] Don't expose modifiable PrioritizedDeque.iterator

2020-11-15 Thread GitBox
AHeise merged pull request #14073: URL: https://github.com/apache/flink/pull/14073 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] rmetzger commented on pull request #14044: [FLINK-20098] Don't add flink-connector-files to flink-dist

2020-11-15 Thread GitBox
rmetzger commented on pull request #14044: URL: https://github.com/apache/flink/pull/14044#issuecomment-727789464 Note to all people involved in this PR: The CI run of this PR showed a test break that has been merged to master: https://issues.apache.org/jira/browse/FLINK-20149 I will re

[jira] [Assigned] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout."

2020-11-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20149: -- Assignee: Robert Metzger > SQLClientKafkaITCase.testKafka failed with "Did not get ex

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

2020-11-15 Thread GitBox
wangyang0918 commented on pull request #14006: URL: https://github.com/apache/flink/pull/14006#issuecomment-727789055 I have created a new ticket FLINK-20167 for the follow-up(rework the HA documentation). This is an automat

[GitHub] [flink] AHeise commented on pull request #14073: [FLINK-20145][task] Don't expose modifiable PrioritizedDeque.iterator

2020-11-15 Thread GitBox
AHeise commented on pull request #14073: URL: https://github.com/apache/flink/pull/14073#issuecomment-727789160 I'm merging but not closing the ticket as I couldn't confirm yet, if it's indeed causing the issue. (It's only valid for union gates). --

[jira] [Created] (FLINK-20167) Rework the high availability documentation

2020-11-15 Thread Yang Wang (Jira)
Yang Wang created FLINK-20167: - Summary: Rework the high availability documentation Key: FLINK-20167 URL: https://issues.apache.org/jira/browse/FLINK-20167 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-20164) Add docs for ProcessFunction and Timer in Python DataStream API.

2020-11-15 Thread Shuiqiang Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuiqiang Chen updated FLINK-20164: --- Summary: Add docs for ProcessFunction and Timer in Python DataStream API. (was: Add docs fo

[GitHub] [flink] flinkbot edited a comment on pull request #14075: [FLINK-20163][docs-zh] Translate page "raw format" into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #14077: [FLINK-20141][fs-connector] Translate FileSink document into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

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

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

2020-11-15 Thread GitBox
wangyang0918 commented on a change in pull request #14006: URL: https://github.com/apache/flink/pull/14006#discussion_r523933632 ## File path: docs/ops/jobmanager_high_availability.md ## @@ -215,6 +215,76 @@ Starting zookeeper daemon on host localhost. $ bin/yarn-session.

[GitHub] [flink] zhuzhurk commented on a change in pull request #14020: [FLINK-20078][coordination] Factor out an ExecutionGraph factory method for DefaultExecutionTopology

2020-11-15 Thread GitBox
zhuzhurk commented on a change in pull request #14020: URL: https://github.com/apache/flink/pull/14020#discussion_r523932872 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java ## @@ -140,6 +115,53 @@ public Defaul

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

2020-11-15 Thread GitBox
guoweiM commented on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-727779205 > The translation is in #14077, @guoweiM could you also have a look at the Chinese translation ? ok. I will take a look.

[jira] [Commented] (FLINK-12884) FLIP-144: Native Kubernetes HA Service

2020-11-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232568#comment-17232568 ] Yang Wang commented on FLINK-12884: --- [~ksp0422] Thanks for your suggestion. I second y

[GitHub] [flink] metaotao commented on pull request #14075: [FLINK-20163][docs-zh] Translate page "raw format" into Chinese

2020-11-15 Thread GitBox
metaotao commented on pull request #14075: URL: https://github.com/apache/flink/pull/14075#issuecomment-727775897 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

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

2020-11-15 Thread GitBox
gaoyunhaii commented on a change in pull request #14061: URL: https://github.com/apache/flink/pull/14061#discussion_r523923047 ## File path: docs/dev/connectors/streamfile_sink.md ## @@ -765,6 +765,7 @@ and Flink will throw an exception. normal job termination (*e.g.* finite i

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

2020-11-15 Thread GitBox
gaoyunhaii edited a comment on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-727768552 The translation is in https://github.com/apache/flink/pull/14077, @guoweiM could you also have a look at the Chinese translation ? ---

[GitHub] [flink] flinkbot commented on pull request #14077: [FLINK-20141][fs-connector] Translate FileSink document into Chinese

2020-11-15 Thread GitBox
flinkbot commented on pull request #14077: URL: https://github.com/apache/flink/pull/14077#issuecomment-727773204 ## CI report: * 605e600a9ed9a0fec3cdd872dfa6208626f0a087 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

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

[GitHub] [flink] flinkbot edited a comment on pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

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

[GitHub] [flink] flinkbot commented on pull request #14077: [FLINK-20141][fs-connector] Translate FileSink document into Chinese

2020-11-15 Thread GitBox
flinkbot commented on pull request #14077: URL: https://github.com/apache/flink/pull/14077#issuecomment-727769142 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] gaoyunhaii edited a comment on pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

2020-11-15 Thread GitBox
gaoyunhaii edited a comment on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-727768552 The translation is in https://github.com/apache/flink/pull/14077 This is an automated message from the

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

2020-11-15 Thread GitBox
gaoyunhaii commented on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-727768552 The translation is in `https://github.com/apache/flink/pull/14077` This is an automated message from the Apac

[GitHub] [flink] gaoyunhaii opened a new pull request #14077: Pr14061 add doc zh

2020-11-15 Thread GitBox
gaoyunhaii opened a new pull request #14077: URL: https://github.com/apache/flink/pull/14077 ## What is the purpose of the change Translating the `FileSink` document into Chinese. ## Verifying this change This change is a trivial rework / code cleanup without any test co

[GitHub] [flink] flinkbot edited a comment on pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

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

[jira] [Commented] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

2020-11-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232558#comment-17232558 ] Yang Wang commented on FLINK-20143: --- Hmm. I think maybe I find the root cause. When th

[GitHub] [flink] flinkbot edited a comment on pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

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

[GitHub] [flink] xiaoHoly commented on pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

2020-11-15 Thread GitBox
xiaoHoly commented on pull request #14076: URL: https://github.com/apache/flink/pull/14076#issuecomment-727752237 HI,@tillrohrmann .PTAL This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [flink] xiaoHoly commented on pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

2020-11-15 Thread GitBox
xiaoHoly commented on pull request #14076: URL: https://github.com/apache/flink/pull/14076#issuecomment-727750065 > @xiaoHoly It will trigger the test atomically when you pushing a new commit. Usually there is no need to trigger the test manually. Besides, you can use command `@flinkbot ru

[GitHub] [flink] dianfu commented on pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

2020-11-15 Thread GitBox
dianfu commented on pull request #14076: URL: https://github.com/apache/flink/pull/14076#issuecomment-727749697 I'm not quite familiar with this part. cc @tillrohrmann This is an automated message from the Apache Git Serv

[GitHub] [flink] dianfu commented on pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

2020-11-15 Thread GitBox
dianfu commented on pull request #14076: URL: https://github.com/apache/flink/pull/14076#issuecomment-727748627 @xiaoHoly It will trigger the test atomically when you pushing a new commit. Usually there is no need to trigger the test manually. Besides, you can use command `@flinkbot run az

[GitHub] [flink] flinkbot edited a comment on pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

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

[GitHub] [flink] xiaoHoly commented on pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

2020-11-15 Thread GitBox
xiaoHoly commented on pull request #14076: URL: https://github.com/apache/flink/pull/14076#issuecomment-727747755 @flinkbot run azure re-run the last Azure build This is an automated message from the Apache Git Service. To re

[GitHub] [flink] xiaoHoly commented on pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

2020-11-15 Thread GitBox
xiaoHoly commented on pull request #14076: URL: https://github.com/apache/flink/pull/14076#issuecomment-727747601 @flinkbot run travis re-run the last Travis build This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-19775) SystemProcessingTimeServiceTest.testImmediateShutdown is instable

2020-11-15 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232536#comment-17232536 ] jiawen xiao commented on FLINK-19775: - Hi,[~dian.fu], Looking forward to your follow

[jira] [Updated] (FLINK-19775) SystemProcessingTimeServiceTest.testImmediateShutdown is instable

2020-11-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19775: --- Labels: pull-request-available test-stability (was: test-stability) > SystemProcessingTimeS

[GitHub] [flink] flinkbot commented on pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

2020-11-15 Thread GitBox
flinkbot commented on pull request #14076: URL: https://github.com/apache/flink/pull/14076#issuecomment-727741544 ## CI report: * 6082a1d0c0f4274e553de47fae1285537c38ace8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] xiaoHoly commented on pull request #14076: Pr holy patch

2020-11-15 Thread GitBox
xiaoHoly commented on pull request #14076: URL: https://github.com/apache/flink/pull/14076#issuecomment-727739140 @flinkbot run travis re-run the last Travis build This is an automated message from the Apache Git Service. To

[GitHub] [flink] xiaoHoly commented on pull request #14076: Pr holy patch

2020-11-15 Thread GitBox
xiaoHoly commented on pull request #14076: URL: https://github.com/apache/flink/pull/14076#issuecomment-727739202 @flinkbot run azure re-run the last Azure build This is an automated message from the Apache Git Service. To re

[GitHub] [flink] xiaoHoly commented on pull request #14076: Pr holy patch

2020-11-15 Thread GitBox
xiaoHoly commented on pull request #14076: URL: https://github.com/apache/flink/pull/14076#issuecomment-727737851 @dianfu ,hi,Teacher Fu,I have finished my work for this problem . Can you help me review my code? This is an a

[GitHub] [flink] flinkbot commented on pull request #14076: Pr holy patch

2020-11-15 Thread GitBox
flinkbot commented on pull request #14076: URL: https://github.com/apache/flink/pull/14076#issuecomment-727737772 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] xiaoHoly opened a new pull request #14076: Pr holy patch

2020-11-15 Thread GitBox
xiaoHoly opened a new pull request #14076: URL: https://github.com/apache/flink/pull/14076 ## What is the purpose of the change I will repair the test function (SystemProcessingTimeServiceTest.testImmediateShutdown) which is instable . Express in the FLINK-19775

[GitHub] [flink] flinkbot edited a comment on pull request #13998: [FLINK-20062][hive] ContinuousHiveSplitEnumerator should be lock-free

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

[GitHub] [flink] flinkbot edited a comment on pull request #13998: [FLINK-20062][hive] ContinuousHiveSplitEnumerator should be lock-free

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

[GitHub] [flink] flinkbot edited a comment on pull request #13900: [FLINK-19949][csv] Unescape CSV format line delimiter character

2020-11-15 Thread GitBox
flinkbot edited a comment on pull request #13900: URL: https://github.com/apache/flink/pull/13900#issuecomment-720989833 ## CI report: * d9e47451664a976692e4e6110bbffa2842f2ae7a UNKNOWN * c9a24a3ac861addff4a26ffa47cffd38db7427ae Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13900: [FLINK-19949][csv] Unescape CSV format line delimiter character

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

[jira] [Comment Edited] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker.

2020-11-15 Thread Jin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232495#comment-17232495 ] Jin Xing edited comment on FLINK-20038 at 11/16/20, 3:56 AM: -

[jira] [Comment Edited] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker.

2020-11-15 Thread Jin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232495#comment-17232495 ] Jin Xing edited comment on FLINK-20038 at 11/16/20, 3:54 AM: -

[jira] [Commented] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker.

2020-11-15 Thread Jin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232495#comment-17232495 ] Jin Xing commented on FLINK-20038: -- Hi [~trohrmann] [~ym] Thanks a lot for your feedba

[jira] [Comment Edited] (FLINK-12884) FLIP-144: Native Kubernetes HA Service

2020-11-15 Thread Kevin Kwon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232493#comment-17232493 ] Kevin Kwon edited comment on FLINK-12884 at 11/16/20, 3:48 AM: ---

[jira] [Commented] (FLINK-12884) FLIP-144: Native Kubernetes HA Service

2020-11-15 Thread Kevin Kwon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232493#comment-17232493 ] Kevin Kwon commented on FLINK-12884: Just in my opinion, I think the e2e test should

[jira] [Commented] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

2020-11-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232488#comment-17232488 ] Yang Wang commented on FLINK-20143: --- [~zhisheng] Could you add the hdfs schema in the

[jira] [Assigned] (FLINK-20164) Add docs for ProcessFunction and Timer for Python DataStream API.

2020-11-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20164: --- Assignee: Shuiqiang Chen > Add docs for ProcessFunction and Timer for Python DataStream API. >

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #13900: [FLINK-19949][csv] Unescape CSV format line delimiter character

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

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

2020-11-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20134. --- Resolution: Done [~zhongwei] Thanks a lot~ > Test non-vectorized Python UDAF >

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

2020-11-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20134: --- Assignee: Wei Zhong > Test non-vectorized Python UDAF > --- > >

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

2020-11-15 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232484#comment-17232484 ] Wei Zhong commented on FLINK-20134: --- Hi [~dian.fu], I have tested the non-vectorized P

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

2020-11-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232483#comment-17232483 ] Xintong Song commented on FLINK-19852: -- [~gaoyunhaii] and I also had a discussion a

[jira] [Commented] (FLINK-20155) java.lang.OutOfMemoryError: Direct buffer memory

2020-11-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232482#comment-17232482 ] Xintong Song commented on FLINK-20155: -- Hi [~roeehersh], The problem you described

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

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

[jira] [Updated] (FLINK-20142) Update the document for CREATE TABLE LIKE that source table from different catalog is supported

2020-11-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20142: Description: The confusion from the [USER mailing list|http://apache-flink-user-mailing-list-archive.2336

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

2020-11-15 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

[jira] [Assigned] (FLINK-20125) Test memory configuration display in the web ui

2020-11-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20125: Assignee: Xintong Song > Test memory configuration display in the web ui > --

[jira] [Commented] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout."

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

[jira] [Created] (FLINK-20166) FlinkKafkaProducerITCase.testRunOutOfProducersInThePool failed with "CheckpointException: Could not complete snapshot 1 for operator MockTask (1/1)#0. Failure reason: Ch

2020-11-15 Thread Dian Fu (Jira)
Dian Fu created FLINK-20166: --- Summary: FlinkKafkaProducerITCase.testRunOutOfProducersInThePool failed with "CheckpointException: Could not complete snapshot 1 for operator MockTask (1/1)#0. Failure reason: Checkpoint was declined." Key

[jira] [Updated] (FLINK-20166) FlinkKafkaProducerITCase.testRunOutOfProducersInThePool failed with "CheckpointException: Could not complete snapshot 1 for operator MockTask (1/1)#0. Failure reason: Ch

2020-11-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20166: Labels: test-stability (was: ) > FlinkKafkaProducerITCase.testRunOutOfProducersInThePool failed with > "

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

2020-11-15 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

[jira] [Commented] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

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

[jira] [Updated] (FLINK-20165) YARNSessionFIFOITCase.checkForProhibitedLogContents: Error occurred during initialization of boot layer java.lang.IllegalStateException: Module system already initialize

2020-11-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20165: Labels: test-stability (was: ) > YARNSessionFIFOITCase.checkForProhibitedLogContents: Error occurred duri

[jira] [Created] (FLINK-20165) YARNSessionFIFOITCase.checkForProhibitedLogContents: Error occurred during initialization of boot layer java.lang.IllegalStateException: Module system already initialize

2020-11-15 Thread Dian Fu (Jira)
Dian Fu created FLINK-20165: --- Summary: YARNSessionFIFOITCase.checkForProhibitedLogContents: Error occurred during initialization of boot layer java.lang.IllegalStateException: Module system already initialized Key: FLINK-20165

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

2020-11-15 Thread GitBox
HuangXingBo commented on pull request #14060: URL: https://github.com/apache/flink/pull/14060#issuecomment-727681489 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, ple

[jira] [Commented] (FLINK-17482) KafkaITCase.testMultipleSourcesOnePartition unstable

2020-11-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232444#comment-17232444 ] Dian Fu commented on FLINK-17482: - Another instance on 1.11: https://dev.azure.com/apac

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

2020-11-15 Thread GitBox
XComp commented on a change in pull request #14033: URL: https://github.com/apache/flink/pull/14033#discussion_r523823323 ## File path: flink-end-to-end-tests/test-scripts/common.sh ## @@ -822,11 +839,20 @@ internal_run_with_timeout() { ( command_pid=$BASHPID -

[jira] [Commented] (FLINK-19250) SplitFetcherManager does not propagate errors correctly

2020-11-15 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232412#comment-17232412 ] Stephan Ewen commented on FLINK-19250: -- Fixed in 1.11.3 (release-1.11) via f220c248

[jira] [Updated] (FLINK-19251) Avoid confusing queue handling in "SplitReader.handleSplitsChanges()"

2020-11-15 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-19251: - Fix Version/s: 1.11.3 > Avoid confusing queue handling in "SplitReader.handleSplitsChanges()" >

[jira] [Commented] (FLINK-19251) Avoid confusing queue handling in "SplitReader.handleSplitsChanges()"

2020-11-15 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232413#comment-17232413 ] Stephan Ewen commented on FLINK-19251: -- Fixed in 1.11.3 (release-1.11) via 257a0da7

[jira] [Commented] (FLINK-19245) Set default queue capacity for FLIP-27 source handover queue to 2

2020-11-15 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232411#comment-17232411 ] Stephan Ewen commented on FLINK-19245: -- Fixed in 1.11.3 (release-1.11) via 406aa9f3

[jira] [Updated] (FLINK-19250) SplitFetcherManager does not propagate errors correctly

2020-11-15 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-19250: - Fix Version/s: 1.11.3 > SplitFetcherManager does not propagate errors correctly > --

[jira] [Commented] (FLINK-18128) CoordinatedSourceITCase.testMultipleSources gets stuck

2020-11-15 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232409#comment-17232409 ] Stephan Ewen commented on FLINK-18128: -- Fixed in 1.11.3 (release-1.11) via e72e4853

[jira] [Updated] (FLINK-19245) Set default queue capacity for FLIP-27 source handover queue to 2

2020-11-15 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-19245: - Fix Version/s: 1.11.3 > Set default queue capacity for FLIP-27 source handover queue to 2 >

[jira] [Commented] (FLINK-19223) Simplify Availability Future Model in Base Connector

2020-11-15 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232410#comment-17232410 ] Stephan Ewen commented on FLINK-19223: -- Fixed in 1.11.3 (release-1.11) via 0e821eaa

  1   2   >