liangji created FLINK-16489:
---
Summary: flink on yarn模式下，rm重启am，没有从失败的am保存的chk来重启
Key: FLINK-16489
URL: https://issues.apache.org/jira/browse/FLINK-16489
Project: Flink
Issue Type: Bug
R
flinkbot edited a comment on issue #11320: [FLINK-16437][runtime] Make
SlotManager allocate resource from ResourceManager at the worker granularity.
URL: https://github.com/apache/flink/pull/11320#issuecomment-595174225
## CI report:
* c046c02c0afdfe2c17bc226aa32a249c438978d0 Tra
flinkbot edited a comment on issue #11320: [FLINK-16437][runtime] Make
SlotManager allocate resource from ResourceManager at the worker granularity.
URL: https://github.com/apache/flink/pull/11320#issuecomment-595174225
## CI report:
* b46d3159b0b1fe2a7f5f3210185c50b5e7252cc0 Tra
flinkbot edited a comment on issue #11320: [FLINK-16437][runtime] Make
SlotManager allocate resource from ResourceManager at the worker granularity.
URL: https://github.com/apache/flink/pull/11320#issuecomment-595174225
## CI report:
* b46d3159b0b1fe2a7f5f3210185c50b5e7252cc0 Tra
xintongsong commented on a change in pull request #11320:
[FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager
at the worker granularity.
URL: https://github.com/apache/flink/pull/11320#discussion_r389333966
##
File path:
flink-runtime/src/main/java/org/a
TisonKun commented on a change in pull request #11320: [FLINK-16437][runtime]
Make SlotManager allocate resource from ResourceManager at the worker
granularity.
URL: https://github.com/apache/flink/pull/11320#discussion_r389332767
##
File path:
flink-runtime/src/main/java/org/apac
xintongsong commented on a change in pull request #11320:
[FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager
at the worker granularity.
URL: https://github.com/apache/flink/pull/11320#discussion_r389332200
##
File path:
flink-runtime/src/main/java/org/a
TisonKun commented on a change in pull request #11320: [FLINK-16437][runtime]
Make SlotManager allocate resource from ResourceManager at the worker
granularity.
URL: https://github.com/apache/flink/pull/11320#discussion_r389331955
##
File path:
flink-runtime/src/main/java/org/apac
xintongsong commented on a change in pull request #11320:
[FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager
at the worker granularity.
URL: https://github.com/apache/flink/pull/11320#discussion_r389331707
##
File path:
flink-runtime/src/main/java/org/a
[
https://issues.apache.org/jira/browse/FLINK-13483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17054273#comment-17054273
]
Dian Fu commented on FLINK-13483:
-
Another instance: [https://api.travis-ci.org/v3/job/6
[
https://issues.apache.org/jira/browse/FLINK-15674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17054264#comment-17054264
]
Guowei Ma commented on FLINK-15674:
---
I think we should make java type extractor stack
[
https://issues.apache.org/jira/browse/FLINK-16363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-16363:
-
Assignee: godfrey he
> Correct the execution behavior of TableEnvironment and StreamTableEnviro
[
https://issues.apache.org/jira/browse/FLINK-16488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Mathews updated FLINK-16488:
-
Description:
When running a slim downed version of the wordcount example, I am seeing some
very
[
https://issues.apache.org/jira/browse/FLINK-16488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Mathews updated FLINK-16488:
-
Description:
When running a slim downed version of the wordcount example, I am seeing some
very
John Mathews created FLINK-16488:
Summary: Logging issues when running through K8s
Key: FLINK-16488
URL: https://issues.apache.org/jira/browse/FLINK-16488
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17054175#comment-17054175
]
Steven Zhen Wu commented on FLINK-16444:
+1. this is super useful if RocksDB / d
danp11 opened a new pull request #51: Make PersistedTable maintain the
insertion order.
URL: https://github.com/apache/flink-statefun/pull/51
This is an automated message from the Apache Git Service.
To respond to the messag
flinkbot edited a comment on issue #11344: [FLINK-16250][python][ml] Add
interfaces for PipelineStage and Pipeline
URL: https://github.com/apache/flink/pull/11344#issuecomment-596094520
## CI report:
* 99e47d0ba1b97997531c2bbaee32091ddc1e344e Travis:
[SUCCESS](https://travis-ci.
flinkbot edited a comment on issue #11343: [FLINK-15000] [web] WebUI metrics is
very slow in large parallelism
URL: https://github.com/apache/flink/pull/11343#issuecomment-596094500
## CI report:
* 45ee7bfb32e5eb33606d6978dc85496c664984f4 Travis:
[SUCCESS](https://travis-ci.com/
flinkbot edited a comment on issue #11341: [FLINK-16273][python] Set
io.netty.tryReflectionSetAccessible to true by default
URL: https://github.com/apache/flink/pull/11341#issuecomment-596093032
## CI report:
* acf3524b26cbdaf98666a78d72c2e0355e193fd7 Travis:
[FAILURE](https://t
flinkbot edited a comment on issue #11342: [FLINK-16483][python] Add Python
building blocks to make sure the basic functionality of vectorized Python UDF
could work
URL: https://github.com/apache/flink/pull/11342#issuecomment-596093049
## CI report:
* 27f93cc605b980ae0ce93b1d550
flinkbot edited a comment on issue #11344: [FLINK-16250][python][ml] Add
interfaces for PipelineStage and Pipeline
URL: https://github.com/apache/flink/pull/11344#issuecomment-596094520
## CI report:
* 99e47d0ba1b97997531c2bbaee32091ddc1e344e Travis:
[PENDING](https://travis-ci.
flinkbot edited a comment on issue #11343: [FLINK-15000] [web] WebUI metrics is
very slow in large parallelism
URL: https://github.com/apache/flink/pull/11343#issuecomment-596094500
## CI report:
* 45ee7bfb32e5eb33606d6978dc85496c664984f4 Travis:
[PENDING](https://travis-ci.com/
[
https://issues.apache.org/jira/browse/FLINK-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17054102#comment-17054102
]
ShijieZhang commented on FLINK-16155:
-
[~jark], get it. Thanks a lot.
> Translate "
faaronzheng commented on a change in pull request #10299: [FLINK-14560]
[runtime] The value of taskmanager.memory.size in flink…
URL: https://github.com/apache/flink/pull/10299#discussion_r389258812
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/util/Configurati
flinkbot commented on issue #11344: [FLINK-16250][python][ml] Add interfaces
for PipelineStage and Pipeline
URL: https://github.com/apache/flink/pull/11344#issuecomment-596094520
## CI report:
* 99e47d0ba1b97997531c2bbaee32091ddc1e344e UNKNOWN
Bot commands
The @fl
flinkbot edited a comment on issue #11342: [FLINK-16483][python] Add Python
building blocks to make sure the basic functionality of vectorized Python UDF
could work
URL: https://github.com/apache/flink/pull/11342#issuecomment-596093049
## CI report:
* 27f93cc605b980ae0ce93b1d550
flinkbot edited a comment on issue #11341: [FLINK-16273][python] Set
io.netty.tryReflectionSetAccessible to true by default
URL: https://github.com/apache/flink/pull/11341#issuecomment-596093032
## CI report:
* acf3524b26cbdaf98666a78d72c2e0355e193fd7 Travis:
[PENDING](https://t
flinkbot commented on issue #11343: [FLINK-15000] [web] WebUI metrics is very
slow in large parallelism
URL: https://github.com/apache/flink/pull/11343#issuecomment-596094500
## CI report:
* 45ee7bfb32e5eb33606d6978dc85496c664984f4 UNKNOWN
Bot commands
The @flinkb
wuchong commented on a change in pull request #11296: [FLINK-16363] [table]
Correct the execution behavior of TableEnvironment and StreamTableEnvironment
URL: https://github.com/apache/flink/pull/11296#discussion_r389258550
##
File path:
flink-table/flink-table-planner/src/main/sca
[
https://issues.apache.org/jira/browse/FLINK-16250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-16250:
Fix Version/s: 1.11.0
> Add interfaces for PipelineStage and Pipeline
> --
flinkbot commented on issue #11344: [FLINK-16250][python][ml] Add interfaces
for PipelineStage and Pipeline
URL: https://github.com/apache/flink/pull/11344#issuecomment-596093350
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to r
[
https://issues.apache.org/jira/browse/FLINK-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17054090#comment-17054090
]
Jark Wu commented on FLINK-16155:
-
Hi [~CrazyTomatoOo], It's great to see you are active
hequn8128 opened a new pull request #11344: [FLINK-16250][python][ml] Add
interfaces for PipelineStage and Pipeline
URL: https://github.com/apache/flink/pull/11344
## What is the purpose of the change
A pipeline is a linear workflow that chains some PipelineStages, e.g.,
Estimat
[
https://issues.apache.org/jira/browse/FLINK-16250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16250:
---
Labels: pull-request-available (was: )
> Add interfaces for PipelineStage and Pipeline
> --
[
https://issues.apache.org/jira/browse/FLINK-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17054089#comment-17054089
]
fa zheng commented on FLINK-15000:
--
[~vthinkxie] sorry for replying so late. I have al
flinkbot commented on issue #11342: [FLINK-16483][python] Add Python building
blocks to make sure the basic functionality of vectorized Python UDF could work
URL: https://github.com/apache/flink/pull/11342#issuecomment-596093049
## CI report:
* 27f93cc605b980ae0ce93b1d5503031ae98
flinkbot commented on issue #11341: [FLINK-16273][python] Set
io.netty.tryReflectionSetAccessible to true by default
URL: https://github.com/apache/flink/pull/11341#issuecomment-596093032
## CI report:
* acf3524b26cbdaf98666a78d72c2e0355e193fd7 UNKNOWN
Bot commands
flinkbot commented on issue #11343: [FLINK-15000] [web] WebUI metrics is very
slow in large parallelism
URL: https://github.com/apache/flink/pull/11343#issuecomment-596092734
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to revie
faaronzheng opened a new pull request #11343: [FLINK-15000] [web] WebUI metrics
is very slow in large parallelism
URL: https://github.com/apache/flink/pull/11343
## What is the purpose of the change
This pull request add search function and fix slow loading for high
paralle
[
https://issues.apache.org/jira/browse/FLINK-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-15000:
---
Labels: pull-request-available (was: )
> WebUI Metrics is very slow in large parallelism
>
flinkbot commented on issue #11342: [FLINK-16483][python] Add Python building
blocks to make sure the basic functionality of vectorized Python UDF could work
URL: https://github.com/apache/flink/pull/11342#issuecomment-596091572
Thanks a lot for your contribution to the Apache Flink project
godfreyhe commented on a change in pull request #11296: [FLINK-16363] [table]
Correct the execution behavior of TableEnvironment and StreamTableEnvironment
URL: https://github.com/apache/flink/pull/11296#discussion_r389256767
##
File path:
flink-table/flink-table-planner-blink/src/
flinkbot commented on issue #11341: [FLINK-16273][python] Set
io.netty.tryReflectionSetAccessible to true by default
URL: https://github.com/apache/flink/pull/11341#issuecomment-596091576
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the communit
[
https://issues.apache.org/jira/browse/FLINK-16483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16483:
---
Labels: pull-request-available (was: )
> Add Python building blocks to make sure the basic
dianfu opened a new pull request #11342: [FLINK-16483][python] Add Python
building blocks to make sure the basic functionality of vectorized Python UDF
could work
URL: https://github.com/apache/flink/pull/11342
## What is the purpose of the change
*This pull request add the Pyth
godfreyhe commented on a change in pull request #11296: [FLINK-16363] [table]
Correct the execution behavior of TableEnvironment and StreamTableEnvironment
URL: https://github.com/apache/flink/pull/11296#discussion_r389256531
##
File path:
flink-table/flink-table-planner/src/test/s
[
https://issues.apache.org/jira/browse/FLINK-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16273:
---
Labels: pull-request-available (was: )
> Solve "sun.misc.Unseafe or java.nio.DirectByteBuff
dianfu opened a new pull request #11341: [FLINK-16273][python] Set
io.netty.tryReflectionSetAccessible to true by default
URL: https://github.com/apache/flink/pull/11341
## What is the purpose of the change
* This pull request set the property io.netty.tryReflectionSetAccessible
godfreyhe commented on a change in pull request #11296: [FLINK-16363] [table]
Correct the execution behavior of TableEnvironment and StreamTableEnvironment
URL: https://github.com/apache/flink/pull/11296#discussion_r389256028
##
File path:
flink-table/flink-table-planner/src/main/s
[
https://issues.apache.org/jira/browse/FLINK-16436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16436:
---
Labels: pull-request-available (was: )
> Update Apache downloads link due to INFRA structur
[
https://issues.apache.org/jira/browse/FLINK-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17054014#comment-17054014
]
ShijieZhang commented on FLINK-16155:
-
Sorry, it`s my fault. I will go to find other
leonardBang commented on a change in pull request #11334:
[FLINK-16464][sql-client]result-mode tableau may shift when content contains
Chinese String in SQL CLI
URL: https://github.com/apache/flink/pull/11334#discussion_r389232752
##
File path:
flink-table/flink-sql-client/src/tes
[
https://issues.apache.org/jira/browse/FLINK-16481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16481:
---
Priority: Minor (was: Major)
> Improved FlinkkafkaConnector support for dynamically increasing capacity
> -
[
https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16482:
---
Priority: Critical (was: Minor)
> Flink Job throw CloseException when call the FlinkKafkaConsumer cancel
>
[
https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16482:
---
Priority: Minor (was: Critical)
> Flink Job throw CloseException when call the FlinkKafkaConsumer cancel
>
[
https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16482:
---
Priority: Major (was: Critical)
> Flink Job throw CloseException when call the FlinkKafkaConsumer cancel
>
[
https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16482:
---
Priority: Critical (was: Major)
> Flink Job throw CloseException when call the FlinkKafkaConsumer cancel
>
[
https://issues.apache.org/jira/browse/FLINK-16487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhimin Li updated FLINK-16487:
--
Component/s: Connectors / Common
> Add flink-connector-kudu
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-16487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhimin Li updated FLINK-16487:
--
Description:
Kudu needs to be used in many streaming processing scenarios. Our company's
production e
[
https://issues.apache.org/jira/browse/FLINK-16487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053975#comment-17053975
]
Zhimin Li edited comment on FLINK-16487 at 3/7/20, 10:35 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-16487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053975#comment-17053975
]
Zhimin Li commented on FLINK-16487:
---
When creating the sink a \{@code addr} must be sp
Zhimin Li created FLINK-16487:
-
Summary: Add flink-connector-kudu
Key: FLINK-16487
URL: https://issues.apache.org/jira/browse/FLINK-16487
Project: Flink
Issue Type: New Feature
Componen
[
https://issues.apache.org/jira/browse/FLINK-16487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhimin Li updated FLINK-16487:
--
Attachment: kudu_sink_process.pdf
> Add flink-connector-kudu
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-16487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhimin Li updated FLINK-16487:
--
Description:
Kudu needs to be used in many flow processing scenarios. Our company's
production enviro
[
https://issues.apache.org/jira/browse/FLINK-10850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053971#comment-17053971
]
Maximilian Michels commented on FLINK-10850:
Just to update this here, if th
[
https://issues.apache.org/jira/browse/FLINK-16486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16486:
Component/s: Documentation
> Add documentation for vectorized Python UDF
> ---
[
https://issues.apache.org/jira/browse/FLINK-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16273:
Parent: FLINK-16114
Issue Type: Sub-task (was: Bug)
> Solve "sun.misc.Unseafe or java.nio.DirectB
Dian Fu created FLINK-16486:
---
Summary: Add documentation for vectorized Python UDF
Key: FLINK-16486
URL: https://issues.apache.org/jira/browse/FLINK-16486
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-16485:
---
Summary: Support vectorized Python UDF in the batch mode of old
planner
Key: FLINK-16485
URL: https://issues.apache.org/jira/browse/FLINK-16485
Project: Flink
Issue T
Dian Fu created FLINK-16484:
---
Summary: Support all the data types in vectorized Python UDF
Key: FLINK-16484
URL: https://issues.apache.org/jira/browse/FLINK-16484
Project: Flink
Issue Type: Sub-tas
[
https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16482:
---
Description:
*Background：*
Today I tried to detect my Flink job with a timing threa
[
https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16482:
---
Attachment: The bug and solution.docx
> Flink Job throw CloseException when call the FlinkKafkaConsumer canc
[
https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16482:
---
Attachment: (was: image-2020-03-07-17-59-25-739.png)
> Flink Job throw CloseException when call the Flin
[
https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16482:
---
Attachment: image-2020-03-07-17-59-25-739.png
> Flink Job throw CloseException when call the FlinkKafkaConsu
[
https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16482:
---
Description:
*Background：*
Today I tried to detect my Flink job with a timing threa
[
https://issues.apache.org/jira/browse/FLINK-16483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-16483:
---
Assignee: Dian Fu
> Add Python building blocks to make sure the basic functionality of vectorized
Dian Fu created FLINK-16483:
---
Summary: Add Python building blocks to make sure the basic
functionality of vectorized Python UDF could work
Key: FLINK-16483
URL: https://issues.apache.org/jira/browse/FLINK-16483
[
https://issues.apache.org/jira/browse/FLINK-16481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16481:
---
Description:
The source and sink of the community version of Flink-kafka-connector do
not have th
[
https://issues.apache.org/jira/browse/FLINK-16481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16481:
---
Summary: Improved FlinkkafkaConnector support for dynamically increasing
capacity (was: Improved metadata t
[
https://issues.apache.org/jira/browse/FLINK-16481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16481:
---
Summary: Improved metadata to increase the capacity of consciousness
FlinkkafkaConnector (was: flink-kafka-
[
https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16482:
---
Description:
*Background：*
Today I tried to detect my Flink job with a timing threa
[
https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16482:
---
Description:
*Background：*
Today I tried to detect my Flink job with a timing threa
TisonKun commented on a change in pull request #11320: [FLINK-16437][runtime]
Make SlotManager allocate resource from ResourceManager at the worker
granularity.
URL: https://github.com/apache/flink/pull/11320#discussion_r389241300
##
File path:
flink-runtime/src/main/java/org/apac
[
https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16482:
---
Summary: Flink Job throw CloseException when call the FlinkKafkaConsumer
cancel function (was: Flink任务的kafk
[
https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053951#comment-17053951
]
Hequn Cheng commented on FLINK-16482:
-
[~kangzai] Hi, thanks a lot for reporting the
TisonKun commented on issue #10526: [FLINK-15090][build] Reverse the dependency
from flink-streaming-java to flink-client
URL: https://github.com/apache/flink/pull/10526#issuecomment-596064328
Latest Azure build passed:
https://dev.azure.com/rmetzger/Flink/_build/results?buildId=6040&view=
likang created FLINK-16482:
--
Summary: Flink任务的kafkaSource因为cancel导致任务失败而重启
Key: FLINK-16482
URL: https://issues.apache.org/jira/browse/FLINK-16482
Project: Flink
Issue Type: Bug
Reporter
[
https://issues.apache.org/jira/browse/FLINK-16481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16481:
---
Attachment: Flink-Kafka-Connetor的改进.docx
> flink-kafka-connector 支持动态扩缩容
> -
>
>
TisonKun commented on a change in pull request #11320: [FLINK-16437][runtime]
Make SlotManager allocate resource from ResourceManager at the worker
granularity.
URL: https://github.com/apache/flink/pull/11320#discussion_r389238604
##
File path:
flink-runtime/src/main/java/org/apac
likang created FLINK-16481:
--
Summary: flink-kafka-connector 支持动态扩缩容
Key: FLINK-16481
URL: https://issues.apache.org/jira/browse/FLINK-16481
Project: Flink
Issue Type: Improvement
Component
TisonKun commented on a change in pull request #11320: [FLINK-16437][runtime]
Make SlotManager allocate resource from ResourceManager at the worker
granularity.
URL: https://github.com/apache/flink/pull/11320#discussion_r389238604
##
File path:
flink-runtime/src/main/java/org/apac
TisonKun commented on a change in pull request #11320: [FLINK-16437][runtime]
Make SlotManager allocate resource from ResourceManager at the worker
granularity.
URL: https://github.com/apache/flink/pull/11320#discussion_r389238535
##
File path:
flink-runtime/src/main/java/org/apac
[
https://issues.apache.org/jira/browse/FLINK-16437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-16437:
-
Assignee: Xintong Song
> Make SlotManager allocate resource from ResourceManager at the worker
94 matches
Mail list logo
