[
https://issues.apache.org/jira/browse/FLINK-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15685987#comment-15685987
]
Fabian Hueske commented on FLINK-5122:
--
Thanks for reporting this issue [~melmoth].
Would be great
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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.
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15685867#comment-15685867
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15685244#comment-15685244
]
Manu Zhang commented on FLINK-5061:
---
I mean users will want to fire before the end of event-time window
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
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15685136#comment-15685136
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15685110#comment-15685110
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15685111#comment-15685111
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a diff in the pull
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
---
@@
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
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 @@
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15685073#comment-15685073
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15685064#comment-15685064
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a diff in the pull
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=15685063#comment-15685063
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15685062#comment-15685062
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a diff in the pull
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
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
[
https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15684988#comment-15684988
]
ASF GitHub Bot commented on FLINK-3921:
---
Github user rekhajoshm commented on the issue:
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
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
[
https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15684865#comment-15684865
]
ASF GitHub Bot commented on FLINK-4900:
---
Github user EronWright commented on the issue:
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
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
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15684617#comment-15684617
]
ASF GitHub Bot commented on FLINK-4832:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15684619#comment-15684619
]
ASF GitHub Bot commented on FLINK-4832:
---
Github user fhueske commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15684616#comment-15684616
]
ASF GitHub Bot commented on FLINK-4832:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15684618#comment-15684618
]
ASF GitHub Bot commented on FLINK-4832:
---
Github user fhueske commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15684615#comment-15684615
]
ASF GitHub Bot commented on FLINK-4832:
---
Github user fhueske commented on a diff in the pull
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
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15684280#comment-15684280
]
Fabian Hueske commented on FLINK-2662:
--
I have a patch for this issue.
Should get into the 1.1.4 (and
[
https://issues.apache.org/jira/browse/FLINK-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15684241#comment-15684241
]
Till Rohrmann commented on FLINK-3516:
--
The test timed out in this instance so that it was terminated
[
https://issues.apache.org/jira/browse/FLINK-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15684180#comment-15684180
]
ASF GitHub Bot commented on FLINK-5085:
---
Github user tillrohrmann commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15684170#comment-15684170
]
ASF GitHub Bot commented on FLINK-5085:
---
Github user StefanRRichter commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15684146#comment-15684146
]
ASF GitHub Bot commented on FLINK-4928:
---
Github user tillrohrmann commented on the issue:
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]
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
[
https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=15684097#comment-15684097
]
ASF GitHub Bot commented on FLINK-5071:
---
Github user asfgit closed the pull request at:
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-4991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=15684046#comment-15684046
]
Anton Mushin commented on FLINK-2435:
-
Hi everyone,
is issue actual?
bq.It would be good to add
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
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
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:
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15684009#comment-15684009
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user greghogan commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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=15683952#comment-15683952
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user vasia commented on a diff in the pull request:
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 @@
+/*
+ *
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15683950#comment-15683950
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user vasia commented on a diff in the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15683938#comment-15683938
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user vasia commented on a diff in the pull request:
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15683927#comment-15683927
]
ASF GitHub Bot commented on FLINK-5085:
---
Github user tillrohrmann commented on the issue:
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 @@
+/*
+ *
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 @@
+/*
+ *
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 @@
+/*
+ *
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 @@
+/*
+ *
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15683914#comment-15683914
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15683917#comment-15683917
]
Aljoscha Krettek commented on FLINK-5061:
-
What do you mean by this? I still think that having
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15683916#comment-15683916
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15683913#comment-15683913
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15683912#comment-15683912
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15683915#comment-15683915
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user greghogan commented on a diff in the pull
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=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=15683873#comment-15683873
]
Yassine Marzougui commented on FLINK-3869:
--
[~aljoscha] Yes, I could fix the Scala API en the end
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
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
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
1 - 100 of 364 matches
Mail list logo
