[jira] [Commented] (FLINK-9182) async checkpoints for timer service

[ https://issues.apache.org/jira/browse/FLINK-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470209#comment-16470209 ] ASF GitHub Bot commented on FLINK-9182: --- Github user makeyang commented on a diff in the pull

[jira] [Commented] (FLINK-9325) generate the _meta file for checkpoint only when the writing is truly successful

[ https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470221#comment-16470221 ] ASF GitHub Bot commented on FLINK-9325: --- Github user sihuazhou commented on the issue:

[GitHub] flink issue #5982: [FLINK-9325][checkpoint]generate the meta file for checkp...

Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5982 Hi @StephanEwen Could you please have a look at this? ---

[jira] [Created] (FLINK-9330) Improve logging of SlotPool for debugging purposes

Till Rohrmann created FLINK-9330: Summary: Improve logging of SlotPool for debugging purposes Key: FLINK-9330 URL: https://issues.apache.org/jira/browse/FLINK-9330 Project: Flink Issue Type:

[GitHub] flink pull request #5980: [FLINK-9324] Wait for slot release before completi...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5980#discussion_r187305983 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SingleLogicalSlot.java --- @@ -159,10 +159,51 @@ public

[GitHub] flink pull request #5983: [FLINK-7789][DataStream API] Add handler for Async...

GitHub user kisimple opened a pull request: https://github.com/apache/flink/pull/5983 [FLINK-7789][DataStream API] Add handler for Async IO operator timeouts ## What is the purpose of the change *Currently Async IO operator does not provide a mechanism to handle timeouts.

[jira] [Commented] (FLINK-7789) Add handler for Async IO operator timeouts

[ https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470100#comment-16470100 ] ASF GitHub Bot commented on FLINK-7789: --- GitHub user kisimple opened a pull request:

[GitHub] flink pull request #5979: [FLINK-9070][state]improve the performance of Rock...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5979#discussion_r187278034 --- Diff: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java --- @@ -356,6

[GitHub] flink issue #3359: [FLINK-5544][streaming] Add InternalTimerService implemen...

Github user shixiaogang commented on the issue: https://github.com/apache/flink/pull/3359 Because the old code is too outdated, I have updated the PR, reimplementing RocksDBInternalTimerService from scratch. Some problems mentioned in the previous comments may still exist, but I

[jira] [Commented] (FLINK-5544) Implement Internal Timer Service in RocksDB

[ https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470133#comment-16470133 ] ASF GitHub Bot commented on FLINK-5544: --- Github user shixiaogang commented on the issue:

[jira] [Created] (FLINK-9328) RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs

Yun Tang created FLINK-9328: --- Summary: RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs Key: FLINK-9328 URL:

[jira] [Updated] (FLINK-9329) hasRowtimeAttribute will throw NPE if user use setProctimeAttribute for table source

[ https://issues.apache.org/jira/browse/FLINK-9329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuemeng updated FLINK-9329: --- Description: {code:java} KafkaTableSource source = Kafka010JsonTableSource.builder()

[GitHub] flink pull request #5984: [FLINK-9328][state] Fix RocksDBStateBackend restor...

GitHub user Myasuka opened a pull request: https://github.com/apache/flink/pull/5984 [FLINK-9328][state] Fix RocksDBStateBackend restore problem due to StateBackendTestBase not registering snapshots ## What is the purpose of the change Currently, StateBackendTestBase

[GitHub] flink pull request #5908: [FLINK-9182]async checkpoints for timer service

Github user makeyang commented on a diff in the pull request: https://github.com/apache/flink/pull/5908#discussion_r187296892 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimer.java --- @@ -97,6 +105,32 @@ public String toString()

[jira] [Commented] (FLINK-9324) SingleLogicalSlot returns completed release future before slot is properly returned

[ https://issues.apache.org/jira/browse/FLINK-9324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470247#comment-16470247 ] ASF GitHub Bot commented on FLINK-9324: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Assigned] (FLINK-8518) Support DOW, EPOCH, DECADE for EXTRACT

[ https://issues.apache.org/jira/browse/FLINK-8518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-8518: -- Assignee: Sergey Nuyanzin > Support DOW, EPOCH, DECADE for EXTRACT >

[jira] [Commented] (FLINK-9329) hasRowtimeAttribute will throw NPE if user use setProctimeAttribute for table source

[ https://issues.apache.org/jira/browse/FLINK-9329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470152#comment-16470152 ] yuqi commented on FLINK-9329: - More description are wanted [~yuemeng] > hasRowtimeAttribute will throw NPE if

[jira] [Commented] (FLINK-8518) Support DOW, EPOCH, DECADE for EXTRACT

[ https://issues.apache.org/jira/browse/FLINK-8518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470154#comment-16470154 ] Sergey Nuyanzin commented on FLINK-8518: Hello [~twalthr] I think I could take however I have a

[jira] [Commented] (FLINK-9328) RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs

[ https://issues.apache.org/jira/browse/FLINK-9328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470165#comment-16470165 ] ASF GitHub Bot commented on FLINK-9328: --- GitHub user Myasuka opened a pull request:

[GitHub] flink pull request #5908: [FLINK-9182]async checkpoints for timer service

Github user makeyang commented on a diff in the pull request: https://github.com/apache/flink/pull/5908#discussion_r187297365 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java --- @@ -395,36 +402,102 @@ public final

[jira] [Commented] (FLINK-9182) async checkpoints for timer service

[ https://issues.apache.org/jira/browse/FLINK-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470206#comment-16470206 ] ASF GitHub Bot commented on FLINK-9182: --- Github user makeyang commented on a diff in the pull

[jira] [Commented] (FLINK-9326) TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode

[ https://issues.apache.org/jira/browse/FLINK-9326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470243#comment-16470243 ] Till Rohrmann commented on FLINK-9326: -- You're right [~Sam_D]. That way the user experience out of

[GitHub] flink pull request #5908: [FLINK-9182]async checkpoints for timer service

Github user makeyang commented on a diff in the pull request: https://github.com/apache/flink/pull/5908#discussion_r187294295 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimer.java --- @@ -39,11 +40,18 @@ private final

[GitHub] flink pull request #5908: [FLINK-9182]async checkpoints for timer service

Github user makeyang commented on a diff in the pull request: https://github.com/apache/flink/pull/5908#discussion_r187294255 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java --- @@ -49,13 +50,13 @@ /**

[jira] [Commented] (FLINK-9182) async checkpoints for timer service

[ https://issues.apache.org/jira/browse/FLINK-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470189#comment-16470189 ] ASF GitHub Bot commented on FLINK-9182: --- Github user makeyang commented on a diff in the pull

[jira] [Commented] (FLINK-9182) async checkpoints for timer service

[ https://issues.apache.org/jira/browse/FLINK-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470191#comment-16470191 ] ASF GitHub Bot commented on FLINK-9182: --- Github user makeyang commented on a diff in the pull

[GitHub] flink pull request #5980: [FLINK-9324] Wait for slot release before completi...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5980#discussion_r187306715 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SingleLogicalSlot.java --- @@ -159,10 +159,51 @@ public

[jira] [Commented] (FLINK-9324) SingleLogicalSlot returns completed release future before slot is properly returned

[ https://issues.apache.org/jira/browse/FLINK-9324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470248#comment-16470248 ] ASF GitHub Bot commented on FLINK-9324: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear()

[ https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470129#comment-16470129 ] ASF GitHub Bot commented on FLINK-9070: --- Github user sihuazhou commented on a diff in the pull

[jira] [Created] (FLINK-9329) hasRowtimeAttribute will throw NPE if user use setProctimeAttribute for table source

yuemeng created FLINK-9329: -- Summary: hasRowtimeAttribute will throw NPE if user use setProctimeAttribute for table source Key: FLINK-9329 URL: https://issues.apache.org/jira/browse/FLINK-9329 Project:

[jira] [Comment Edited] (FLINK-8518) Support DOW, EPOCH, DECADE for EXTRACT

[ https://issues.apache.org/jira/browse/FLINK-8518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470154#comment-16470154 ] Sergey Nuyanzin edited comment on FLINK-8518 at 5/10/18 9:45 AM: - Hello

[jira] [Updated] (FLINK-9329) hasRowtimeAttribute will throw NPE if user use setProctimeAttribute for table source

[ https://issues.apache.org/jira/browse/FLINK-9329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuemeng updated FLINK-9329: --- Description: {code:java} Examples: KafkaTableSource source = Kafka010JsonTableSource.builder()

[GitHub] flink pull request #5980: [FLINK-9324] Wait for slot release before completi...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5980#discussion_r187307945 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SingleLogicalSlot.java --- @@ -159,10 +159,51 @@ public

[jira] [Commented] (FLINK-9324) SingleLogicalSlot returns completed release future before slot is properly returned

[ https://issues.apache.org/jira/browse/FLINK-9324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470253#comment-16470253 ] ASF GitHub Bot commented on FLINK-9324: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470259#comment-16470259 ] ASF GitHub Bot commented on FLINK-8946: --- Github user yanghua commented on the issue:

[jira] [Closed] (FLINK-8284) Explicitly mention port conflicts in reporter docs

[ https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8284. --- Resolution: Fixed Fix Version/s: 1.4.3 1.5.0 master:

[jira] [Closed] (FLINK-9125) MiniClusterResource should set CoreOptions.TMP_DIRS

[ https://issues.apache.org/jira/browse/FLINK-9125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9125. --- Resolution: Fixed Fix Version/s: 1.5.0 master:

[jira] [Closed] (FLINK-9282) Update quickstart page

[ https://issues.apache.org/jira/browse/FLINK-9282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9282. --- Resolution: Fixed master: ea4a04799e447f2a5f8d9600a28dd8d1b8a1a0f5 1.5:

[GitHub] flink pull request #5974: [FLINK-9319][docs] Move reflection dependencies in...

Github user zentol closed the pull request at: https://github.com/apache/flink/pull/5974 ---

[GitHub] flink pull request #5985: [FLINK-8135][docs] Add description to MessageParam...

GitHub user andrew-half opened a pull request: https://github.com/apache/flink/pull/5985 [FLINK-8135][docs] Add description to MessageParameter ## This pull request adds methods for auto-documenting REST API. Introduced getDescription() method will generate path and query

[jira] [Closed] (FLINK-9319) Move some flink-docs dependencies into profiles

[ https://issues.apache.org/jira/browse/FLINK-9319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9319. --- Resolution: Won't Fix The dependencies are also necessary for executing tests. > Move some

[jira] [Commented] (FLINK-9319) Move some flink-docs dependencies into profiles

[ https://issues.apache.org/jira/browse/FLINK-9319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470296#comment-16470296 ] ASF GitHub Bot commented on FLINK-9319: --- Github user zentol closed the pull request at:

[jira] [Closed] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled

[ https://issues.apache.org/jira/browse/FLINK-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9261. Resolution: Fixed Fixed via master: 3afa5eb3c4 1.5.0: a357bedede > Regression - Flink CLI and Web

[jira] [Commented] (FLINK-9289) Parallelism of generated operators should have max parallism of input

[ https://issues.apache.org/jira/browse/FLINK-9289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470460#comment-16470460 ] Xingcan Cui commented on FLINK-9289: Hi [~fhueske], I checked the sub-classes of

[GitHub] flink pull request #5856: [FLINK-9179] [conf] Fix deduplicate WebOptions.POR...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5856 ---

[jira] [Commented] (FLINK-8649) Scala StreamExecutionEnvironment.createInput should pass on the TypeInfo

[ https://issues.apache.org/jira/browse/FLINK-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470264#comment-16470264 ] ASF GitHub Bot commented on FLINK-8649: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9179) Deduplicate WebOptions.PORT and RestOptions.REST_PORT

[ https://issues.apache.org/jira/browse/FLINK-9179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470269#comment-16470269 ] ASF GitHub Bot commented on FLINK-9179: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4809: [FLINK-7803][Documentation] Add missing savepoint ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4809 ---

[GitHub] flink pull request #5907: [FLINK-8912][WebUI] Update error handling for flip...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5907 ---

[GitHub] flink pull request #5936: [FLINK-9265] Upgrade Prometheus version

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5936 ---

[jira] [Commented] (FLINK-7856) Port JobVertexBackPressureHandler to REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470265#comment-16470265 ] ASF GitHub Bot commented on FLINK-7856: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-9141) Calling getSideOutput() and split() on one DataStream causes NPE

[ https://issues.apache.org/jira/browse/FLINK-9141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9141. --- Resolution: Fixed master: b32ad44f7b6d9053aefa3c9db7a9328b1571b19c 1.5:

[jira] [Closed] (FLINK-9318) Mark ConfigOptionsDocsCompletenessTest as IT case

[ https://issues.apache.org/jira/browse/FLINK-9318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9318. --- Resolution: Fixed master: 0ff88b0e8da5cae764510edfb226947e4ba52b83 1.5:

[jira] [Closed] (FLINK-9331) MesosResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9331. Resolution: Fixed Fixed via master: 1b1122fce18eaba4cc3539708fa555dbeafe88b5 1.5.0:

[GitHub] flink pull request #5986: [FLINK-9331] [mesos] Let MesosResourceManager requ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5986 ---

[jira] [Resolved] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9190. -- Resolution: Fixed Fixed via master: fa11015ddcdb0217da6a8b2be1e2a55efd26d7fa 1.5.0:

[jira] [Closed] (FLINK-9330) Improve logging of SlotPool for debugging purposes

[ https://issues.apache.org/jira/browse/FLINK-9330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9330. Resolution: Fixed Fixed via master: 6b892a6394a3e8e99dbc9b24276edafa2c8285e1 1.5.0:

[jira] [Closed] (FLINK-9324) SingleLogicalSlot returns completed release future before slot is properly returned

[ https://issues.apache.org/jira/browse/FLINK-9324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9324. Resolution: Fixed Fixed via master: c7eb6acaf95a6656ec6bd0a0b401c1944473e7f2 1.5.0:

[jira] [Commented] (FLINK-9331) MesosResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470448#comment-16470448 ] ASF GitHub Bot commented on FLINK-9331: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470446#comment-16470446 ] ASF GitHub Bot commented on FLINK-9190: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9324) SingleLogicalSlot returns completed release future before slot is properly returned

[ https://issues.apache.org/jira/browse/FLINK-9324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470447#comment-16470447 ] ASF GitHub Bot commented on FLINK-9324: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-9323) Move checkstyle configuration to plugin management

[ https://issues.apache.org/jira/browse/FLINK-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9323. --- Resolution: Fixed master: 3495b4d2560f176907ba51e7b1576b763a2b8b6c 1.5:

[jira] [Closed] (FLINK-9265) Upgrade Prometheus version

[ https://issues.apache.org/jira/browse/FLINK-9265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9265. --- Resolution: Fixed master:725c0563fa3e65b17ea4ca11d0c8bc62d038e582 1.5:

[jira] [Closed] (FLINK-8134) Add description to MessageHeaders

[ https://issues.apache.org/jira/browse/FLINK-8134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8134. --- Resolution: Fixed master: f126ac2089fece4cf94c3bd833cf18a5950e595f 1.5:

[jira] [Closed] (FLINK-9321) Rename SubtasksAllAccumulatorsHandlers

[ https://issues.apache.org/jira/browse/FLINK-9321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9321. --- Resolution: Fixed master: ee3ae3745345db4a6264fdba64b52770879a0a7e 1.5:

[jira] [Closed] (FLINK-9317) Async I/O API Example For Scala has Variable Name error

[ https://issues.apache.org/jira/browse/FLINK-9317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9317. --- Resolution: Fixed Fix Version/s: 1.4.3 1.5.0 master:

[jira] [Updated] (FLINK-9317) Async I/O API Example For Scala has Variable Name error

[ https://issues.apache.org/jira/browse/FLINK-9317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9317: Affects Version/s: (was: 1.4.1) > Async I/O API Example For Scala has Variable Name

[jira] [Closed] (FLINK-9309) Recommend HA setup on Production Readiness Checklist

[ https://issues.apache.org/jira/browse/FLINK-9309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9309. --- Resolution: Fixed Fix Version/s: 1.5.0 master:

[jira] [Created] (FLINK-9331) MesosResourceManager sometimes does not request new Containers

Till Rohrmann created FLINK-9331: Summary: MesosResourceManager sometimes does not request new Containers Key: FLINK-9331 URL: https://issues.apache.org/jira/browse/FLINK-9331 Project: Flink

[jira] [Commented] (FLINK-9331) MesosResourceManager sometimes does not request new Containers

[ https://issues.apache.org/jira/browse/FLINK-9331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470392#comment-16470392 ] ASF GitHub Bot commented on FLINK-9331: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #5986: [FLINK-9331] [mesos] Let MesosResourceManager requ...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5986 [FLINK-9331] [mesos] Let MesosResourceManager request new tasks for failed ones ## What is the purpose of the change In order to avoid the problem of not fulfilling allocation

[GitHub] flink pull request #5931: [FLINK-9190][flip6,yarn] Request new container if ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5931 ---

[GitHub] flink pull request #5980: [FLINK-9324] Wait for slot release before completi...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5980 ---

[GitHub] flink issue #5970: [FLINK-9292] [core] Remove TypeInfoParser (part 2)

Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5970 cc @StephanEwen fixed a incompatibility error ---

[jira] [Commented] (FLINK-9324) SingleLogicalSlot returns completed release future before slot is properly returned

[ https://issues.apache.org/jira/browse/FLINK-9324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470255#comment-16470255 ] ASF GitHub Bot commented on FLINK-9324: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-9292) Remove TypeInfoParser

[ https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470257#comment-16470257 ] ASF GitHub Bot commented on FLINK-9292: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5869: [FLINK-8946] TaskManager stop sending metrics after JobMa...

Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5869 cc @tillrohrmann ---

[GitHub] flink issue #5980: [FLINK-9324] Wait for slot release before completing rele...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5980 Thanks for the review @StephanEwen. I've addressed your comments and added some more tests. Once Travis passes, I'll merge it. ---

[GitHub] flink pull request #5976: [FLINK-9309] Recommend HA setup on Production Read...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5976 ---

[jira] [Commented] (FLINK-7495) AbstractUdfStreamOperator#initializeState() should be called in AsyncWaitOperator#initializeState()

[ https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470267#comment-16470267 ] ASF GitHub Bot commented on FLINK-7495: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5957: [FLINK-9282][doc] Synchronize Quickstart with the ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5957 ---

[GitHub] flink pull request #5971: [FLINK-9321] Rename SubtasksAllAccumulatorsHandler...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5971 ---

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470268#comment-16470268 ] ASF GitHub Bot commented on FLINK-6352: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3915: [FLINK-6352] Support to use timestamp to set the i...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3915 ---

[jira] [Commented] (FLINK-9141) Calling getSideOutput() and split() on one DataStream causes NPE

[ https://issues.apache.org/jira/browse/FLINK-9141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470263#comment-16470263 ] ASF GitHub Bot commented on FLINK-9141: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9125) MiniClusterResource should set CoreOptions.TMP_DIRS

[ https://issues.apache.org/jira/browse/FLINK-9125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470272#comment-16470272 ] ASF GitHub Bot commented on FLINK-9125: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5933: [FLINK-9125] MiniClusterResource should set CoreOp...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5933 ---

[GitHub] flink pull request #4893: [FLINK-7856][flip6] Port JobVertexBackPressureHand...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4893 ---

[jira] [Commented] (FLINK-9282) Update quickstart page

[ https://issues.apache.org/jira/browse/FLINK-9282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470271#comment-16470271 ] ASF GitHub Bot commented on FLINK-9282: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5967: [FLINK-8134] add method getDescription() to Messag...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5967 ---

[GitHub] flink pull request #5968: [FLINK-9317] Async I/O API Example For Scala has V...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5968 ---

[jira] [Commented] (FLINK-9323) Move checkstyle configuration to plugin management

[ https://issues.apache.org/jira/browse/FLINK-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470276#comment-16470276 ] ASF GitHub Bot commented on FLINK-9323: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-9179) Deduplicate WebOptions.PORT and RestOptions.REST_PORT

[ https://issues.apache.org/jira/browse/FLINK-9179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9179. --- Resolution: Fixed master: 3474dbb4b28d093796e6945994c8fe7c1241b53c 1.5:

[jira] [Commented] (FLINK-9265) Upgrade Prometheus version

[ https://issues.apache.org/jira/browse/FLINK-9265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470279#comment-16470279 ] ASF GitHub Bot commented on FLINK-9265: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5975: [FLINK-9138][docs][tests] Make ConfigOptionsDocsCo...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5975 ---

[GitHub] flink pull request #5981: fix syntax error in dataset_transformations.md

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5981 ---

[jira] [Commented] (FLINK-9317) Async I/O API Example For Scala has Variable Name error

[ https://issues.apache.org/jira/browse/FLINK-9317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470273#comment-16470273 ] ASF GitHub Bot commented on FLINK-9317: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5972: [FLINK-9323][build] Properly organize checkstyle-p...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5972 ---

[jira] [Commented] (FLINK-7803) Update savepoint Documentation

[ https://issues.apache.org/jira/browse/FLINK-7803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16470266#comment-16470266 ] ASF GitHub Bot commented on FLINK-7803: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-8912) Web UI does not render error messages correctly in FLIP-6 mode

[ https://issues.apache.org/jira/browse/FLINK-8912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8912. --- Resolution: Fixed master: a6cdc2085a3ea3d66271ec63f2224bcadbd5d5d7 1.5:

  1   2   >