zentol commented on issue #7451: [FLINK-11270][build] Do not include hadoop in
flink-dist by default
URL: https://github.com/apache/flink/pull/7451#issuecomment-457361147
n, a new IT case was added since my last rebase...
[
https://issues.apache.org/jira/browse/FLINK-11354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-11354.
-
Resolution: Fixed
Fix Version/s: 1.8.0
Fixed via
tillrohrmann closed pull request #7539: [FLINK-11354][tests] Port
JobManagerHARecoveryTest to new code base
URL: https://github.com/apache/flink/pull/7539
This is an automated message from the Apache Git Service.
To respond
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_r250841364
##
File path:
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_r250841487
##
File path:
xueyumusic opened a new pull request #7576: [FLINK-11046][elasticsearch] Fix
ElasticSearch6Connector thread blocked when index failed with retry
URL: https://github.com/apache/flink/pull/7576
## What is the purpose of the change
This PR tried to fix the issue that es6 connector thread
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_r250841068
##
File path:
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_r250842739
##
File path:
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_r250841836
##
File path:
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_r250843488
##
File path:
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_r250843033
##
File path:
vinoyang created FLINK-11432:
Summary: YarnFlinkResourceManagerTest test case timeout
Key: FLINK-11432
URL: https://issues.apache.org/jira/browse/FLINK-11432
Project: Flink
Issue Type: Test
[
https://issues.apache.org/jira/browse/FLINK-11432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11432:
-
Description:
{code:java}
07:24:07.034 [ERROR]
[
https://issues.apache.org/jira/browse/FLINK-11430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
leesf reassigned FLINK-11430:
-
Assignee: leesf
> Incorrect Akka timeout syntax
> -
>
>
klion26 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_r250839001
##
File path:
klion26 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_r250837942
##
File path:
klion26 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_r250635618
##
File path:
klion26 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_r250628433
##
File path:
klion26 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_r250662806
##
File path:
klion26 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_r250838867
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11046:
---
Labels: pull-request-available (was: )
> ElasticSearch6Connector cause thread blocked when
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_r250843974
##
File path:
jgrier commented on issue #7099: [FLINK-10887] [jobmaster] Add source watermark
tracking to the JobMaster
URL: https://github.com/apache/flink/pull/7099#issuecomment-457430460
@tweise Have a look.. Also, I didn't ignore the input about "idleness"
issues but that will be handled by the
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_r250852309
##
File path:
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_r250852230
##
File path:
kezhuw commented on issue #7548: [FLINK-11326] [streaming] Fix forbidden
negative offset in window assigners
URL: https://github.com/apache/flink/pull/7548#issuecomment-457413613
@rmetzger Thanks, I know it. By the way, is there any document somewhere
listing component maintainers so
klion26 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_r250638945
##
File path:
klion26 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_r250641203
##
File path:
klion26 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_r250642300
##
File path:
klion26 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_r250630206
##
File path:
klion26 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_r250637402
##
File path:
klion26 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_r250839391
##
File path:
klion26 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_r250839384
##
File path:
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_r250840172
##
File path:
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_r250842546
##
File path:
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_r250842279
##
File path:
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_r250844818
##
File path:
libenchao commented on issue #7572: [hotfix] [javadocs] fix typo in JobMaster
URL: https://github.com/apache/flink/pull/7572#issuecomment-457431547
@klion26 Thanks for the review. The title has been updated.
This is an
[
https://issues.apache.org/jira/browse/FLINK-11379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16751944#comment-16751944
]
Haibo Suen commented on FLINK-11379:
Thanks for the response [~StephanEwen]. I will use 4K as the
[
https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750856#comment-16750856
]
Fabian Wollert commented on FLINK-10707:
Hi [~lining] ... currently waiting for FLINK-10706 and
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750870#comment-16750870
]
Chesnay Schepler commented on FLINK-7608:
-
[~suez1224] You can query the latency metrics with the
lining created FLINK-11424:
--
Summary:
org.apache.flink.metrics.datadog.DatadogHttpReporter#report remove will throw
exception
Key: FLINK-11424
URL: https://issues.apache.org/jira/browse/FLINK-11424
asfgit closed pull request #7526: [FLINK-11353][tests] Port
JobManagerHAJobGraphRecoveryITCase to new code base
URL: https://github.com/apache/flink/pull/7526
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750891#comment-16750891
]
xueyu commented on FLINK-11046:
---
It looks that this kind of IndexRequest could result in reponse
[
https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edward Rojas updated FLINK-11419:
-
Description:
If a job with a StreamingFileSink sending data to HDFS is running in a cluster
[
https://issues.apache.org/jira/browse/FLINK-10460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lining updated FLINK-10460:
---
Attachment: image-2019-01-24-16-00-56-280.png
> DataDog reporter JsonMappingException
>
lavkesh opened a new pull request #7573: [FLINK-11423] Propagate the error
message from Main method to JarRunHandler
URL: https://github.com/apache/flink/pull/7573
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
[
https://issues.apache.org/jira/browse/FLINK-10460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lining reassigned FLINK-10460:
--
Assignee: lining
> DataDog reporter JsonMappingException
> -
>
>
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-457112913
@azagrebin thank you for your review, I've updated the code based on your
suggestions. Please
[
https://issues.apache.org/jira/browse/FLINK-11370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750889#comment-16750889
]
lining commented on FLINK-11370:
[~Tison], ok.
> Check and port ZooKeeperLeaderElectionITCase to new
[
https://issues.apache.org/jira/browse/FLINK-11370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lining reassigned FLINK-11370:
--
Assignee: lining (was: TisonKun)
> Check and port ZooKeeperLeaderElectionITCase to new code base if
[
https://issues.apache.org/jira/browse/FLINK-11424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750893#comment-16750893
]
lining commented on FLINK-11424:
why delete the key？
>
[
https://issues.apache.org/jira/browse/FLINK-11353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-11353.
-
Resolution: Fixed
Fix Version/s: 1.8.0
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750831#comment-16750831
]
Till Rohrmann commented on FLINK-11380:
---
Another instance:
[
https://issues.apache.org/jira/browse/FLINK-11423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11423:
---
Labels: pull-request-available (was: )
> Propagate the error message from Main method to
[
https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750874#comment-16750874
]
Chesnay Schepler commented on FLINK-11301:
--
We've been experiencing issues with{{transfer.sh}}
[
https://issues.apache.org/jira/browse/FLINK-11424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750921#comment-16750921
]
Chesnay Schepler commented on FLINK-11424:
--
Because a gauge that throws exceptions is probably
[
https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edward Rojas updated FLINK-11419:
-
Description:
If a job with a StreamingFileSink sending data to HDFS is running in a cluster
[
https://issues.apache.org/jira/browse/FLINK-11424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lining updated FLINK-11424:
---
Description:
{code:java}
for (Map.Entry entry : gauges.entrySet()) {
DGauge g = entry.getValue();
try
[
https://issues.apache.org/jira/browse/FLINK-10460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750840#comment-16750840
]
lining commented on FLINK-10460:
[~elevy] In code write `Will throw exception if the Gauge is not of
[
https://issues.apache.org/jira/browse/FLINK-10460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lining reassigned FLINK-10460:
--
Assignee: (was: lining)
> DataDog reporter JsonMappingException
>
[
https://issues.apache.org/jira/browse/FLINK-11424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lining reassigned FLINK-11424:
--
Assignee: lining
> org.apache.flink.metrics.datadog.DatadogHttpReporter#report remove will throw
>
[
https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-11421:
-
Component/s: (was: Core)
Table API & SQL
> Providing more compilation
[
https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750967#comment-16750967
]
Kostas Kloudas edited comment on FLINK-11419 at 1/24/19 10:13 AM:
--
Hi
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r250555126
##
File path:
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r250556244
##
File path:
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r250562404
##
File path:
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r250554995
##
File path:
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r250559222
##
File path:
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r250556445
##
File path:
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r250558861
##
File path:
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r250553467
##
File path:
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r250561743
##
File path:
tillrohrmann commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r250559108
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750971#comment-16750971
]
Kostas Kloudas commented on FLINK-11419:
In any case, from your report it seems that the initial
[
https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10251.
-
Resolution: Fixed
Fix Version/s: (was: 1.7.2)
(was: 1.6.4)
asfgit closed pull request #6876: [FLINK-10251] Handle oversized response
messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876
This is an automated message from the Apache Git Service.
To respond to the
jayantak opened a new pull request #7574: [hotfix] [docs] Fix wrong port in
docs for Kubernetes Setup
URL: https://github.com/apache/flink/pull/7574
This is an automated message from the Apache Git Service.
To respond to
Guang Hu created FLINK-11427:
Summary: Protobuf parquet writer implementation
Key: FLINK-11427
URL: https://issues.apache.org/jira/browse/FLINK-11427
Project: Flink
Issue Type: Improvement
LiuJi created FLINK-11425:
-
Summary: Support of “Hash Teams” in Hybrid Hash Join
Key: FLINK-11425
URL: https://issues.apache.org/jira/browse/FLINK-11425
Project: Flink
Issue Type: New Feature
azagrebin 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_r250110054
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16751035#comment-16751035
]
Stephan Ewen commented on FLINK-11425:
--
We are currently looking to merge a major contribution
[
https://issues.apache.org/jira/browse/FLINK-11219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16751102#comment-16751102
]
Chesnay Schepler commented on FLINK-11219:
--
MIrroring my comment from the flink-shaded
jayantak commented on issue #7574: [hotfix] [docs] Fix wrong port in docs for
Kubernetes Setup
URL: https://github.com/apache/flink/pull/7574#issuecomment-457172129
The rpc port defined does not match between the Taskmanager deployment and
the job manager deployment.
jayantak edited a comment on issue #7574: [hotfix] [docs] Fix wrong port in
docs for Kubernetes Setup
URL: https://github.com/apache/flink/pull/7574#issuecomment-457172129
The rpc port defined did not match between the Taskmanager deployment and
the job manager deployment.
tillrohrmann commented on issue #7356: [FLINK-10868][flink-yarn] Enforce
maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#issuecomment-457152497
Current test failure is unrelated.
This
vinoyang created FLINK-11426:
Summary: FlinkKafkaProducerBase test case failed
Key: FLINK-11426
URL: https://issues.apache.org/jira/browse/FLINK-11426
Project: Flink
Issue Type: Test
[
https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750967#comment-16750967
]
Kostas Kloudas commented on FLINK-11419:
Hi [~edRojas]. Thanks for reporting this.
I would
[
https://issues.apache.org/jira/browse/FLINK-11336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-11336:
--
Component/s: Distributed Coordination
> Flink HA didn't remove ZK metadata
>
[
https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16751059#comment-16751059
]
Hequn Cheng commented on FLINK-11301:
-
[~Zentol] Sounds good. We can observe it a bit longer. If
GJL commented on issue #7544: [FLINK-11366][tests] Port TaskManagerMetricsTest
to new code base
URL: https://github.com/apache/flink/pull/7544#issuecomment-457181080
I think it is better to delete the original test:
- `TaskManagerMetricsTest` was asserting that the MetricRegistry is
Myasuka commented on issue #7544: [FLINK-11366][tests] Port
TaskManagerMetricsTest to new code base
URL: https://github.com/apache/flink/pull/7544#issuecomment-457189414
@GJL Thanks for your clarification.
The only thing I feel a bit confused is that, please correct me if I am
wrong,
Congxian Qiu created FLINK-11428:
Summary: BufferFileWriterFileSegmentReaderTest#testWriteRead
failed on Travis
Key: FLINK-11428
URL: https://issues.apache.org/jira/browse/FLINK-11428
Project: Flink
klion26 commented on issue #7572: fix typo in JobMaster
URL: https://github.com/apache/flink/pull/7572#issuecomment-457213864
@libenchao Thank you for your contribution! Could you please update the PR's
title just like [this](https://github.com/apache/flink/pull/7574).
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_r250625564
##
File path:
zentol commented on a change in pull request #7539: [FLINK-11354][tests] Port
JobManagerHARecoveryTest to new code base
URL: https://github.com/apache/flink/pull/7539#discussion_r250600745
##
File path:
zentol commented on a change in pull request #7539: [FLINK-11354][tests] Port
JobManagerHARecoveryTest to new code base
URL: https://github.com/apache/flink/pull/7539#discussion_r250599168
##
File path:
zentol commented on a change in pull request #7539: [FLINK-11354][tests] Port
JobManagerHARecoveryTest to new code base
URL: https://github.com/apache/flink/pull/7539#discussion_r250600872
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Congxian Qiu updated FLINK-11428:
-
Component/s: Tests
> BufferFileWriterFileSegmentReaderTest#testWriteRead failed on Travis
>
Mario Georgiev created FLINK-11429:
---
Summary: Flink fails to authenticate s3a with core-site.xml
Key: FLINK-11429
URL: https://issues.apache.org/jira/browse/FLINK-11429
Project: Flink
1 - 100 of 174 matches
Mail list logo
