[GitHub] [flink] flinkbot edited a comment on pull request #13061: [FLINK-18764][python] Add DataStream class and support from_collectio…

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13061: URL: https://github.com/apache/flink/pull/13061#issuecomment-668934853 ## CI report: * 8ccc4bad17d568058446ad6816a6d181f090ecf0 Azure:

[GitHub] [flink] klion26 commented on pull request #13056: [FLINK-18798][docs-zh] Translate "Debugging Windows & Event Time" page of "Debugging & Monitoring" into Chinese

2020-08-04 Thread GitBox
klion26 commented on pull request #13056: URL: https://github.com/apache/flink/pull/13056#issuecomment-668987047 @RocMarshal thanks for your contribution. the pr is under my radar now, will review it soon. This is an

[GitHub] [flink] flinkbot edited a comment on pull request #13061: [FLINK-18764][python] Add DataStream class and support from_collectio…

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13061: URL: https://github.com/apache/flink/pull/13061#issuecomment-668934853 ## CI report: * 8ccc4bad17d568058446ad6816a6d181f090ecf0 Azure:

[GitHub] [flink] klion26 commented on a change in pull request #9008: [FLINK-12942][docs-zh] Translate Elasticsearch Connector page into Ch…

2020-08-04 Thread GitBox
klion26 commented on a change in pull request #9008: URL: https://github.com/apache/flink/pull/9008#discussion_r465473496 ## File path: docs/dev/connectors/elasticsearch.zh.md ## @@ -58,23 +56,19 @@ of the Elasticsearch installation: -Note that the streaming connectors

[GitHub] [flink] shuiqiangchen commented on pull request #13061: [FLINK-18764][python] Add DataStream class and support from_collectio…

2020-08-04 Thread GitBox
shuiqiangchen commented on pull request #13061: URL: https://github.com/apache/flink/pull/13061#issuecomment-668982834 Hi @hequn8128 , thank you for your comments, I have updated the pr according to your suggestions, please have a look at it.

[jira] [Closed] (FLINK-18769) MiniBatch doesn't work with FLIP-95 source

2020-08-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18769. --- Resolution: Fixed Fixed in - master (1.12.0): 94b23885ca34927e37334fce51b930933cfd79dd - 1.11.2:

[GitHub] [flink] wuchong commented on pull request #13038: [FLINK-18769][table-planner-blink] Fix MiniBatch doesn't work with FLIP-95 source

2020-08-04 Thread GitBox
wuchong commented on pull request #13038: URL: https://github.com/apache/flink/pull/13038#issuecomment-668973384 Merging... The failed case is caused by FLINK-18819 which is not related to this PR. This is an automated

[GitHub] [flink] wuchong merged pull request #13038: [FLINK-18769][table-planner-blink] Fix MiniBatch doesn't work with FLIP-95 source

2020-08-04 Thread GitBox
wuchong merged pull request #13038: URL: https://github.com/apache/flink/pull/13038 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 #13064: [hotfix][docs]fix java code in scala snippet

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13064: URL: https://github.com/apache/flink/pull/13064#issuecomment-668968561 ## CI report: * bfa4fc0154d4bf5c86efff15f6141424ac1ba8e9 Azure:

[GitHub] [flink] flinkbot commented on pull request #13064: [hotfix][docs]fix java code in scala snippet

2020-08-04 Thread GitBox
flinkbot commented on pull request #13064: URL: https://github.com/apache/flink/pull/13064#issuecomment-668968561 ## CI report: * bfa4fc0154d4bf5c86efff15f6141424ac1ba8e9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] danny0405 edited a comment on pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

2020-08-04 Thread GitBox
danny0405 edited a comment on pull request #13050: URL: https://github.com/apache/flink/pull/13050#issuecomment-668928645 > Could you name a few of these breaking changes? I know about the dropped windows but what else? I listed some features i though important (very probably

[jira] [Commented] (FLINK-18819) All the PubSub tests are failing

2020-08-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171254#comment-17171254 ] Jark Wu commented on FLINK-18819: - Another instance:

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

