[GitHub] [flink] flinkbot edited a comment on pull request #12620: [FLINK-18226][runtime] Fix ActiveResourceManager requesting extra workers on termination of existing workers.

flinkbot edited a comment on pull request #12620: URL: https://github.com/apache/flink/pull/12620#issuecomment-643030171 ## CI report: * ebbf877a656482468f1337520a39aa46267b8642 Azure:

[jira] [Commented] (FLINK-17639) Document which FileSystems are supported by the StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-17639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134644#comment-17134644 ] Guowei Ma commented on FLINK-17639: --- yes. :) > Document which FileSystems are supported by the

[GitHub] [flink] becketqin commented on pull request #12510: [FLINK-18039]

becketqin commented on pull request #12510: URL: https://github.com/apache/flink/pull/12510#issuecomment-643563232 @StephanEwen Thanks for the comment. Please see the reply below: `RecreateOnResetOperatorCoordinator` v.s. having the logic in `OperatorCoordinatorHolder`. I

[GitHub] [flink] JingsongLi commented on pull request #12527: [FLINK-18173][build] Bundle flink-csv,flink-json,flink-avro jars in lib

JingsongLi commented on pull request #12527: URL: https://github.com/apache/flink/pull/12527#issuecomment-643560152 Considering that flink-avro also relies on Avro and Hadoop, if the user bundled Avro and Hadoop in the user's classloader, this may lead to the problem that the relevant

[jira] [Comment Edited] (FLINK-17761) FutureCompletingBlockingQueue should have a capacity limit.

