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
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?
---
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4795
Failing test cases are unrelated.
---
[
https://issues.apache.org/jira/browse/FLINK-7793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213945#comment-16213945
]
ASF GitHub Bot commented on FLINK-7793:
---
Github user tillrohrmann commented on the issue:
[
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-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213988#comment-16213988
]
ASF GitHub Bot commented on FLINK-7575:
---
Github user tillrohrmann commented on the issue:
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`
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-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213924#comment-16213924
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user xccui commented on a diff in the pull request:
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=16213917#comment-16213917
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user xccui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213923#comment-16213923
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user xccui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213925#comment-16213925
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user xccui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=16213927#comment-16213927
]
ASF GitHub Bot commented on FLINK-7839:
---
Github user mcfongtw closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213937#comment-16213937
]
Till Rohrmann commented on FLINK-7844:
--
[~zhenzhongxu], the akka ask timeout is not important in
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-7793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213948#comment-16213948
]
ASF GitHub Bot commented on FLINK-7793:
---
Github user asfgit closed the pull request at:
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-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
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=16213921#comment-16213921
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user xccui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213918#comment-16213918
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user xccui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213919#comment-16213919
]
ASF GitHub Bot commented on FLINK-6094:
---
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/4471#discussion_r146104452
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,211 @@
+/*
+ *
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213916#comment-16213916
]
ASF GitHub Bot commented on FLINK-6094:
---
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/4471#discussion_r146105104
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/DataStreamInnerJoin.scala
---
@@ -0,0 +1,287 @@
+/*
+ *
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 @@
+/*
+ *
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 @@
+/*
+ *
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
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213920#comment-16213920
]
ASF GitHub Bot commented on FLINK-6094:
---
Github user xccui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213922#comment-16213922
]
ASF GitHub Bot commented on FLINK-6094:
---
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/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_r146104323
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -0,0 +1,211 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213990#comment-16213990
]
ASF GitHub Bot commented on FLINK-7575:
---
Github user tillrohrmann commented on the issue:
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/4833
---
[
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
[
https://issues.apache.org/jira/browse/FLINK-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213787#comment-16213787
]
ASF GitHub Bot commented on FLINK-5968:
---
Github user aljoscha closed the pull request at:
[
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
[
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213795#comment-16213795
]
ASF GitHub Bot commented on FLINK-7839:
---
Github user aljoscha commented on the issue:
[
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
>
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 resolved FLINK-7839.
-
Resolution: Fixed
Documentation updated in 8d2b6a8d646db77892bc4f54f4d86b95bbe298ea
>
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-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213828#comment-16213828
]
ASF GitHub Bot commented on FLINK-7196:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4381
---
[
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()
> ---
>
>
[
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
>
[
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-7832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16213820#comment-16213820
]
ASF GitHub Bot commented on FLINK-7832:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4823
---
[
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
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=16213829#comment-16213829
]
ASF GitHub Bot commented on FLINK-7262:
---
Github user asfgit closed the pull request at:
[
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
62 matches
Mail list logo
