[
https://issues.apache.org/jira/browse/FLINK-14289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14289:
---
Labels: pull-request-available (was: )
> Remove Optional fields from RecordWriter relevant
zhijiangW opened a new pull request #9818: [FLINK-14289][runtime] Remove
Optional fields from RecordWriter relevant classes
URL: https://github.com/apache/flink/pull/9818
## What is the purpose of the change
*Based on the code style guides for Jave Optional , it should not be used
flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark
in StreamSource may arrive the downstream operator early
URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116
## CI report:
* cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE
flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark
in StreamSource may arrive the downstream operator early
URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116
## CI report:
* cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE
flinkbot edited a comment on issue #9817: [FLINK-14178] Downgrade
maven-shade-plugin to 3.1.0
URL: https://github.com/apache/flink/pull/9817#issuecomment-536390486
## CI report:
* 2072428596808c2e32690b4cf72f022dd905e2d6 : SUCCESS
sunhaibotb commented on issue #9804: [FLINK-14239] Fix the max watermark in
StreamSource may arrive the downstream operator early
URL: https://github.com/apache/flink/pull/9804#issuecomment-536400700
@flinkbot run travis
flinkbot edited a comment on issue #9817: [FLINK-14178] Downgrade
maven-shade-plugin to 3.1.0
URL: https://github.com/apache/flink/pull/9817#issuecomment-536390486
## CI report:
* 2072428596808c2e32690b4cf72f022dd905e2d6 : PENDING
flinkbot edited a comment on issue #9805: [FLINK-14227] translate
dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#issuecomment-536295524
## CI report:
* 9ad039de6bbb953c7e2dd74b3118d80ae552f31e : FAILURE
[
https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940639#comment-16940639
]
jackylau edited comment on FLINK-14243 at 9/30/19 3:56 AM:
---
[~ykt836] This
flinkbot commented on issue #9817: [FLINK-14178] Downgrade maven-shade-plugin
to 3.1.0
URL: https://github.com/apache/flink/pull/9817#issuecomment-536390486
## CI report:
* 2072428596808c2e32690b4cf72f022dd905e2d6 : UNKNOWN
[
https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940639#comment-16940639
]
jackylau commented on FLINK-14243:
--
This problem I consulted spark community before in wechat spark
flinkbot edited a comment on issue #9805: [FLINK-14227] translate
dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#issuecomment-536295524
## CI report:
* 9ad039de6bbb953c7e2dd74b3118d80ae552f31e : FAILURE
flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark
in StreamSource may arrive the downstream operator early
URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116
## CI report:
* cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE
[
https://issues.apache.org/jira/browse/FLINK-14273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940637#comment-16940637
]
hailong wang commented on FLINK-14273:
--
I'd like to fix this problem, thx.
> when User-Defined
KarmaGYZ commented on a change in pull request #9801: [FLINK-13983][runtime]
Launch task executor with new memory calculation logics
URL: https://github.com/apache/flink/pull/9801#discussion_r329400418
##
File path:
JingsongLi commented on a change in pull request #9796:
[FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only
when dynamic partition insert
URL: https://github.com/apache/flink/pull/9796#discussion_r329400159
##
File path:
KurtYoung commented on a change in pull request #9796:
[FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only
when dynamic partition insert
URL: https://github.com/apache/flink/pull/9796#discussion_r329399640
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-14226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940631#comment-16940631
]
Dian Fu commented on FLINK-14226:
-
Hi [~sunjincheng121], I'm +1 to downgrade maven-shade-plugin to
[
https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-14178:
---
Assignee: Dian Fu
> maven-shade-plugin 3.2.1 doesn't work on ARM for Flink
>
[
https://issues.apache.org/jira/browse/FLINK-14288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940630#comment-16940630
]
Hequn Cheng commented on FLINK-14288:
-
Fixed in
1.9.1: c9c10d84f063a2a2bcf98563891e43cae2e95697
[
https://issues.apache.org/jira/browse/FLINK-14288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-14288.
---
Fix Version/s: 1.10.0
Resolution: Fixed
> Add Py4j NOTICE for source release
>
[
https://issues.apache.org/jira/browse/FLINK-14288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940629#comment-16940629
]
Hequn Cheng commented on FLINK-14288:
-
[~sunjincheng121] [~dian.fu] thanks a lot for reporting and
flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark
in StreamSource may arrive the downstream operator early
URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116
## CI report:
* cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE
flinkbot commented on issue #9817: [FLINK-14178] Downgrade maven-shade-plugin
to 3.1.0 as 3.2.1 doesn't work on ARM for Flink
URL: https://github.com/apache/flink/pull/9817#issuecomment-536386845
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the
[
https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940628#comment-16940628
]
wangxiyuan commented on FLINK-14178:
agree to downgrade it if x86 hit the same issue.
>
[
https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14178:
---
Labels: pull-request-available (was: )
> maven-shade-plugin 3.2.1 doesn't work on ARM for
dianfu opened a new pull request #9817: [FLINK-14178] Downgrade
maven-shade-plugin to 3.1.0 as 3.2.1 doesn't work on ARM for Flink
URL: https://github.com/apache/flink/pull/9817
## What is the purpose of the change
*This pull request downgrades maven-shade-plugin to 3.1.0 as
hequn8128 closed pull request #9816: [FLINK-14288][legal] Add Py4J NOTICE for
source release
URL: https://github.com/apache/flink/pull/9816
This is an automated message from the Apache Git Service.
To respond to the
JingsongLi commented on a change in pull request #9796:
[FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only
when dynamic partition insert
URL: https://github.com/apache/flink/pull/9796#discussion_r329398357
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-14268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940627#comment-16940627
]
Yang Wang commented on FLINK-14268:
---
Do you mean `yarn.application-attempts` does not works? I have
[
https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940626#comment-16940626
]
Dian Fu commented on FLINK-14178:
-
[~sunjincheng121] Downgrading the maven-shade-plugin to 3.1.0 makes
[
https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940624#comment-16940624
]
Kurt Young commented on FLINK-14243:
The cache you mentioned is a normal class fields, and AFAIK
[
https://issues.apache.org/jira/browse/FLINK-14226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940623#comment-16940623
]
sunjincheng commented on FLINK-14226:
-
Thanks for report the issue and thanks for share your
[
https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940622#comment-16940622
]
sunjincheng commented on FLINK-14178:
-
Thanks for the discussion [~wangxiyuan] and [~dian.fu]. Due
[
https://issues.apache.org/jira/browse/FLINK-14289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-14289:
-
Description:
Based on the code style guides for [Jave Optional|#java-optional] , the
optional should
[
https://issues.apache.org/jira/browse/FLINK-14289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-14289:
-
Description:
Based on the code style guides for [Jave Optional|#java-optional]] , the
optional should
zhijiang created FLINK-14289:
Summary: Remove Optional fields from RecordWriter relevant classes
Key: FLINK-14289
URL: https://issues.apache.org/jira/browse/FLINK-14289
Project: Flink
Issue
flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl
URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685
## CI report:
* bd2624914db1147588ea838ae542333c310290cc : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/builds/127790175)
[
https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-14243:
-
Description:
Flink1.9 brings in hive connector, but it will have some problem when the
original hive
[
https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-14243:
-
Summary: flink hiveudf needs some check when it is using cache (was: flink
hiveudf need some check
[
https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940619#comment-16940619
]
jackylau commented on FLINK-14243:
--
[~ykt836] The original udf function uses cache, which you can see
flinkbot edited a comment on issue #9816: [FLINK-14288][legal] Add Py4J NOTICE
for source release
URL: https://github.com/apache/flink/pull/9816#issuecomment-536370360
## CI report:
* 2647196a7e0997b7a3a22a0212d062ee309f1db6 : SUCCESS
[
https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-14243:
-
Summary: flink hiveudf need some check when it is using cache (was: flink
hiveudf need some check
[
https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-14243:
-
Description:
Flink1.9 bring in hive connector, but it will have some problem when the
original hive
flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark
in StreamSource may arrive the downstream operator early
URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116
## CI report:
* cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE
KurtYoung commented on a change in pull request #9796:
[FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only
when dynamic partition insert
URL: https://github.com/apache/flink/pull/9796#discussion_r329395856
##
File path:
flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl
URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685
## CI report:
* bd2624914db1147588ea838ae542333c310290cc : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/builds/127790175)
[
https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940614#comment-16940614
]
Kurt Young commented on FLINK-14243:
What do you mean by using cache?
> flink hiveudf need some
xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add
the FlatMapper and related classes for later al…
URL: https://github.com/apache/flink/pull/9300#discussion_r329391447
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940610#comment-16940610
]
liupengcheng commented on FLINK-14123:
--
[~StephanEwen] Thanks for your reply, I tested the app with
[
https://issues.apache.org/jira/browse/FLINK-14250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940609#comment-16940609
]
sunjincheng commented on FLINK-14250:
-
I'm glad to see this proposal [~aljoscha]！(y)
I think
flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl
URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685
## CI report:
* bd2624914db1147588ea838ae542333c310290cc : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/builds/127790175)
flinkbot edited a comment on issue #9816: [FLINK-14288][legal] Add Py4J NOTICE
for source release
URL: https://github.com/apache/flink/pull/9816#issuecomment-536370360
## CI report:
* 2647196a7e0997b7a3a22a0212d062ee309f1db6 : PENDING
KurtYoung merged pull request #9795: [hotfix] [variable name] Typo in Table
Planner RuleSets: JOIN_REORDER_PERPARE_RULES
URL: https://github.com/apache/flink/pull/9795
This is an automated message from the Apache Git
zhuzhurk commented on a change in pull request #9783: [FLINK-14040][travis]
Enable MiniCluster tests based on schedulerNG in Flink cron build
URL: https://github.com/apache/flink/pull/9783#discussion_r329390451
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-14271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940606#comment-16940606
]
Zhu Zhu commented on FLINK-14271:
-
cc [~GJL]
> Deprecate legacy RestartPipelinedRegionStrategy
>
flinkbot commented on issue #9816: [FLINK-14288][legal] Add Py4J NOTICE for
source release
URL: https://github.com/apache/flink/pull/9816#issuecomment-536370360
## CI report:
* 2647196a7e0997b7a3a22a0212d062ee309f1db6 : UNKNOWN
HuangZhenQiu commented on issue #9689: [FLINK-7151] add a basic function ddl
URL: https://github.com/apache/flink/pull/9689#issuecomment-536370130
@bowenli86 @danny0405 @suez1224
Would you please review this PR?
This is
HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a
basic function ddl
URL: https://github.com/apache/flink/pull/9689#discussion_r329387849
##
File path:
flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl
##
@@ -155,6 +155,24
HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a
basic function ddl
URL: https://github.com/apache/flink/pull/9689#discussion_r329387836
##
File path:
flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl
##
@@ -155,6 +155,24
flinkbot commented on issue #9816: [FLINK-14288][legal] Add Py4J NOTICE for
source release
URL: https://github.com/apache/flink/pull/9816#issuecomment-536366200
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
[
https://issues.apache.org/jira/browse/FLINK-14288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14288:
---
Labels: pull-request-available (was: )
> Add Py4j NOTICE for source release
>
dianfu opened a new pull request #9816: [FLINK-14288][legal] Add Py4J NOTICE
for source release
URL: https://github.com/apache/flink/pull/9816
## What is the purpose of the change
*This pull request adds Py4J to the NOTICE as it's bundled in the source
release*
##
[
https://issues.apache.org/jira/browse/FLINK-14288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940592#comment-16940592
]
sunjincheng commented on FLINK-14288:
-
Done, great thanks to take this ticket. [~dian.fu]
> Add
[
https://issues.apache.org/jira/browse/FLINK-14288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-14288:
---
Assignee: Dian Fu
> Add Py4j NOTICE for source release
>
[
https://issues.apache.org/jira/browse/FLINK-14288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940591#comment-16940591
]
Dian Fu commented on FLINK-14288:
-
Hi [~sunjincheng121], good catch! I'd like to take this issue. Would
sunjincheng created FLINK-14288:
---
Summary: Add Py4j NOTICE for source release
Key: FLINK-14288
URL: https://issues.apache.org/jira/browse/FLINK-14288
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-14274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940589#comment-16940589
]
Kurt Young commented on FLINK-14274:
[~hailong wang] Once RuntimeContext exposed to user, the
[
https://issues.apache.org/jira/browse/FLINK-14274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-14274.
--
Resolution: Won't Fix
> RuntimeContext can be get from FunctionContext
>
flinkbot edited a comment on issue #9815: [FLINK-14117][docs]Translate changes
on documentation index page to Chinese
URL: https://github.com/apache/flink/pull/9815#issuecomment-536343016
## CI report:
* 615acdb2511760c55f8831934f710678a8962acc : FAILURE
walterddr commented on issue #9373: [FLINK-13596][ml] Add two utils for Table
transformations
URL: https://github.com/apache/flink/pull/9373#issuecomment-536348043
Thanks for the contribution @xuyang1706. looks like this PR depends on #9184
yes?
flinkbot edited a comment on issue #9355: [FLINK-13577][ml] Add an util class
to build result row and generate …
URL: https://github.com/apache/flink/pull/9355#issuecomment-518089359
## CI report:
* f8f3792f7ce55735f05200c90431b20b99a42d18 : FAILURE
flinkbot edited a comment on issue #9814: [FLINK-14283][kinesis][docs] Update
Kinesis consumer docs for recent feature additions
URL: https://github.com/apache/flink/pull/9814#issuecomment-536328322
## CI report:
* dafafa4f7974e75b63c1b2f353d9ead63c359ccf : SUCCESS
walterddr commented on a change in pull request #9355: [FLINK-13577][ml] Add an
util class to build result row and generate …
URL: https://github.com/apache/flink/pull/9355#discussion_r329372704
##
File path:
walterddr commented on a change in pull request #9355: [FLINK-13577][ml] Add an
util class to build result row and generate …
URL: https://github.com/apache/flink/pull/9355#discussion_r329372857
##
File path:
walterddr commented on a change in pull request #9355: [FLINK-13577][ml] Add an
util class to build result row and generate …
URL: https://github.com/apache/flink/pull/9355#discussion_r329372657
##
File path:
flinkbot edited a comment on issue #9815: [FLINK-14117][docs]Translate changes
on documentation index page to Chinese
URL: https://github.com/apache/flink/pull/9815#issuecomment-536343016
## CI report:
* 615acdb2511760c55f8831934f710678a8962acc : PENDING
flinkbot edited a comment on issue #9814: [FLINK-14283][kinesis][docs] Update
Kinesis consumer docs for recent feature additions
URL: https://github.com/apache/flink/pull/9814#issuecomment-536328322
## CI report:
* dafafa4f7974e75b63c1b2f353d9ead63c359ccf : SUCCESS
flinkbot commented on issue #9815: [FLINK-14117][docs]Translate changes on
documentation index page to Chinese
URL: https://github.com/apache/flink/pull/9815#issuecomment-536343016
## CI report:
* 615acdb2511760c55f8831934f710678a8962acc : UNKNOWN
flinkbot commented on issue #9815: [FLINK-14117][docs]Translate changes on
documentation index page to Chinese
URL: https://github.com/apache/flink/pull/9815#issuecomment-536341137
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
flinkbot edited a comment on issue #9814: [FLINK-14283][kinesis][docs] Update
Kinesis consumer docs for recent feature additions
URL: https://github.com/apache/flink/pull/9814#issuecomment-536328322
## CI report:
* dafafa4f7974e75b63c1b2f353d9ead63c359ccf : SUCCESS
[
https://issues.apache.org/jira/browse/FLINK-14117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14117:
---
Labels: pull-request-available (was: )
> Translate changes on documentation index page to
koonchen opened a new pull request #9815: [FLINK-14117][docs]Translate changes
on documentation index page to Chinese
URL: https://github.com/apache/flink/pull/9815
## What is the purpose of the change
Translate changes on documentation index page to Chinese
## Brief change
flinkbot edited a comment on issue #9814: [FLINK-14283][kinesis][docs] Update
Kinesis consumer docs for recent feature additions
URL: https://github.com/apache/flink/pull/9814#issuecomment-536328322
## CI report:
* dafafa4f7974e75b63c1b2f353d9ead63c359ccf : SUCCESS
flinkbot edited a comment on issue #9813: [FLINK-14287] Decouple leader address
from LeaderContender
URL: https://github.com/apache/flink/pull/9813#issuecomment-536324105
## CI report:
* b7a7e7b6dc8a16d23097911aa98852e2cf4d9c00 : FAILURE
flinkbot edited a comment on issue #9814: [FLINK-14283][kinesis][docs] Update
Kinesis consumer docs for recent feature additions
URL: https://github.com/apache/flink/pull/9814#issuecomment-536328322
## CI report:
* dafafa4f7974e75b63c1b2f353d9ead63c359ccf : PENDING
flinkbot commented on issue #9814: [FLINK-14283][kinesis][docs] Update Kinesis
consumer docs for recent feature additions
URL: https://github.com/apache/flink/pull/9814#issuecomment-536328322
## CI report:
* dafafa4f7974e75b63c1b2f353d9ead63c359ccf : UNKNOWN
flinkbot commented on issue #9814: [FLINK-14283][kinesis][docs] Update Kinesis
consumer docs for recent feature additions
URL: https://github.com/apache/flink/pull/9814#issuecomment-536326818
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the
[
https://issues.apache.org/jira/browse/FLINK-14283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14283:
---
Labels: pull-request-available (was: )
> Update Kinesis consumer documentation for
tweise opened a new pull request #9814: [FLINK-14283][kinesis][docs] Update
Kinesis consumer docs for recent feature additions
URL: https://github.com/apache/flink/pull/9814
## What is the purpose of the change
Documentation update for Kinesis consumer.
flinkbot edited a comment on issue #9813: [FLINK-14287] Decouple leader address
from LeaderContender
URL: https://github.com/apache/flink/pull/9813#issuecomment-536324105
## CI report:
* b7a7e7b6dc8a16d23097911aa98852e2cf4d9c00 : PENDING
flinkbot commented on issue #9813: [FLINK-14287] Decouple leader address from
LeaderContender
URL: https://github.com/apache/flink/pull/9813#issuecomment-536324105
## CI report:
* b7a7e7b6dc8a16d23097911aa98852e2cf4d9c00 : UNKNOWN
flinkbot edited a comment on issue #9810: [FLINK-14284] Add shut down future to
Dispatcher
URL: https://github.com/apache/flink/pull/9810#issuecomment-536320582
## CI report:
* 3ea0f47e7dd76ec115db4ef583b416685107604b : FAILURE
flinkbot edited a comment on issue #9812: [FLINK-14286] Remove Akka specific
parsing from LeaderConnectionInfo
URL: https://github.com/apache/flink/pull/9812#issuecomment-536322371
## CI report:
* c1ca1131b02a2c555cd8386fd07aa1cfccbab161 : FAILURE
flinkbot edited a comment on issue #9809: [FLINK-14282] Simplify
DispatcherResourceManagerComponent hierarchy
URL: https://github.com/apache/flink/pull/9809#issuecomment-536318695
## CI report:
* 531cd688ceb25b544833025d9b556a0d686b29c4 : FAILURE
flinkbot commented on issue #9812: [FLINK-14286] Remove Akka specific parsing
from LeaderConnectionInfo
URL: https://github.com/apache/flink/pull/9812#issuecomment-536322371
## CI report:
* c1ca1131b02a2c555cd8386fd07aa1cfccbab161 : UNKNOWN
flinkbot edited a comment on issue #9811: [FLINK-14285] Remove generics from
Dispatcher factories
URL: https://github.com/apache/flink/pull/9811#issuecomment-536320588
## CI report:
* 658cddd4424505c1a904a926ad6e626abbd85cd7 : FAILURE
flinkbot edited a comment on issue #9810: [FLINK-14284] Add shut down future to
Dispatcher
URL: https://github.com/apache/flink/pull/9810#issuecomment-536320582
## CI report:
* 3ea0f47e7dd76ec115db4ef583b416685107604b : PENDING
flinkbot edited a comment on issue #9808: [FLINK-14281] Add
DispatcherRunner#getShutDownFuture
URL: https://github.com/apache/flink/pull/9808#issuecomment-536316924
## CI report:
* 02c93d5d7d69324c33461040fec5c4014eb2b8d6 : SUCCESS
flinkbot commented on issue #9813: [FLINK-14287] Decouple leader address from
LeaderContender
URL: https://github.com/apache/flink/pull/9813#issuecomment-536322127
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your
1 - 100 of 395 matches
Mail list logo
