123avi commented on issue #7418: FLINK-11053 Documentation - update scala
sample code for bucketing sink according
URL: https://github.com/apache/flink/pull/7418#issuecomment-455762397
@hequn8128 any other modifications needed or this PR can be approved ?
[
https://issues.apache.org/jira/browse/FLINK-11394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Nitavskyi updated FLINK-11394:
Description:
In case back-end requests for the job state take longer than
[
https://issues.apache.org/jira/browse/FLINK-11394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Nitavskyi updated FLINK-11394:
Description:
In case back-end requests for the job state take longer than
[
https://issues.apache.org/jira/browse/FLINK-11394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Nitavskyi updated FLINK-11394:
Description:
In case back-end requests for the job state take longer than
[
https://issues.apache.org/jira/browse/FLINK-11394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Nitavskyi updated FLINK-11394:
Description:
In case back-end requests for the job state take longer than
[
https://issues.apache.org/jira/browse/FLINK-11394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Nitavskyi updated FLINK-11394:
Description:
In case back-end requests for the job state take longer than
[
https://issues.apache.org/jira/browse/FLINK-11394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Nitavskyi updated FLINK-11394:
Description:
In case back-end requests for the job state take longer than
[
https://issues.apache.org/jira/browse/FLINK-11396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Nitavskyi updated FLINK-11396:
Description:
On Flink version 1.6.x we observe a significant increase of the
Oleksandr Nitavskyi created FLINK-11396:
---
Summary: MetricStore creates significant GC pressure
Key: FLINK-11396
URL: https://issues.apache.org/jira/browse/FLINK-11396
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Nitavskyi updated FLINK-11396:
Attachment: GC_parallel_flink_job_manager.log
g1.txt
[
https://issues.apache.org/jira/browse/FLINK-11396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16746997#comment-16746997
]
Oleksandr Nitavskyi commented on FLINK-11396:
-
On GC tuning side, G1 ergonomic concluded we
[
https://issues.apache.org/jira/browse/FLINK-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Nitavskyi reopened FLINK-10342:
-
> Kafka duplicate topic consumption when topic name is changed
>
[
https://issues.apache.org/jira/browse/FLINK-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Nitavskyi closed FLINK-10342.
---
Resolution: Won't Fix
> Kafka duplicate topic consumption when topic name is
[
https://issues.apache.org/jira/browse/FLINK-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Nitavskyi closed FLINK-10342.
---
Resolution: Fixed
> Kafka duplicate topic consumption when topic name is changed
>
EugeneYushin commented on a change in pull request #6760: [FLINK-10422] Follow
AWS specs in Kinesis Consumer
URL: https://github.com/apache/flink/pull/6760#discussion_r249241807
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747322#comment-16747322
]
shengjk1 commented on FLINK-11336:
--
1.No matter what form stop flink, such as cancel,failed with no
stevenzwu commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249265860
##
File path:
stevenzwu commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249265860
##
File path:
Myasuka opened a new pull request #7544: [FLINK-11366][tests] Port
TaskManagerMetricsTest to new code base
URL: https://github.com/apache/flink/pull/7544
## What is the purpose of the change
Port `TaskManagerMetricsTest` to new code base.
## Brief change log
- Move
[
https://issues.apache.org/jira/browse/FLINK-11366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11366:
---
Labels: pull-request-available (was: )
> Check and port TaskManagerMetricsTest to new code
stevenzwu commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249265860
##
File path:
asfgit closed pull request #7403: [FLINK-11256] Replace the reference of
StreamNode object with ID in S…
URL: https://github.com/apache/flink/pull/7403
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-11256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-11256.
---
Resolution: Fixed
Fix Version/s: 1.8.0
Fixed in master:
anil477 commented on issue #6301: [FLINK-9794] [jdbc] JDBCOutputFormat does not
consider idle connection and multithreads synchronization
URL: https://github.com/apache/flink/pull/6301#issuecomment-455801153
@yanghua @walterddr @sihuazhou This PR has been dormant for a while now. If
it's
24 matches
Mail list logo
