[
https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln.lee updated FLINK-7942:
---
Description:
Test case *testFilterRule1* fails due to a NPE
{code}
java.lang.RuntimeException: Error
[
https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln.lee updated FLINK-7942:
---
Component/s: Table API & SQL
> NPE when apply FilterJoinRule
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln.lee updated FLINK-7942:
---
Description:
Test case *testFilterRule1* fails due to a NPE
{code}
java.lang.RuntimeException: Error
lincoln.lee created FLINK-7942:
--
Summary: NPE when apply FilterJoinRule
Key: FLINK-7942
URL: https://issues.apache.org/jira/browse/FLINK-7942
Project: Flink
Issue Type: Bug
Reporter:
[
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&focusedCommentId=16224395#comment-16224395
]
aitozi commented on FLINK-6109:
---
Is anyone working on this issue, Now in version 1.3.2 we ca
[
https://issues.apache.org/jira/browse/FLINK-7940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16224206#comment-16224206
]
ASF GitHub Bot commented on FLINK-7940:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-7940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16224208#comment-16224208
]
ASF GitHub Bot commented on FLINK-7940:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-7940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16224207#comment-16224207
]
ASF GitHub Bot commented on FLINK-7940:
---
Github user zentol commented on a diff in t
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 failure
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 failure
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 failure
[
https://issues.apache.org/jira/browse/FLINK-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069086#comment-16069086
]
Ted Yu edited comment on FLINK-7049 at 10/29/17 7:14 PM:
-
Stack tr
[
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 t
[
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 into
[
https://issues.apache.org/jira/browse/FLINK-7940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16224046#comment-16224046
]
ASF GitHub Bot commented on FLINK-7940:
---
GitHub user tillrohrmann opened a pull requ
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
Compo
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16224043#comment-16224043
]
ASF GitHub Bot commented on FLINK-7880:
---
Github user asfgit closed the pull request
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
> flink-queryable-
[
https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16224027#comment-16224027
]
ASF GitHub Bot commented on FLINK-7548:
---
Github user xccui commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16224025#comment-16224025
]
ASF GitHub Bot commented on FLINK-7548:
---
Github user xccui commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16224024#comment-16224024
]
ASF GitHub Bot commented on FLINK-7548:
---
Github user xccui commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16224026#comment-16224026
]
ASF GitHub Bot commented on FLINK-7548:
---
Github user xccui commented on a diff in th
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 th
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 A
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 S
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 scala.collection.mutab
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 thre
[
https://issues.apache.org/jira/browse/FLINK-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16224019#comment-16224019
]
ASF GitHub Bot commented on FLINK-7739:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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
---
37 matches
Mail list logo