[
https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-5789:
Fix Version/s: (was: 1.4.0)
1.5.0
> Make Bucketing Sink independent of Hadoop's FileS
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4647
The next time we touch `MutableIOMetrics`, we should also refactor
`MutableIOMetrics#addIOMetrics` such that one passes an IOMetrics object into
it instead of the `MetricFetcher`.
---
[
https://issues.apache.org/jira/browse/FLINK-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213990#comment-16213990
]
ASF GitHub Bot commented on FLINK-7575:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213988#comment-16213988
]
ASF GitHub Bot commented on FLINK-7575:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4647
Sorry for joining the party so late, but I think the solution is
incomplete. Flink displays many metrics for the different components of the
system. For example, the `TaskManagersHandler` displa
[
https://issues.apache.org/jira/browse/FLINK-7705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-7705:
Assignee: Till Rohrmann (was: Hai Zhou UTC+8)
> Port JobDetailsHandler to new REST endpoin
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4757
Hi @bowenli86, what's the state of this handler? Are you still working on
it?
---
[
https://issues.apache.org/jira/browse/FLINK-7817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann deleted FLINK-7817:
-
> Add TaskManagerDetailsHandler
> -
>
> Key: FLINK-7817
>
[
https://issues.apache.org/jira/browse/FLINK-7793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213948#comment-16213948
]
ASF GitHub Bot commented on FLINK-7793:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7793.
Resolution: Fixed
Fix Version/s: 1.4.0
Fixed via e0b98969ee4cd16b6667a416c0c2ffb60132fb12
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4795
---
[
https://issues.apache.org/jira/browse/FLINK-7800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui reassigned FLINK-7800:
--
Assignee: Xingcan Cui
> Enable window joins without equi-join predicates
>
[
https://issues.apache.org/jira/browse/FLINK-7793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213945#comment-16213945
]
ASF GitHub Bot commented on FLINK-7793:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4795
Failing test cases are unrelated.
---
Ted Yu created FLINK-7897:
-
Summary: Consider using nio.Files for file deletion in
TransientBlobCleanupTask
Key: FLINK-7897
URL: https://issues.apache.org/jira/browse/FLINK-7897
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213937#comment-16213937
]
Till Rohrmann commented on FLINK-7844:
--
[~zhenzhongxu], the akka ask timeout is not i
[
https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213926#comment-16213926
]
ASF GitHub Bot commented on FLINK-7839:
---
Github user mcfongtw commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213927#comment-16213927
]
ASF GitHub Bot commented on FLINK-7839:
---
Github user mcfongtw closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213925#comment-16213925
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user xccui commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213924#comment-16213924
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user xccui commented on a diff in th
Github user mcfongtw commented on the issue:
https://github.com/apache/flink/pull/4848
Thanks!
---
Github user mcfongtw closed the pull request at:
https://github.com/apache/flink/pull/4848
---
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213917#comment-16213917
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user xccui commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213923#comment-16213923
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user xccui commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213918#comment-16213918
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user xccui commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213919#comment-16213919
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user xccui commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213922#comment-16213922
]
ASF GitHub Bot commented on FLINK-6094:
---
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/4471#discussion_r146105057
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/CRowWrappingMultiOuputCollector.scala
---
@@ -0,0 +1,48 @@
+/*
+ *
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4471#discussion_r146104524
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala
---
@@ -0,0 +1,112 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213921#comment-16213921
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user xccui commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213920#comment-16213920
]
ASF GitHub Bot commented on FLINK-6094:
---
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/4471#discussion_r146104452
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,211 @@
+/*
+ * L
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4471#discussion_r146105266
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala
---
@@ -0,0 +1,287 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213916#comment-16213916
]
ASF GitHub Bot commented on FLINK-6094:
---
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/4471#discussion_r146105104
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala
---
@@ -0,0 +1,287 @@
+/*
+ * Licen
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4471#discussion_r146105359
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala
---
@@ -0,0 +1,287 @@
+/*
+ * Licen
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4471#discussion_r146105512
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala
---
@@ -0,0 +1,287 @@
+/*
+ * Licen
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4471#discussion_r146104323
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,211 @@
+/*
+ * L
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4471#discussion_r146104539
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala
---
@@ -0,0 +1,112 @@
+/*
+
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4471#discussion_r146104726
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala
---
@@ -56,16 +58,20 @@ object UpdatingPlanChe
[
https://issues.apache.org/jira/browse/FLINK-7262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-7262.
--
Resolution: Fixed
Fix Version/s: 1.4.0
Fixed via 6c5ecc2f4a0a6888d8c4517bbe050fb2553faf98
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4403
---
[
https://issues.apache.org/jira/browse/FLINK-7262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213829#comment-16213829
]
ASF GitHub Bot commented on FLINK-7262:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213828#comment-16213828
]
ASF GitHub Bot commented on FLINK-7196:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4381
---
[
https://issues.apache.org/jira/browse/FLINK-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-7196.
--
Resolution: Fixed
Fix Version/s: 1.4.0
Fixed via a1d48317964df584c66d2cc9d7f539d31fa3d713
[
https://issues.apache.org/jira/browse/FLINK-7832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213820#comment-16213820
]
ASF GitHub Bot commented on FLINK-7832:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4823
---
[
https://issues.apache.org/jira/browse/FLINK-7832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7832.
Resolution: Done
Added via e7a2f57eec05f47c94339e03865d09943acf5aaf
> SlotManager should return num
[
https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7838:
--
Summary: Kafka011ProducerExactlyOnceITCase do not finish (was: Kafka 0.11
producer exactly-once
[
https://issues.apache.org/jira/browse/FLINK-7896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-7896.
-
Resolution: Duplicate
> Kafka011ProducerExactlyOnceITCase.testExactlyOnceRegularSink does not fini
Till Rohrmann created FLINK-7896:
Summary:
Kafka011ProducerExactlyOnceITCase.testExactlyOnceRegularSink does not finish on
Travis
Key: FLINK-7896
URL: https://issues.apache.org/jira/browse/FLINK-7896
[
https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213795#comment-16213795
]
ASF GitHub Bot commented on FLINK-7839:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4848
Thanks a lot for adding this! ð
I just merged, could you please close this PR if it doesn't close
automatically?
---
[
https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7839.
---
> Creating Quickstart project for SNAPSHOT version fails
> ---
[
https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-7839.
-
Resolution: Fixed
Documentation updated in 8d2b6a8d646db77892bc4f54f4d86b95bbe298ea
> Cre
[
https://issues.apache.org/jira/browse/FLINK-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5968.
---
> Document WindowedStream.aggregate()
> ---
>
> Ke
[
https://issues.apache.org/jira/browse/FLINK-7837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-7837.
-
Resolution: Fixed
Fixed in f176c917d56fa682c047930be9e579b635d7268b
> AggregatingFunction
[
https://issues.apache.org/jira/browse/FLINK-7837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7837.
---
> AggregatingFunction does not work with immutable types
> ---
[
https://issues.apache.org/jira/browse/FLINK-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-5968.
-
Resolution: Done
Documented in 558c71d2e24515515f9c71d98e8176205b5dd854
> Document Window
[
https://issues.apache.org/jira/browse/FLINK-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16213787#comment-16213787
]
ASF GitHub Bot commented on FLINK-5968:
---
Github user aljoscha closed the pull reques
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/4833
---
62 matches
Mail list logo
