[jira] [Commented] (FLINK-14157) Temporarily remove S3 StreamingFileSink end-to-end test

[ https://issues.apache.org/jira/browse/FLINK-14157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936708#comment-16936708 ] Till Rohrmann commented on FLINK-14157: --- I think removing the jaxb dependency made

[jira] [Commented] (FLINK-14059) Introduce option allSourcesInSamePipelinedRegion in ExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-14059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936706#comment-16936706 ] Zhu Zhu commented on FLINK-14059: - Hi [~trohrmann], I'd like to work on this task, could

[jira] [Commented] (FLINK-13748) Streaming File Sink s3 end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936707#comment-16936707 ] Till Rohrmann commented on FLINK-13748: --- I guess that reverting the jaxb dependenc

[GitHub] [flink] AHeise commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

AHeise commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327571012 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/a

[jira] [Created] (FLINK-14197) Increasing trend for state size of keyed stream using ProcessWindowFunction with ProcessingTimeSessionWindows

Oliver Kostera created FLINK-14197: -- Summary: Increasing trend for state size of keyed stream using ProcessWindowFunction with ProcessingTimeSessionWindows Key: FLINK-14197 URL: https://issues.apache.org/jira/bro

[jira] [Closed] (FLINK-14167) Move python-related scripts in flink-dist to flink-python

[ https://issues.apache.org/jira/browse/FLINK-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14167. --- Resolution: Resolved > Move python-related scripts in flink-dist to flink-python > -

[jira] [Resolved] (FLINK-14158) Update Mesos configs to add leaseOfferExpiration and declinedOfferRefuse durations

[ https://issues.apache.org/jira/browse/FLINK-14158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14158. --- Fix Version/s: 1.10.0 Resolution: Done Done via c235253a101d21a089404dc20690b58640686

[jira] [Updated] (FLINK-14158) Update Mesos configs to add leaseOfferExpiration and declinedOfferRefuse durations

[ https://issues.apache.org/jira/browse/FLINK-14158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14158: -- Issue Type: Improvement (was: Bug) > Update Mesos configs to add leaseOfferExpiration and dec

[GitHub] [flink] tillrohrmann closed pull request #9737: [FLINK-14158] Update Mesos scheduler to make leaseOfferExpiration and declinedOfferRefuse duration configurable

tillrohrmann closed pull request #9737: [FLINK-14158] Update Mesos scheduler to make leaseOfferExpiration and declinedOfferRefuse duration configurable URL: https://github.com/apache/flink/pull/9737 This is an automated mess

[jira] [Updated] (FLINK-14167) Move python-related scripts in flink-dist to flink-python

[ https://issues.apache.org/jira/browse/FLINK-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14167: Fix Version/s: 1.10.0 > Move python-related scripts in flink-dist to flink-python > --

[GitHub] [flink] dianfu commented on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python function e

dianfu commented on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python function execution URL: https://github.com/apache/flink/pull/9748#issuecomment-534522102 @sunjincheng121 Thanks a lot

[jira] [Updated] (FLINK-14167) Move python-related scripts in flink-dist to flink-python

[ https://issues.apache.org/jira/browse/FLINK-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14167: Affects Version/s: (was: 1.9.0) > Move python-related scripts in flink-dist to flink-python >

[jira] [Assigned] (FLINK-14158) Update Mesos configs to add leaseOfferExpiration and declinedOfferRefuse durations

[ https://issues.apache.org/jira/browse/FLINK-14158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14158: - Assignee: Piyush Narang > Update Mesos configs to add leaseOfferExpiration and declined

[jira] [Updated] (FLINK-14167) Move python-related scripts in flink-dist to flink-python

[ https://issues.apache.org/jira/browse/FLINK-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14167: Affects Version/s: 1.9.0 > Move python-related scripts in flink-dist to flink-python > ---

[jira] [Commented] (FLINK-14167) Move python-related scripts in flink-dist to flink-python

[ https://issues.apache.org/jira/browse/FLINK-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936698#comment-16936698 ] Hequn Cheng commented on FLINK-14167: - Resolved in 1.10.0 via 44e86178831284524d8151

[jira] [Comment Edited] (FLINK-13748) Streaming File Sink s3 end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936690#comment-16936690 ] Yu Li edited comment on FLINK-13748 at 9/24/19 11:44 AM: - There'

[GitHub] [flink] flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381 ## CI report: * 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] flinkbot edited a comment on issue #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime

flinkbot edited a comment on issue #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime URL: https://github.com/apache/flink/pull/9745#issuecomment-534005398 ## CI report: * d4ab076561b7d4d88347d55a1764d2a6d57507c3 : FAILURE [Build](https://tra

[GitHub] [flink] flinkbot edited a comment on issue #9743: [hotfix][coordination] Fix MiniCluster#closeAsync to correctly close all components and services

flinkbot edited a comment on issue #9743: [hotfix][coordination] Fix MiniCluster#closeAsync to correctly close all components and services URL: https://github.com/apache/flink/pull/9743#issuecomment-533978420 ## CI report: * 0ff3661a4946c47acc4ea362a869b9885e5712b6 : SUCCESS [Bu

[jira] [Comment Edited] (FLINK-14178) maven-shade-plugin 3.2.1 doesn't work on ARM for Flink

[ https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936693#comment-16936693 ] Dian Fu edited comment on FLINK-14178 at 9/24/19 11:36 AM: --- Hi

[jira] [Comment Edited] (FLINK-14178) maven-shade-plugin 3.2.1 doesn't work on ARM for Flink

[ https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936693#comment-16936693 ] Dian Fu edited comment on FLINK-14178 at 9/24/19 11:35 AM: --- Hi

[GitHub] [flink] hequn8128 closed pull request #9746: [FLINK-14167][python] Move python-related scripts from flink-dist to flink-python.

hequn8128 closed pull request #9746: [FLINK-14167][python] Move python-related scripts from flink-dist to flink-python. URL: https://github.com/apache/flink/pull/9746 This is an automated message from the Apache Git Service.

[jira] [Commented] (FLINK-14178) maven-shade-plugin 3.2.1 doesn't work on ARM for Flink

[ https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936693#comment-16936693 ] Dian Fu commented on FLINK-14178: - Hi [~wangxiyuan], Thanks a lot for your great work.

[jira] [Commented] (FLINK-13748) Streaming File Sink s3 end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936690#comment-16936690 ] Yu Li commented on FLINK-13748: --- There're some probably related issues, FYI: FLINK-14186,

[jira] [Deleted] (FLINK-13844) AtOmXpLuS

[ https://issues.apache.org/jira/browse/FLINK-13844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Thomas deleted FLINK-13844: > AtOmXpLuS > - > > Key: FLINK-13844 > URL: https://issues.ap

[jira] [Deleted] (FLINK-14056) AtOm+Electron+TypedE-Mail

[ https://issues.apache.org/jira/browse/FLINK-14056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Thomas deleted FLINK-14056: > AtOm+Electron+TypedE-Mail > - > > Key: FLINK-14056 >

[jira] [Created] (FLINK-14196) Nightly e2e-sticky-hadoop2.8 fails due to NPE

Yu Li created FLINK-14196: - Summary: Nightly e2e-sticky-hadoop2.8 fails due to NPE Key: FLINK-14196 URL: https://issues.apache.org/jira/browse/FLINK-14196 Project: Flink Issue Type: Bug Com

[jira] [Created] (FLINK-14195) Nightly connectors-jdk11 fails because of missing jaxb classes

Yu Li created FLINK-14195: - Summary: Nightly connectors-jdk11 fails because of missing jaxb classes Key: FLINK-14195 URL: https://issues.apache.org/jira/browse/FLINK-14195 Project: Flink Issue Type:

[jira] [Created] (FLINK-14194) Clean-up of legacy mode.

Xintong Song created FLINK-14194: Summary: Clean-up of legacy mode. Key: FLINK-14194 URL: https://issues.apache.org/jira/browse/FLINK-14194 Project: Flink Issue Type: Sub-task Rep

[jira] [Created] (FLINK-14193) Update RestAPI / Web UI

Xintong Song created FLINK-14193: Summary: Update RestAPI / Web UI Key: FLINK-14193 URL: https://issues.apache.org/jira/browse/FLINK-14193 Project: Flink Issue Type: Sub-task Repo

[jira] [Created] (FLINK-14191) Extend SlotManager to support dynamic slot allocation on pending task executors

Xintong Song created FLINK-14191: Summary: Extend SlotManager to support dynamic slot allocation on pending task executors Key: FLINK-14191 URL: https://issues.apache.org/jira/browse/FLINK-14191 Proje

[jira] [Created] (FLINK-14190) Extend SlotManager to support dynamic slot allocation on registered TaskExecutors.

Xintong Song created FLINK-14190: Summary: Extend SlotManager to support dynamic slot allocation on registered TaskExecutors. Key: FLINK-14190 URL: https://issues.apache.org/jira/browse/FLINK-14190 Pr

[jira] [Created] (FLINK-14192) Enable the dynamic slot allocation feature.

Xintong Song created FLINK-14192: Summary: Enable the dynamic slot allocation feature. Key: FLINK-14192 URL: https://issues.apache.org/jira/browse/FLINK-14192 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-14188) TaskExecutor derive and register with default slot resource profile

Xintong Song created FLINK-14188: Summary: TaskExecutor derive and register with default slot resource profile Key: FLINK-14188 URL: https://issues.apache.org/jira/browse/FLINK-14188 Project: Flink

[jira] [Created] (FLINK-14189) Extend TaskExecutor to support dynamic slot allocation

Xintong Song created FLINK-14189: Summary: Extend TaskExecutor to support dynamic slot allocation Key: FLINK-14189 URL: https://issues.apache.org/jira/browse/FLINK-14189 Project: Flink Issue

[jira] [Created] (FLINK-14187) FLIP-56 Dynamic Slot Allocation

Xintong Song created FLINK-14187: Summary: FLIP-56 Dynamic Slot Allocation Key: FLINK-14187 URL: https://issues.apache.org/jira/browse/FLINK-14187 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-14186) Nightly e2e-misc-jdk11 fails complaining unrecognized VM option

Yu Li created FLINK-14186: - Summary: Nightly e2e-misc-jdk11 fails complaining unrecognized VM option Key: FLINK-14186 URL: https://issues.apache.org/jira/browse/FLINK-14186 Project: Flink Issue Type

[GitHub] [flink] flinkbot edited a comment on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server.

flinkbot edited a comment on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server. URL: https://github.com/apache/flink/pull/9758#issuecomment-534506161 ## CI report: * 028ca1a6dd16e5f9ac8e7090d5583f5b9a724cb2 : PENDING [Build]

[GitHub] [flink] TisonKun commented on a change in pull request #9743: [hotfix][coordination] Fix MiniCluster#closeAsync to correctly close all components and services

TisonKun commented on a change in pull request #9743: [hotfix][coordination] Fix MiniCluster#closeAsync to correctly close all components and services URL: https://github.com/apache/flink/pull/9743#discussion_r327558251 ## File path: flink-runtime/src/main/java/org/apache/flink/run

[GitHub] [flink] flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-534149758 ## CI report: * 141eb6db531af4b12a9506489f280f180c02a408 : FAILURE [Build](https://travis-ci.co

[jira] [Comment Edited] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936671#comment-16936671 ] Zhu Zhu edited comment on FLINK-14164 at 9/24/19 11:10 AM: --- >>

[jira] [Commented] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936671#comment-16936671 ] Zhu Zhu commented on FLINK-14164: - >> So maybe we could say that fullRestart is actually

[GitHub] [flink] flinkbot edited a comment on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly

flinkbot edited a comment on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly URL: https://github.com/apache/flink/pull/9719#issuecomment-533096961 ## CI report: * c4a475ad50edd91fb1189f57651734f3a3df3508 : SUCCESS [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9681: [FLINK-13450][test] Adjust tests to tolerate arithmetic differences between x86 and ARM

flinkbot edited a comment on issue #9681: [FLINK-13450][test] Adjust tests to tolerate arithmetic differences between x86 and ARM URL: https://github.com/apache/flink/pull/9681#issuecomment-531682914 ## CI report: * 41a6a987d8a5ea52e0b2104a552c2bd38a0af3aa : FAILURE [Build](http

[GitHub] [flink] TisonKun commented on a change in pull request #9743: [hotfix][coordination] Wait for completion of MiniCluster#terminateExecutors

TisonKun commented on a change in pull request #9743: [hotfix][coordination] Wait for completion of MiniCluster#terminateExecutors URL: https://github.com/apache/flink/pull/9743#discussion_r327552955 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/Min

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327552339 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327551382 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327551424 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327551484 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327551509 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327551549 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327551609 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327551336 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] flinkbot commented on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server.

flinkbot commented on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server. URL: https://github.com/apache/flink/pull/9758#issuecomment-534506161 ## CI report: * 028ca1a6dd16e5f9ac8e7090d5583f5b9a724cb2 : UNKNOWN --

[GitHub] [flink] flinkbot edited a comment on issue #9757: [FLINK-14183][runtime] Remove unnecessary scala Duration usages in flink-runtime

flinkbot edited a comment on issue #9757: [FLINK-14183][runtime] Remove unnecessary scala Duration usages in flink-runtime URL: https://github.com/apache/flink/pull/9757#issuecomment-534477715 ## CI report: * 665c10facbe808e8437f4ca4534e00173e5a1240 : FAILURE [Build](https://tra

[GitHub] [flink] flinkbot edited a comment on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly

flinkbot edited a comment on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly URL: https://github.com/apache/flink/pull/9719#issuecomment-533096961 ## CI report: * c4a475ad50edd91fb1189f57651734f3a3df3508 : SUCCESS [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9681: [FLINK-13450][test] Adjust tests to tolerate arithmetic differences between x86 and ARM

flinkbot edited a comment on issue #9681: [FLINK-13450][test] Adjust tests to tolerate arithmetic differences between x86 and ARM URL: https://github.com/apache/flink/pull/9681#issuecomment-531682914 ## CI report: * 41a6a987d8a5ea52e0b2104a552c2bd38a0af3aa : FAILURE [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381 ## CI report: * 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] flinkbot commented on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server.

flinkbot commented on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server. URL: https://github.com/apache/flink/pull/9758#issuecomment-534500882 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help th

[jira] [Updated] (FLINK-14185) AbstractServerTest failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14185: --- Labels: pull-request-available (was: ) > AbstractServerTest failed on Travis >

[GitHub] [flink] wsry opened a new pull request #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server.

wsry opened a new pull request #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server. URL: https://github.com/apache/flink/pull/9758 ## What is the purpose of the change The purpose of this pr is to fix the unstable test case AbstractServe

[GitHub] [flink] flinkbot edited a comment on issue #9757: [FLINK-14183][runtime] Remove unnecessary scala Duration usages in flink-runtime

flinkbot edited a comment on issue #9757: [FLINK-14183][runtime] Remove unnecessary scala Duration usages in flink-runtime URL: https://github.com/apache/flink/pull/9757#issuecomment-534477715 ## CI report: * 665c10facbe808e8437f4ca4534e00173e5a1240 : FAILURE [Build](https://tra

[GitHub] [flink] flinkbot edited a comment on issue #9756: [backport to 1.9][FLINK-14145] Fix getLatestCheckpoint(true) returns wrong checkpoint

flinkbot edited a comment on issue #9756: [backport to 1.9][FLINK-14145] Fix getLatestCheckpoint(true) returns wrong checkpoint URL: https://github.com/apache/flink/pull/9756#issuecomment-534477677 ## CI report: * 1d4e1e431334c98b5a1a1a4bc519dedab9b0f71a : SUCCESS [Build](https:

[jira] [Commented] (FLINK-14168) Remove unused BootstrapTools#generateTaskManagerConfiguration

[ https://issues.apache.org/jira/browse/FLINK-14168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936655#comment-16936655 ] Maximilian Michels commented on FLINK-14168: The code was indeed not used at

[GitHub] [flink] flinkbot edited a comment on issue #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime

flinkbot edited a comment on issue #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime URL: https://github.com/apache/flink/pull/9745#issuecomment-534005398 ## CI report: * d4ab076561b7d4d88347d55a1764d2a6d57507c3 : FAILURE [Build](https://tra

[GitHub] [flink] wangxiyuan commented on issue #9681: [FLINK-13450][test] Adjust tests to tolerate arithmetic differences between x86 and ARM

wangxiyuan commented on issue #9681: [FLINK-13450][test] Adjust tests to tolerate arithmetic differences between x86 and ARM URL: https://github.com/apache/flink/pull/9681#issuecomment-534496310 @StephanEwen Thanks for your review. ThenI just change the place where affect the test. -

[GitHub] [flink] flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381 ## CI report: * 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] TisonKun commented on a change in pull request #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly

TisonKun commented on a change in pull request #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly URL: https://github.com/apache/flink/pull/9719#discussion_r327536119 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/ent

[GitHub] [flink] flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-534149758 ## CI report: * 141eb6db531af4b12a9506489f280f180c02a408 : FAILURE [Build](https://travis-ci.co

[GitHub] [flink] flinkbot edited a comment on issue #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime

flinkbot edited a comment on issue #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime URL: https://github.com/apache/flink/pull/9745#issuecomment-534005398 ## CI report: * d4ab076561b7d4d88347d55a1764d2a6d57507c3 : FAILURE [Build](https://tra

[GitHub] [flink] TisonKun commented on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly

TisonKun commented on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly URL: https://github.com/apache/flink/pull/9719#issuecomment-534492273 Thanks for your insight @tillrohrmann. I put on the version causing fatal error in `YarnResourceM

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327532862 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ##

[jira] [Commented] (FLINK-11374) See more failover and can filter by time range

[ https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936644#comment-16936644 ] Till Rohrmann commented on FLINK-11374: --- Yes, we can make {{MAX_NUMBER_EXCEPTION_T

[GitHub] [flink] tillrohrmann commented on a change in pull request #9743: [hotfix][coordination] Wait for completion of MiniCluster#terminateExecutors

tillrohrmann commented on a change in pull request #9743: [hotfix][coordination] Wait for completion of MiniCluster#terminateExecutors URL: https://github.com/apache/flink/pull/9743#discussion_r327531469 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327531754 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ##

[jira] [Commented] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936639#comment-16936639 ] Till Rohrmann commented on FLINK-14164: --- I think you are right that with the new f

[GitHub] [flink] flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381 ## CI report: * 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327529268 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotProvider.java

[GitHub] [flink] flinkbot edited a comment on issue #9756: [backport to 1.9][FLINK-14145] Fix getLatestCheckpoint(true) returns wrong checkpoint

flinkbot edited a comment on issue #9756: [backport to 1.9][FLINK-14145] Fix getLatestCheckpoint(true) returns wrong checkpoint URL: https://github.com/apache/flink/pull/9756#issuecomment-534477677 ## CI report: * 1d4e1e431334c98b5a1a1a4bc519dedab9b0f71a : PENDING [Build](https:

[GitHub] [flink] flinkbot edited a comment on issue #9755: [FLINK-14168][runtime] Remove unused BootstrapTools#generateTaskManagerConfiguration

flinkbot edited a comment on issue #9755: [FLINK-14168][runtime] Remove unused BootstrapTools#generateTaskManagerConfiguration URL: https://github.com/apache/flink/pull/9755#issuecomment-534461186 ## CI report: * 66f1bf8e65fae825523a7e8b826c8add9ed40f82 : SUCCESS [Build](https:/

[GitHub] [flink] flinkbot edited a comment on issue #9757: [FLINK-14183][runtime] Remove unnecessary scala Duration usages in flink-runtime

flinkbot edited a comment on issue #9757: [FLINK-14183][runtime] Remove unnecessary scala Duration usages in flink-runtime URL: https://github.com/apache/flink/pull/9757#issuecomment-534477715 ## CI report: * 665c10facbe808e8437f4ca4534e00173e5a1240 : FAILURE [Build](https://tra

[GitHub] [flink] flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-534149758 ## CI report: * 141eb6db531af4b12a9506489f280f180c02a408 : FAILURE [Build](https://travis-ci.co

[jira] [Resolved] (FLINK-14168) Remove unused BootstrapTools#generateTaskManagerConfiguration

[ https://issues.apache.org/jira/browse/FLINK-14168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14168. --- Resolution: Done Done via fee61e1c4ff08ff956735247c8fbd08239c9487d > Remove unused Bootstra

[GitHub] [flink] tillrohrmann closed pull request #9755: [FLINK-14168][runtime] Remove unused BootstrapTools#generateTaskManagerConfiguration

tillrohrmann closed pull request #9755: [FLINK-14168][runtime] Remove unused BootstrapTools#generateTaskManagerConfiguration URL: https://github.com/apache/flink/pull/9755 This is an automated message from the Apache Git Ser

[jira] [Resolved] (FLINK-14182) Make TimeUtils able to parse duration string with plural form labels

[ https://issues.apache.org/jira/browse/FLINK-14182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14182. --- Resolution: Done Done via b3722800586780670a4f3e059c9c36ce10b7c839 > Make TimeUtils able to

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327524238 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[GitHub] [flink] tillrohrmann closed pull request #9754: [FLINK-14182][core] Make TimeUtils able to parse duration string with plural form labels

tillrohrmann closed pull request #9754: [FLINK-14182][core] Make TimeUtils able to parse duration string with plural form labels URL: https://github.com/apache/flink/pull/9754 This is an automated message from the Apache Git

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327524488 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java #

[jira] [Created] (FLINK-14185) AbstractServerTest failed on Travis

Yingjie Cao created FLINK-14185: --- Summary: AbstractServerTest failed on Travis Key: FLINK-14185 URL: https://issues.apache.org/jira/browse/FLINK-14185 Project: Flink Issue Type: Bug C

[GitHub] [flink] sunjincheng121 commented on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python fu

sunjincheng121 commented on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python function execution URL: https://github.com/apache/flink/pull/9748#issuecomment-534481069 Thanks a lot for yo

[GitHub] [flink] tillrohrmann commented on a change in pull request #9737: [FLINK-14158] Update Mesos scheduler to make leaseOfferExpiration and declinedOfferRefuse duration configurable

tillrohrmann commented on a change in pull request #9737: [FLINK-14158] Update Mesos scheduler to make leaseOfferExpiration and declinedOfferRefuse duration configurable URL: https://github.com/apache/flink/pull/9737#discussion_r327519095 ## File path: flink-mesos/src/main/java/or

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327518481 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/NeverRe

[GitHub] [flink] flinkbot commented on issue #9756: [backport to 1.9][FLINK-14145] Fix getLatestCheckpoint(true) returns wrong checkpoint

flinkbot commented on issue #9756: [backport to 1.9][FLINK-14145] Fix getLatestCheckpoint(true) returns wrong checkpoint URL: https://github.com/apache/flink/pull/9756#issuecomment-534477677 ## CI report: * 1d4e1e431334c98b5a1a1a4bc519dedab9b0f71a : UNKNOWN -

[GitHub] [flink] flinkbot commented on issue #9757: [FLINK-14183][runtime] Remove unnecessary scala Duration usages in flink-runtime

flinkbot commented on issue #9757: [FLINK-14183][runtime] Remove unnecessary scala Duration usages in flink-runtime URL: https://github.com/apache/flink/pull/9757#issuecomment-534477715 ## CI report: * 665c10facbe808e8437f4ca4534e00173e5a1240 : UNKNOWN --

[GitHub] [flink] flinkbot edited a comment on issue #9754: [FLINK-14182][core] Make TimeUtils able to parse duration string with plural form labels

flinkbot edited a comment on issue #9754: [FLINK-14182][core] Make TimeUtils able to parse duration string with plural form labels URL: https://github.com/apache/flink/pull/9754#issuecomment-534452743 ## CI report: * 95c46083a6afaa0a71de01efd1664252a6f0cf7b : SUCCESS [Build](htt

[GitHub] [flink] flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-534387866 ## CI report: * 5b73b3d6319447fd2d81b48183d9f22012133a6b : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/

[GitHub] [flink] flinkbot edited a comment on issue #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime

flinkbot edited a comment on issue #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime URL: https://github.com/apache/flink/pull/9745#issuecomment-534005398 ## CI report: * d4ab076561b7d4d88347d55a1764d2a6d57507c3 : FAILURE [Build](https://tra

[GitHub] [flink] tillrohrmann commented on a change in pull request #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly

tillrohrmann commented on a change in pull request #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly URL: https://github.com/apache/flink/pull/9719#discussion_r327514563 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime

[jira] [Comment Edited] (FLINK-14173) ANSI-style JOIN with Temporal Table Function fails

[ https://issues.apache.org/jira/browse/FLINK-14173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936597#comment-16936597 ] Benoît Paris edited comment on FLINK-14173 at 9/24/19 9:25 AM: ---

[jira] [Commented] (FLINK-14173) ANSI-style JOIN with Temporal Table Function fails

[ https://issues.apache.org/jira/browse/FLINK-14173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936597#comment-16936597 ] Benoît Paris commented on FLINK-14173: -- Hi [~jark]! I was so sure I used the ANSI-

<    1   2   3   4   5   >