2020-08-04 Thread Kai Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18785: - Component/s: Runtime / Coordination > flink goes into dead lock leader election when restoring from a

[jira] [Updated] (FLINK-18811) if a disk is damaged, taskmanager should choose another disk for temp dir , rather than throw an IOException, which causes flink job restart over and over again

2020-08-04 Thread Kai Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-18811: - Component/s: (was: Table SQL / Runtime) Runtime / Network > if a disk is damaged,

[GitHub] [flink] flinkbot commented on pull request #13064: [hotfix][docs]fix java code in scala snippet

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

[GitHub] [flink] Jiezhi opened a new pull request #13064: [hotfix][docs]fix java code in scala snippet

2020-08-04 Thread GitBox
Jiezhi opened a new pull request #13064: URL: https://github.com/apache/flink/pull/13064 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

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13061: [FLINK-18764][python] Add DataStream class and support from_collectio…

2020-08-04 Thread GitBox
shuiqiangchen commented on a change in pull request #13061: URL: https://github.com/apache/flink/pull/13061#discussion_r465444604 ## File path: flink-python/pyflink/datastream/tests/test_stream_execution_environment.py ## @@ -22,9 +22,12 @@ import unittest + Review

[jira] [Commented] (FLINK-10658) org.apache.flink.util.FlinkException: Releasing shared slot parent.

