[
https://issues.apache.org/jira/browse/FLINK-5103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15678795#comment-15678795
]
ASF GitHub Bot commented on FLINK-5103:
---
GitHub user zhuhaifengleon opened a pull re
GitHub user zhuhaifengleon opened a pull request:
https://github.com/apache/flink/pull/2833
[FLINK-5103] [Metrics] TaskManager process virtual memory and physical
memory used size gauge
This PR add TaskManger process virtual memory and physical memory used size
gauge metrics.
You
[
https://issues.apache.org/jira/browse/FLINK-5103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhuhaifeng updated FLINK-5103:
--
Summary: TaskManager process virtual memory and physical memory used size
gauge (was: Process virtual m
[
https://issues.apache.org/jira/browse/FLINK-5103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhuhaifeng updated FLINK-5103:
--
Component/s: Metrics
> TaskManager process virtual memory and physical memory used size gauge
>
zhuhaifeng created FLINK-5103:
-
Summary: Process virtual memory and physical memory used size gauge
Key: FLINK-5103
URL: https://issues.apache.org/jira/browse/FLINK-5103
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15678716#comment-15678716
]
Renkai Ge edited comment on FLINK-5031 at 11/19/16 6:29 AM:
[~
[
https://issues.apache.org/jira/browse/FLINK-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15678716#comment-15678716
]
Renkai Ge commented on FLINK-5031:
--
[~fhueske]The second split was not ignored, it was un
[
https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-5053:
--
Description:
There is currently basically no difference between savepoints and checkpoints
in F
Ufuk Celebi created FLINK-5102:
--
Summary: Connection establishment does not react to interrupt
Key: FLINK-5102
URL: https://issues.apache.org/jira/browse/FLINK-5102
Project: Flink
Issue Type: Bu
[
https://issues.apache.org/jira/browse/FLINK-4288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677737#comment-15677737
]
ASF GitHub Bot commented on FLINK-4288:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2511#discussion_r88737982
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/TableEnvironment.scala
---
@@ -133,12 +134,24 @@ abstract class TableEnvironm
[
https://issues.apache.org/jira/browse/FLINK-4288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677735#comment-15677735
]
ASF GitHub Bot commented on FLINK-4288:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677736#comment-15677736
]
ASF GitHub Bot commented on FLINK-4288:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2511#discussion_r88737974
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/TableEnvironment.scala
---
@@ -133,12 +134,24 @@ abstract class TableEnvironm
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2511#discussion_r88737674
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/FlinkSchema.scala
---
@@ -0,0 +1,57 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677686#comment-15677686
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677690#comment-15677690
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677684#comment-15677684
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677687#comment-15677687
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677688#comment-15677688
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677685#comment-15677685
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677689#comment-15677689
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677691#comment-15677691
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2319#discussion_r88679280
--- Diff: docs/dev/table_api.md ---
@@ -1656,6 +1656,29 @@ temporalOverlaps(TIMEPOINT, TEMPORAL, TIMEPOINT,
TEMPORAL)
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2319#discussion_r88684517
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/composite.scala
---
@@ -0,0 +1,88 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2319#discussion_r88679626
--- Diff: docs/dev/table_api.md ---
@@ -1656,6 +1656,29 @@ temporalOverlaps(TIMEPOINT, TEMPORAL, TIMEPOINT,
TEMPORAL)
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2319#discussion_r88683102
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/composite.scala
---
@@ -0,0 +1,88 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2319#discussion_r88699109
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/RexNodeTranslator.scala
---
@@ -74,15 +75,52 @@ object RexNodeTranslator
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2319#discussion_r88682935
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/ExpressionParser.scala
---
@@ -324,10 +335,19 @@ object Expressio
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2319#discussion_r88682137
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/FlinkTypeFactory.scala
---
@@ -79,14 +83,27 @@ class FlinkTypeFactory(typeSys
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2319#discussion_r88699648
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/composite.scala
---
@@ -0,0 +1,88 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677519#comment-15677519
]
Malte Schwarzer commented on FLINK-1914:
I'm having the same issue with Flink 1.1.
[
https://issues.apache.org/jira/browse/FLINK-5101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-5101:
---
Assignee: Chesnay Schepler
> Test CassandraConnectorITCase instable
> ---
[
https://issues.apache.org/jira/browse/FLINK-4936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677434#comment-15677434
]
ASF GitHub Bot commented on FLINK-4936:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2832
[FLINK-4936] [gelly] Operator names for Gelly inputs
Provide descriptive operator names for Graph and GraphCsvReader.
Condense multiple type conversion maps into a single mapper.
Reuse obje
[
https://issues.apache.org/jira/browse/FLINK-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677332#comment-15677332
]
Stephan Ewen commented on FLINK-5002:
-
The link is referring to opening a pull request
Stefan Richter created FLINK-5101:
-
Summary: Test CassandraConnectorITCase instable
Key: FLINK-5101
URL: https://issues.apache.org/jira/browse/FLINK-5101
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-5100:
-
Summary: Test testZooKeeperReelection is instable
Key: FLINK-5100
URL: https://issues.apache.org/jira/browse/FLINK-5100
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-5099:
-
Summary: Test testCancelPartitionRequest is instable
Key: FLINK-5099
URL: https://issues.apache.org/jira/browse/FLINK-5099
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677048#comment-15677048
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user LordFB commented on the issue:
Github user LordFB commented on the issue:
https://github.com/apache/flink/pull/2367
Hi @mushketyk,
too bad, with this missing it is kind of a gamebreaker for Flink in my Use
Case.
Jeah, that'd be great, if Till would show some action on this and the
related PRs.
-
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15677009#comment-15677009
]
Philipp von dem Bussche commented on FLINK-2821:
[~StephanEwen] I am not q
[
https://issues.apache.org/jira/browse/FLINK-4679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676958#comment-15676958
]
Fabian Hueske commented on FLINK-4679:
--
Hi [~jark], I think this approach could work
[
https://issues.apache.org/jira/browse/FLINK-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paris Carbone updated FLINK-2390:
-
Assignee: (was: Paris Carbone)
> Replace iteration timeout with algorithm for detecting termin
[
https://issues.apache.org/jira/browse/FLINK-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paris Carbone reassigned FLINK-2390:
Assignee: Paris Carbone
> Replace iteration timeout with algorithm for detecting terminatio
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676845#comment-15676845
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676846#comment-15676846
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676839#comment-15676839
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676838#comment-15676838
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676844#comment-15676844
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676842#comment-15676842
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676848#comment-15676848
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676847#comment-15676847
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676840#comment-15676840
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676843#comment-15676843
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676841#comment-15676841
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88641722
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/IncrementalAggregateReduceFunction.scala
---
@@ -0,0 +1,69
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88657597
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/DataStreamAggregate.scala
---
@@ -135,50 +128,123 @@ cl
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88638112
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/IncrementalAggregateReduceFunction.scala
---
@@ -0,0 +1,69
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88659144
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/DataStreamAggregate.scala
---
@@ -135,50 +128,123 @@ cl
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88633784
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateMapFunction.scala
---
@@ -30,9 +30,9 @@ class Aggr
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88635921
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateAllTimeWindowFunction.scala
---
@@ -48,6 +48,6 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88653721
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/IncrementalAggregateReduceFunction.scala
---
@@ -0,0 +1,69
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88658743
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/DataStreamAggregate.scala
---
@@ -231,6 +297,64 @@ obje
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88637570
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/IncrementalAggregateTimeWindowFunction.scala
---
@@ -0,0 +1
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88659308
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/DataStreamAggregate.scala
---
@@ -135,50 +128,123 @@ cl
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88636193
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateTimeWindowFunction.scala
---
@@ -52,6 +52,6 @@ cla
[
https://issues.apache.org/jira/browse/FLINK-5010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676830#comment-15676830
]
ASF GitHub Bot commented on FLINK-5010:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2831
[FLINK-5010] [akka] Introduce default configuration values for Akka's
deathwatch
Set the akka deathwatch interval to 10s, the akka deathwatch pause to 60s
and the tcp
connection timeout to
[
https://issues.apache.org/jira/browse/FLINK-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676805#comment-15676805
]
Roman Maier commented on FLINK-5002:
Please check the implementation of this issue:
ht
[
https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-4591.
--
Resolution: Won't Fix
> Select star does not work with grouping
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-5094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676772#comment-15676772
]
Fabian Hueske commented on FLINK-5094:
--
Yes, the incremental aggregation functions ar
[
https://issues.apache.org/jira/browse/FLINK-5094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676759#comment-15676759
]
Jark Wu commented on FLINK-5094:
Hi [~fhueske], this may need to modify the implementation
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2830
[FLINK-5098] [akka] Detect unreachable remote actors to fail ask calls
eagerly
This PR adds to every sent ask message an additional Identify message which
is used to
detect whether the tar
[
https://issues.apache.org/jira/browse/FLINK-5098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676758#comment-15676758
]
ASF GitHub Bot commented on FLINK-5098:
---
GitHub user tillrohrmann opened a pull requ
Till Rohrmann created FLINK-5098:
Summary: Detect network problems to eagerly time out ask operations
Key: FLINK-5098
URL: https://issues.apache.org/jira/browse/FLINK-5098
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676714#comment-15676714
]
Fabian Hueske commented on FLINK-3617:
--
Don't know. [~jgrier] who reported the issue
[
https://issues.apache.org/jira/browse/FLINK-4679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676708#comment-15676708
]
Jark Wu commented on FLINK-4679:
Hi [~fhueske] [~twalthr], if I understand correctly, the
Vasia Kalavri created FLINK-5097:
Summary: The TypeExtractor is missing input type information in
some Graph methods
Key: FLINK-5097
URL: https://issues.apache.org/jira/browse/FLINK-5097
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676696#comment-15676696
]
Stephan Ewen commented on FLINK-3617:
-
How pressing is that? Is it a serious problem t
[
https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676692#comment-15676692
]
Stephan Ewen commented on FLINK-5090:
-
I have added min/max/avg across the channels fo
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676689#comment-15676689
]
Stephan Ewen commented on FLINK-2821:
-
Concerning HA setups: Publishing the JobManager
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676678#comment-15676678
]
Stephan Ewen commented on FLINK-2821:
-
+1 for getting rid of {{jobmanager.rpc.bind-add
Kostas Kloudas created FLINK-5096:
-
Summary: Make the RollingSink rescalable.
Key: FLINK-5096
URL: https://issues.apache.org/jira/browse/FLINK-5096
Project: Flink
Issue Type: Improvement
Chesnay Schepler created FLINK-5095:
---
Summary: Add explicit notifyOfAddedX methods to MetricReporter
interface
Key: FLINK-5095
URL: https://issues.apache.org/jira/browse/FLINK-5095
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5095:
Priority: Minor (was: Major)
> Add explicit notifyOfAddedX methods to MetricReporter interf
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/2829
I don't expect this to change any behaviour as clearing the serializer
twice does actually not hurt and is only some waste of resources so FLINK-4719
should not be affected at all
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-4719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676660#comment-15676660
]
ASF GitHub Bot commented on FLINK-4719:
---
Github user NicoK commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676633#comment-15676633
]
ASF GitHub Bot commented on FLINK-4719:
---
Github user fpompermaier commented on the i
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2829
Could you modify the PR title to something more descriptive?
---
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 ha
Github user fpompermaier commented on the issue:
https://github.com/apache/flink/pull/2829
Could this be a possible fix for FLINK-4719?
---
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 fe
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/2829#discussion_r88649470
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpanningRecordSerializer.java
---
@@ -151,6 +176,15 @@ private Seri
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2829#discussion_r88649329
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpanningRecordSerializer.java
---
@@ -151,6 +176,15 @@ private Ser
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/2829
Hotfix 2016 11 18
Prevent RecordWriter#flush() to clear the serializer twice.
Also add some documentation to RecordWriter, RecordSerializer and
SpanningRecordSerializer.
You can merge this pull r
[
https://issues.apache.org/jira/browse/FLINK-5094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5094:
-
Description:
Support {{RichReduceFunction}} and {{RichFoldFunction}} as incremental window
aggreg
Fabian Hueske created FLINK-5094:
Summary: Support RichReduceFunction and RichFoldFunction as
incremental window aggregation functions
Key: FLINK-5094
URL: https://issues.apache.org/jira/browse/FLINK-5094
[
https://issues.apache.org/jira/browse/FLINK-5094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5094:
-
Component/s: Streaming
> Support RichReduceFunction and RichFoldFunction as incremental window
>
[
https://issues.apache.org/jira/browse/FLINK-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676468#comment-15676468
]
ASF GitHub Bot commented on FLINK-2609:
---
Github user zentol closed the pull request
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/1833
---
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 wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-5054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-5054.
---
Resolution: Fixed
Fixed in 13ebb36bb6c7fbe591d9e7834a2fc34d8469bc00
> Make the BucketingSink
1 - 100 of 154 matches
Mail list logo
