bowenli86 commented on a change in pull request #9721: [FLINK-14129][hive]
HiveTableSource should implement ProjectableTable…
URL: https://github.com/apache/flink/pull/9721#discussion_r326790235
##
File path:
flinkbot edited a comment on issue #9737: [FLINK-14158] Update Mesos scheduler
to make leaseOfferExpiration and declinedOfferRefuse duration configurable
URL: https://github.com/apache/flink/pull/9737#issuecomment-533692308
## CI report:
*
[
https://issues.apache.org/jira/browse/FLINK-14158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14158:
---
Labels: pull-request-available (was: )
> Update Mesos configs to add leaseOfferExpiration
kl0u commented on issue #9581: [FLINK-13864][streaming]: Modify the
StreamingFileSink Builder interface to allow for easier subclassing of
StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#issuecomment-533688638
@tweise It would be nice if it can be addressed before
yxu-valleytider removed a comment on issue #9581: [FLINK-13864][streaming]:
Modify the StreamingFileSink Builder interface to allow for easier subclassing
of StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#issuecomment-533666729
yxu-valleytider commented on issue #9581: [FLINK-13864][streaming]: Modify the
StreamingFileSink Builder interface to allow for easier subclassing of
StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#issuecomment-533666729
yxu-valleytider commented on issue #9581: [FLINK-13864][streaming]: Modify the
StreamingFileSink Builder interface to allow for easier subclassing of
StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#issuecomment-533666702
> @yxu-valleytider I think we can merge this PR as
tweise commented on issue #9581: [FLINK-13864][streaming]: Modify the
StreamingFileSink Builder interface to allow for easier subclassing of
StreamingFileSink
URL: https://github.com/apache/flink/pull/9581#issuecomment-533679202
@kl0u thanks for working through this. Should the
Piyush Narang created FLINK-14158:
-
Summary: Update Mesos configs to add leaseOfferExpiration and
declinedOfferRefuse durations
Key: FLINK-14158
URL: https://issues.apache.org/jira/browse/FLINK-14158
flinkbot commented on issue #9737: [FLINK-14158] Update Mesos scheduler to make
leaseOfferExpiration and declinedOfferRefuse duration configurable
URL: https://github.com/apache/flink/pull/9737#issuecomment-533692308
## CI report:
* 6570149a99fac86e45cc3b0c9a83b32ff7b32365 :
piyushnarang opened a new pull request #9737: [FLINK-14158] Update Mesos
scheduler to make leaseOfferExpiration and declinedOfferRefuse duration
configurable
URL: https://github.com/apache/flink/pull/9737
## What is the purpose of the change
While debugging some Flink on
flinkbot edited a comment on issue #9726: [FLINK-14113][client] Remove class
JobWithJars
URL: https://github.com/apache/flink/pull/9726#issuecomment-533472035
## CI report:
* 9d72829c8c3697d2e2582005ba60863d525ffc66 : UNKNOWN
* 49a801cce0eb397c0248250d986ce99ade485941 :
flinkbot commented on issue #9737: [FLINK-14158] Update Mesos scheduler to make
leaseOfferExpiration and declinedOfferRefuse duration configurable
URL: https://github.com/apache/flink/pull/9737#issuecomment-533687706
Thanks a lot for your contribution to the Apache Flink project. I'm the
flinkbot edited a comment on issue #9737: [FLINK-14158] Update Mesos scheduler
to make leaseOfferExpiration and declinedOfferRefuse duration configurable
URL: https://github.com/apache/flink/pull/9737#issuecomment-533692308
## CI report:
*
jackylau created FLINK-14159:
Summary: flink rocksdb StreamCompressionDecorator not right
Key: FLINK-14159
URL: https://issues.apache.org/jira/browse/FLINK-14159
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934884#comment-16934884
]
jackylau commented on FLINK-14159:
--
who is responsible for , and who can see this issue [~lzljs3620320]
[
https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-14159:
-
Description:
I think the current flink rocksdb StreamCompressionDecorator is not right when
calling
[
https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934884#comment-16934884
]
jackylau edited comment on FLINK-14159 at 9/21/19 2:36 AM:
---
I want to konw who
flinkbot edited a comment on issue #9416: [FLINK-13646][build system] Add basic
ARM CI job definition
URL: https://github.com/apache/flink/pull/9416#issuecomment-520285701
## CI report:
* dbf749f0d0c3167265287b182dd1ea7b4aed84c1 : FAILURE
[
https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934921#comment-16934921
]
Zijie Lu commented on FLINK-13746:
--
I have submitted a pull request
flinkbot commented on issue #9738: [FLINK-13746]Whitelist [Terror] to avoid end
to end test failure in e…
URL: https://github.com/apache/flink/pull/9738#issuecomment-533770354
## CI report:
* b13b6edb9952c74ba5b68d0f64bd6393534c73ea : UNKNOWN
flinkbot edited a comment on issue #9416: [FLINK-13646][build system] Add basic
ARM CI job definition
URL: https://github.com/apache/flink/pull/9416#issuecomment-520285701
## CI report:
* dbf749f0d0c3167265287b182dd1ea7b4aed84c1 : FAILURE
lirui-apache commented on a change in pull request #9721: [FLINK-14129][hive]
HiveTableSource should implement ProjectableTable…
URL: https://github.com/apache/flink/pull/9721#discussion_r326846024
##
File path:
wangxiyuan commented on issue #9416: [FLINK-13646][build system] Add basic ARM
CI job definition
URL: https://github.com/apache/flink/pull/9416#issuecomment-533758675
check_arm
This is an automated message from the Apache
flinkbot edited a comment on issue #9416: [FLINK-13646][build system] Add basic
ARM CI job definition
URL: https://github.com/apache/flink/pull/9416#issuecomment-520285701
## CI report:
* dbf749f0d0c3167265287b182dd1ea7b4aed84c1 : FAILURE
flinkbot commented on issue #9738: [FLINK-13746]Whitelist [Terror] to avoid end
to end test failure in e…
URL: https://github.com/apache/flink/pull/9738#issuecomment-533770121
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
TszKitLo40 opened a new pull request #9738: [FLINK-13746]Whitelist [Terror] to
avoid end to end test failure in e…
URL: https://github.com/apache/flink/pull/9738
…s 2.3.5
## What is the purpose of the change
*(For example: This pull request makes task deployment go
[
https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13746:
---
Labels: pull-request-available test-stability (was: test-stability)
> Elasticsearch
Wei Zhong created FLINK-14150:
-
Summary: Unnecessary __pycache__ directories appears in pyflink.zip
Key: FLINK-14150
URL: https://issues.apache.org/jira/browse/FLINK-14150
Project: Flink
Issue
yanghua commented on issue #9720: [FLINK-13025] Elasticsearch 7.x support
URL: https://github.com/apache/flink/pull/9720#issuecomment-533494206
@aljoscha What do you think about this PR? Anything that I missed, please
let me know. Thanks
[
https://issues.apache.org/jira/browse/FLINK-14150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-14150:
---
Assignee: Wei Zhong
> Unnecessary __pycache__ directories appears in pyflink.zip
>
[
https://issues.apache.org/jira/browse/FLINK-9749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934266#comment-16934266
]
Shimin Yang commented on FLINK-9749:
Hi [~kkl0u], it does seem like a replicating of window
1u0 commented on a change in pull request #9727: [FLINK-14145] Fix
getLatestCheckpoint(true) returns wrong checkpoint
URL: https://github.com/apache/flink/pull/9727#discussion_r326561727
##
File path:
1u0 commented on a change in pull request #9727: [FLINK-14145] Fix
getLatestCheckpoint(true) returns wrong checkpoint
URL: https://github.com/apache/flink/pull/9727#discussion_r326561669
##
File path:
flinkbot edited a comment on issue #9726: [FLINK-14113][client] Remove class
JobWithJars
URL: https://github.com/apache/flink/pull/9726#issuecomment-533472035
## CI report:
* 9d72829c8c3697d2e2582005ba60863d525ffc66 : UNKNOWN
* 49a801cce0eb397c0248250d986ce99ade485941 :
azagrebin commented on issue #8934: [FLINK-12628][Runtime / Coordination] Check
test failure if partitionhas no consumers in
Execution.getPartitionMaxParallelism
URL: https://github.com/apache/flink/pull/8934#issuecomment-533497230
@liyafan82
the CI actually reported success, we can
liyafan82 opened a new pull request #8934: [FLINK-12628][Runtime /
Coordination] Check test failure if partitionhas no consumers in
Execution.getPartitionMaxParallelism
URL: https://github.com/apache/flink/pull/8934
## What is the purpose of the change
Resolve issue
[
https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934283#comment-16934283
]
liupengcheng commented on FLINK-14123:
--
[~StephanEwen] Yes, you are right, we are using jdk8, and
AHeise commented on a change in pull request #9717: [FLINK-14044] [runtime]
Reducing synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#discussion_r326572673
##
File path:
AHeise commented on a change in pull request #9717: [FLINK-14044] [runtime]
Reducing synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#discussion_r326573093
##
File path:
1u0 commented on a change in pull request #9727: [FLINK-14145] Fix
getLatestCheckpoint(true) returns wrong checkpoint
URL: https://github.com/apache/flink/pull/9727#discussion_r326561727
##
File path:
liyafan82 opened a new pull request #9728: [FLINK-12628][Runtime /
Coordination] Check test failure if partitionhas no consumers in
Execution.getPartitionMaxParallelism
URL: https://github.com/apache/flink/pull/9728
## What is the purpose of the change
Resolve issue
liyafan82 commented on issue #8934: [FLINK-12628][Runtime / Coordination] Check
test failure if partitionhas no consumers in
Execution.getPartitionMaxParallelism
URL: https://github.com/apache/flink/pull/8934#issuecomment-533505704
> @liyafan82
> the CI actually reported success, we
flinkbot commented on issue #9728: [FLINK-12628][Runtime / Coordination] Check
test failure if partitionhas no consumers in
Execution.getPartitionMaxParallelism
URL: https://github.com/apache/flink/pull/9728#issuecomment-533505734
Thanks a lot for your contribution to the Apache Flink
liyafan82 closed pull request #9728: [FLINK-12628][Runtime / Coordination]
Check test failure if partitionhas no consumers in
Execution.getPartitionMaxParallelism
URL: https://github.com/apache/flink/pull/9728
This is an
flinkbot edited a comment on issue #9727: [FLINK-14145] Fix
getLatestCheckpoint(true) returns wrong checkpoint
URL: https://github.com/apache/flink/pull/9727#issuecomment-533484572
## CI report:
* 31a78ba191c36561f073b0b5a0a2c1b6aa2d18a0 : SUCCESS
1u0 commented on a change in pull request #9727: [FLINK-14145] Fix
getLatestCheckpoint(true) returns wrong checkpoint
URL: https://github.com/apache/flink/pull/9727#discussion_r326561727
##
File path:
flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing
synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#issuecomment-533068819
## CI report:
* 9cfda801891969ac460f45ea639d636b519f22db : FAILURE
flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x
support
URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106
## CI report:
* d9c1dd529ef235649909d067cc78099179656e62 : FAILURE
flinkbot commented on issue #9723: [FLINK-14114] [client] Shift down
ClusterClient#timeout to RestClusterClient
URL: https://github.com/apache/flink/pull/9723#issuecomment-533419662
## CI report:
* 7c3eef29f2f40406bdd24f9c78889f5a68853308 : UNKNOWN
flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x
support
URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106
## CI report:
* d9c1dd529ef235649909d067cc78099179656e62 : FAILURE
flinkbot edited a comment on issue #9723: [FLINK-14114] [client] Shift down
ClusterClient#timeout to RestClusterClient
URL: https://github.com/apache/flink/pull/9723#issuecomment-533419662
## CI report:
* 7c3eef29f2f40406bdd24f9c78889f5a68853308 : PENDING
[
https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934108#comment-16934108
]
Wei Zhong commented on FLINK-14019:
---
Hi [~sunjincheng121], [~hequn8128] and [~dian.fu], I have
zhuzhurk commented on a change in pull request #9663:
[WIP][FLINK-12433][runtime] Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r326482996
##
File path:
zhuzhurk commented on a change in pull request #9663:
[WIP][FLINK-12433][runtime] Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r326485570
##
File path:
zhuzhurk commented on a change in pull request #9663:
[WIP][FLINK-12433][runtime] Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r326489325
##
File path:
zhuzhurk commented on a change in pull request #9663:
[WIP][FLINK-12433][runtime] Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r326484256
##
File path:
AHeise commented on issue #9385: [FLINK-13635][datastream] Avoid unexpected
interruption of AsyncFunction
URL: https://github.com/apache/flink/pull/9385#issuecomment-533432744
Hi @ifndef-SleePy ,
I just stumbled upon this PR (it's assigned to the wrong component).
The issue
Yingjie Cao created FLINK-14139:
---
Summary: Fix potential memory leak of rest server when using
session/standalone cluster
Key: FLINK-14139
URL: https://issues.apache.org/jira/browse/FLINK-14139
Wei Zhong created FLINK-14140:
-
Summary: The Flink Logo Displayed in Flink Python Shell is Broken
Key: FLINK-14140
URL: https://issues.apache.org/jira/browse/FLINK-14140
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-14140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-14140:
---
Assignee: Wei Zhong
> The Flink Logo Displayed in Flink Python Shell is Broken
>
[
https://issues.apache.org/jira/browse/FLINK-14140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934149#comment-16934149
]
Hequn Cheng commented on FLINK-14140:
-
Good catch!
> The Flink Logo Displayed in Flink Python Shell
[
https://issues.apache.org/jira/browse/FLINK-13635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu closed FLINK-13635.
Resolution: Won't Fix
This scenario should not exist anymore after integrating AsyncWaitOperator with
[
https://issues.apache.org/jira/browse/FLINK-14140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei Zhong updated FLINK-14140:
--
Attachment: image-2019-09-20-15-23-17-810.png
> The Flink Logo Displayed in Flink Python Shell is
[
https://issues.apache.org/jira/browse/FLINK-14140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14140:
---
Labels: pull-request-available (was: )
> The Flink Logo Displayed in Flink Python Shell is
[
https://issues.apache.org/jira/browse/FLINK-12662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934168#comment-16934168
]
vinoyang commented on FLINK-12662:
--
[~trohrmann] I want to active this issue. Can you give some
flinkbot commented on issue #9725: [FLINK-14140][python] fix the broken flink
logo in flink python shell.
URL: https://github.com/apache/flink/pull/9725#issuecomment-533444961
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
flinkbot edited a comment on issue #9721: [FLINK-14129][hive] HiveTableSource
should implement ProjectableTable…
URL: https://github.com/apache/flink/pull/9721#issuecomment-533163569
## CI report:
* ffcb98bf85b81ec59ce7ea0fa021076afdcd40d4 : SUCCESS
Yadong Xie created FLINK-14143:
--
Summary: Failed Attempt does not display in the timeline
Key: FLINK-14143
URL: https://issues.apache.org/jira/browse/FLINK-14143
Project: Flink
Issue Type:
flinkbot commented on issue #9724: [FLINK-13971][rest]Add TaskManager ID in
JobVertexTaskManagersInfo.TaskManagersInfo
URL: https://github.com/apache/flink/pull/9724#issuecomment-533448816
## CI report:
* e22963f52f08f9462b4a0b5928791dff3dadb750 : UNKNOWN
flinkbot commented on issue #9725: [FLINK-14140][python] fix the broken flink
logo in flink python shell.
URL: https://github.com/apache/flink/pull/9725#issuecomment-533448841
## CI report:
* 1e7eb9f35320c3903e32fc8dd45221e7d06d0898 : UNKNOWN
lirui-apache commented on a change in pull request #9721: [FLINK-14129][hive]
HiveTableSource should implement ProjectableTable…
URL: https://github.com/apache/flink/pull/9721#discussion_r326512198
##
File path:
dianfu commented on issue #9725: [FLINK-14140][python] fix the broken flink
logo in flink python shell.
URL: https://github.com/apache/flink/pull/9725#issuecomment-533454080
@WeiZhong94 Thanks for the PR. LGTM. +1 from my side.
flinkbot edited a comment on issue #9724: [FLINK-13971][rest]Add TaskManager ID
in JobVertexTaskManagersInfo.TaskManagersInfo
URL: https://github.com/apache/flink/pull/9724#issuecomment-533448816
## CI report:
* e22963f52f08f9462b4a0b5928791dff3dadb750 : PENDING
flinkbot edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing
synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#issuecomment-533068819
## CI report:
* 9cfda801891969ac460f45ea639d636b519f22db : FAILURE
flinkbot edited a comment on issue #9721: [FLINK-14129][hive] HiveTableSource
should implement ProjectableTable…
URL: https://github.com/apache/flink/pull/9721#issuecomment-533163569
## CI report:
* ffcb98bf85b81ec59ce7ea0fa021076afdcd40d4 : SUCCESS
flinkbot edited a comment on issue #9725: [FLINK-14140][python] fix the broken
flink logo in flink python shell.
URL: https://github.com/apache/flink/pull/9725#issuecomment-533448841
## CI report:
* 1e7eb9f35320c3903e32fc8dd45221e7d06d0898 : PENDING
Ufuk Celebi created FLINK-14145:
---
Summary: getLatestCheckpoint returns wrong checkpoint
Key: FLINK-14145
URL: https://issues.apache.org/jira/browse/FLINK-14145
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-14145:
Description:
The flag to prefer checkpoints for recovery introduced in FLINK-11159 returns
the
[
https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934190#comment-16934190
]
Stephan Ewen commented on FLINK-14123:
--
Thanks!
What GC were you using? G1, CMS, Parallel?
The logs
Yijie Shen created FLINK-14146:
--
Summary: Introduce Pulsar connector
Key: FLINK-14146
URL: https://issues.apache.org/jira/browse/FLINK-14146
Project: Flink
Issue Type: New Feature
flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an
implementation of pipeline's api
URL: https://github.com/apache/flink/pull/9184#issuecomment-513425405
## CI report:
* bd7ade5e0b57dc8577d7f864afcbbb24c2513e56 : FAILURE
[
https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei Zhong updated FLINK-14019:
--
Comment: was deleted
(was: Hi [~sunjincheng121], [~hequn8128] and [~dian.fu], I have finished the
[
https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934106#comment-16934106
]
Wei Zhong commented on FLINK-14019:
---
Hi [~sunjincheng121], [~hequn8128] and [~dian.fu], I have
flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x
support
URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106
## CI report:
* d9c1dd529ef235649909d067cc78099179656e62 : FAILURE
zhuzhurk commented on a change in pull request #9663:
[WIP][FLINK-12433][runtime] Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r326487486
##
File path:
zhuzhurk commented on a change in pull request #9663:
[WIP][FLINK-12433][runtime] Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r326483593
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-14139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934144#comment-16934144
]
Yingjie Cao commented on FLINK-14139:
-
Some other user of netty also encountered this problem:
ifndef-SleePy commented on issue #9385: [FLINK-13635][datastream] Avoid
unexpected interruption of AsyncFunction
URL: https://github.com/apache/flink/pull/9385#issuecomment-533436759
Hi @AHeise ,
Thanks for feedback. (I almost forgot this pending PR...)
Glad to hear this scenario is
ifndef-SleePy closed pull request #9385: [FLINK-13635][datastream] Avoid
unexpected interruption of AsyncFunction
URL: https://github.com/apache/flink/pull/9385
This is an automated message from the Apache Git Service.
To
JingsongLi commented on a change in pull request #9721: [FLINK-14129][hive]
HiveTableSource should implement ProjectableTable…
URL: https://github.com/apache/flink/pull/9721#discussion_r326498479
##
File path:
flinkbot edited a comment on issue #9723: [FLINK-14114] [client] Shift down
ClusterClient#timeout to RestClusterClient
URL: https://github.com/apache/flink/pull/9723#issuecomment-533419662
## CI report:
* 7c3eef29f2f40406bdd24f9c78889f5a68853308 : SUCCESS
flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x
support
URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106
## CI report:
* d9c1dd529ef235649909d067cc78099179656e62 : FAILURE
[
https://issues.apache.org/jira/browse/FLINK-14140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934149#comment-16934149
]
Hequn Cheng edited comment on FLINK-14140 at 9/20/19 7:15 AM:
--
Good catch!
Yadong Xie created FLINK-14141:
--
Summary: Locate Jobs/SubTask/Vertex Running on TaskManager
Key: FLINK-14141
URL: https://issues.apache.org/jira/browse/FLINK-14141
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-14145:
Attachment: 0001-FLINK-14145-runtime-Add-getLatestCheckpoint-test.patch
> getLatestCheckpoint
[
https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-14145:
Description:
The flag to prefer checkpoints for recovery introduced in FLINK-11159 returns
the
[
https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-14145:
Description:
The flag to prefer checkpoints for recovery introduced in FLINK-11159 returns
the
StephanEwen closed pull request #9498: [FLINK-13810][Docs]Update `Elasticsearch
Connector` label
URL: https://github.com/apache/flink/pull/9498
This is an automated message from the Apache Git Service.
To respond to the
StephanEwen commented on issue #9498: [FLINK-13810][Docs]Update `Elasticsearch
Connector` label
URL: https://github.com/apache/flink/pull/9498#issuecomment-533456418
I believe the docs are correct as they are. ES is a sink in both cases not a
source.
1 - 100 of 323 matches
Mail list logo
