[
https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818682#comment-16818682
]
ryantaocer edited comment on FLINK-12070 at 4/16/19 6:51 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818682#comment-16818682
]
ryantaocer edited comment on FLINK-12070 at 4/16/19 6:48 AM:
-
dawidwys commented on a change in pull request #8162: [FLINK-12174][table]
Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences
URL: https://github.com/apache/flink/pull/8162#discussion_r275649921
##
File path:
flink-table/flink-table-planner/src/main/java/o
hequn8128 commented on issue #8162: [FLINK-12174][table] Introduce
FlinkAggregateExtractProjectRule and remove extractFieldReferences
URL: https://github.com/apache/flink/pull/8162#issuecomment-483532677
@dawidwys Thank you very much for your review. I have updated the PR
according to your
zentol commented on issue #8181: [FLINK-12199][network] Refactor IOMetrics to
not distinguish between local/remote in/out bytes
URL: https://github.com/apache/flink/pull/8181#issuecomment-483530939
Even if _we_ combine them for the purpose of the UI, this may not be the
case for users.
[
https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818682#comment-16818682
]
ryantaocer commented on FLINK-12070:
It's so cool to unify the network buffered and
hequn8128 commented on a change in pull request #8162: [FLINK-12174][table]
Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences
URL: https://github.com/apache/flink/pull/8162#discussion_r275622038
##
File path:
flink-table/flink-table-planner/src/main/java/
hequn8128 commented on a change in pull request #8162: [FLINK-12174][table]
Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences
URL: https://github.com/apache/flink/pull/8162#discussion_r275623637
##
File path:
flink-table/flink-table-planner/src/main/java/
[
https://issues.apache.org/jira/browse/FLINK-12209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-12209:
-
Description: This issue tracks the work of T3 section about in design
document :
[https://docs.google.c
vinoyang created FLINK-12209:
Summary: Refactor failure handling with CheckpointFailureManager
Key: FLINK-12209
URL: https://issues.apache.org/jira/browse/FLINK-12209
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-12189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liya Fan updated FLINK-12189:
-
Priority: Critical (was: Major)
> Fix bugs and typos in memory management related code
> --
[
https://issues.apache.org/jira/browse/FLINK-12205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hobo Chen closed FLINK-12205.
-
Resolution: Not A Bug
> Internal server error., akka.pattern.AskTimeoutException: Ask timed out on
> [
[
https://issues.apache.org/jira/browse/FLINK-12205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818660#comment-16818660
]
Hobo Chen commented on FLINK-12205:
---
maybe my develop env have some error. I run this
flinkbot commented on issue #8181: [FLINK-12199][network] Refactor IOMetrics to
not distinguish between local/remote in/out bytes
URL: https://github.com/apache/flink/pull/8181#issuecomment-483518115
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help
[
https://issues.apache.org/jira/browse/FLINK-12199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12199:
---
Labels: pull-request-available (was: )
> Refactor IOMetrics to not distinguish between loca
zjffdu edited a comment on issue #8144: [FLINK-12159]. Enable YarnMiniCluster
integration test under non-secure mode
URL: https://github.com/apache/flink/pull/8144#issuecomment-483517975
> If a downstream process sets up a YarnMiniCluster it could configure the
port differently. Flink woul
zjffdu commented on issue #8144: [FLINK-12159]. Enable YarnMiniCluster
integration test under non-secure mode
URL: https://github.com/apache/flink/pull/8144#issuecomment-483517975
> If a downstream process sets up a YarnMiniCluster it could configure the
port differently. Flink would not n
zhijiangW opened a new pull request #8181: [FLINK-12199][network] Refactor
IOMetrics to not distinguish between local/remote in/out bytes
URL: https://github.com/apache/flink/pull/8181
## What is the purpose of the change
*At the moment we have `numBytesInLocal/numBytesInRemote` in `
[
https://issues.apache.org/jira/browse/FLINK-12205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818647#comment-16818647
]
Hobo Chen commented on FLINK-12205:
---
I think the error like this
[http://mail-archive
[
https://issues.apache.org/jira/browse/FLINK-12208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818643#comment-16818643
]
Jark Wu commented on FLINK-12208:
-
It would be great if we can introduce what's the diff
[
https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818619#comment-16818619
]
zhijiang edited comment on FLINK-12070 at 4/16/19 4:25 AM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818619#comment-16818619
]
zhijiang edited comment on FLINK-12070 at 4/16/19 4:24 AM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818619#comment-16818619
]
zhijiang commented on FLINK-12070:
--
Thanks for providing the POC for this feature [~Ste
hequn8128 commented on a change in pull request #8162: [FLINK-12174][table]
Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences
URL: https://github.com/apache/flink/pull/8162#discussion_r275623637
##
File path:
flink-table/flink-table-planner/src/main/java/
hequn8128 commented on a change in pull request #8162: [FLINK-12174][table]
Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences
URL: https://github.com/apache/flink/pull/8162#discussion_r275622038
##
File path:
flink-table/flink-table-planner/src/main/java/
sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement
the runtime handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#discussion_r275620766
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/run
sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement
the runtime handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#discussion_r275620766
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/run
[
https://issues.apache.org/jira/browse/FLINK-12172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818588#comment-16818588
]
Biao Liu commented on FLINK-12172:
--
Hi Mario,
Could you share more detail information
[
https://issues.apache.org/jira/browse/FLINK-11813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818575#comment-16818575
]
Zhu Zhu edited comment on FLINK-11813 at 4/16/19 3:15 AM:
--
I th
[
https://issues.apache.org/jira/browse/FLINK-11813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818575#comment-16818575
]
Zhu Zhu edited comment on FLINK-11813 at 4/16/19 3:14 AM:
--
I th
[
https://issues.apache.org/jira/browse/FLINK-11813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818575#comment-16818575
]
Zhu Zhu edited comment on FLINK-11813 at 4/16/19 3:13 AM:
--
I th
[
https://issues.apache.org/jira/browse/FLINK-12147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-12147:
Attachment: metric-error.log
Description: when use influxDB store metric datas, and metric kaf
[
https://issues.apache.org/jira/browse/FLINK-12132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818579#comment-16818579
]
Wang Geng commented on FLINK-12132:
---
Thanks for assigning this issue to me. I'm workin
Jing Zhang created FLINK-12208:
--
Summary: Introduce Sort / TemporalSort / SortLimit/ Limit
operators for blink streaming runtime
Key: FLINK-12208
URL: https://issues.apache.org/jira/browse/FLINK-12208
[
https://issues.apache.org/jira/browse/FLINK-11813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818575#comment-16818575
]
Zhu Zhu edited comment on FLINK-11813 at 4/16/19 2:55 AM:
--
I th
[
https://issues.apache.org/jira/browse/FLINK-11813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818575#comment-16818575
]
Zhu Zhu edited comment on FLINK-11813 at 4/16/19 2:54 AM:
--
I th
[
https://issues.apache.org/jira/browse/FLINK-11813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818575#comment-16818575
]
Zhu Zhu commented on FLINK-11813:
-
I think with SubmittedJobGraphStore been a underlying
[
https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818572#comment-16818572
]
lamber-ken edited comment on FLINK-10818 at 4/16/19 2:53 AM:
-
asfgit closed pull request #8109: [FLINK-12017][table-runtime-blink] Introduce
Rank and Deduplicate operators for blink streaming runtime
URL: https://github.com/apache/flink/pull/8109
This is an automated message from the A
[
https://issues.apache.org/jira/browse/FLINK-12017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-12017.
---
> Introduce Rank and Deduplicate operators for blink streaming runtime
> -
[
https://issues.apache.org/jira/browse/FLINK-12017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu resolved FLINK-12017.
-
Resolution: Fixed
Assignee: Jing Zhang
Fixed in 1.9: 82419542ba7ec80380fb7db0eaf6927af5b00015
>
[
https://issues.apache.org/jira/browse/FLINK-12160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-12160:
-
Assignee: Yang Wang
> Support for transferring user config files on kubernetes
> --
[
https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818572#comment-16818572
]
lamber-ken commented on FLINK-10818:
hi, [~till.rohrmann], I don't know which mode I
[
https://issues.apache.org/jira/browse/FLINK-12017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-12017:
---
Summary: Introduce Rank and Deduplicate operators for blink streaming
runtime (was: Support trans
[
https://issues.apache.org/jira/browse/FLINK-11955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818568#comment-16818568
]
vinoyang commented on FLINK-11955:
--
Yes, I will try my best to work on this issue. I ha
[
https://issues.apache.org/jira/browse/FLINK-12204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818567#comment-16818567
]
Liya Fan commented on FLINK-12204:
--
[~hequn8128], thanks for your fast response. Please
FaxianZhao commented on issue #7965: [FLINK-12204] [jdbc] make JDBCOutputFormat
ClassCastException more helpful
URL: https://github.com/apache/flink/pull/7965#issuecomment-483488471
@fhueske Thanks for your help. I'm learning how to be a contributor. :)
sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement
the runtime handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#discussion_r275609702
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/run
sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement
the runtime handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#discussion_r275609702
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/run
sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement
the runtime handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#discussion_r275609702
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/run
sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement
the runtime handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#discussion_r275609702
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/run
sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement
the runtime handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#discussion_r275609702
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/run
[
https://issues.apache.org/jira/browse/FLINK-12204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818512#comment-16818512
]
Hequn Cheng edited comment on FLINK-12204 at 4/16/19 2:24 AM:
[
https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818517#comment-16818517
]
Jingsong Lee commented on FLINK-11974:
--
1.As [https://shipilev.net/blog/2015/black-
[
https://issues.apache.org/jira/browse/FLINK-12204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818512#comment-16818512
]
Hequn Cheng commented on FLINK-12204:
-
[~fan_li_ya] Glad that you are also intereste
godfreyhe commented on a change in pull request #8157: [FLINK-12170]
[table-planner-blink] Add support for generating optimized logical plan for
Over aggregate
URL: https://github.com/apache/flink/pull/8157#discussion_r275607517
##
File path:
flink-table/flink-table-planner-blink/
[
https://issues.apache.org/jira/browse/FLINK-12204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-12204:
---
Assignee: Hequn Cheng
> Improve JDBCOutputFormat ClassCastException
> -
[
https://issues.apache.org/jira/browse/FLINK-3991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818509#comment-16818509
]
Ji Liu commented on FLINK-3991:
---
[~Zentol] Alright, thanks for replying.
> Remove deprecat
sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement
the runtime handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#discussion_r275427363
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/run
sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement
the runtime handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#discussion_r275606159
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/run
flinkbot commented on issue #8180: fix FLINK-12207 "==" bug
URL: https://github.com/apache/flink/pull/8180#issuecomment-483481590
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment
LynnYuanInspur opened a new pull request #8180: fix FLINK-12207 "==" bug
URL: https://github.com/apache/flink/pull/8180
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we
[
https://issues.apache.org/jira/browse/FLINK-12207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12207:
---
Labels: pull-request-available (was: )
> JsonRowDeserializationSchema and JsonRowSerializat
wuchong commented on issue #8109: [FLINK-12017][table-planner-blink] Support
translation from Rank/Deduplicate to StreamTransformation
URL: https://github.com/apache/flink/pull/8109#issuecomment-483480984
Merging...
This is
lynn created FLINK-12207:
Summary: JsonRowDeserializationSchema and
JsonRowSerializationSchema Types "==" bug
Key: FLINK-12207
URL: https://issues.apache.org/jira/browse/FLINK-12207
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-12204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818499#comment-16818499
]
Liya Fan commented on FLINK-12204:
--
I vote for this issue, because it helps debugging.
yjk891 commented on issue #8128: [FLINK-12137][Documentation] Add more proper
explanation on flink streaming connectors
URL: https://github.com/apache/flink/pull/8128#issuecomment-483473373
Thanks for acceptance my PR and the review
[
https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818365#comment-16818365
]
Stephan Ewen commented on FLINK-12070:
--
I have a proof-of-concept for this feature
Yu Yang created FLINK-12206:
---
Summary: cannot query nested fields using Flink SQL
Key: FLINK-12206
URL: https://issues.apache.org/jira/browse/FLINK-12206
Project: Flink
Issue Type: Bug
Co
[
https://issues.apache.org/jira/browse/FLINK-12206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Yang updated FLINK-12206:
Description:
We feed list of events with the following RowTypeInfo to flink,
{code:java}
Row(
timestamp
[
https://issues.apache.org/jira/browse/FLINK-12206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Yang updated FLINK-12206:
Description:
We feed list of events with the following RowTypeInfo to flink,
{code:java}
Row(
timestamp
flinkbot commented on issue #8179: [FLINK-12200] [Table API] Support UNNEST for
MAP types
URL: https://github.com/apache/flink/pull/8179#issuecomment-483393389
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull req
[
https://issues.apache.org/jira/browse/FLINK-12200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12200:
---
Labels: pull-request-available (was: )
> [Table API] Support UNNEST for MAP types
> --
art4ul opened a new pull request #8179: [FLINK-12200] [Table API] Support
UNNEST for MAP types
URL: https://github.com/apache/flink/pull/8179
## What is the purpose of the change
This pull request adds support of UNNEST operator for MAP types.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-12205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818240#comment-16818240
]
Ken Krugler commented on FLINK-12205:
-
Hi [~hbchen] - I didn't see this posted on th
[
https://issues.apache.org/jira/browse/FLINK-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818217#comment-16818217
]
Yan Yan commented on FLINK-8801:
Thanks [~till.rohrmann]! [~NicoK] Could you share your t
[
https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818210#comment-16818210
]
Piotr Nowojski commented on FLINK-11974:
Thanks for the benchmarks [~lzljs362032
aloyszhang commented on issue #8178: [hotfix][docs] add missing bracket for
cli.md
URL: https://github.com/apache/flink/pull/8178#issuecomment-483347698
@tillrohrmann
This is an automated message from the Apache Git Service.
flinkbot commented on issue #8178: [hotfix][docs] add missing bracket for cli.md
URL: https://github.com/apache/flink/pull/8178#issuecomment-483347513
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We w
aloyszhang opened a new pull request #8178: [hotfix][docs] add missing bracket
for cli.md
URL: https://github.com/apache/flink/pull/8178
## What is the purpose of the change
This pull request add missing bracket for cli.md
## Brief change log
add missing bracket for
fhueske commented on issue #8101: [hotfix][docs] fix error in Process Function
Doc
URL: https://github.com/apache/flink/pull/8101#issuecomment-483345803
Thanks for the PR @zsq12138!
The changes look good to me.
@flinkbot approve description consensus architecture quality
I'
aloyszhang commented on issue #8054: [hotfix][docs] add explicit description
for checkpoint directory
URL: https://github.com/apache/flink/pull/8054#issuecomment-483336977
@fhueske @zentol
This is an automated message fro
fhueske commented on issue #8128: [FLINK-12137][Documentation] Add more proper
explanation on flink streaming connectors
URL: https://github.com/apache/flink/pull/8128#issuecomment-483337001
Hi @yjk891, thanks for your PR!
The changes look good.
@flinkbot approve description conse
HuangZhenQiu commented on a change in pull request #7978: [FLINK-11910] [Yarn]
add customizable yarn application type
URL: https://github.com/apache/flink/pull/7978#discussion_r275456947
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
[
https://issues.apache.org/jira/browse/FLINK-6984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-6984:
---
Assignee: Yun Tang
> Do not recover CompletedCheckpointStore on every restore
>
Myasuka commented on a change in pull request #7813: [FLINK-10712] Support to
restore state when using RestartPipelinedRegionStrategy
URL: https://github.com/apache/flink/pull/7813#discussion_r275454355
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongra
[
https://issues.apache.org/jira/browse/FLINK-12137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-12137:
-
Assignee: JoongkeunYang
> Add more proper explanation on flink streaming connectors
>
Myasuka commented on a change in pull request #7813: [FLINK-10712] Support to
restore state when using RestartPipelinedRegionStrategy
URL: https://github.com/apache/flink/pull/7813#discussion_r275452126
##
File path:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/Reg
[
https://issues.apache.org/jira/browse/FLINK-12177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-12177.
Resolution: Fixed
master: 734686ff29c520d930f24c72dc069f18fd1674b7
> Remove legacy FlinkU
fhueske commented on issue #8129: [FLINK-12132]The example in yarn setup should
specify a prefix for input and output files
URL: https://github.com/apache/flink/pull/8129#issuecomment-483329954
Hi @biggeng, Thanks for your PR!
The fix looks good.
@flinkbot approve description cons
zentol merged pull request #8160: [FLINK-12177][coordination] Remove legacy
FlinkUntypedActor
URL: https://github.com/apache/flink/pull/8160
This is an automated message from the Apache Git Service.
To respond to the message
[
https://issues.apache.org/jira/browse/FLINK-3991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-3991:
---
Assignee: (was: Ji Liu)
> Remove deprecated configuration keys from ConfigConsta
[
https://issues.apache.org/jira/browse/FLINK-3991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818157#comment-16818157
]
Chesnay Schepler commented on FLINK-3991:
-
[~tianchen92] I recommend reading thro
[
https://issues.apache.org/jira/browse/FLINK-12132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-12132:
-
Assignee: Wang Geng
> The example in /docs/ops/deployment/yarn_setup.md should be updat
zentol commented on issue #8172: [FLINK-3991]Remove deprecated configuration
keys from ConfigConstants
URL: https://github.com/apache/flink/pull/8172#issuecomment-483328818
Removing these constants is an API breaking change, and as such can only be
done once Flink 2.0 (no ETA) comes around
zentol closed pull request #8172: [FLINK-3991]Remove deprecated configuration
keys from ConfigConstants
URL: https://github.com/apache/flink/pull/8172
This is an automated message from the Apache Git Service.
To respond to t
fhueske commented on issue #8143: [hotfix][javadocs] remove redundant 'for
example' for InputFormat
URL: https://github.com/apache/flink/pull/8143#issuecomment-483324316
Hi @aloyszhang, Thanks for your PR.
The change looks good to me.
@flinkbot approve description consensus archi
fhueske commented on issue #7940: [hotfix][docs] fix error in functions example
URL: https://github.com/apache/flink/pull/7940#issuecomment-483322056
Hi @leesf, thanks for your PR!
The fix looks good to me.
@flinkbot approve description consensus architecture quality
I'
[
https://issues.apache.org/jira/browse/FLINK-12205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hobo Chen updated FLINK-12205:
--
Description:
I followed Local Step Tutorial to start flink.
*env*
OSX
flink-1.8.0-bin-scala_2.11
StefanRRichter commented on issue #7813: [FLINK-10712] Support to restore state
when using RestartPipelinedRegionStrategy
URL: https://github.com/apache/flink/pull/7813#issuecomment-483321502
@Myasuka thank you very much for addressing all the comments! I had a few
more minor comments and
1 - 100 of 347 matches
Mail list logo
