[jira] [Commented] (FLINK-10460) DataDog reporter JsonMappingException

[ https://issues.apache.org/jira/browse/FLINK-10460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750837#comment-16750837 ] lining commented on FLINK-10460: [~phoenixjiangnan] see code 

[jira] [Closed] (FLINK-11356) Check and port JobManagerStartupTest to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11356. - Resolution: Fixed Fix Version/s: 1.8.0 Fixed via

[GitHub] tillrohrmann closed pull request #7541: [FLINK-11356][tests] Port JobManagerStartupTest to new code base

tillrohrmann closed pull request #7541: [FLINK-11356][tests] Port JobManagerStartupTest to new code base URL: https://github.com/apache/flink/pull/7541 This is an automated message from the Apache Git Service. To respond to

[GitHub] tillrohrmann commented on a change in pull request #7526: [FLINK-11353][tests] Port JobManagerHAJobGraphRecoveryITCase to new code base

tillrohrmann commented on a change in pull request #7526: [FLINK-11353][tests] Port JobManagerHAJobGraphRecoveryITCase to new code base URL: https://github.com/apache/flink/pull/7526#discussion_r250494997 ## File path:

[jira] [Commented] (FLINK-10477) Add rescale button to web interface

[ https://issues.apache.org/jira/browse/FLINK-10477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750818#comment-16750818 ] lining commented on FLINK-10477: Hi, [~yanghua]. How  it is going? > Add rescale button to web

[GitHub] libenchao opened a new pull request #7572: fix typo in JobMaster

libenchao opened a new pull request #7572: fix typo in JobMaster URL: https://github.com/apache/flink/pull/7572 Fix typo in JobMaster This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-10707) Improve Cluster Overview in Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750811#comment-16750811 ] lining commented on FLINK-10707: Hi， [~wolli]. How is it going? > Improve Cluster Overview in Flink

[GitHub] pnowojski commented on a change in pull request #7570: [FLINK-11422] Prefer testing class to mock StreamTask in AbstractStre…

pnowojski commented on a change in pull request #7570: [FLINK-11422] Prefer testing class to mock StreamTask in AbstractStre… URL: https://github.com/apache/flink/pull/7570#discussion_r250487400 ## File path:

[jira] [Created] (FLINK-11423) Propagate the error message from Main method to JarRunHandler

Lavkesh Lahngir created FLINK-11423: --- Summary: Propagate the error message from Main method to JarRunHandler Key: FLINK-11423 URL: https://issues.apache.org/jira/browse/FLINK-11423 Project: Flink

[jira] [Updated] (FLINK-10724) Refactor failure handling in check point coordinator

[ https://issues.apache.org/jira/browse/FLINK-10724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10724: --- Labels: pull-request-available (was: ) > Refactor failure handling in check point

[GitHub] yanghua opened a new pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator

yanghua opened a new pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571 ## What is the purpose of the change *This pull request refactored failure handling in checkpoint coordinator and reimplemented

[GitHub] zhijiangW commented on a change in pull request #7199: [FLINK-10662][network] Refactor the ChannelSelector interface for single selected channel

zhijiangW commented on a change in pull request #7199: [FLINK-10662][network] Refactor the ChannelSelector interface for single selected channel URL: https://github.com/apache/flink/pull/7199#discussion_r250484212 ## File path:

[GitHub] klion26 commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread

klion26 commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread URL: https://github.com/apache/flink/pull/7351#discussion_r250477821 ## File path:

[GitHub] klion26 edited a comment on issue #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread

klion26 edited a comment on issue #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread URL: https://github.com/apache/flink/pull/7351#issuecomment-457074711 Seems like there is a relevant test failed after reusing the registry, I'm looking into

[GitHub] klion26 commented on issue #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread

klion26 commented on issue #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread URL: https://github.com/apache/flink/pull/7351#issuecomment-457074711 Seems like there is a relevant test failed, I'm looking into it.

[GitHub] alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r250467958 ## File path:

[GitHub] alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r250457396 ## File path:

[jira] [Assigned] (FLINK-11397) Speed up initialization of AbstractStreamOperatorTestHarness

[ https://issues.apache.org/jira/browse/FLINK-11397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-11397: Assignee: (was: TisonKun) > Speed up initialization of AbstractStreamOperatorTestHarness >

[jira] [Updated] (FLINK-11422) Prefer testing class to mock StreamTask in AbstractStreamOperatorTestHarness

[ https://issues.apache.org/jira/browse/FLINK-11422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11422: --- Labels: pull-request-available (was: ) > Prefer testing class to mock StreamTask in

[GitHub] TisonKun opened a new pull request #7570: [FLINK-11422] Prefer testing class to mock StreamTask in AbstractStre…

TisonKun opened a new pull request #7570: [FLINK-11422] Prefer testing class to mock StreamTask in AbstractStre… URL: https://github.com/apache/flink/pull/7570 …amOperatorTestHarness ## What is the purpose of the change As title, we prefer using a testing class to a mockito

[GitHub] klion26 commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread

klion26 commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread URL: https://github.com/apache/flink/pull/7351#discussion_r250456369 ## File path:

[jira] [Created] (FLINK-11422) Prefer testing class to mock StreamTask in AbstractStreamOperatorTestHarness

TisonKun created FLINK-11422: Summary: Prefer testing class to mock StreamTask in AbstractStreamOperatorTestHarness Key: FLINK-11422 URL: https://issues.apache.org/jira/browse/FLINK-11422 Project: Flink

[jira] [Commented] (FLINK-11397) Speed up initialization of AbstractStreamOperatorTestHarness

[ https://issues.apache.org/jira/browse/FLINK-11397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750680#comment-16750680 ] TisonKun commented on FLINK-11397: -- [~pnowojski] I find such "cause" when running a debugger step by

[jira] [Updated] (FLINK-11397) Speed up initialization of AbstractStreamOperatorTestHarness

[ https://issues.apache.org/jira/browse/FLINK-11397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-11397: - Description: Currently Kafka connector tests are unbearably slow, which is tracked by FLINK-10603.

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750675#comment-16750675 ] Shuyi Chen commented on FLINK-7608: --- [~Zentol], [~aljoscha], it appears that after this PR, I can no

[GitHub] alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r250453890 ## File path:

[GitHub] alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r250453715 ## File path:

[GitHub] alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r250453628 ## File path:

[GitHub] alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#issuecomment-457051271 The compile problem was due master flink-connector-kafka-base uses Kafka 0.10.2.1, where

[jira] [Updated] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11301: Attachment: error.log > Travis failed: No output has been received in the last 10m0s >

[jira] [Commented] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750659#comment-16750659 ] Hequn Cheng commented on FLINK-11301: - I encountered the same error in my last PR.  Log link has

[jira] [Updated] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11301: Description: -[https://api.travis-ci.org/v3/job/47082/log.txt]- new log link: 

[jira] [Reopened] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reopened FLINK-11301: - > Travis failed: No output has been received in the last 10m0s >

[jira] [Created] (FLINK-11421) Providing more compilation options for code-generated operators

Liya Fan created FLINK-11421: Summary: Providing more compilation options for code-generated operators Key: FLINK-11421 URL: https://issues.apache.org/jira/browse/FLINK-11421 Project: Flink

[jira] [Commented] (FLINK-11416) DISTINCT on a JOIN inside of an UNION is not working

[ https://issues.apache.org/jira/browse/FLINK-11416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750611#comment-16750611 ] Hequn Cheng commented on FLINK-11416: - Hi [~lordon], Thanks for reporting the issue. It is probably

[jira] [Created] (FLINK-11420) Serialization of case classes containing a Map[String, Any] sometimes throws ArrayIndexOutOfBounds

Jürgen Kreileder created FLINK-11420: Summary: Serialization of case classes containing a Map[String, Any] sometimes throws ArrayIndexOutOfBounds Key: FLINK-11420 URL:

[jira] [Updated] (FLINK-11420) Serialization of case classes containing a Map[String, Any] sometimes throws ArrayIndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-11420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jürgen Kreileder updated FLINK-11420: - Summary: Serialization of case classes containing a Map[String, Any] sometimes throws

[GitHub] stevenzwu commented on a change in pull request #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an…

stevenzwu commented on a change in pull request #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an… URL: https://github.com/apache/flink/pull/7020#discussion_r250397313 ## File path:

[GitHub] stevenzwu commented on a change in pull request #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an…

stevenzwu commented on a change in pull request #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an… URL: https://github.com/apache/flink/pull/7020#discussion_r250398973 ## File path:

[GitHub] stevenzwu commented on a change in pull request #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an…

stevenzwu commented on a change in pull request #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an… URL: https://github.com/apache/flink/pull/7020#discussion_r250397468 ## File path:

[GitHub] stevenzwu commented on a change in pull request #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an…

stevenzwu commented on a change in pull request #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an… URL: https://github.com/apache/flink/pull/7020#discussion_r250397435 ## File path:

[GitHub] stevenzwu commented on a change in pull request #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an…

stevenzwu commented on a change in pull request #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an… URL: https://github.com/apache/flink/pull/7020#discussion_r250397313 ## File path:

[jira] [Updated] (FLINK-11008) Speed up upload checkpoint files using multi-thread

[ https://issues.apache.org/jira/browse/FLINK-11008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-11008: Fix Version/s: 1.8.0 > Speed up upload checkpoint files using multi-thread >

[jira] [Assigned] (FLINK-11397) Speed up initialization of AbstractStreamOperatorTestHarness

[ https://issues.apache.org/jira/browse/FLINK-11397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-11397: Assignee: TisonKun > Speed up initialization of AbstractStreamOperatorTestHarness >

[GitHub] azagrebin commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread

azagrebin commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread URL: https://github.com/apache/flink/pull/7351#discussion_r250325106 ## File path:

[GitHub] azagrebin commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread

azagrebin commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread URL: https://github.com/apache/flink/pull/7351#discussion_r250317750 ## File path:

[GitHub] azagrebin commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread

azagrebin commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread URL: https://github.com/apache/flink/pull/7351#discussion_r250323327 ## File path:

[GitHub] azagrebin commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread

azagrebin commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread URL: https://github.com/apache/flink/pull/7351#discussion_r250322353 ## File path:

[GitHub] azagrebin commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread

azagrebin commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread URL: https://github.com/apache/flink/pull/7351#discussion_r250324277 ## File path:

[GitHub] azagrebin commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread

azagrebin commented on a change in pull request #7351: [FLINK-11008][State Backends, Checkpointing]SpeedUp upload state files using multithread URL: https://github.com/apache/flink/pull/7351#discussion_r250319960 ## File path:

[GitHub] azagrebin commented on issue #7320: [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer

azagrebin commented on issue #7320: [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer URL: https://github.com/apache/flink/pull/7320#issuecomment-456912423 Thanks for the review @tillrohrmann ! I pushed a commit to address the concerns.

[GitHub] alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#issuecomment-456910348 Weird build is fine locally using 1.8.0_181-b13, but fails on Travis with 1.8.0_151-b12:

[jira] [Created] (FLINK-11419) StreamingFileSink fails to recover after taskmanager failure

Edward Rojas created FLINK-11419: Summary: StreamingFileSink fails to recover after taskmanager failure Key: FLINK-11419 URL: https://issues.apache.org/jira/browse/FLINK-11419 Project: Flink

[GitHub] tweise merged pull request #7559: [FLINK-11048] Mark new RemoteStreamEnvironment constructor PublicEvolving

tweise merged pull request #7559: [FLINK-11048] Mark new RemoteStreamEnvironment constructor PublicEvolving URL: https://github.com/apache/flink/pull/7559 This is an automated message from the Apache Git Service. To respond

[jira] [Closed] (FLINK-11282) Merge StreamRecordWriter into RecordWriter

[ https://issues.apache.org/jira/browse/FLINK-11282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-11282. -- Resolution: Fixed merged commit b12d392 into apache:master > Merge StreamRecordWriter into

[GitHub] pnowojski merged pull request #7438: [FLINK-11282][network] Merge StreamRecordWriter into RecordWriter

pnowojski merged pull request #7438: [FLINK-11282][network] Merge StreamRecordWriter into RecordWriter URL: https://github.com/apache/flink/pull/7438 This is an automated message from the Apache Git Service. To respond to

[jira] [Comment Edited] (FLINK-11397) Speed up initialization of AbstractStreamOperatorTestHarness

[ https://issues.apache.org/jira/browse/FLINK-11397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750256#comment-16750256 ] Piotr Nowojski edited comment on FLINK-11397 at 1/23/19 5:34 PM: -

[jira] [Commented] (FLINK-11397) Speed up initialization of AbstractStreamOperatorTestHarness

[ https://issues.apache.org/jira/browse/FLINK-11397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750256#comment-16750256 ] Piotr Nowojski commented on FLINK-11397: [~Tison] thanks for reporting the issue. Can you tell

[jira] [Commented] (FLINK-11418) Unable to build docs in Docker image

[ https://issues.apache.org/jira/browse/FLINK-11418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750185#comment-16750185 ] Chesnay Schepler commented on FLINK-11418: -- Did you try following the docker instructions that

[jira] [Commented] (FLINK-9920) BucketingSinkFaultToleranceITCase fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750226#comment-16750226 ] Till Rohrmann commented on FLINK-9920: -- Another instance:

[jira] [Commented] (FLINK-11418) Unable to build docs in Docker image

[ https://issues.apache.org/jira/browse/FLINK-11418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750221#comment-16750221 ] Robert Metzger commented on FLINK-11418: :) I have found a fix for the issue. Will open a PR

[GitHub] alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r250282725 ## File path:

[GitHub] alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r250282725 ## File path:

[jira] [Commented] (FLINK-11418) Unable to build docs in Docker image

[ https://issues.apache.org/jira/browse/FLINK-11418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750200#comment-16750200 ] Chesnay Schepler commented on FLINK-11418: -- oh, this is about the _flink_ docs, not flink-web

[jira] [Commented] (FLINK-11418) Unable to build docs in Docker image

[ https://issues.apache.org/jira/browse/FLINK-11418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750192#comment-16750192 ] Robert Metzger commented on FLINK-11418: Ah, I didn't know about these. The readme file in the

[GitHub] azagrebin commented on a change in pull request #7526: [FLINK-11353][tests] Port JobManagerHAJobGraphRecoveryITCase to new code base

azagrebin commented on a change in pull request #7526: [FLINK-11353][tests] Port JobManagerHAJobGraphRecoveryITCase to new code base URL: https://github.com/apache/flink/pull/7526#discussion_r250231423 ## File path:

[jira] [Assigned] (FLINK-11362) Check and port TaskManagerComponentsStartupShutdownTest to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-11362: --- Assignee: (was: boshu Zheng) > Check and port TaskManagerComponentsStartupShutdownTest

[jira] [Created] (FLINK-11418) Unable to build docs in Docker image

Robert Metzger created FLINK-11418: -- Summary: Unable to build docs in Docker image Key: FLINK-11418 URL: https://issues.apache.org/jira/browse/FLINK-11418 Project: Flink Issue Type: Bug

[GitHub] alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r250247173 ## File path:

[GitHub] tillrohrmann commented on issue #7546: [FLINK-11390][tests] Port YARNSessionCapacitySchedulerITCase#testTaskManagerFailure to new code base

tillrohrmann commented on issue #7546: [FLINK-11390][tests] Port YARNSessionCapacitySchedulerITCase#testTaskManagerFailure to new code base URL: https://github.com/apache/flink/pull/7546#issuecomment-456836215 As @zentol pointed out, it could work to use the metrics to query the number of

[GitHub] tillrohrmann commented on a change in pull request #7546: [FLINK-11390][tests] Port YARNSessionCapacitySchedulerITCase#testTaskManagerFailure to new code base

tillrohrmann commented on a change in pull request #7546: [FLINK-11390][tests] Port YARNSessionCapacitySchedulerITCase#testTaskManagerFailure to new code base URL: https://github.com/apache/flink/pull/7546#discussion_r250224836 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7546: [FLINK-11390][tests] Port YARNSessionCapacitySchedulerITCase#testTaskManagerFailure to new code base

tillrohrmann commented on a change in pull request #7546: [FLINK-11390][tests] Port YARNSessionCapacitySchedulerITCase#testTaskManagerFailure to new code base URL: https://github.com/apache/flink/pull/7546#discussion_r250225736 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7546: [FLINK-11390][tests] Port YARNSessionCapacitySchedulerITCase#testTaskManagerFailure to new code base

tillrohrmann commented on a change in pull request #7546: [FLINK-11390][tests] Port YARNSessionCapacitySchedulerITCase#testTaskManagerFailure to new code base URL: https://github.com/apache/flink/pull/7546#discussion_r250227506 ## File path:

[jira] [Commented] (FLINK-11249) FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer

[ https://issues.apache.org/jira/browse/FLINK-11249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750075#comment-16750075 ] Piotr Nowojski commented on FLINK-11249: Thanks for the response [~elevy]. That would be my

[GitHub] azagrebin commented on issue #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

azagrebin commented on issue #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#issuecomment-456828901 Thanks for the review @StefanRRichter ! I activated this feature in the existing e2e test. I also extended the

[GitHub] igalshilman commented on issue #7557: [FLINK-11406] [core] Return INCOMPATIBLE when nested serializers arity don't match in CompositeTypeSerializerSnapshot

igalshilman commented on issue #7557: [FLINK-11406] [core] Return INCOMPATIBLE when nested serializers arity don't match in CompositeTypeSerializerSnapshot URL: https://github.com/apache/flink/pull/7557#issuecomment-456826190 LGTM 

[GitHub] tillrohrmann commented on a change in pull request #7320: [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer

tillrohrmann commented on a change in pull request #7320: [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer URL: https://github.com/apache/flink/pull/7320#discussion_r250218492 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7320: [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer

tillrohrmann commented on a change in pull request #7320: [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer URL: https://github.com/apache/flink/pull/7320#discussion_r250212255 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7320: [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer

tillrohrmann commented on a change in pull request #7320: [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer URL: https://github.com/apache/flink/pull/7320#discussion_r250210160 ## File path:

[GitHub] asfgit closed pull request #7569: [hotfix] [javadocs] fix typo in JobManagerRunner

asfgit closed pull request #7569: [hotfix] [javadocs] fix typo in JobManagerRunner URL: https://github.com/apache/flink/pull/7569 This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750025#comment-16750025 ] xueyu commented on FLINK-11046: --- Hi, [~dawidwys][~tzulitai], I don't know how to make elastic6 response

[jira] [Resolved] (FLINK-11348) Port YARNSessionCapacitySchedulerITCase#testClientStartup to new code base

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

[jira] [Updated] (FLINK-11409) Make `ProcessFunction`, `ProcessWindowFunction` and etc. pure interfaces

[ https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kezhu Wang updated FLINK-11409: --- Description: I found these functions express no opinionated demands from implementing classes. It

[GitHub] tillrohrmann commented on a change in pull request #7320: [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer

tillrohrmann commented on a change in pull request #7320: [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer URL: https://github.com/apache/flink/pull/7320#discussion_r250206990 ## File path:

[GitHub] rmetzger commented on issue #7569: [hotfix] [javadocs] fix typo in JobManagerRunner

rmetzger commented on issue #7569: [hotfix] [javadocs] fix typo in JobManagerRunner URL: https://github.com/apache/flink/pull/7569#issuecomment-456811678 Thank you. Will merge. This is an automated message from the Apache

[jira] [Updated] (FLINK-11409) Make `ProcessFunction`, `ProcessWindowFunction` and etc. pure interfaces

[ https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kezhu Wang updated FLINK-11409: --- Description: I found these functions express no opinionated demands from implementing classes. It

[GitHub] tillrohrmann merged pull request #7538: [FLINK-11348][tests] Port testClientStartup to new codebase

tillrohrmann merged pull request #7538: [FLINK-11348][tests] Port testClientStartup to new codebase URL: https://github.com/apache/flink/pull/7538 This is an automated message from the Apache Git Service. To respond to the

[GitHub] tillrohrmann commented on issue #7526: [FLINK-11353][tests] Port JobManagerHAJobGraphRecoveryITCase to new code base

tillrohrmann commented on issue #7526: [FLINK-11353][tests] Port JobManagerHAJobGraphRecoveryITCase to new code base URL: https://github.com/apache/flink/pull/7526#issuecomment-456809149 Thanks for the review @azagrebin. I've addressed your comments and moved

[GitHub] tillrohrmann commented on a change in pull request #7526: [FLINK-11353][tests] Port JobManagerHAJobGraphRecoveryITCase to new code base

tillrohrmann commented on a change in pull request #7526: [FLINK-11353][tests] Port JobManagerHAJobGraphRecoveryITCase to new code base URL: https://github.com/apache/flink/pull/7526#discussion_r250202116 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7526: [FLINK-11353][tests] Port JobManagerHAJobGraphRecoveryITCase to new code base

tillrohrmann commented on a change in pull request #7526: [FLINK-11353][tests] Port JobManagerHAJobGraphRecoveryITCase to new code base URL: https://github.com/apache/flink/pull/7526#discussion_r250198790 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7526: [FLINK-11353][tests] Port JobManagerHAJobGraphRecoveryITCase to new code base

tillrohrmann commented on a change in pull request #7526: [FLINK-11353][tests] Port JobManagerHAJobGraphRecoveryITCase to new code base URL: https://github.com/apache/flink/pull/7526#discussion_r250197888 ## File path:

[GitHub] tillrohrmann commented on issue #7541: [FLINK-11356][tests] Port JobManagerStartupTest to new code base

tillrohrmann commented on issue #7541: [FLINK-11356][tests] Port JobManagerStartupTest to new code base URL: https://github.com/apache/flink/pull/7541#issuecomment-456803334 Thanks for the review @GJL. I've addressed your comments.

[GitHub] tillrohrmann commented on a change in pull request #7541: [FLINK-11356][tests] Port JobManagerStartupTest to new code base

tillrohrmann commented on a change in pull request #7541: [FLINK-11356][tests] Port JobManagerStartupTest to new code base URL: https://github.com/apache/flink/pull/7541#discussion_r250195669 ## File path:

[jira] [Closed] (FLINK-11355) Check and port JobManagerProcessReapingTest if necessary to new code base

[ https://issues.apache.org/jira/browse/FLINK-11355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11355. - Resolution: Fixed Fix Version/s: 1.8.0 Fixed via

[GitHub] tillrohrmann commented on a change in pull request #7541: [FLINK-11356][tests] Port JobManagerStartupTest to new code base

tillrohrmann commented on a change in pull request #7541: [FLINK-11356][tests] Port JobManagerStartupTest to new code base URL: https://github.com/apache/flink/pull/7541#discussion_r250194572 ## File path:

[GitHub] tillrohrmann merged pull request #7540: [FLINK-11355][tests] Remove JobManagerProcessReapingTest

tillrohrmann merged pull request #7540: [FLINK-11355][tests] Remove JobManagerProcessReapingTest URL: https://github.com/apache/flink/pull/7540 This is an automated message from the Apache Git Service. To respond to the

[GitHub] tillrohrmann commented on issue #7540: [FLINK-11355][tests] Remove JobManagerProcessReapingTest

tillrohrmann commented on issue #7540: [FLINK-11355][tests] Remove JobManagerProcessReapingTest URL: https://github.com/apache/flink/pull/7540#issuecomment-456800082 Thanks for your review @azagrebin. Merging this PR. This

[GitHub] tillrohrmann closed pull request #7524: [FLINK-11351][tests] Port JobManagerCleanupITCase to new code base

tillrohrmann closed pull request #7524: [FLINK-11351][tests] Port JobManagerCleanupITCase to new code base URL: https://github.com/apache/flink/pull/7524 This is an automated message from the Apache Git Service. To respond

[jira] [Closed] (FLINK-11351) Port JobManagerCleanupITCase to new code base

[ https://issues.apache.org/jira/browse/FLINK-11351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11351. - Resolution: Fixed Fix Version/s: 1.8.0 Fixed via

[GitHub] tillrohrmann commented on issue #7524: [FLINK-11351][tests] Port JobManagerCleanupITCase to new code base

tillrohrmann commented on issue #7524: [FLINK-11351][tests] Port JobManagerCleanupITCase to new code base URL: https://github.com/apache/flink/pull/7524#issuecomment-456799536 Thanks for the review @GJL. Merging this PR.

  1   2   >