[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938443#comment-16938443
]
zhijiang commented on FLINK-10672:
--
I think [~gaoyunhaii] would continue helping trace
flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python
building blocks to make sure the basic functionality of Python ScalarFunction
could work
URL: https://github.com/apache/flink/pull/9766#issuecomment-534879961
## CI report:
* 8fffbbc4bc605ccedad7412ac2292
[
https://issues.apache.org/jira/browse/FLINK-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14206:
Description:
With fine grained recovery introduced in 1.9.0, the {{fullRestart}} metric only
counts how m
zhuzhurk opened a new pull request #9778: [FLINK-14206][runtime] Let
fullRestart metric count both full restarts and fine grained restarts
URL: https://github.com/apache/flink/pull/9778
## What is the purpose of the change
With fine grained recovery introduced in 1.9.0, the fullR
[
https://issues.apache.org/jira/browse/FLINK-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14206:
---
Labels: pull-request-available (was: )
> Let fullRestart metric count fine grained restarts
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
[Build](https://travis-ci.com/flink-ci/fli
[
https://issues.apache.org/jira/browse/FLINK-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14206:
Affects Version/s: 1.10.0
> Let fullRestart metric count fine grained restarts as well
> -
[
https://issues.apache.org/jira/browse/FLINK-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14206:
Fix Version/s: 1.10.0
> Let fullRestart metric count fine grained restarts as well
> -
hequn8128 commented on a change in pull request #9766: [FLINK-14018][python]
Add Python building blocks to make sure the basic functionality of Python
ScalarFunction could work
URL: https://github.com/apache/flink/pull/9766#discussion_r328533791
##
File path:
flink-table/flink-tab
hequn8128 commented on a change in pull request #9766: [FLINK-14018][python]
Add Python building blocks to make sure the basic functionality of Python
ScalarFunction could work
URL: https://github.com/apache/flink/pull/9766#discussion_r328514073
##
File path:
flink-table/flink-tab
flinkbot commented on issue #9778: [FLINK-14206][runtime] Let fullRestart
metric count both full restarts and fine grained restarts
URL: https://github.com/apache/flink/pull/9778#issuecomment-535430586
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I hel
zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime]
Reducing synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#discussion_r328538591
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operator
zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime]
Reducing synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#discussion_r328538575
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operator
flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python
building blocks to make sure the basic functionality of Python ScalarFunction
could work
URL: https://github.com/apache/flink/pull/9766#issuecomment-534879961
## CI report:
* 8fffbbc4bc605ccedad7412ac2292
Fabian Hueske created FLINK-14227:
-
Summary: Add Razorpay to Chinese Powered By page
Key: FLINK-14227
URL: https://issues.apache.org/jira/browse/FLINK-14227
Project: Flink
Issue Type: Task
flinkbot commented on issue #9778: [FLINK-14206][runtime] Let fullRestart
metric count both full restarts and fine grained restarts
URL: https://github.com/apache/flink/pull/9778#issuecomment-535435111
## CI report:
* 1aad21713df6970025319183b3774aec674fefde : UNKNOWN
--
1u0 commented on a change in pull request #9717: [FLINK-14044] [runtime]
Reducing synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#discussion_r328539920
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/asyn
aljoscha commented on issue #9720: [FLINK-13025] Elasticsearch 7.x support
URL: https://github.com/apache/flink/pull/9720#issuecomment-535435472
Yes, I will definitely look at this!
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-14186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-14186:
--
Priority: Blocker (was: Critical)
> Nightly e2e-misc-jdk11 fails complaining unrecognized VM
1u0 commented on a change in pull request #9717: [FLINK-14044] [runtime]
Reducing synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#discussion_r328063741
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/asyn
zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime]
Reducing synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#discussion_r328541881
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operator
zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime]
Reducing synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#discussion_r328422187
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator
tillrohrmann commented on issue #9775: [FLINK-14186][e2e] Let JVM ignores
unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11
URL: https://github.com/apache/flink/pull/9775#issuecomment-535438266
We could use `if [[ ${PROFILE} != *"jdk11"* ]]; then` to filter out th
[
https://issues.apache.org/jira/browse/FLINK-14195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-14195:
--
Priority: Blocker (was: Critical)
> Nightly connectors-jdk11 fails because of missing jaxb cl
[
https://issues.apache.org/jira/browse/FLINK-14195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938466#comment-16938466
]
Till Rohrmann commented on FLINK-14195:
---
[~kevin.cyj] thanks for looking into the
[
https://issues.apache.org/jira/browse/FLINK-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-14196:
--
Priority: Blocker (was: Critical)
> Nightly e2e-sticky-hadoop2.8 fails due to NPE
> -
zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime]
Reducing synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#discussion_r328544533
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operator
gaoyunhaii commented on issue #9775: [FLINK-14186][e2e] Let JVM ignores
unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11
URL: https://github.com/apache/flink/pull/9775#issuecomment-535439949
Hi @tillrohrmann , we have also thought of remove this test from java 11
[
https://issues.apache.org/jira/browse/FLINK-14195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938472#comment-16938472
]
Yingjie Cao commented on FLINK-14195:
-
Thanks [~trohrmann].
My branch is
[https://
flinkbot edited a comment on issue #9759: [FLINK-14169][history-server] Cleanup
expired jobs from history server
URL: https://github.com/apache/flink/pull/9759#issuecomment-534565511
## CI report:
* 70cf88200f1b09ca6932462f4d51834c339077e3 : SUCCESS
[Build](https://travis-ci.com
flinkbot edited a comment on issue #9778: [FLINK-14206][runtime] Let
fullRestart metric count both full restarts and fine grained restarts
URL: https://github.com/apache/flink/pull/9778#issuecomment-535435111
## CI report:
* 1aad21713df6970025319183b3774aec674fefde : PENDING
[Bu
zhijiangW commented on issue #9717: [FLINK-14044] [runtime] Reducing
synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#issuecomment-535443887
@AHeise I have finished the first round review. Almost LGTM only for some
tiny comments.
In addition, for t
zhijiangW edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing
synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#issuecomment-535443887
@AHeise I have finished the first round review. Almost LGTM only for some
tiny comments.
In addition
flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python
building blocks to make sure the basic functionality of Python ScalarFunction
could work
URL: https://github.com/apache/flink/pull/9766#issuecomment-534879961
## CI report:
* 8fffbbc4bc605ccedad7412ac2292
flinkbot edited a comment on issue #9778: [FLINK-14206][runtime] Let
fullRestart metric count both full restarts and fine grained restarts
URL: https://github.com/apache/flink/pull/9778#issuecomment-535435111
## CI report:
* 1aad21713df6970025319183b3774aec674fefde : SUCCESS
[Bu
Haibo Sun created FLINK-14228:
-
Summary: The runtime support for Bounded[One|Multi]Input#endInput
does not properly implement their semantics
Key: FLINK-14228
URL: https://issues.apache.org/jira/browse/FLINK-14228
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime]
Reducing synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#discussion_r328571467
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator
Aitozi commented on issue #8479: [FLINK-11193][State Backends]Use user passed
configuration overriding default configuration loading from file
URL: https://github.com/apache/flink/pull/8479#issuecomment-535463434
OK, I have addressed your comments @azagrebin .
-
zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime]
Reducing synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#discussion_r328572264
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
[
https://issues.apache.org/jira/browse/FLINK-14131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14131:
Summary: Support configurable failover strategy for scheduler NG (was:
Support choosing new version failo
[
https://issues.apache.org/jira/browse/FLINK-14131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14131:
Description:
FLINK-10429 introduces new version failover strategies for scheduler NG.
There are 2 failover
flinkbot edited a comment on issue #8479: [FLINK-11193][State Backends]Use user
passed configuration overriding default configuration loading from file
URL: https://github.com/apache/flink/pull/8479#issuecomment-526521132
## CI report:
* fdd6f0e24a689b70d15b2dc190fc2fc3b0600bfa :
zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime]
Reducing synchronization in AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9717#discussion_r328576174
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator
Haibo Sun created FLINK-14229:
-
Summary: Change the endinput call of the downstream operator to
after the upstream operator closes
Key: FLINK-14229
URL: https://issues.apache.org/jira/browse/FLINK-14229
[
https://issues.apache.org/jira/browse/FLINK-14229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun closed FLINK-14229.
-
Resolution: Invalid
> Change the endinput call of the downstream operator to after the upstream
> oper
Haibo Sun created FLINK-14230:
-
Summary: Change the endinput call of the downstream operator to
after the upstream operator closes
Key: FLINK-14230
URL: https://issues.apache.org/jira/browse/FLINK-14230
[
https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14230:
--
Summary: Change the endinput call of the downstream operator to after
closing the upstream operator
Haibo Sun created FLINK-14231:
-
Summary: Support the timers of the upstream operator with endInput
properly
Key: FLINK-14231
URL: https://issues.apache.org/jira/browse/FLINK-14231
Project: Flink
flinkbot edited a comment on issue #8479: [FLINK-11193][State Backends]Use user
passed configuration overriding default configuration loading from file
URL: https://github.com/apache/flink/pull/8479#issuecomment-526521132
## CI report:
* fdd6f0e24a689b70d15b2dc190fc2fc3b0600bfa :
[
https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-14230:
--
Assignee: Haibo Sun
> Change the endinput call of the downstream operator to after c
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-14228:
--
Assignee: Haibo Sun (was: Piotr Nowojski)
> The runtime support for Bounded[One|Mult
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-14228:
--
Assignee: Piotr Nowojski
> The runtime support for Bounded[One|Multi]Input#endInput d
[
https://issues.apache.org/jira/browse/FLINK-14231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-14231:
--
Assignee: Haibo Sun
> Support the timers of the upstream operator with endInput prope
StephanEwen commented on issue #9255: [FLINK-13034] Introduce isEmpty method
for MapState
URL: https://github.com/apache/flink/pull/9255#issuecomment-535474839
@flinkbot run travis
This is an automated message from the Apache
StephanEwen commented on issue #9255: [FLINK-13034] Introduce isEmpty method
for MapState
URL: https://github.com/apache/flink/pull/9255#issuecomment-535475551
Thanks for addressing the comments.
Looks good, +1 to merge this now, pending the Travis run.
-
[
https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14230:
--
Summary: Change the endinput call of the downstream operator to after the
upstream operator closes (
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
a-siuniaev commented on a change in pull request #9767:
[FLINK-14120][API/Datastream] Fix testImmediateShutdown
URL: https://github.com/apache/flink/pull/9767#discussion_r328582079
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SystemProce
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty
method for MapState
URL: https://github.com/apache/flink/pull/9255#issuecomment-515870480
## CI report:
* de863750b7262d091d2e7dd82767b8f9b2e2c52a : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/bui
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
Zhu Zhu created FLINK-14232:
---
Summary: Support full restarts for DefaultScheduler (SchedulerNG)
Key: FLINK-14232
URL: https://issues.apache.org/jira/browse/FLINK-14232
Project: Flink
Issue Type: Su
zhuzhurk commented on a change in pull request #9663: [FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r328585315
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
#
zhuzhurk commented on a change in pull request #9663: [FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r328585315
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
#
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_r328585695
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/a
[
https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938553#comment-16938553
]
Till Rohrmann commented on FLINK-11374:
---
Assigned.
> See more failover and can fi
[
https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-11374:
-
Assignee: lining
> See more failover and can filter by time range
> ---
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_r328587004
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/T
[
https://issues.apache.org/jira/browse/FLINK-14195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938557#comment-16938557
]
Till Rohrmann commented on FLINK-14195:
---
Here is the link to the cron job run:
ht
tillrohrmann commented on issue #9751: [FLINK-14177] bump curator from 2.12.0
to 4.2.0
URL: https://github.com/apache/flink/pull/9751#issuecomment-535483051
> > @zentol could you take a look at the problem with
`tools/releasing/collect_license_files.sh build-target`?
>
> Hi, @tillro
tillrohrmann commented on issue #4844: [FLINK-7844] [ckPt] Fail unacknowledged
pending checkpoints for fine grained recovery
URL: https://github.com/apache/flink/pull/4844#issuecomment-535484524
One reason for not using Mockito is that one usually creates mocks for each
individual test cas
tillrohrmann commented on issue #9775: [FLINK-14186][e2e] Let JVM ignores
unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11
URL: https://github.com/apache/flink/pull/9775#issuecomment-535485689
I think we do not have to cover this scenario atm. Testing all differe
flinkbot edited a comment on issue #8479: [FLINK-11193][State Backends]Use user
passed configuration overriding default configuration loading from file
URL: https://github.com/apache/flink/pull/8479#issuecomment-526521132
## CI report:
* fdd6f0e24a689b70d15b2dc190fc2fc3b0600bfa :
lamber-ken commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to
4.2.0
URL: https://github.com/apache/flink/pull/9751#issuecomment-535486657
hi, @tillrohrmann.
if so, it's better to add `maven-enforcer-plugin` to `pom.xml`.
```
org.apache.maven.plugins
tillrohrmann commented on a change in pull request #9767:
[FLINK-14120][API/Datastream] Fix testImmediateShutdown
URL: https://github.com/apache/flink/pull/9767#discussion_r328592848
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SystemPro
lamber-ken removed a comment on issue #9751: [FLINK-14177] bump curator from
2.12.0 to 4.2.0
URL: https://github.com/apache/flink/pull/9751#issuecomment-535486657
hi, @tillrohrmann.
if so, it's better to add `maven-enforcer-plugin` to `pom.xml`.
```
org.apache.maven.plugi
Zhu Zhu created FLINK-14233:
---
Summary: All task state changes should be notified to
SchedulingStrategy (SchedulerNG)
Key: FLINK-14233
URL: https://issues.apache.org/jira/browse/FLINK-14233
Project: Flink
gaoyunhaii commented on issue #9775: [FLINK-14186][e2e] Let JVM ignores
unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11
URL: https://github.com/apache/flink/pull/9775#issuecomment-535489144
Got it, I am also agree with remove this test now. I will update this PR
[
https://issues.apache.org/jira/browse/FLINK-14209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938573#comment-16938573
]
Gary Yao commented on FLINK-14209:
--
[~f.pompermaier]
{{flink-shaded}} exists so that
zhuzhurk commented on a change in pull request #9663: [FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r328597895
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
tillrohrmann commented on a change in pull request #9767:
[FLINK-14120][API/Datastream] Fix testImmediateShutdown
URL: https://github.com/apache/flink/pull/9767#discussion_r328597931
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SystemPro
zhuzhurk commented on a change in pull request #9663: [FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r328598864
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
Zhu Zhu created FLINK-14234:
---
Summary: All partition consumable events should be notified to
SchedulingStrategy (SchedulerNG)
Key: FLINK-14234
URL: https://issues.apache.org/jira/browse/FLINK-14234
Project:
tillrohrmann commented on issue #9751: [FLINK-14177] bump curator from 2.12.0
to 4.2.0
URL: https://github.com/apache/flink/pull/9751#issuecomment-535494575
Well technically speaking you can also build Flink with maven > 3.2.5. You
just have to build flink-dist after you've built the oth
[
https://issues.apache.org/jira/browse/FLINK-14209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938591#comment-16938591
]
Flavio Pompermaier commented on FLINK-14209:
Hi [~gjy], of course I could us
ex00 commented on a change in pull request #9184: [FLINK-13339][ml] Add an
implementation of pipeline's api
URL: https://github.com/apache/flink/pull/9184#discussion_r328609049
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/AlgoOperator.java
##
flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty
method for MapState
URL: https://github.com/apache/flink/pull/9255#issuecomment-515870480
## CI report:
* de863750b7262d091d2e7dd82767b8f9b2e2c52a : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/bui
[
https://issues.apache.org/jira/browse/FLINK-14162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938601#comment-16938601
]
Till Rohrmann commented on FLINK-14162:
---
This sounds like a very good improvement!
TisonKun commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to
4.2.0
URL: https://github.com/apache/flink/pull/9751#issuecomment-535502898
Thanks for your information @tillrohrmann & @lamber-ken.
May I ask what is "the immutable reactor build"? Is there an further
info
TisonKun edited a comment on issue #9751: [FLINK-14177] bump curator from
2.12.0 to 4.2.0
URL: https://github.com/apache/flink/pull/9751#issuecomment-535502898
Thanks for your information @tillrohrmann & @lamber-ken.
May I ask what is "the immutable reactor build"? Is there further
pnowojski opened a new pull request #9779: [FLINK-14214][runtime] Shortcut
isAvailable().isDone() anti-starvation check in StreamTwoInputProcesso
URL: https://github.com/apache/flink/pull/9779
This probably doesn't speed up the code, but it's how the isAvailable() was
intended to be used.
[
https://issues.apache.org/jira/browse/FLINK-14214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14214:
---
Labels: pull-request-available (was: )
> Performance regression in TwoInputStreamOperator
>
flinkbot commented on issue #9779: [FLINK-14214][runtime] Shortcut
isAvailable().isDone() anti-starvation check in StreamTwoInputProcesso
URL: https://github.com/apache/flink/pull/9779#issuecomment-535518600
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot.
flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate
DataStream Code Walkthrough to Chinese
URL: https://github.com/apache/flink/pull/9749#issuecomment-534149758
## CI report:
* 141eb6db531af4b12a9506489f280f180c02a408 : FAILURE
[Build](https://travis-ci.co
lamber-ken commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to
4.2.0
URL: https://github.com/apache/flink/pull/9751#issuecomment-535520681
> Well technically speaking you can also build Flink with maven > 3.2.5. You
just have to build flink-dist after you've built the other
101 - 200 of 366 matches
Mail list logo
