[
https://issues.apache.org/jira/browse/FLINK-14054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928259#comment-16928259
]
TisonKun commented on FLINK-14054:
--
I might mistake that we are already able to configure parallelism
zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime]
Facilitate enabling new scheduler in MiniCluster Tests
URL: https://github.com/apache/flink/pull/9675#discussion_r323575794
##
File path:
flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate
enabling new scheduler in MiniCluster Tests
URL: https://github.com/apache/flink/pull/9675#issuecomment-530686777
## CI report:
* d15f9751632d4c7897f68a0f8829d5facbdfe14e : PENDING
[
https://issues.apache.org/jira/browse/FLINK-14053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-14053:
---
Assignee: jackylau
> blink planner dense_rank corner case bug
>
[
https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928316#comment-16928316
]
TisonKun commented on FLINK-13417:
--
[~StephanEwen] I figured out that it is because since 3.5.3
flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate
enabling new scheduler in MiniCluster Tests
URL: https://github.com/apache/flink/pull/9675#issuecomment-530682070
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the
zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime]
Facilitate enabling new scheduler in MiniCluster Tests
URL: https://github.com/apache/flink/pull/9675#discussion_r323572659
##
File path: pom.xml
##
@@ -637,6 +639,18 @@ under the License.
zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime]
Facilitate enabling new scheduler in MiniCluster Tests
URL: https://github.com/apache/flink/pull/9675#discussion_r323572659
##
File path: pom.xml
##
@@ -637,6 +639,18 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-14065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928279#comment-16928279
]
Zhilong Hong edited comment on FLINK-14065 at 9/12/19 6:41 AM:
---
It would
[
https://issues.apache.org/jira/browse/FLINK-14065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928279#comment-16928279
]
Zhilong Hong commented on FLINK-14065:
--
It would be my pleasure if I can help to fix this issue.
flinkbot edited a comment on issue #9013: [FLINK-13136] Fix documentation error
about stopping job with restful api
URL: https://github.com/apache/flink/pull/9013#issuecomment-509065631
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 #8912: [FLINK-12709] [runtime] Implement new
generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#issuecomment-506306353
Thanks a lot for your contribution to the Apache Flink project. I'm the
flinkbot edited a comment on issue #9650: [hotfix][blink-planner] Fix return
type for FROM_BASE64 builtin function
URL: https://github.com/apache/flink/pull/9650#issuecomment-529428588
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
[
https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928316#comment-16928316
]
TisonKun edited comment on FLINK-13417 at 9/12/19 7:43 AM:
---
[~StephanEwen] I
flinkbot commented on issue #9675: [FLINK-13953] [runtime] Facilitate enabling
new scheduler in MiniCluster Tests
URL: https://github.com/apache/flink/pull/9675#issuecomment-530686777
## CI report:
* d15f9751632d4c7897f68a0f8829d5facbdfe14e : UNKNOWN
flinkbot edited a comment on issue #8912: [FLINK-12709] [runtime] Implement new
generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#issuecomment-506306353
Thanks a lot for your contribution to the Apache Flink project. I'm the
zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime]
Implement new generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#discussion_r323583514
##
File path:
zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime]
Implement new generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#discussion_r323583514
##
File path:
zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime]
Implement new generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#discussion_r323583478
##
File path:
GJL commented on a change in pull request #9013: [FLINK-13136] Fix
documentation error about stopping job with restful api
URL: https://github.com/apache/flink/pull/9013#discussion_r323583397
##
File path:
GJL commented on a change in pull request #9013: [FLINK-13136] Fix
documentation error about stopping job with restful api
URL: https://github.com/apache/flink/pull/9013#discussion_r323583397
##
File path:
GJL commented on a change in pull request #9013: [FLINK-13136] Fix
documentation error about stopping job with restful api
URL: https://github.com/apache/flink/pull/9013#discussion_r323583397
##
File path:
flinkbot edited a comment on issue #8912: [FLINK-12709] [runtime] Implement new
generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#issuecomment-506306353
Thanks a lot for your contribution to the Apache Flink project. I'm the
zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime]
Implement new generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#discussion_r323583682
##
File path:
zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime]
Implement new generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#discussion_r323583982
##
File path:
zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime]
Implement new generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#discussion_r323595466
##
File path:
flinkbot edited a comment on issue #8912: [FLINK-12709] [runtime] Implement new
generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#issuecomment-506306353
Thanks a lot for your contribution to the Apache Flink project. I'm the
flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate
enabling new scheduler in MiniCluster Tests
URL: https://github.com/apache/flink/pull/9675#issuecomment-530686777
## CI report:
* d15f9751632d4c7897f68a0f8829d5facbdfe14e : SUCCESS
zhuzhurk opened a new pull request #9675: [FLINK-13953] [runtime] Facilitate
enabling new scheduler in MiniCluster Tests
URL: https://github.com/apache/flink/pull/9675
## What is the purpose of the change
Currently, tests using the {{MiniCluster}} use the legacy scheduler by
[
https://issues.apache.org/jira/browse/FLINK-13953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13953:
---
Labels: pull-request-available (was: )
> Facilitate enabling new Scheduler in MiniCluster
[
https://issues.apache.org/jira/browse/FLINK-14054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928235#comment-16928235
]
TisonKun commented on FLINK-14054:
--
Hi [~qinjunjerry]! Thanks for reporting your requirement. I agree
[
https://issues.apache.org/jira/browse/FLINK-14065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhilong Hong updated FLINK-14065:
-
Description:
When MetricGroup registers Metrics in MetricRegistryImpl, sometimes the
libenchao closed pull request #9650: [hotfix][blink-planner] Fix return type
for FROM_BASE64 builtin function
URL: https://github.com/apache/flink/pull/9650
This is an automated message from the Apache Git Service.
To
zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime]
Implement new generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#discussion_r323595466
##
File path:
zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime]
Facilitate enabling new scheduler in MiniCluster Tests
URL: https://github.com/apache/flink/pull/9675#discussion_r323573156
##
File path: flink-connectors/flink-connector-elasticsearch6/pom.xml
flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate
enabling new scheduler in MiniCluster Tests
URL: https://github.com/apache/flink/pull/9675#issuecomment-530682070
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the
flinkbot commented on issue #9675: [FLINK-13953] [runtime] Facilitate enabling
new scheduler in MiniCluster Tests
URL: https://github.com/apache/flink/pull/9675#issuecomment-530682070
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
[
https://issues.apache.org/jira/browse/FLINK-11420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928298#comment-16928298
]
lamber-ken commented on FLINK-11420:
(y)
> Serialization of case classes containing a Map[String,
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r323593378
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java
flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the
implementation of StreamInputProcessor based on StreamTaskInput#emitNext
URL: https://github.com/apache/flink/pull/9478#issuecomment-522374042
## CI report:
* 1530600eaf36324966f343c277437e48c2416dc2 :
flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement
DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#issuecomment-529928149
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate
enabling new scheduler in MiniCluster Tests
URL: https://github.com/apache/flink/pull/9675#issuecomment-530682070
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the
zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime]
Facilitate enabling new scheduler in MiniCluster Tests
URL: https://github.com/apache/flink/pull/9675#discussion_r323576390
##
File path:
Zhilong Hong created FLINK-14065:
Summary: Log metric name when the metric fails on
registration/unregistration
Key: FLINK-14065
URL: https://issues.apache.org/jira/browse/FLINK-14065
Project: Flink
flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate
enabling new scheduler in MiniCluster Tests
URL: https://github.com/apache/flink/pull/9675#issuecomment-530682070
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-14053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928289#comment-16928289
]
Jingsong Lee commented on FLINK-14053:
--
[~jackylau] Thanks for reporting this bug. Yes,
flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement
DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#issuecomment-529928149
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r323591961
##
File path:
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r323613449
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r323613495
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java
[
https://issues.apache.org/jira/browse/FLINK-14030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928370#comment-16928370
]
Leonard Xu edited comment on FLINK-14030 at 9/12/19 8:37 AM:
-
The root cause
flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the
implementation of StreamInputProcessor based on StreamTaskInput#emitNext
URL: https://github.com/apache/flink/pull/9478#issuecomment-522374042
## CI report:
* 1530600eaf36324966f343c277437e48c2416dc2 :
[
https://issues.apache.org/jira/browse/FLINK-14030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928370#comment-16928370
]
Leonard Xu commented on FLINK-14030:
The root cause is that Calcite's simplification logic of isNull
yanghua commented on a change in pull request #9013: [FLINK-13136] Fix
documentation error about stopping job with restful api
URL: https://github.com/apache/flink/pull/9013#discussion_r323628359
##
File path:
flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement
DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381
## CI report:
* 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED
flinkbot edited a comment on issue #9013: [FLINK-13136] Fix documentation error
about stopping job with restful api
URL: https://github.com/apache/flink/pull/9013#issuecomment-509065631
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
yanghua commented on issue #9667: [FLINK-13619] Update
FlinkKafkaProducerMigrationOperatorTest to restore from 1.9 savepoint
URL: https://github.com/apache/flink/pull/9667#issuecomment-530736092
cc @tillrohrmann
This is an
xintongsong opened a new pull request #9676: [FLINK-13981][runtime] Introduce
config switch for enabling the new FLIP-49 task executor memory configurations.
URL: https://github.com/apache/flink/pull/9676
## What is the purpose of the change
This PR introduce a config switch for
[
https://issues.apache.org/jira/browse/FLINK-13981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13981:
---
Labels: pull-request-available (was: )
> Introduce a switch for enabling the new task
Zhu Zhu created FLINK-14069:
---
Summary: Enable TimeUtils to parse all time units labels supported
by scala Duration
Key: FLINK-14069
URL: https://issues.apache.org/jira/browse/FLINK-14069
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-14070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-14070:
-
Assignee: Zhu Zhu
> Use TimeUtils to parse duration configs
>
[
https://issues.apache.org/jira/browse/FLINK-14070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928476#comment-16928476
]
Till Rohrmann commented on FLINK-14070:
---
Nice improvement [~zhuzh]. I've assigned you to work on
GJL commented on a change in pull request #9013: [FLINK-13136] Fix
documentation error about stopping job with restful api
URL: https://github.com/apache/flink/pull/9013#discussion_r323702619
##
File path:
GJL commented on a change in pull request #8912: [FLINK-12709] [runtime]
Implement new generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#discussion_r323601246
##
File path:
flinkbot edited a comment on issue #8912: [FLINK-12709] [runtime] Implement new
generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#issuecomment-506306353
Thanks a lot for your contribution to the Apache Flink project. I'm the
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r323609192
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement
DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#issuecomment-529928149
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
tillrohrmann commented on issue #9672: [FLINK-14047][rest] Let JobConfigHandler
replace sensitive values from user configuration
URL: https://github.com/apache/flink/pull/9672#issuecomment-530729132
Merging this PR now.
This
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r323631332
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-13619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-13619.
-
Resolution: Done
Done via 82ed1a64d1d1e5cde9ab0999804e93d38c9f9149
> Update
flinkbot edited a comment on issue #9667: [FLINK-13619] Update
FlinkKafkaProducerMigrationOperatorTest to restore from 1.9 savepoint
URL: https://github.com/apache/flink/pull/9667#issuecomment-529947799
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I
tillrohrmann closed pull request #9667: [FLINK-13619] Update
FlinkKafkaProducerMigrationOperatorTest to restore from 1.9 savepoint
URL: https://github.com/apache/flink/pull/9667
This is an automated message from the Apache
flinkbot edited a comment on issue #9013: [FLINK-13136] Fix documentation error
about stopping job with restful api
URL: https://github.com/apache/flink/pull/9013#issuecomment-509065631
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 #8912: [FLINK-12709] [runtime] Implement new
generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#issuecomment-506306353
Thanks a lot for your contribution to the Apache Flink project. I'm the
zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime]
Implement new generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#discussion_r323598464
##
File path:
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r323608993
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r323608957
##
File path:
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r323608610
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r323608753
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
[
https://issues.apache.org/jira/browse/FLINK-14066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928369#comment-16928369
]
Dian Fu commented on FLINK-14066:
-
Hi [~coldmoon777], currently PyFlink is still not supported on
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r323627300
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement
DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#issuecomment-529928149
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement
DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381
## CI report:
* 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED
[
https://issues.apache.org/jira/browse/FLINK-13767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13767:
-
Description:
StreamInputProcessor#processInput could return InputStatus instead of current
boolean
[
https://issues.apache.org/jira/browse/FLINK-13767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13767:
-
Summary: Refactor StreamInputProcessor#processInput based on InputStatus
(was: Migrate isFinished
flinkbot edited a comment on issue #9483: [FLINK-13767][task] Refactor
StreamInputProcessor#processInput based on InputStatus
URL: https://github.com/apache/flink/pull/9483#issuecomment-522602263
## CI report:
* 5d079442de5815edf896b85fa7aa3ca599975bb0 : FAILURE
[
https://issues.apache.org/jira/browse/FLINK-14069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-14069:
-
Assignee: Zhu Zhu
> Enable TimeUtils to parse all time units labels supported by scala
[
https://issues.apache.org/jira/browse/FLINK-14069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928465#comment-16928465
]
Till Rohrmann commented on FLINK-14069:
---
Sounds like a good idea [~zhuzh]. I've assigned you the
GJL commented on a change in pull request #8912: [FLINK-12709] [runtime]
Implement new generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#discussion_r323195327
##
File path:
zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime]
Implement new generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#discussion_r323599815
##
File path:
flinkbot edited a comment on issue #8912: [FLINK-12709] [runtime] Implement new
generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#issuecomment-506306353
Thanks a lot for your contribution to the Apache Flink project. I'm the
flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement
DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#issuecomment-529928149
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement
DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#issuecomment-529928149
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement
DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381
## CI report:
* 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED
TisonKun created FLINK-14068:
Summary: Use Java's Duration instead of Flink's Time
Key: FLINK-14068
URL: https://issues.apache.org/jira/browse/FLINK-14068
Project: Flink
Issue Type: Sub-task
flinkbot commented on issue #9676: [FLINK-13981][runtime] Introduce config
switch for enabling the new FLIP-49 task executor memory configurations.
URL: https://github.com/apache/flink/pull/9676#issuecomment-530745271
Thanks a lot for your contribution to the Apache Flink project. I'm the
flinkbot edited a comment on issue #9483: [FLINK-13767][task] Refactor
StreamInputProcessor#processInput based on InputStatus
URL: https://github.com/apache/flink/pull/9483#issuecomment-522597807
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the
zhuzhurk commented on a change in pull request #8912: [FLINK-12709] [runtime]
Implement new generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#discussion_r323684133
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928459#comment-16928459
]
TisonKun commented on FLINK-13417:
--
Hi [~till.rohrmann] I met a NOTICE-binary issue and cannot resolve
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r323611275
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/TestingLogicalSlot.java
1 - 100 of 232 matches
Mail list logo