[
https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569405#comment-15569405
]
Stephan Ewen commented on FLINK-4410:
-
Code that gathers additional metrics is integrated. What is
[
https://issues.apache.org/jira/browse/FLINK-2624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2624.
-
Resolution: Fixed
Fixed in 9215b72422d3e638fe950b61fa01f2e4e04981a0
> RabbitMQ source / sink
[
https://issues.apache.org/jira/browse/FLINK-2624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2624.
---
> RabbitMQ source / sink should participate in checkpointing
>
[
https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569386#comment-15569386
]
Stephan Ewen commented on FLINK-2221:
-
I would like to close this as "won't fix", because it is
[
https://issues.apache.org/jira/browse/FLINK-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3594.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed via 34110fefc6e49bcbe1ae8de090fa43a5f6ef5fec
[
https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4410:
Assignee: (was: Stephan Ewen)
> Report more information about operator checkpoints
>
[
https://issues.apache.org/jira/browse/FLINK-4102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569440#comment-15569440
]
Stephan Ewen commented on FLINK-4102:
-
Can we close that as "could not reproduce" and reopen it once
[
https://issues.apache.org/jira/browse/FLINK-3354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3354.
-
Resolution: Fixed
Fixed in b17632ddbbb58f8b3e3d1a31d6658e59258918c7
> RocksDB should compute
[
https://issues.apache.org/jira/browse/FLINK-3354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3354.
---
> RocksDB should compute checkpoint size based on backup file size
>
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2627
+1, looks good to me ð
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2628
[FLINK-3722] [runtime] Don't / and % when sorting
Replace division and modulus with addition and subtraction.
The timing chart below has three columns for two Gelly algorithms with
[
https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570510#comment-15570510
]
ASF GitHub Bot commented on FLINK-3722:
---
GitHub user greghogan opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570678#comment-15570678
]
ASF GitHub Bot commented on FLINK-4727:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2585#discussion_r83138654
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570730#comment-15570730
]
ASF GitHub Bot commented on FLINK-4723:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2580
Thanks for the review @rmetzger. I've created several local branches to
test out the new IT tests stability as @StephanEwen suggested, and they seem to
be fine.
I'll rebase this, address
[
https://issues.apache.org/jira/browse/FLINK-3037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570751#comment-15570751
]
Tzu-Li (Gordon) Tai commented on FLINK-3037:
I'm a little bit confused here.
On checkpoints /
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r83141867
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer08.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570766#comment-15570766
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570763#comment-15570763
]
Tzu-Li (Gordon) Tai commented on FLINK-4280:
I think using the {{KafkaTopicPartition}} is a
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2509
Rebasing + adding tests for the new functions now.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
[
https://issues.apache.org/jira/browse/FLINK-4627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570772#comment-15570772
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4627 at 10/13/16 4:13 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570769#comment-15570769
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15570772#comment-15570772
]
Tzu-Li (Gordon) Tai commented on FLINK-4627:
Hi Neelesh,
I'm not aware of anyone working on
201 - 224 of 224 matches
Mail list logo
