[
https://issues.apache.org/jira/browse/FLINK-7941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong reassigned FLINK-7941:
Assignee: Fang Yong
> Port SubtasksTimesHandler to new REST endpoint
>
Fang Yong created FLINK-7941:
Summary: Port SubtasksTimesHandler to new REST endpoint
Key: FLINK-7941
URL: https://issues.apache.org/jira/browse/FLINK-7941
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi reassigned FLINK-6109:
-
Assignee: aitozi
> Add "consumer lag" report metric to FlinkKafkaConsumer
>
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi reassigned FLINK-6109:
-
Assignee: aitozi
> Add "consumer lag" report metric to FlinkKafkaConsumer
>
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi reassigned FLINK-6109:
-
Assignee: (was: aitozi)
> Add "consumer lag" report metric to FlinkKafkaConsumer
>
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224395#comment-16224395
]
aitozi commented on FLINK-6109:
---
Is anyone working on this issue, Now in version 1.3.2 we can only see that
[
https://issues.apache.org/jira/browse/FLINK-7940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224206#comment-16224206
]
ASF GitHub Bot commented on FLINK-7940:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224208#comment-16224208
]
ASF GitHub Bot commented on FLINK-7940:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224207#comment-16224207
]
ASF GitHub Bot commented on FLINK-7940:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4918#discussion_r147594462
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
---
@@ -446,19 +449,67 @@ public void onComplete(Throwable
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4918#discussion_r147594496
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
---
@@ -446,19 +449,67 @@ public void onComplete(Throwable
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4918#discussion_r147594412
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
---
@@ -446,19 +449,67 @@ public void onComplete(Throwable
[
https://issues.apache.org/jira/browse/FLINK-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16069086#comment-16069086
]
Ted Yu edited comment on FLINK-7049 at 10/29/17 7:14 PM:
-
Stack trace for
[
https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7642:
--
Description:
Surefire 2.19 release introduced more useful test filters which would let us
run a subset of the
[
https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7795:
--
Description:
http://errorprone.info/ is a tool which detects common coding mistakes.
We should incorporate
[
https://issues.apache.org/jira/browse/FLINK-7940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224046#comment-16224046
]
ASF GitHub Bot commented on FLINK-7940:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4918
[FLINK-7940] Add FutureUtils.orTimeout
## What is the purpose of the change
This commit adds a convenience function `FutureUtils#orTimeout` which
allows to easily add a timeout to
Till Rohrmann created FLINK-7940:
Summary: Add timeout for futures
Key: FLINK-7940
URL: https://issues.apache.org/jira/browse/FLINK-7940
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224043#comment-16224043
]
ASF GitHub Bot commented on FLINK-7880:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4909
---
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-7880.
-
Resolution: Fixed
Merged on master at 6b8f7dc2d818cbe87bdfbe8852cfec5507f77a5a
>
[
https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224027#comment-16224027
]
ASF GitHub Bot commented on FLINK-7548:
---
Github user xccui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224025#comment-16224025
]
ASF GitHub Bot commented on FLINK-7548:
---
Github user xccui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224024#comment-16224024
]
ASF GitHub Bot commented on FLINK-7548:
---
Github user xccui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224026#comment-16224026
]
ASF GitHub Bot commented on FLINK-7548:
---
Github user xccui commented on a diff in the pull request:
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4894#discussion_r147583120
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/FieldComputer.scala
---
@@ -0,0 +1,63 @@
+/*
+ * Licensed to the
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4894#discussion_r147574828
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSourceUtil.scala
---
@@ -0,0 +1,518 @@
+/*
+ * Licensed to
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4894#discussion_r147580191
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/StreamTableSourceScan.scala
---
@@ -56,33 +63,123 @@ class
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4894#discussion_r147582469
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala
---
@@ -38,23 +38,26 @@ import
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4751
I assume that the `Thread.sleep(1)` should not do much harm if the Kafka
Producer already blocks due to buffering and I/O. If it should not block, then
the `Thread.sleep(1)` will give other
[
https://issues.apache.org/jira/browse/FLINK-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224019#comment-16224019
]
ASF GitHub Bot commented on FLINK-7739:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16223885#comment-16223885
]
ASF GitHub Bot commented on FLINK-7548:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4894
I'm planning to merge this PR before the feature freeze on Tuesday.
Cheers, Fabian
---
33 matches
Mail list logo