[
https://issues.apache.org/jira/browse/FLINK-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756979#comment-16756979
]
Till Rohrmann commented on FLINK-10819:
---
Another instance:
tillrohrmann commented on issue #7606: [FLINK-10774] Rework lifecycle
management of partitionDiscoverer in FlinkKafkaConsumerBase
URL: https://github.com/apache/flink/pull/7606#issuecomment-459245503
Thanks for the review @tzulitai. Merging.
[
https://issues.apache.org/jira/browse/FLINK-11370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756943#comment-16756943
]
lining edited comment on FLINK-11370 at 1/31/19 7:08 AM:
-
[~till.rohrmann], I
jinglining commented on a change in pull request #7613:
[FLINK-11370][test]Check and port ZooKeeperLeaderElectionITCase to ne…
URL: https://github.com/apache/flink/pull/7613#discussion_r252554942
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756943#comment-16756943
]
lining commented on FLINK-11370:
[~till.rohrmann], I have find some bug in
[
https://issues.apache.org/jira/browse/FLINK-11370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756941#comment-16756941
]
lining commented on FLINK-11370:
Hi, [~Tison]. I have pushed the code, you can review it. Thanks for
jinglining opened a new pull request #7613: [FLINK-11370][test]Check and port
ZooKeeperLeaderElectionITCase to ne…
URL: https://github.com/apache/flink/pull/7613
## What is the purpose of the change
This pull request Check and port ZooKeeperLeaderElectionITCase to new code
base
[
https://issues.apache.org/jira/browse/FLINK-11370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11370:
---
Labels: pull-request-available (was: )
> Check and port ZooKeeperLeaderElectionITCase to
klion26 commented on issue #7612: [FLINK-11483][tests] Improve
StreamOperatorSnapshotRestoreTest with JUnit's Parameterized
URL: https://github.com/apache/flink/pull/7612#issuecomment-459236367
@tzulitai thank you for your quick review. I think you may have pinged the
wrong person in the
[
https://issues.apache.org/jira/browse/FLINK-11322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-11322.
---
Resolution: Fixed
Merged for 1.8.0:
64cbf2a20178cf8b4f643ba510653881a3e5ce2f
> Use
Tzu-Li (Gordon) Tai created FLINK-11485:
---
Summary: Migrate PojoSerializer to use new serialization
compatibility abstractions
Key: FLINK-11485
URL: https://issues.apache.org/jira/browse/FLINK-11485
klion26 commented on a change in pull request #7612: [FLINK-11483][tests]
Improve StreamOperatorSnapshotRestoreTest with JUnit's Parameterized
URL: https://github.com/apache/flink/pull/7612#discussion_r252551404
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-11461.
---
Resolution: Fixed
Merged for 1.8.0: 0e94ecfc7b65021905087b7efa94e3e04f761baf
>
hequn8128 commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r252550288
##
File path:
asfgit closed pull request #7611: [FLINK-11460][test] Remove the useless class
AcknowledgeStreamMockEnvironment
URL: https://github.com/apache/flink/pull/7611
This is an automated message from the Apache Git Service.
To
asfgit closed pull request #7610: [FLINK-11461][test] Remove the useless
MockRecordReader class
URL: https://github.com/apache/flink/pull/7610
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-11460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-11460.
---
Resolution: Fixed
Merged for 1.8.0: 52c2b22bd047912c690edd1d770d567250f6d710
>
tzulitai commented on issue #7610: [FLINK-11461][test] Remove the useless
MockRecordReader class
URL: https://github.com/apache/flink/pull/7610#issuecomment-459232224
LGTM, +1
Merging ..
This is an automated message from
tzulitai commented on issue #7611: [FLINK-11460][test] Remove the useless class
AcknowledgeStreamMockEnvironment
URL: https://github.com/apache/flink/pull/7611#issuecomment-459232032
LGTM, +1.
Merging this ..
This is an
tzulitai commented on a change in pull request #7612: [FLINK-11483][tests]
Improve StreamOperatorSnapshotRestoreTest with JUnit's Parameterized
URL: https://github.com/apache/flink/pull/7612#discussion_r252544276
##
File path:
tzulitai commented on a change in pull request #7612: [FLINK-11483][tests]
Improve StreamOperatorSnapshotRestoreTest with JUnit's Parameterized
URL: https://github.com/apache/flink/pull/7612#discussion_r252544131
##
File path:
tzulitai commented on a change in pull request #7612: [FLINK-11483][tests]
Improve StreamOperatorSnapshotRestoreTest with JUnit's Parameterized
URL: https://github.com/apache/flink/pull/7612#discussion_r252544244
##
File path:
tzulitai commented on a change in pull request #7612: [FLINK-11483][tests]
Improve StreamOperatorSnapshotRestoreTest with JUnit's Parameterized
URL: https://github.com/apache/flink/pull/7612#discussion_r252543815
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756910#comment-16756910
]
vinoyang commented on FLINK-11471:
--
I am not sure, it is feasible to introduce another JobStatus. I
tzulitai commented on issue #7206: [FLINK-11042][kafka,tests] Drop invalid
kafka producer tests
URL: https://github.com/apache/flink/pull/7206#issuecomment-459229838
Ok. Since we've already been removing tests that rely on shutting down Kafka
brokers (which were mostly the ones causing a
casidiablo commented on issue #2671: [FLINK-4862] fix Timer register in
ContinuousEventTimeTrigger
URL: https://github.com/apache/flink/pull/2671#issuecomment-459222191
I don't have enough time to fix this. I documented what I found here
https://issues.apache.org/jira/browse/FLINK-11408
[
https://issues.apache.org/jira/browse/FLINK-11471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756836#comment-16756836
]
Zhu Zhu commented on FLINK-11471:
-
I see. So in the future, a Job is "RUNNING" when and only when at
hequn8128 commented on a change in pull request #7587: [FLINK-11064] [table]
Setup a new flink-table module structure
URL: https://github.com/apache/flink/pull/7587#discussion_r252527514
##
File path: flink-table/flink-table-planner/pom.xml
##
@@ -22,13 +22,18 @@ under
[
https://issues.apache.org/jira/browse/FLINK-11483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11483:
---
Labels: pull-request-available (was: )
> Improve StreamOperatorSnapshotRestoreTest with
klion26 opened a new pull request #7612: [FLINK-11483][tests] Improve
StreamOperatorSnapshotRestoreTest with JUnit's Parameterized
URL: https://github.com/apache/flink/pull/7612
## What is the purpose of the change
Improve StreamOperatorSnapshotRestoreTest with JUnit's
[
https://issues.apache.org/jira/browse/FLINK-10769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-10769.
Resolution: Invalid
Release Note: no need to port existing InMemoryCatalog since we will
develop
[
https://issues.apache.org/jira/browse/FLINK-10026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
boshu Zheng reassigned FLINK-10026:
---
Assignee: boshu Zheng
> Integrate heap based timers in RocksDB backend with incremental
[
https://issues.apache.org/jira/browse/FLINK-11471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756815#comment-16756815
]
vinoyang commented on FLINK-11471:
--
Currently, the transformation of {{JobStatus.RUNNING}} does not
[
https://issues.apache.org/jira/browse/FLINK-11461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11461:
---
Labels: pull-request-available (was: )
> Remove useless MockRecordWriter
>
[
https://issues.apache.org/jira/browse/FLINK-11460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11460:
---
Labels: pull-request-available (was: )
> Remove useless AcknowledgeStreamMockEnvironment
>
zhijiangW opened a new pull request #7611: [FLINK-11460][test] Remove the
useless class AcknowledgeStreamMockEnvironment
URL: https://github.com/apache/flink/pull/7611
## What is the purpose of the change
*The class `AcknowledgeStreamMockEnvironment` is not used any more in
zhijiangW opened a new pull request #7610: [FLINK-11461][test] Remove the
useless MockRecordReader class
URL: https://github.com/apache/flink/pull/7610
## What is the purpose of the change
*The `MockRecordReader` class is not used any more in current code path, so
delete it to make
yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor
failure handling in check point coordinator
URL: https://github.com/apache/flink/pull/7571#discussion_r252518530
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756800#comment-16756800
]
vinoyang commented on FLINK-11440:
--
[~aljoscha] In fact, I am not very sure whether this failure is due
[
https://issues.apache.org/jira/browse/FLINK-11471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756792#comment-16756792
]
Zhu Zhu commented on FLINK-11471:
-
Hi [~yanghua] and [~NicoK], do you have the solution for this issue
tzulitai commented on issue #7606: [FLINK-10774] Rework lifecycle management of
partitionDiscoverer in FlinkKafkaConsumerBase
URL: https://github.com/apache/flink/pull/7606#issuecomment-459186967
Since I've already reviewed this as part of the efforts in #7020, and Travis
is green, LGTM
tzulitai removed a comment on issue #7606: [FLINK-10774] Rework lifecycle
management of partitionDiscoverer in FlinkKafkaConsumerBase
URL: https://github.com/apache/flink/pull/7606#issuecomment-459186967
Since I've already reviewed this as part of the efforts in #7020, and Travis
is
tzulitai edited a comment on issue #7606: [FLINK-10774] Rework lifecycle
management of partitionDiscoverer in FlinkKafkaConsumerBase
URL: https://github.com/apache/flink/pull/7606#issuecomment-459186967
Since I've already reviewed this as part of the efforts in #7020, and Travis
is green,
pj created FLINK-11484:
--
Summary: Blink java.util.concurrent.TimeoutException
Key: FLINK-11484
URL: https://issues.apache.org/jira/browse/FLINK-11484
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-11471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11471:
Assignee: vinoyang
> Job is reported RUNNING prematurely for queued scheduling
>
jinglining commented on issue #7552: [FLINK-11405][rest]can see task and task
attempt exception by start e…
URL: https://github.com/apache/flink/pull/7552#issuecomment-459183827
@zentol can you review it？
This is an
themez opened a new pull request #7609: [FLINK-filesystems]
[flink-s3-fs-hadoop] Add mirrored config key for s3 endpoint
URL: https://github.com/apache/flink/pull/7609
## What is the purpose of the change
Add s3 endpoint configuration so flink can connect to S3 in china
Congxian Qiu created FLINK-11483:
Summary: Improve StreamOperatorSnapshotRestoreTest with
Parameterized
Key: FLINK-11483
URL: https://issues.apache.org/jira/browse/FLINK-11483
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11470:
Assignee: vinoyang
> LocalEnvironment doesn't call FileSystem.initialize()
>
[
https://issues.apache.org/jira/browse/FLINK-11455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11455:
Assignee: vinoyang
> Support evictor operations on slicing and merging operators
>
EronWright commented on issue #7390: [FLINK-11240] [table] External Catalog
Factory and Descriptor
URL: https://github.com/apache/flink/pull/7390#issuecomment-459178024
@twalthr ping
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-10744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756766#comment-16756766
]
Eron Wright commented on FLINK-10744:
--
Update on my end, all issues assigned to me have PRs open;
jinglining commented on issue #7554: [FLINK-11357][test]Check and port
LeaderChangeJobRecoveryTest to new …
URL: https://github.com/apache/flink/pull/7554#issuecomment-459178142
Thanks.
This is an automated message from the
EronWright commented on issue #7392: [FLINK-11241][table] - Enhance
TableEnvironment to connect to a catalog via descriptor
URL: https://github.com/apache/flink/pull/7392#issuecomment-459178101
@twalthr ping
This is an
EronWright commented on issue #7393: [FLINK-9172][table][sql-client] - Support
external catalogs in SQL-Client
URL: https://github.com/apache/flink/pull/7393#issuecomment-459177902
@twalthr ping
This is an automated message
EronWright commented on issue #7389: [FLINK-11237] [table] Enhance
LocalExecutor to wrap TableEnvironment w/ classloader
URL: https://github.com/apache/flink/pull/7389#issuecomment-459177499
@twalthr ping
This is an
[
https://issues.apache.org/jira/browse/FLINK-11456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11456:
Assignee: vinoyang
> Improve window operator with sliding window assigners
>
[
https://issues.apache.org/jira/browse/FLINK-10618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuefu Zhang updated FLINK-10618:
Comment: was deleted
(was: This task is superseded by FLINK-11482. )
> Introduce catalog for
[
https://issues.apache.org/jira/browse/FLINK-10697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756756#comment-16756756
]
Xuefu Zhang commented on FLINK-10697:
-
The task here is superseded by FLINK-11475.
> Create
[
https://issues.apache.org/jira/browse/FLINK-10697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuefu Zhang closed FLINK-10697.
---
Resolution: Duplicate
Fix Version/s: (was: 1.8.0)
> Create FlinkInMemoryCatalog class,
[
https://issues.apache.org/jira/browse/FLINK-10699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuefu Zhang closed FLINK-10699.
---
Resolution: Duplicate
This duplicates FLINK-11482.
> Create FlinkHmsCatalog for persistent Flink
Xuefu Zhang created FLINK-11482:
---
Summary: Implement GenericHiveMetastoreCatalog
Key: FLINK-11482
URL: https://issues.apache.org/jira/browse/FLINK-11482
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-10618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756752#comment-16756752
]
Xuefu Zhang commented on FLINK-10618:
-
This task is superseded by FLINK-11482.
> Introduce catalog
[
https://issues.apache.org/jira/browse/FLINK-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuefu Zhang closed FLINK-10542.
---
Resolution: Duplicate
> Implement an external catalog for Hive
>
[
https://issues.apache.org/jira/browse/FLINK-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756748#comment-16756748
]
Xuefu Zhang commented on FLINK-10542:
-
The task here is superseded by FLINK-11479.
> Implement an
Xuefu Zhang created FLINK-11481:
---
Summary: Integrate HiveTableFactory with existing table factory
discovery mechanism
Key: FLINK-11481
URL: https://issues.apache.org/jira/browse/FLINK-11481
Project:
Xuefu Zhang created FLINK-11480:
---
Summary: Create HiveTableFactory that creates TableSource/Sink
from a Hive table
Key: FLINK-11480
URL: https://issues.apache.org/jira/browse/FLINK-11480
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuefu Zhang updated FLINK-11275:
Description:
During Flink-Hive integration, we found that the current Catalog APIs are quite
Xuefu Zhang created FLINK-11479:
---
Summary: Implement HiveCatalog
Key: FLINK-11479
URL: https://issues.apache.org/jira/browse/FLINK-11479
Project: Flink
Issue Type: Sub-task
Xuefu Zhang created FLINK-11477:
---
Summary: Define catalog entries in SQL client YAML file and handle
the creation and registration of those entries
Key: FLINK-11477
URL:
Xuefu Zhang created FLINK-11478:
---
Summary: Handle existing table registration via YAML file in the
context of catalog support
Key: FLINK-11478
URL: https://issues.apache.org/jira/browse/FLINK-11478
Xuefu Zhang created FLINK-11476:
---
Summary: Create CatalogManager to manage multiple catalogs and
encapsulate Calcite schema
Key: FLINK-11476
URL: https://issues.apache.org/jira/browse/FLINK-11476
Xuefu Zhang created FLINK-11475:
---
Summary: Adapt existing InMemoryExternalCatalog to
GenericInMemoryCatalog
Key: FLINK-11475
URL: https://issues.apache.org/jira/browse/FLINK-11475
Project: Flink
Xuefu Zhang created FLINK-11474:
---
Summary: Add ReadableCatalog, ReadableWritableCatalog, and other
related interfaces
Key: FLINK-11474
URL: https://issues.apache.org/jira/browse/FLINK-11474
Project:
TisonKun commented on issue #7570: [FLINK-11422] Prefer testing class to mock
StreamTask in AbstractStre…
URL: https://github.com/apache/flink/pull/7570#issuecomment-459151470
@pnowojski thanks for your review!
This is an
[
https://issues.apache.org/jira/browse/FLINK-11363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756567#comment-16756567
]
Gary Yao edited comment on FLINK-11363 at 1/30/19 9:24 PM:
---
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-11363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-11363:
-
Fix Version/s: 1.8.0
> Check and remove TaskManagerConfigurationTest
>
[
https://issues.apache.org/jira/browse/FLINK-11363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-11363.
Resolution: Fixed
> Check and remove TaskManagerConfigurationTest
>
[
https://issues.apache.org/jira/browse/FLINK-11363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reopened FLINK-11363:
--
> Check and remove TaskManagerConfigurationTest
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-11363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-11363.
Resolution: Fixed
Fixed via
969c8b2d08afae9dafe0349c2a10cf43c6deb918
GJL merged pull request #7595: [FLINK-11363][tests] Port
TaskManagerConfigurationTest to new code base
URL: https://github.com/apache/flink/pull/7595
This is an automated message from the Apache Git Service.
To respond to
walterddr commented on issue #7607: [FLINK-10076][table] Upgrade Calcite
dependency to 1.18
URL: https://github.com/apache/flink/pull/7607#issuecomment-459101279
@zentol yes I think definitely wait for @twalthr to merge #7587 first. It
shouldn't be too much of a merge issue.
[
https://issues.apache.org/jira/browse/FLINK-11473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-11473:
-
Description:
The documenation on Latency Tracking states:
{noformat}
All intermediate
[
https://issues.apache.org/jira/browse/FLINK-11473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-11473:
-
Summary: Clarify Documenation on Latency Tracking (was: Clarify
Documenation on
[
https://issues.apache.org/jira/browse/FLINK-11473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11473:
---
Labels: pull-request-available (was: )
> Clarify Documenation on Latency Markers
>
knaufk opened a new pull request #7608: FLINK-11473 [documentation][ Clarify
documenation on Latency Tracking
URL: https://github.com/apache/flink/pull/7608
Konstantin Knauf created FLINK-11473:
Summary: Clarify Documenation on Latency Markers
Key: FLINK-11473
URL: https://issues.apache.org/jira/browse/FLINK-11473
Project: Flink
Issue Type:
zentol commented on issue #7607: [FLINK-10076][table] Upgrade Calcite
dependency to 1.18
URL: https://github.com/apache/flink/pull/7607#issuecomment-459066684
With #7587 being close to being merged you should probably re-base your PR
on of it.
[
https://issues.apache.org/jira/browse/FLINK-11357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-11357.
Resolution: Fixed
Fixed via 969c8b2d08afae9dafe0349c2a10cf43c6deb918
> Check and port
GJL merged pull request #7554: [FLINK-11357][test]Check and port
LeaderChangeJobRecoveryTest to new …
URL: https://github.com/apache/flink/pull/7554
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-10076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10076:
---
Labels: pull-request-available (was: )
> Upgrade Calcite dependency to 1.18
>
walterddr opened a new pull request #7607: [FLINK-10076][table] Upgrade Calcite
dependency to 1.18
URL: https://github.com/apache/flink/pull/7607
## What is the purpose of the change
Upgrade Calcite dependency to 1.18 for flink-table package. including
various bug fixes and
[
https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756394#comment-16756394
]
Edward Rojas commented on FLINK-11419:
--
[~kkl0u] Travis build is failing but it's not related to
NicoK commented on a change in pull request #6705: [FLINK-10356][network] add
sanity checks to SpillingAdaptiveSpanningRecordDeserializer
URL: https://github.com/apache/flink/pull/6705#discussion_r252367679
##
File path:
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers
URL: https://github.com/apache/flink/pull/7356#discussion_r252360494
##
File path:
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers
URL: https://github.com/apache/flink/pull/7356#discussion_r252354300
##
File path: docs/_includes/generated/mesos_configuration.html
##
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers
URL: https://github.com/apache/flink/pull/7356#discussion_r252354509
##
File path: docs/_includes/generated/yarn_config_configuration.html
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers
URL: https://github.com/apache/flink/pull/7356#discussion_r252364001
##
File path:
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers
URL: https://github.com/apache/flink/pull/7356#discussion_r252360333
##
File path:
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers
URL: https://github.com/apache/flink/pull/7356#discussion_r252360809
##
File path:
1 - 100 of 420 matches
Mail list logo