2020-08-04 Thread andrew (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171247#comment-17171247 ] andrew commented on FLINK-10658: hi, chauncy. The same exception happened in my application. I have

[jira] [Updated] (FLINK-10658) org.apache.flink.util.FlinkException: Releasing shared slot parent.

2020-08-04 Thread andrew (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] andrew updated FLINK-10658: --- Attachment: 3.png 1.png > org.apache.flink.util.FlinkException: Releasing shared slot

[GitHub] [flink] flinkbot edited a comment on pull request #13063: [FLINK-15448] Add Node information to the ResourceId of TaskExecutor …

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13063: URL: https://github.com/apache/flink/pull/13063#issuecomment-668948742 ## CI report: * c0c3cc811dba6b3ef30730c79ea1e12cd7c8c0a9 Azure:

[jira] [Created] (FLINK-18820) SourceOperator should send MAX_WATERMARK to downstream operator when closed

2020-08-04 Thread Xuannan Su (Jira)
Xuannan Su created FLINK-18820: -- Summary: SourceOperator should send MAX_WATERMARK to downstream operator when closed Key: FLINK-18820 URL: https://issues.apache.org/jira/browse/FLINK-18820 Project:

[GitHub] [flink] dianfu commented on pull request #13034: [FLINK-9992][tests] Fix FsStorageLocationReferenceTest#testEncodeAndDecode by adding retries to generate a valid path

2020-08-04 Thread GitBox
dianfu commented on pull request #13034: URL: https://github.com/apache/flink/pull/13034#issuecomment-668951790 cc @StephanEwen This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] hequn8128 commented on a change in pull request #13061: [FLINK-18764][python] Add DataStream class and support from_collectio…

2020-08-04 Thread GitBox
hequn8128 commented on a change in pull request #13061: URL: https://github.com/apache/flink/pull/13061#discussion_r465435385 ## File path: flink-python/pyflink/datastream/tests/test_util.py ## @@ -0,0 +1,45 @@

[GitHub] [flink] flinkbot commented on pull request #13063: [FLINK-15448] Add Node information to the ResourceId of TaskExecutor …

2020-08-04 Thread GitBox
flinkbot commented on pull request #13063: URL: https://github.com/apache/flink/pull/13063#issuecomment-668948742 ## CI report: * c0c3cc811dba6b3ef30730c79ea1e12cd7c8c0a9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Closed] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

2020-08-04 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-18816. --- Fix Version/s: 1.11.2 1.12.0 Resolution: Fixed Fixed in Master:

[jira] [Commented] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

2020-08-04 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171240#comment-17171240 ] sunjincheng commented on FLINK-18816: - Thanks for the PR [~huaouo] > Correct API usage in Pyflink

[jira] [Assigned] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

2020-08-04 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-18816: --- Assignee: Zhenhua Yang > Correct API usage in Pyflink Dependency Management page >

[GitHub] [flink] zhuzhurk commented on a change in pull request #13028: [FLINK-18739] Implement MergingSharedSlotProfileRetriever

2020-08-04 Thread GitBox
zhuzhurk commented on a change in pull request #13028: URL: https://github.com/apache/flink/pull/13028#discussion_r465441978 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/MergingSharedSlotProfileRetrieverTest.java ## @@ -0,0 +1,182 @@ +/* + *

[jira] [Comment Edited] (FLINK-18819) All the PubSub tests are failing

2020-08-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171237#comment-17171237 ] Dian Fu edited comment on FLINK-18819 at 8/5/20, 2:49 AM: -- It's probably caused

[jira] [Commented] (FLINK-18819) All the PubSub tests are failing

2020-08-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171238#comment-17171238 ] Dian Fu commented on FLINK-18819: - Instance on 1.11:

[jira] [Updated] (FLINK-18819) All the PubSub tests are failing

2020-08-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18819: Affects Version/s: 1.11.2 > All the PubSub tests are failing > > >

[jira] [Updated] (FLINK-18819) All the PubSub tests are failing

2020-08-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18819: Fix Version/s: 1.11.2 > All the PubSub tests are failing > > >

[jira] [Commented] (FLINK-18819) All the PubSub tests are failing

2020-08-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171237#comment-17171237 ] Dian Fu commented on FLINK-18819: - It's probably caused by the upgrade of the docker image

[jira] [Closed] (FLINK-18690) Implement LocalInputPreferredSlotSharingStrategy

2020-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-18690. --- Fix Version/s: 1.12.0 Resolution: Fixed Done via: 2542d86861cd5dd94feb9fcc92ef8e06398c8241

[GitHub] [flink] sunjincheng121 merged pull request #13062: [FLINK-18816] [docs] Correct API change in pyflink dependency management page

2020-08-04 Thread GitBox
sunjincheng121 merged pull request #13062: URL: https://github.com/apache/flink/pull/13062 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

[GitHub] [flink] sunjincheng121 commented on pull request #13062: [FLINK-18816] [docs] Correct API change in pyflink dependency management page

2020-08-04 Thread GitBox
sunjincheng121 commented on pull request #13062: URL: https://github.com/apache/flink/pull/13062#issuecomment-668944112 Thanks for the PR @huaouo Merging... This is an automated message from the Apache Git Service. To

[GitHub] [flink] zhuzhurk merged pull request #13009: [FLINK-18690][runtime] Implement LocalInputPreferredSlotSharingStrategy

2020-08-04 Thread GitBox
zhuzhurk merged pull request #13009: URL: https://github.com/apache/flink/pull/13009 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Updated] (FLINK-18819) All the PubSub tests are failing

2020-08-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18819: Component/s: Tests > All the PubSub tests are failing > > >

[jira] [Updated] (FLINK-18819) All the PubSub tests are failing

2020-08-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18819: Labels: test-stability (was: ) > All the PubSub tests are failing > > >

[jira] [Created] (FLINK-18819) All the PubSub tests are failing

2020-08-04 Thread Dian Fu (Jira)
Dian Fu created FLINK-18819: --- Summary: All the PubSub tests are failing Key: FLINK-18819 URL: https://issues.apache.org/jira/browse/FLINK-18819 Project: Flink Issue Type: Bug Components:

[GitHub] [flink] flinkbot commented on pull request #13063: [FLINK-15448] Add Node information to the ResourceId of TaskExecutor …

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

[jira] [Issue Comment Deleted] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

2020-08-04 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-18816: --- Comment: was deleted (was: [~sunjincheng121]Could you please assign this to me?) > Correct

[GitHub] [flink] KarmaGYZ opened a new pull request #13063: [FLINK-15448] Add Node information to the ResourceId of TaskExecutor …

2020-08-04 Thread GitBox
KarmaGYZ opened a new pull request #13063: URL: https://github.com/apache/flink/pull/13063 …in Yarn ## What is the purpose of the change Add Node information to the ResourceId of TaskExecutor in Yarn ## Brief change log Add Node information to the

[GitHub] [flink] flinkbot commented on pull request #13062: [FLINK-18816] [docs] Correct API change in pyflink dependency management page

2020-08-04 Thread GitBox
flinkbot commented on pull request #13062: URL: https://github.com/apache/flink/pull/13062#issuecomment-668940997 ## CI report: * 37fd035148d09bc22640aa912ea172b96e6dbba4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13061: [FLINK-18764][python] Add DataStream class and support from_collectio…

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13061: URL: https://github.com/apache/flink/pull/13061#issuecomment-668934853 ## CI report: * 8ccc4bad17d568058446ad6816a6d181f090ecf0 Azure:

[jira] [Commented] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

2020-08-04 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171231#comment-17171231 ] Nicholas Jiang commented on FLINK-18816: [~sunjincheng121]Could you please assign this to me? >

[jira] [Comment Edited] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

2020-08-04 Thread Zhenhua Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171224#comment-17171224 ] Zhenhua Yang edited comment on FLINK-18816 at 8/5/20, 2:21 AM: --- I created

[GitHub] [flink] flinkbot commented on pull request #13062: [FLINK-18816] [docs] Correct API change in pyflink dependency management page

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

[jira] [Comment Edited] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

2020-08-04 Thread Zhenhua Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171224#comment-17171224 ] Zhenhua Yang edited comment on FLINK-18816 at 8/5/20, 2:20 AM: --- I created

[jira] [Commented] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

2020-08-04 Thread Zhenhua Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171224#comment-17171224 ] Zhenhua Yang commented on FLINK-18816: -- I created a [pull

[jira] [Updated] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

2020-08-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18816: --- Labels: beginner pull-request-available (was: beginner) > Correct API usage in Pyflink

[GitHub] [flink] huaouo opened a new pull request #13062: [FLINK-18816] [docs] Correct API change in pyflink dependency management page

2020-08-04 Thread GitBox
huaouo opened a new pull request #13062: URL: https://github.com/apache/flink/pull/13062 ## What is the purpose of the change This pull request corrects API change in pyflink dependency management page. ## Brief change log - *Update `dependency_management.md` and

[jira] [Commented] (FLINK-18749) Correct dependencies in Kubernetes pom

2020-08-04 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171223#comment-17171223 ] Yang Wang commented on FLINK-18749: --- Hi [~trohrmann], I notice that you have changed the {{Fix

[GitHub] [flink] flinkbot commented on pull request #13061: [FLINK-18764][python] Add DataStream class and support from_collectio…

2020-08-04 Thread GitBox
flinkbot commented on pull request #13061: URL: https://github.com/apache/flink/pull/13061#issuecomment-668934853 ## CI report: * 8ccc4bad17d568058446ad6816a6d181f090ecf0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13061: [FLINK-18764][python] Add DataStream class and support from_collectio…

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

[jira] [Updated] (FLINK-18764) Support from_collection for Python DataStream API

2020-08-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18764: --- Labels: pull-request-available (was: ) > Support from_collection for Python DataStream API

[GitHub] [flink] shuiqiangchen opened a new pull request #13061: [FLINK-18764][python] Add DataStream class and support from_collectio…

2020-08-04 Thread GitBox
shuiqiangchen opened a new pull request #13061: URL: https://github.com/apache/flink/pull/13061 ## What is the purpose of the change Introduced a new class named DataStream including its common interfaces. And support to get a DataStream through

[GitHub] [flink] danny0405 edited a comment on pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

2020-08-04 Thread GitBox
danny0405 edited a comment on pull request #13050: URL: https://github.com/apache/flink/pull/13050#issuecomment-668928645 > Could you name a few of these breaking changes? I know about the dropped windows but what else? I listed some features i though important (very probably

[GitHub] [flink] danny0405 commented on pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

2020-08-04 Thread GitBox
danny0405 commented on pull request #13050: URL: https://github.com/apache/flink/pull/13050#issuecomment-668928645 > Could you name a few of these breaking changes? I know about the dropped windows but what else? I listed some features i though important (very probably breaking)

[jira] [Updated] (FLINK-18818) HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with "java.io.IOException: The stream is closed"

2020-08-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18818: Labels: test-stability (was: ) > HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed

[jira] [Commented] (FLINK-18817) 'Kerberized YARN per-job on Docker test' failed

2020-08-04 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171216#comment-17171216 ] Yangze Guo commented on FLINK-18817: It seems the same issue with FLINK-18771. > 'Kerberized YARN

[jira] [Updated] (FLINK-18818) HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with "java.io.IOException: The stream is closed"

2020-08-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18818: Component/s: Tests > HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with >

[jira] [Created] (FLINK-18818) HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with "java.io.IOException: The stream is closed"

2020-08-04 Thread Dian Fu (Jira)
Dian Fu created FLINK-18818: --- Summary: HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with "java.io.IOException: The stream is closed" Key: FLINK-18818 URL:

[jira] [Created] (FLINK-18817) 'Kerberized YARN per-job on Docker test' failed

2020-08-04 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-18817: --- Summary: 'Kerberized YARN per-job on Docker test' failed Key: FLINK-18817 URL: https://issues.apache.org/jira/browse/FLINK-18817 Project: Flink Issue Type:

[GitHub] [flink] hequn8128 merged pull request #13029: [FLINK-18763][python] Support basic TypeInformation for Python DataSt…

2020-08-04 Thread GitBox
hequn8128 merged pull request #13029: URL: https://github.com/apache/flink/pull/13029 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Assigned] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

2020-08-04 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-18816: --- Assignee: (was: sunjincheng) > Correct API usage in Pyflink Dependency Management page

[jira] [Assigned] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

2020-08-04 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-18816: --- Assignee: sunjincheng > Correct API usage in Pyflink Dependency Management page >

[jira] [Updated] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

2020-08-04 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18816: Labels: beginner (was: ) > Correct API usage in Pyflink Dependency Management page >

[jira] [Created] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

2020-08-04 Thread sunjincheng (Jira)
sunjincheng created FLINK-18816: --- Summary: Correct API usage in Pyflink Dependency Management page Key: FLINK-18816 URL: https://issues.apache.org/jira/browse/FLINK-18816 Project: Flink Issue

[GitHub] [flink] tweise commented on a change in pull request #13042: [FLINK-16510] Allow overriding of graceful with forceful shutdown

2020-08-04 Thread GitBox
tweise commented on a change in pull request #13042: URL: https://github.com/apache/flink/pull/13042#discussion_r465360429 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java ## @@ -470,4 +479,30 @@ static String

[GitHub] [flink] flinkbot edited a comment on pull request #13060: [hotfix][docs] Rephrase the docs about file names in StreamingFileSink

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13060: URL: https://github.com/apache/flink/pull/13060#issuecomment-668656762 ## CI report: * fcfa6ca7e8aaa669c1df0e7650bc04a68d8c6f4c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13055: [FLINK-18677] Added handling of suspended or lost connections

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13055: URL: https://github.com/apache/flink/pull/13055#issuecomment-668083003 ## CI report: * 6acb8dae3e8cefea998c5ec78683a4dab16a1f78 UNKNOWN * f5df4b17aae9f1abda5c07430bf24c38f08de3e6 Azure:

[jira] [Created] (FLINK-18815) AbstractCloseableRegistryTest.testClose unstable

2020-08-04 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-18815: -- Summary: AbstractCloseableRegistryTest.testClose unstable Key: FLINK-18815 URL: https://issues.apache.org/jira/browse/FLINK-18815 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #13038: [FLINK-18769][table-planner-blink] Fix MiniBatch doesn't work with FLIP-95 source

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13038: URL: https://github.com/apache/flink/pull/13038#issuecomment-667062198 ## CI report: * de3fdd7aeba276a5d66d6d759b126597443c1371 Azure:

[jira] [Commented] (FLINK-18810) Golang remote functions SDK

2020-08-04 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170974#comment-17170974 ] Seth Wiesman commented on FLINK-18810: -- [~slinkydeveloper] I've pushed the code here. I'll try to

[GitHub] [flink-statefun] sjwiesman commented on pull request #128: [hotfix] fix python sdk example

2020-08-04 Thread GitBox
sjwiesman commented on pull request #128: URL: https://github.com/apache/flink-statefun/pull/128#issuecomment-668710123 Thanks. Merged into master and 2.1 to fix the stable docs. This is an automated message from the Apache

[GitHub] [flink-statefun] sjwiesman closed pull request #128: [hotfix] fix python sdk example

2020-08-04 Thread GitBox
sjwiesman closed pull request #128: URL: https://github.com/apache/flink-statefun/pull/128 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

[GitHub] [flink-statefun] sjwiesman commented on a change in pull request #128: [hotfix] fix python sdk example

2020-08-04 Thread GitBox
sjwiesman commented on a change in pull request #128: URL: https://github.com/apache/flink-statefun/pull/128#discussion_r465191925 ## File path: docs/sdk/python.md ## @@ -132,23 +132,23 @@ The delayed message is non-blocking so functions will continue to process record The

[GitHub] [flink-statefun] sjwiesman commented on a change in pull request #129: [FLINK-18812][statefun-core] Upgrade Flink to 1.11.1

2020-08-04 Thread GitBox
sjwiesman commented on a change in pull request #129: URL: https://github.com/apache/flink-statefun/pull/129#discussion_r465189718 ## File path: statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java ## @@ -113,9

[GitHub] [flink] flinkbot edited a comment on pull request #13038: [FLINK-18769][table-planner-blink] Fix MiniBatch doesn't work with FLIP-95 source

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13038: URL: https://github.com/apache/flink/pull/13038#issuecomment-667062198 ## CI report: * 4d42c1496efbb3644557382033d931c0239ecd28 Azure:

[jira] [Commented] (FLINK-18095) Custom Execution Environment for TableEnvironment

2020-08-04 Thread Satyam Shekhar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170950#comment-17170950 ] Satyam Shekhar commented on FLINK-18095: For testing purposes, I create a mini-cluster that can

[GitHub] [flink-statefun] sjwiesman commented on a change in pull request #129: [FLINK-18812][statefun-core] Upgrade Flink to 1.11.1

2020-08-04 Thread GitBox
sjwiesman commented on a change in pull request #129: URL: https://github.com/apache/flink-statefun/pull/129#discussion_r465186356 ## File path: statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsJob.java ## @@ -74,7 +75,9

[jira] [Updated] (FLINK-18812) Upgrade StateFun to Flink 1.11.1

2020-08-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18812: --- Labels: pull-request-available (was: ) > Upgrade StateFun to Flink 1.11.1 >

[GitHub] [flink-statefun] sjwiesman commented on pull request #129: [FLINK-18812][statefun-core] Upgrade Flink to 1.11.1

2020-08-04 Thread GitBox
sjwiesman commented on pull request #129: URL: https://github.com/apache/flink-statefun/pull/129#issuecomment-668704149 cc @igalshilman This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-statefun] sjwiesman opened a new pull request #129: [FLINK-18812][statefun-core] Upgrade Flink to 1.11.1

2020-08-04 Thread GitBox
sjwiesman opened a new pull request #129: URL: https://github.com/apache/flink-statefun/pull/129 Upgraded to Flink 1.11.1 and made necessary internal API changes. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #13038: [FLINK-18769][table-planner-blink] Fix MiniBatch doesn't work with FLIP-95 source

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13038: URL: https://github.com/apache/flink/pull/13038#issuecomment-667062198 ## CI report: * 4d42c1496efbb3644557382033d931c0239ecd28 Azure:

[GitHub] [flink] azagrebin commented on a change in pull request #13009: [FLINK-18690][runtime] Implement LocalInputPreferredSlotSharingStrategy

2020-08-04 Thread GitBox
azagrebin commented on a change in pull request #13009: URL: https://github.com/apache/flink/pull/13009#discussion_r465143555 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java ## @@ -0,0 +1,297 @@ +/* + *

[GitHub] [flink] azagrebin commented on a change in pull request #13009: [FLINK-18690][runtime] Implement LocalInputPreferredSlotSharingStrategy

2020-08-04 Thread GitBox
azagrebin commented on a change in pull request #13009: URL: https://github.com/apache/flink/pull/13009#discussion_r465143204 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java ## @@ -0,0 +1,297 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #13060: [hotfix][docs] Rephrase the docs about file names in StreamingFileSink

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13060: URL: https://github.com/apache/flink/pull/13060#issuecomment-668656762 ## CI report: * fcfa6ca7e8aaa669c1df0e7650bc04a68d8c6f4c Azure:

[GitHub] [flink] azagrebin commented on a change in pull request #13009: [FLINK-18690][runtime] Implement LocalInputPreferredSlotSharingStrategy

2020-08-04 Thread GitBox
azagrebin commented on a change in pull request #13009: URL: https://github.com/apache/flink/pull/13009#discussion_r465137625 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java ## @@ -0,0 +1,297 @@ +/* + *

[GitHub] [flink] azagrebin commented on a change in pull request #13009: [FLINK-18690][runtime] Implement LocalInputPreferredSlotSharingStrategy

2020-08-04 Thread GitBox
azagrebin commented on a change in pull request #13009: URL: https://github.com/apache/flink/pull/13009#discussion_r465137414 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java ## @@ -0,0 +1,297 @@ +/* + *

[jira] [Commented] (FLINK-18786) Performance regresssion on 2020.07.29 in some state backend benchmarks

2020-08-04 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170876#comment-17170876 ] Roman Khachatryan commented on FLINK-18786: --- The same symptoms as in FLINK-18684: regression

[jira] [Commented] (FLINK-18810) Golang remote functions SDK

2020-08-04 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170873#comment-17170873 ] Francesco Guardiani commented on FLINK-18810: - Cool I'll give a look and help, any plans to

[GitHub] [flink] flinkbot edited a comment on pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-667140037 ## CI report: * 31abcb25fdf72394dbfa91d0ba9e151968375ad7 UNKNOWN * db99952f8166cb4d6337dcb3815e72ff2b49604b UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13058: [FLINK-18749][k8s] Correct dependencies in Kubernetes pom

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13058: URL: https://github.com/apache/flink/pull/13058#issuecomment-668542483 ## CI report: * d1596d1c5c10b64f52ecc80488dfa5a7b6d59a5d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13055: [FLINK-18677] Added handling of suspended or lost connections

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13055: URL: https://github.com/apache/flink/pull/13055#issuecomment-668083003 ## CI report: * ed6fb2c77645701eb585d2700c852657b1f66fc9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13059: [hotfix][docs] Update the links' tags in the 'Debugging Windows & Event Time' page of 'Debugging & Monitoring'

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13059: URL: https://github.com/apache/flink/pull/13059#issuecomment-668646523 ## CI report: * d0dc17404bdfab4e84838811f130a1e8c1695e55 Azure:

[GitHub] [flink] flinkbot commented on pull request #13060: [hotfix][docs] Rephrase the docs about file names in StreamingFileSink

2020-08-04 Thread GitBox
flinkbot commented on pull request #13060: URL: https://github.com/apache/flink/pull/13060#issuecomment-668656762 ## CI report: * fcfa6ca7e8aaa669c1df0e7650bc04a68d8c6f4c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-18810) Golang remote functions SDK

2020-08-04 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170861#comment-17170861 ] Seth Wiesman commented on FLINK-18810: -- Hi [~slinkydeveloper], I have a very rough golang sdk

[GitHub] [flink] flinkbot commented on pull request #13060: [hotfix][docs] Rephrase the docs about file names in StreamingFileSink

2020-08-04 Thread GitBox
flinkbot commented on pull request #13060: URL: https://github.com/apache/flink/pull/13060#issuecomment-668649622 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

  1   2   3   >