[ https://issues.apache.org/jira/browse/FLINK-17761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129243#comment-17129243 ] liufangliang edited comment on FLINK-17761 at 6/13/20, 2:55 AM: Hi

[jira] [Updated] (FLINK-18283) [Javdoc] Update outdated Javadoc for clear method of ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-18283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhijit Shandilya updated FLINK-18283: -- Description: +*Summary:*+ Javadoc for ProcessWindowFunction is has incorrect

[jira] [Updated] (FLINK-18283) [Javdoc] Update outdated Javadoc for clear method of ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-18283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhijit Shandilya updated FLINK-18283: -- Description: +*Summary:*+ Javadoc for ProcessWindowFunction is has incorrect

[jira] [Updated] (FLINK-18283) [Javdoc] Update outdated Javadoc for clear method of ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-18283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhijit Shandilya updated FLINK-18283: -- Description: +*Summary:*+ Javadoc for ProcessWindowFunction is has incorrect

[jira] [Updated] (FLINK-18283) [Javdoc] Update outdated Javadoc for clear method of ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-18283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhijit Shandilya updated FLINK-18283: -- Description: +*Summary:*+ Javadoc for ProcessWindowFunction is has incorrect

[jira] [Updated] (FLINK-18283) [Javdoc] Update outdated Javadoc for clear method of ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-18283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhijit Shandilya updated FLINK-18283: -- Description: +*Summary:*+ Javadoc for ProcessWindowFunction is has incorrect

[jira] [Created] (FLINK-18283) [Javdoc] Update outdated Javadoc for clear method of ProcessWindowFunction

Abhijit Shandilya created FLINK-18283: - Summary: [Javdoc] Update outdated Javadoc for clear method of ProcessWindowFunction Key: FLINK-18283 URL: https://issues.apache.org/jira/browse/FLINK-18283

[GitHub] [flink] flinkbot edited a comment on pull request #12640: [FLINK-18281] [streaming-java][window-assigners] Add WindowStagger into TumblingEventTimeWindows

flinkbot edited a comment on pull request #12640: URL: https://github.com/apache/flink/pull/12640#issuecomment-643501688 ## CI report: * 726575fd6fe334be89300f3668fa4a4c23a74b31 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12620: [FLINK-18226][runtime] Fix ActiveResourceManager requesting extra workers on termination of existing workers.

flinkbot edited a comment on pull request #12620: URL: https://github.com/apache/flink/pull/12620#issuecomment-643030171 ## CI report: * 4123e5f74a0c4f312588fdaf616dce9b6899371b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12620: [FLINK-18226][runtime] Fix ActiveResourceManager requesting extra workers on termination of existing workers.

flinkbot edited a comment on pull request #12620: URL: https://github.com/apache/flink/pull/12620#issuecomment-643030171 ## CI report: * 4123e5f74a0c4f312588fdaf616dce9b6899371b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12619: [FLINK-17623][Connectors/Elasticsearch] Support user resource cleanup in Elasticsearch sink

flinkbot edited a comment on pull request #12619: URL: https://github.com/apache/flink/pull/12619#issuecomment-643008650 ## CI report: * 92495354c92ecc83f992bda04f3aad9a4715f9da Azure:

[GitHub] [flink] xintongsong commented on pull request #12620: [FLINK-18226][runtime] Fix ActiveResourceManager requesting extra workers on termination of existing workers.

xintongsong commented on pull request #12620: URL: https://github.com/apache/flink/pull/12620#issuecomment-643522632 Thanks for the review, @tillrohrmann. I've addressed your comments. Please take another look. BTW. The revert commit is added to clearly show what have been changed

[GitHub] [flink] flinkbot edited a comment on pull request #12641: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

flinkbot edited a comment on pull request #12641: URL: https://github.com/apache/flink/pull/12641#issuecomment-643512051 ## CI report: * 0e8df0b545052af481e0e67abe668f2811296936 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/171175430) Bot

[GitHub] [flink] flinkbot edited a comment on pull request #12641: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

flinkbot edited a comment on pull request #12641: URL: https://github.com/apache/flink/pull/12641#issuecomment-643512051 ## CI report: * 0e8df0b545052af481e0e67abe668f2811296936 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/171175430) Bot

[GitHub] [flink] xintongsong commented on a change in pull request #12620: [FLINK-18226][runtime] Fix ActiveResourceManager requesting extra workers on termination of existing workers.

xintongsong commented on a change in pull request #12620: URL: https://github.com/apache/flink/pull/12620#discussion_r439673126 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java ## @@ -404,13 +404,17 @@ private void

[GitHub] [flink] flinkbot commented on pull request #12641: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

flinkbot commented on pull request #12641: URL: https://github.com/apache/flink/pull/12641#issuecomment-643512051 ## CI report: * 0e8df0b545052af481e0e67abe668f2811296936 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] xintongsong commented on a change in pull request #12620: [FLINK-18226][runtime] Fix ActiveResourceManager requesting extra workers on termination of existing workers.

xintongsong commented on a change in pull request #12620: URL: https://github.com/apache/flink/pull/12620#discussion_r439670500 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResourceManagerTest.java ## @@ -390,31 +429,7 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #12639: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

flinkbot edited a comment on pull request #12639: URL: https://github.com/apache/flink/pull/12639#issuecomment-643422829 ## CI report: * b8e0ff532826ddcca57b902525543fe66f4a050e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12640: [FLINK-18281] [streaming-java][window-assigners] Add WindowStagger into TumblingEventTimeWindows

flinkbot edited a comment on pull request #12640: URL: https://github.com/apache/flink/pull/12640#issuecomment-643501688 ## CI report: * 726575fd6fe334be89300f3668fa4a4c23a74b31 Azure:

[GitHub] [flink] xintongsong commented on a change in pull request #12620: [FLINK-18226][runtime] Fix ActiveResourceManager requesting extra workers on termination of existing workers.

xintongsong commented on a change in pull request #12620: URL: https://github.com/apache/flink/pull/12620#discussion_r439666292 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerGateway.java ## @@ -104,13 +104,15 @@

[jira] [Commented] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134561#comment-17134561 ] Arvid Heise commented on FLINK-17322: - Proper fix has been merged to master; currently backporting.

[GitHub] [flink] flinkbot commented on pull request #12641: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

flinkbot commented on pull request #12641: URL: https://github.com/apache/flink/pull/12641#issuecomment-643506524 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-17322) Enable latency tracker would corrupt the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-17322: Affects Version/s: 1.12.0 1.11.0 > Enable latency tracker would corrupt

[GitHub] [flink] AHeise opened a new pull request #12641: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

AHeise opened a new pull request #12641: URL: https://github.com/apache/flink/pull/12641 (Mildly adjusted backport from https://github.com/apache/flink/pull/12353/) ## What is the purpose of the change `BroadcastRecordWriter#randomEmit` initialized buffer consumers for

[GitHub] [flink] flinkbot commented on pull request #12640: [FLINK-18281] [streaming-java][window-assigners] Add WindowStagger into TumblingEventTimeWindows

flinkbot commented on pull request #12640: URL: https://github.com/apache/flink/pull/12640#issuecomment-643501688 ## CI report: * 726575fd6fe334be89300f3668fa4a4c23a74b31 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #12640: [FLINK-18281] [streaming-java][window-assigners] Add WindowStagger into TumblingEventTimeWindows

flinkbot commented on pull request #12640: URL: https://github.com/apache/flink/pull/12640#issuecomment-643492455 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] TengHu edited a comment on pull request #12640: [FLINK-18281] [streaming-java][window-assigners] Add WindowStagger into TumblingEventTimeWindows

TengHu edited a comment on pull request #12640: URL: https://github.com/apache/flink/pull/12640#issuecomment-643491078 @aljoscha Here is a followup change of the [PR 12297](https://github.com/apache/flink/pull/12297). Thank you

[GitHub] [flink] TengHu commented on pull request #12640: [FLINK-18281] [streaming-java][window-assigners] Add WindowStagger into TumblingEventTimeWindows

TengHu commented on pull request #12640: URL: https://github.com/apache/flink/pull/12640#issuecomment-643491078 @aljoscha Here is a followup change of the [PRR 12297](https://github.com/apache/flink/pull/12297). Thank you

[GitHub] [flink] TengHu opened a new pull request #12640: [FLINK-18281] [streaming-java][window-assigners] Add WindowStagger into TumblingEventTimeWindows

TengHu opened a new pull request #12640: URL: https://github.com/apache/flink/pull/12640 ## What is the purpose of the change This PR is a follow-up of [FLINK-12855](https://issues.apache.org/jira/browse/FLINK-12855) and [PR 12297](FLINK-12855), which introduces WindowStagger in

[jira] [Updated] (FLINK-18281) Add WindowStagger into all Tumbling and Sliding Windows

[ https://issues.apache.org/jira/browse/FLINK-18281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18281: --- Labels: pull-request-available (was: ) > Add WindowStagger into all Tumbling and Sliding

[GitHub] [flink] flinkbot edited a comment on pull request #12619: [FLINK-17623][Connectors/Elasticsearch] Support user resource cleanup in Elasticsearch sink

flinkbot edited a comment on pull request #12619: URL: https://github.com/apache/flink/pull/12619#issuecomment-643008650 ## CI report: * a73bb3685261f7e63cb062190eb5ae7a3e68739a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12638: [FLINK-17977] Improve checkpoint triggering log message

flinkbot edited a comment on pull request #12638: URL: https://github.com/apache/flink/pull/12638#issuecomment-643389717 ## CI report: * cf9f0210248a376ecb0e036240dc1afed837b800 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12619: [FLINK-17623][Connectors/Elasticsearch] Support user resource cleanup in Elasticsearch sink

flinkbot edited a comment on pull request #12619: URL: https://github.com/apache/flink/pull/12619#issuecomment-643008650 ## CI report: * a73bb3685261f7e63cb062190eb5ae7a3e68739a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12636: [FLINK-17998][hs] Support Flink history server archive size limitation

flinkbot edited a comment on pull request #12636: URL: https://github.com/apache/flink/pull/12636#issuecomment-643369693 ## CI report: * c91fac7a9ceaae8605e7146cdeffa00e2a15e187 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12637: [FLINK-18279][docs] Simplify Table Overview

flinkbot edited a comment on pull request #12637: URL: https://github.com/apache/flink/pull/12637#issuecomment-643369795 ## CI report: * 568eefffd9384c30d022a8bd3f4fd010aebee9e6 Azure:

[GitHub] [flink] yun-wang commented on a change in pull request #12619: [FLINK-17623][Connectors/Elasticsearch] Support user resource cleanup in Elasticsearch sink

yun-wang commented on a change in pull request #12619: URL: https://github.com/apache/flink/pull/12619#discussion_r439613236 ## File path:

[GitHub] [flink] yun-wang commented on a change in pull request #12619: [FLINK-17623][Connectors/Elasticsearch] Support user resource cleanup in Elasticsearch sink

yun-wang commented on a change in pull request #12619: URL: https://github.com/apache/flink/pull/12619#discussion_r439611794 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #12635: [FLINK-17891][yarn] Set execution.target to yarn-session in FlinkYarnSessionCli.run()

flinkbot edited a comment on pull request #12635: URL: https://github.com/apache/flink/pull/12635#issuecomment-643335280 ## CI report: * 6d193f40eaee7d91d0006b62b1f2f9aa46821d34 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12634: [FLINK-18191] Rename jobmanager.memory.* configuration options into master.memory.*

flinkbot edited a comment on pull request #12634: URL: https://github.com/apache/flink/pull/12634#issuecomment-643310855 ## CI report: * 3756d9ac6bae01760b04fd3a165b98ab7df608ea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12639: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

flinkbot edited a comment on pull request #12639: URL: https://github.com/apache/flink/pull/12639#issuecomment-643422829 ## CI report: * b8e0ff532826ddcca57b902525543fe66f4a050e Azure:

[GitHub] [flink] flinkbot commented on pull request #12639: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

flinkbot commented on pull request #12639: URL: https://github.com/apache/flink/pull/12639#issuecomment-643422829 ## CI report: * b8e0ff532826ddcca57b902525543fe66f4a050e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-7022) Flink Job Manager Scheduler & Web Frontend out of sync when Zookeeper is unavailable on startup

[ https://issues.apache.org/jira/browse/FLINK-7022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134451#comment-17134451 ] Jonathan Foley commented on FLINK-7022: --- I'm deploying to Kubernetes, so my plan to workaround is

[GitHub] [flink] flinkbot edited a comment on pull request #12633: [FLINK-18277][elasticsearch] Fix es6 sink identifier

flinkbot edited a comment on pull request #12633: URL: https://github.com/apache/flink/pull/12633#issuecomment-643289026 ## CI report: * 05f89e5b713b63cadc23bc6c4cef92dff684609e UNKNOWN * 3b0affdb70679f6502a3bae91332487b32dcb4d9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12632: [FLINK-18134][FLINK-18135][docs] Add documentation for Debezium and Canal formats

flinkbot edited a comment on pull request #12632: URL: https://github.com/apache/flink/pull/12632#issuecomment-643271701 ## CI report: * efab4bd06cb85c507e51f1c4b5f916ed67957eec Azure:

[GitHub] [flink] flinkbot commented on pull request #12639: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

flinkbot commented on pull request #12639: URL: https://github.com/apache/flink/pull/12639#issuecomment-643414461 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-7022) Flink Job Manager Scheduler & Web Frontend out of sync when Zookeeper is unavailable on startup

[ https://issues.apache.org/jira/browse/FLINK-7022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Foley updated FLINK-7022: -- Attachment: log2.txt > Flink Job Manager Scheduler & Web Frontend out of sync when Zookeeper

[jira] [Commented] (FLINK-7022) Flink Job Manager Scheduler & Web Frontend out of sync when Zookeeper is unavailable on startup

[ https://issues.apache.org/jira/browse/FLINK-7022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134437#comment-17134437 ] Jonathan Foley commented on FLINK-7022: --- [~trohrmann] the web UI perpetually returns 503 errors

[jira] [Created] (FLINK-18282) retranslate the documentation home page

David Anderson created FLINK-18282: -- Summary: retranslate the documentation home page Key: FLINK-18282 URL: https://issues.apache.org/jira/browse/FLINK-18282 Project: Flink Issue Type:

[GitHub] [flink] AHeise opened a new pull request #12639: [FLINK-17322][network] Fixes BroadcastRecordWriter overwriting memory segments on first finished BufferConsumer.

AHeise opened a new pull request #12639: URL: https://github.com/apache/flink/pull/12639 (Unchanged backport of https://github.com/apache/flink/pull/12353/) ## What is the purpose of the change `BroadcastRecordWriter#randomEmit` initialized buffer consumers for other

[GitHub] [flink] flinkbot edited a comment on pull request #12638: [FLINK-17977] Improve checkpoint triggering log message

flinkbot edited a comment on pull request #12638: URL: https://github.com/apache/flink/pull/12638#issuecomment-643389717 ## CI report: * cf9f0210248a376ecb0e036240dc1afed837b800 Azure:

[jira] [Created] (FLINK-18281) Add WindowStagger into all Tumbling and Sliding Windows

Teng Hu created FLINK-18281: --- Summary: Add WindowStagger into all Tumbling and Sliding Windows Key: FLINK-18281 URL: https://issues.apache.org/jira/browse/FLINK-18281 Project: Flink Issue Type:

[GitHub] [flink] StephanEwen commented on pull request #12510: [FLINK-18039]

StephanEwen commented on pull request #12510: URL: https://github.com/apache/flink/pull/12510#issuecomment-643396266 Thanks for the patch! I like the general direction, but am unsure about a few details. The earlier version of the code had the re-creation separately in the

[jira] [Commented] (FLINK-7022) Flink Job Manager Scheduler & Web Frontend out of sync when Zookeeper is unavailable on startup

[ https://issues.apache.org/jira/browse/FLINK-7022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134399#comment-17134399 ] Till Rohrmann commented on FLINK-7022: -- How is the web UI behaving in your case [~jfoley_harmonia]?

[GitHub] [flink] flinkbot edited a comment on pull request #12609: [FLINK-17836][hive][doc] Add document for Hive dim join

flinkbot edited a comment on pull request #12609: URL: https://github.com/apache/flink/pull/12609#issuecomment-642647320 ## CI report: * b8af77cd844986ae37c6054db98abc0e9619da0b Azure:

[GitHub] [flink] flinkbot commented on pull request #12638: [FLINK-17977] Improve checkpoint triggering log message

flinkbot commented on pull request #12638: URL: https://github.com/apache/flink/pull/12638#issuecomment-643389717 ## CI report: * cf9f0210248a376ecb0e036240dc1afed837b800 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12589: [FLINK-17327] Fix Kafka Producer Resource Leaks

flinkbot edited a comment on pull request #12589: URL: https://github.com/apache/flink/pull/12589#issuecomment-642078835 ## CI report: * 0cd1604b7e3ae2382235c61c8e1a246eb3f584e1 Azure:

[GitHub] [flink-web] rmetzger commented on pull request #346: Create Japanese Edition.

rmetzger commented on pull request #346: URL: https://github.com/apache/flink-web/pull/346#issuecomment-64338 Thanks again for your pull request. I am personally quite excited about the idea of adding Japanese to the list of languages that Flink offers :) As you can see from the

[GitHub] [flink] zhuzhurk commented on pull request #12540: [WIP][FLINK-17016][runtime] Change blink planner batch jobs to run with pipelined region scheduling

zhuzhurk commented on pull request #12540: URL: https://github.com/apache/flink/pull/12540#issuecomment-643388491 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] zhuzhurk removed a comment on pull request #12540: [WIP][FLINK-17016][runtime] Change blink planner batch jobs to run with pipelined region scheduling

zhuzhurk removed a comment on pull request #12540: URL: https://github.com/apache/flink/pull/12540#issuecomment-642443978 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] tillrohrmann commented on a change in pull request #12620: [FLINK-18226][runtime] Fix ActiveResourceManager requesting extra workers on termination of existing workers.

tillrohrmann commented on a change in pull request #12620: URL: https://github.com/apache/flink/pull/12620#discussion_r439463764 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerGateway.java ## @@ -104,13 +104,15 @@

[GitHub] [flink] flinkbot commented on pull request #12638: [FLINK-17977] Improve checkpoint triggering log message

flinkbot commented on pull request #12638: URL: https://github.com/apache/flink/pull/12638#issuecomment-643381179 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] rmetzger opened a new pull request #12638: [FLINK-17977] Improve checkpoint triggering log message

rmetzger opened a new pull request #12638: URL: https://github.com/apache/flink/pull/12638 ## What is the purpose of the change Before this change, it was not possible to distinguish whether a checkpoint is a normal checkpoint or a savepoint. After this change, the logs look as

[GitHub] [flink] flinkbot edited a comment on pull request #12636: [FLINK-17998][hs] Support Flink history server archive size limitation

flinkbot edited a comment on pull request #12636: URL: https://github.com/apache/flink/pull/12636#issuecomment-643369693 ## CI report: * c91fac7a9ceaae8605e7146cdeffa00e2a15e187 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12637: [FLINK-18279][docs] Simplify Table Overview

flinkbot edited a comment on pull request #12637: URL: https://github.com/apache/flink/pull/12637#issuecomment-643369795 ## CI report: * 568eefffd9384c30d022a8bd3f4fd010aebee9e6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12633: [FLINK-18277][elasticsearch] Fix es6 sink identifier

flinkbot edited a comment on pull request #12633: URL: https://github.com/apache/flink/pull/12633#issuecomment-643289026 ## CI report: * 9498ab67e6569d6c2b0a7c9ab45e1db18233e03a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12622: [FLINK-18261][parquet][orc] flink-orc and flink-parquet have invalid NOTICE file

flinkbot edited a comment on pull request #12622: URL: https://github.com/apache/flink/pull/12622#issuecomment-643039828 ## CI report: * 409adc2e3f4e30a3070213da099d3649eb38659e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12577: [FLINK-17599][docs] Update documents due to FLIP-84

flinkbot edited a comment on pull request #12577: URL: https://github.com/apache/flink/pull/12577#issuecomment-641885509 ## CI report: * 5df6fa1b717dd664c1f10c76941636d96937a6ce Azure:

[jira] [Updated] (FLINK-18280) Kotlin adapters for Flink types?

[ https://issues.apache.org/jira/browse/FLINK-18280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marshall Pierce updated FLINK-18280: Description: Currently, using a Kotlin lambda for, say, a {{KeySelector}} doesn't work –

[jira] [Updated] (FLINK-18280) Kotlin adapters for Flink types?

[ https://issues.apache.org/jira/browse/FLINK-18280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marshall Pierce updated FLINK-18280: Description: Currently, using a Kotlin lambda for, say, a {{KeySelector}} doesn't work –

[GitHub] [flink] carp84 commented on pull request #12605: [FLINK-18242][state-backend-rocksdb] Separate RocksDBOptionsFactory from OptionsFactory

carp84 commented on pull request #12605: URL: https://github.com/apache/flink/pull/12605#issuecomment-643373293 @StephanEwen could you take a look here? Thanks. This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-18280) Kotlin adapters for Flink types?

[ https://issues.apache.org/jira/browse/FLINK-18280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marshall Pierce updated FLINK-18280: Description: Currently, using a Kotlin lambda for, say, a {{KeySelector}} doesn't work –

[jira] [Created] (FLINK-18280) Kotlin adapters for Flink types?

Marshall Pierce created FLINK-18280: --- Summary: Kotlin adapters for Flink types? Key: FLINK-18280 URL: https://issues.apache.org/jira/browse/FLINK-18280 Project: Flink Issue Type: Wish

[jira] [Updated] (FLINK-18280) Kotlin adapters for Flink types?

[ https://issues.apache.org/jira/browse/FLINK-18280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marshall Pierce updated FLINK-18280: Description: Currently, using a Kotlin lambda for, say, a {{KeySelector}} doesn't work –

[GitHub] [flink] carp84 commented on pull request #12508: [hotfix][state] Add error message to precondition in KeyGroupPartitio…

carp84 commented on pull request #12508: URL: https://github.com/apache/flink/pull/12508#issuecomment-643371372 @Tartarus0zm Mind clarify in which case you got the exception in description? While adding the error log is good, I'm just curious whether the exception indicates any more

[GitHub] [flink] flinkbot commented on pull request #12637: [FLINK-18279][docs] Simplify Table Overview

flinkbot commented on pull request #12637: URL: https://github.com/apache/flink/pull/12637#issuecomment-643369795 ## CI report: * 568eefffd9384c30d022a8bd3f4fd010aebee9e6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #12636: [FLINK-17998][hs] Support Flink history server archive size limitation

flinkbot commented on pull request #12636: URL: https://github.com/apache/flink/pull/12636#issuecomment-643369693 ## CI report: * c91fac7a9ceaae8605e7146cdeffa00e2a15e187 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12633: [FLINK-18277][elasticsearch] Fix es6 sink identifier

flinkbot edited a comment on pull request #12633: URL: https://github.com/apache/flink/pull/12633#issuecomment-643289026 ## CI report: * 9498ab67e6569d6c2b0a7c9ab45e1db18233e03a Azure:

[GitHub] [flink] carp84 commented on pull request #12514: [FLINK-17800][roksdb] Ensure total order seek to avoid user misuse

carp84 commented on pull request #12514: URL: https://github.com/apache/flink/pull/12514#issuecomment-643363267 > Forwarding my comments from the #12529 PR (the 1.11.0 port of this PR) > > I would suggest that we avoid "parameterized" tests for this. I think this is not a

[jira] [Commented] (FLINK-18209) Replace "charged" words in the Flink codebase.

[ https://issues.apache.org/jira/browse/FLINK-18209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134354#comment-17134354 ] Stephan Ewen commented on FLINK-18209: -- [~AHeise] We can approach this step by step. The "slaves"

[jira] [Commented] (FLINK-7022) Flink Job Manager Scheduler & Web Frontend out of sync when Zookeeper is unavailable on startup

[ https://issues.apache.org/jira/browse/FLINK-7022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134352#comment-17134352 ] Jonathan Foley commented on FLINK-7022: --- I still encounter this issue in Flink 1.10.0. Can this

[jira] [Updated] (FLINK-7022) Flink Job Manager Scheduler & Web Frontend out of sync when Zookeeper is unavailable on startup

[ https://issues.apache.org/jira/browse/FLINK-7022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Foley updated FLINK-7022: -- Attachment: log.txt > Flink Job Manager Scheduler & Web Frontend out of sync when Zookeeper is

[GitHub] [flink] flinkbot commented on pull request #12637: [FLINK-18279][docs] Simplify Table Overview

flinkbot commented on pull request #12637: URL: https://github.com/apache/flink/pull/12637#issuecomment-643358793 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] [Commented] (FLINK-17637) HadoopS3RecoverableWriterITCase fails with Expected exception: java.io.FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-17637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134349#comment-17134349 ] Stephan Ewen commented on FLINK-17637: -- Guowei is right. We need to do something like

[jira] [Commented] (FLINK-17998) Support limiting job history size

[ https://issues.apache.org/jira/browse/FLINK-17998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134348#comment-17134348 ] Daniel Laszlo Magyar commented on FLINK-17998: -- I've just opened the PR

[jira] [Updated] (FLINK-18279) Simplify table overview page

[ https://issues.apache.org/jira/browse/FLINK-18279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18279: --- Labels: pull-request-available (was: ) > Simplify table overview page >

[GitHub] [flink] sjwiesman opened a new pull request #12637: [FLINK-18279][docs] Simplify Table Overview

sjwiesman opened a new pull request #12637: URL: https://github.com/apache/flink/pull/12637 ## What is the purpose of the change Description The table overview page contains an overwhelming amount of information. We should simplify the page so users quickly know: *

[jira] [Commented] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134344#comment-17134344 ] Stephan Ewen commented on FLINK-18091: -- Test looks good, thanks. Verifies that this works from

[GitHub] [flink-web] zjffdu commented on a change in pull request #339: [blog] flink on zeppelin - part1

zjffdu commented on a change in pull request #339: URL: https://github.com/apache/flink-web/pull/339#discussion_r439512677 ## File path: _posts/2020-05-25-flink-on-zeppelin-part1.md ## @@ -0,0 +1,88 @@ +--- +layout: post +title: "Flink on Zeppelin Notebooks for Interactive

[jira] [Created] (FLINK-18279) Simplify table overview page

Seth Wiesman created FLINK-18279: Summary: Simplify table overview page Key: FLINK-18279 URL: https://issues.apache.org/jira/browse/FLINK-18279 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-18278) Translate new documenation homepage

Seth Wiesman created FLINK-18278: Summary: Translate new documenation homepage Key: FLINK-18278 URL: https://issues.apache.org/jira/browse/FLINK-18278 Project: Flink Issue Type: Improvement

[GitHub] [flink] StephanEwen commented on pull request #12514: [FLINK-17800][roksdb] Ensure total order seek to avoid user misuse

StephanEwen commented on pull request #12514: URL: https://github.com/apache/flink/pull/12514#issuecomment-643354823 Forwarding my comments from the #12529 PR (the 1.11.0 port of this PR) I would suggest that we avoid "parameterized" tests for this. I think this is not a

[jira] [Commented] (FLINK-17981) Add new Flink docs homepage content

[ https://issues.apache.org/jira/browse/FLINK-17981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134339#comment-17134339 ] Seth Wiesman commented on FLINK-17981: -- fixed in master: 0b60c1b9e6a405c53cc43a0f16d51adfbb149666

[jira] [Resolved] (FLINK-17981) Add new Flink docs homepage content

[ https://issues.apache.org/jira/browse/FLINK-17981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman resolved FLINK-17981. -- Resolution: Fixed > Add new Flink docs homepage content > ---

[GitHub] [flink] flinkbot commented on pull request #12636: [FLINK-17998][hs] Support Flink history server archive size limitation

flinkbot commented on pull request #12636: URL: https://github.com/apache/flink/pull/12636#issuecomment-643354398 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] sjwiesman closed pull request #12556: [FLINK-17981][docs] rewrite docs home page

sjwiesman closed pull request #12556: URL: https://github.com/apache/flink/pull/12556 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-17998) Support limiting job history size

[ https://issues.apache.org/jira/browse/FLINK-17998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17998: --- Labels: pull-request-available (was: ) > Support limiting job history size >

  1   2   3   4   5   >