[
https://issues.apache.org/jira/browse/FLINK-10460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750837#comment-16750837
]
lining commented on FLINK-10460:
[~phoenixjiangnan] see code
org.apache.flink.metrics.d
[
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 bb64862b8b7e3ee35625bfe8cb003e8eada8e949
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
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:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher
[
https://issues.apache.org/jira/browse/FLINK-10477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750818#comment-16750818
]
lining commented on FLINK-10477:
Hi, [~yanghua]. How it is going?
> Add rescale button
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
[
https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750811#comment-16750811
]
lining commented on FLINK-10707:
Hi, [~wolli]. How is it going?
> Improve Cluster Overv
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:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/Abstra
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
[
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 coordinat
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
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:
flink-runtime/src/main/java/org/apache/flink/runtime/i
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:
flink-state-backends/flink-statebackend-rocksdb/src/main/
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 it
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.
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:
flink-connectors/flink-connector-kafka-base/src/main/java/org/
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:
flink-connectors/flink-connector-kafka-base/src/main/java/org/
[
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
> --
[
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 Abstrac
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 mo
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:
flink-state-backends/flink-statebackend-rocksdb/src/main/
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
[
https://issues.apache.org/jira/browse/FLINK-11397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750680#comment-16750680
]
TisonKun commented on FLINK-11397:
--
[~pnowojski] I find such "cause" when running a deb
[
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. With
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750675#comment-16750675
]
Shuyi Chen commented on FLINK-7608:
---
[~Zentol], [~aljoscha], it appears that after thi
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:
flink-connectors/flink-connector-kafka-base/src/main/java/org/
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:
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/
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:
flink-connectors/flink-connector-kafka-0.8/src/main/java/org/a
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 ConsumerRecor
[
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
> ---
[
https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750659#comment-16750659
]
Hequn Cheng commented on FLINK-11301:
-
I encountered the same error in my last PR.
[
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:
[https://api.t
[
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
> ---
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
Issu
[
https://issues.apache.org/jira/browse/FLINK-11416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750611#comment-16750611
]
Hequn Cheng commented on FLINK-11416:
-
Hi [~lordon], Thanks for reporting the issue.
Jürgen Kreileder created FLINK-11420:
Summary: Serialization of case classes containing a Map[String,
Any] sometimes throws ArrayIndexOutOfBounds
Key: FLINK-11420
URL: https://issues.apache.org/jira/browse/FLI
[
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 Ar
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:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apa
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:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apa
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:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apa
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:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apa
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:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apa
[
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
> -
[
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
> -
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:
flink-state-backends/flink-statebackend-rocksdb/src/mai
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:
flink-runtime/src/main/java/org/apache/flink/runtime/st
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:
flink-state-backends/flink-statebackend-rocksdb/src/mai
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:
flink-state-backends/flink-statebackend-rocksdb/src/mai
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:
flink-state-backends/flink-statebackend-rocksdb/src/mai
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:
flink-state-backends/flink-statebackend-rocksdb/src/mai
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.
-
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:
>17:38
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
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
[
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 Re
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 th
[
https://issues.apache.org/jira/browse/FLINK-11397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750256#comment-16750256
]
Piotr Nowojski edited comment on FLINK-11397 at 1/23/19 5:34 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-11397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750256#comment-16750256
]
Piotr Nowojski commented on FLINK-11397:
[~Tison] thanks for reporting the issue
[
https://issues.apache.org/jira/browse/FLINK-11418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750185#comment-16750185
]
Chesnay Schepler commented on FLINK-11418:
--
Did you try following the docker in
[
https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750226#comment-16750226
]
Till Rohrmann commented on FLINK-9920:
--
Another instance: https://api.travis-ci.org/
[
https://issues.apache.org/jira/browse/FLINK-11418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750221#comment-16750221
]
Robert Metzger commented on FLINK-11418:
:) I have found a fix for the issue. Wi
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:
flink-connectors/flink-connector-kafka-base/src/main/java/org/
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:
flink-connectors/flink-connector-kafka-base/src/main/java/org/
[
https://issues.apache.org/jira/browse/FLINK-11418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750200#comment-16750200
]
Chesnay Schepler commented on FLINK-11418:
--
oh, this is about the _flink_ docs,
[
https://issues.apache.org/jira/browse/FLINK-11418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750192#comment-16750192
]
Robert Metzger commented on FLINK-11418:
Ah, I didn't know about these. The read
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:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/Di
[
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
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
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:
flink-connectors/flink-connector-kafka-base/src/main/java/org/
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
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:
flink-yarn-tests/src/test/java/org/apach
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:
flink-yarn-tests/src/test/java/org/apach
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:
flink-yarn-tests/src/test/java/org/apach
[
https://issues.apache.org/jira/browse/FLINK-11249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750075#comment-16750075
]
Piotr Nowojski commented on FLINK-11249:
Thanks for the response [~elevy]. That
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 u
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 👍
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:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/fli
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:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/fli
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:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateSnapshotTran
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 lo
[
https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16750025#comment-16750025
]
xueyu commented on FLINK-11046:
---
Hi, [~dawidwys][~tzulitai], I don't know how to make elas
[
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
https://github.com/apache/flink/com
[
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 w
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:
flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshotTran
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 Git
[
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 w
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 m
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
`testPersistedJobGraphWhenDisp
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:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher
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:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher
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:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher
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.
--
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:
flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobServerTest.jav
[
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
https://github.com/apache/flink/commit/
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:
flink-runtime/src/test/java/org/apache/flink/runtime/clusterframework/Bootst
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 mess
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 is
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
[
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 960feb4437c439084cfb317dd127645cfd176578
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.
Thi
1 - 100 of 165 matches
Mail list logo