[
https://issues.apache.org/jira/browse/FLINK-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15685987#comment-15685987
]
Fabian Hueske commented on FLINK-5122:
--
Thanks for reporting this issue [~melmoth].
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15685955#comment-15685955
]
ASF GitHub Bot commented on FLINK-2662:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/2848
[FLINK-2662] [optimizer] Fix computation of global properties of union
operator.
Fix computation of global properties of union operator.
This solves the problem of invalid shipping strategy betw
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/2792
Hi,@fhueske thanks a lot for the review. I have updated the PR according
to your comments. The change list:
1. Amend code styleï¼Including Class / Object / Trait / Methodï¼
2. Refa
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15685867#comment-15685867
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on the
[
https://issues.apache.org/jira/browse/FLINK-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15685826#comment-15685826
]
ASF GitHub Bot commented on FLINK-5031:
---
GitHub user Renkai opened a pull request:
GitHub user Renkai opened a pull request:
https://github.com/apache/flink/pull/2847
[FLINK-5031]Consecutive DataStream.split() ignored
I think this is a way to solve this issue, but might not be the best
one.Since I'm knowing the code base enough, I hope someone may review it and
g
[
https://issues.apache.org/jira/browse/FLINK-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15685244#comment-15685244
]
Manu Zhang commented on FLINK-5061:
---
I mean users will want to fire before the end of ev
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89015695
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/IncrementalAggregateReduceFunction.scala
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15685136#comment-15685136
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15685110#comment-15685110
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15685111#comment-15685111
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89014267
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/IncrementalAggregateReduceFunction.scala
---
@@ -0,0
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89014242
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateTimeWindowFunction.scala
---
@@ -52,6 +52,6
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89012878
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateMapFunction.scala
---
@@ -30,9 +30,9 @@ cla
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15685073#comment-15685073
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15685064#comment-15685064
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89012187
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/DataStreamAggregate.scala
---
@@ -231,6 +297,64
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15685062#comment-15685062
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15685063#comment-15685063
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89012143
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/DataStreamAggregate.scala
---
@@ -135,50 +128,12
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89012102
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/DataStreamAggregate.scala
---
@@ -135,50 +128,12
[
https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684988#comment-15684988
]
ASF GitHub Bot commented on FLINK-3921:
---
Github user rekhajoshm commented on the iss
Github user rekhajoshm commented on the issue:
https://github.com/apache/flink/pull/2060
Agree @greghogan , we started this just for StringParser encoding :-)
I am in tight schedule, however did a quick update for comments, please
have a look.thank you.
- Removed unused me
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/2703
@mxm LGTM
---
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 th
[
https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684865#comment-15684865
]
ASF GitHub Bot commented on FLINK-4900:
---
Github user EronWright commented on the iss
static-max created FLINK-5122:
-
Summary: Elasticsearch Sink loses documents when cluster has high
load
Key: FLINK-5122
URL: https://issues.apache.org/jira/browse/FLINK-5122
Project: Flink
Issue
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2841
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2834
---
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-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684650#comment-15684650
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2319
+1 to merge
---
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
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2840#discussion_r88978610
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetAggregate.scala
---
@@ -157,4 +161,41 @@ class Data
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684617#comment-15684617
]
ASF GitHub Bot commented on FLINK-4832:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684619#comment-15684619
]
ASF GitHub Bot commented on FLINK-4832:
---
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/2840#discussion_r88979272
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetAggregate.scala
---
@@ -133,7 +137,7 @@ class DataS
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684618#comment-15684618
]
ASF GitHub Bot commented on FLINK-4832:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684616#comment-15684616
]
ASF GitHub Bot commented on FLINK-4832:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684615#comment-15684615
]
ASF GitHub Bot commented on FLINK-4832:
---
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/2840#discussion_r88979147
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/AggregationsITCase.scala
---
@@ -400,5 +400,36 @@ class Aggregati
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2840#discussion_r88978720
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/sql/AggregationsITCase.scala
---
@@ -258,4 +258,42 @@ class Aggregation
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2840#discussion_r88977919
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetAggregate.scala
---
@@ -157,4 +161,41 @@ class Data
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2841
Thanks for the fix.
+1 to merge
---
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
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2834
Thanks for the fixes @mindprince!
+1 to merge
---
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 f
[
https://issues.apache.org/jira/browse/FLINK-5001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-5001.
---
Resolution: Won't Fix
Closing as "Won't fix" since this is an issue of Kafka.
> Ensure that t
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684280#comment-15684280
]
Fabian Hueske commented on FLINK-2662:
--
I have a patch for this issue.
Should get int
[
https://issues.apache.org/jira/browse/FLINK-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684241#comment-15684241
]
Till Rohrmann commented on FLINK-3516:
--
The test timed out in this instance so that i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2826
Thanks for the review @StefanRRichter. Once Travis gives green light, I'll
merge the PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
[
https://issues.apache.org/jira/browse/FLINK-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684180#comment-15684180
]
ASF GitHub Bot commented on FLINK-5085:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684170#comment-15684170
]
ASF GitHub Bot commented on FLINK-5085:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2826
+1 LGTM
---
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
[
https://issues.apache.org/jira/browse/FLINK-5113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5113:
Summary: Make all Testing Functions implement CheckpointedFunction
Interface. (was: Make al
[
https://issues.apache.org/jira/browse/FLINK-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684146#comment-15684146
]
ASF GitHub Bot commented on FLINK-4928:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2744
Hi @shuai-xu, thanks for your contribution. Unfortunately, the PR does not
compile correctly:
```
[INFO] -
[ERROR] COMPILAT
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2319
@fhueske I reworked the PR again. I will rebase it now.
---
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 t
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684123#comment-15684123
]
ASF GitHub Bot commented on FLINK-4294:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684097#comment-15684097
]
ASF GitHub Bot commented on FLINK-5071:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2839
---
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-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-5071.
---
Resolution: Fixed
Fixed via 5836f7eddb4849b95d4860cf20045bc61d061918 on the master bra
[
https://issues.apache.org/jira/browse/FLINK-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-5071:
--
Affects Version/s: (was: 1.1.4)
> YARN: yarn.containers.vcores config not respected
[
https://issues.apache.org/jira/browse/FLINK-5071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-5071:
--
Fix Version/s: (was: 1.1.4)
> YARN: yarn.containers.vcores config not respected when
[
https://issues.apache.org/jira/browse/FLINK-4991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684031#comment-15684031
]
ASF GitHub Bot commented on FLINK-4991:
---
Github user uce closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684046#comment-15684046
]
Anton Mushin commented on FLINK-2435:
-
Hi everyone,
is issue actual?
bq.It would be go
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2842
Thanks! Let me look into these and I'll get back to you.
---
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 th
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684040#comment-15684040
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user vasia commented on the issue:
Github user uce closed the pull request at:
https://github.com/apache/flink/pull/2739
---
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 enabled
[
https://issues.apache.org/jira/browse/FLINK-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-5118:
---
Assignee: Chesnay Schepler
> Inconsistent records sent/received metrics
> ---
Ufuk Celebi created FLINK-5121:
--
Summary: Integrate YARN application ID with web interface
Key: FLINK-5121
URL: https://issues.apache.org/jira/browse/FLINK-5121
Project: Flink
Issue Type: Improv
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15684009#comment-15684009
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2842
I count nine uses of `TypeExtractor.createTypeInfo` in `Graph` and one each
in `ScatterGatherIteration`, `VertexCentricIteration`, and
`GatherSumApplyIteration`. The latter still need to allow for
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2842
@greghogan if the input types are known, we should pass them, yes. What
other cases did you find?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683964#comment-15683964
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user vasia commented on the issue:
Ufuk Celebi created FLINK-5120:
--
Summary: Show TM PID in web frontend
Key: FLINK-5120
URL: https://issues.apache.org/jira/browse/FLINK-5120
Project: Flink
Issue Type: Improvement
Compo
Ufuk Celebi created FLINK-5119:
--
Summary: Last taskmanager heartbeat not showing in web frontend
Key: FLINK-5119
URL: https://issues.apache.org/jira/browse/FLINK-5119
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683952#comment-15683952
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user vasia commented on a diff in th
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2842#discussion_r88926689
--- Diff:
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/TypeExtractorTest.java
---
@@ -0,0 +1,106 @@
+/*
+ * License
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2842#discussion_r88926534
--- Diff:
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/TypeExtractorTest.java
---
@@ -0,0 +1,106 @@
+/*
+ * License
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683950#comment-15683950
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user vasia commented on a diff in th
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2826
Review @StefanRRichter
---
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 wis
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683938#comment-15683938
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user vasia commented on a diff in th
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2842#discussion_r88925478
--- Diff:
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/TypeExtractorTest.java
---
@@ -0,0 +1,106 @@
+/*
+ * License
[
https://issues.apache.org/jira/browse/FLINK-4898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683935#comment-15683935
]
ASF GitHub Bot commented on FLINK-4898:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2766
Thanks for the PR, @EronWright. I think @uce is most familiar with the
network layer. Just wondering from a first quick look, if the code removes
duplicate implementation of network components by providi
[
https://issues.apache.org/jira/browse/FLINK-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683927#comment-15683927
]
ASF GitHub Bot commented on FLINK-5085:
---
Github user tillrohrmann commented on the i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2842#discussion_r88920404
--- Diff:
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/TypeExtractorTest.java
---
@@ -0,0 +1,106 @@
+/*
+ * Lic
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2842#discussion_r88919069
--- Diff:
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/TypeExtractorTest.java
---
@@ -0,0 +1,106 @@
+/*
+ * Lic
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2842#discussion_r88914659
--- Diff:
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/TypeExtractorTest.java
---
@@ -0,0 +1,106 @@
+/*
+ * Lic
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2842#discussion_r88919762
--- Diff:
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/TypeExtractorTest.java
---
@@ -0,0 +1,106 @@
+/*
+ * Lic
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2842#discussion_r88921327
--- Diff:
flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/TypeExtractorTest.java
---
@@ -0,0 +1,106 @@
+/*
+ * Lic
[
https://issues.apache.org/jira/browse/FLINK-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683917#comment-15683917
]
Aljoscha Krettek commented on FLINK-5061:
-
What do you mean by this? I still thin
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683914#comment-15683914
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683913#comment-15683913
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683912#comment-15683912
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683916#comment-15683916
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683915#comment-15683915
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user greghogan commented on a diff i
Ufuk Celebi created FLINK-5118:
--
Summary: Inconsistent records sent/received metrics
Key: FLINK-5118
URL: https://issues.apache.org/jira/browse/FLINK-5118
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683873#comment-15683873
]
Yassine Marzougui edited comment on FLINK-3869 at 11/21/16 3:35 PM:
[
https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683873#comment-15683873
]
Yassine Marzougui commented on FLINK-3869:
--
[~aljoscha] Yes, I could fix the Scal
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2845#discussion_r88917513
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/RollingSinkITCase.java
---
@@ -638,6 +6
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2845#discussion_r88910876
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/RollingSinkITCase.java
---
@@ -638,6 +6
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2845#discussion_r88909481
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/RollingSinkITCase.java
---
@@ -638,6 +6
1 - 100 of 366 matches
Mail list logo
