[
https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15691503#comment-15691503
]
ASF GitHub Bot commented on FLINK-4997:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-5146:
--
Priority: Blocker (was: Major)
> Improved resource cleanup in RocksDB keyed state backend
>
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r89424283
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollector.java
---
@@ -0,0 +1,103 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15691892#comment-15691892
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a diff in the pull
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2756
The changes look very good! ð
I'll rebase on top of the recent changes that introduced new
`fold()`/`reduce()` and will also reshuffle/squash the commits a bit to make
the history
[
https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15691610#comment-15691610
]
Ivan Mushketyk commented on FLINK-1536:
---
Oh, sorry, I didn't mean to type "bipartiate" word there :)
[
https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15691610#comment-15691610
]
Ivan Mushketyk edited comment on FLINK-1536 at 11/23/16 11:11 PM:
--
Oh,
[
https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15691858#comment-15691858
]
Liang Chen commented on FLINK-2646:
---
Please go ahead, thanks.
Sorry, i am a little busy recently.
>
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/commit/da53953e5366185567515d209fcc85d4006f7e8a#commitcomment-19948322
In
flink-core/src/main/java/org/apache/flink/api/common/state/FoldingStateDescriptor.java:
In
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15692081#comment-15692081
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5000.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Implemented in
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15692468#comment-15692468
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user AlexanderShoshin commented on the issue:
Github user AlexanderShoshin commented on the issue:
https://github.com/apache/flink/pull/2811
Hi, Fabian.
I've made all the corrections. One thing I didn't understand - are we going
to allow the case of !joinCondition.isEqui in DataSetSingleRowCrossRule?
I also
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r89431529
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java
---
@@ -0,0 +1,453 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-2608.
-
Resolution: Fixed
Had to unarchive the 1.0.0 version temporarily because this had been
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2836#discussion_r89282258
--- Diff: pom.xml ---
@@ -93,7 +93,7 @@ under the License.
1C
true
log4j-test.properties
- -Xms256m
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2836#discussion_r89284243
--- Diff: flink-streaming-connectors/flink-connector-kafka-0.10/pom.xml ---
@@ -197,9 +196,7 @@ under the License.
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2836#discussion_r89282667
--- Diff: pom.xml ---
@@ -996,10 +996,9 @@ under the License.
${flink.reuseForks}
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2836#discussion_r89284270
--- Diff: flink-streaming-connectors/flink-connector-cassandra/pom.xml ---
@@ -50,9 +49,7 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689549#comment-15689549
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-2608:
--
Fix Version/s: (was: 1.0.0)
> Arrays.asList(..) does not work with
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689614#comment-15689614
]
ASF GitHub Bot commented on FLINK-5092:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689615#comment-15689615
]
ASF GitHub Bot commented on FLINK-5092:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689612#comment-15689612
]
ASF GitHub Bot commented on FLINK-5092:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689613#comment-15689613
]
ASF GitHub Bot commented on FLINK-5092:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689611#comment-15689611
]
ASF GitHub Bot commented on FLINK-5092:
---
Github user mxm commented on a diff in the pull request:
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r89289895
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java
---
@@ -0,0 +1,453 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689709#comment-15689709
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689706#comment-15689706
]
Kostas Kloudas commented on FLINK-2646:
---
Can I take the issue? It seems inactive for the last year
[
https://issues.apache.org/jira/browse/FLINK-5143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689734#comment-15689734
]
ASF GitHub Bot commented on FLINK-5143:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/2853
[FLINK-5143] [table] Add EXISTS to list of supported operators
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2854
[typo] fix toString() of ContinuousEventTimeTrigger
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/flink master
Alternatively you can review
[
https://issues.apache.org/jira/browse/FLINK-4686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689841#comment-15689841
]
ASF GitHub Bot commented on FLINK-4686:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2553
Thanks @wuchong. I think we can convert the modified ITCases to
TableTestBase tests. I will try it and merge this.
---
If your project is set up for it, you can reply to this email and have your
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2851
---
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-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689530#comment-15689530
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user mxm commented on the issue:
Frank Lauterwald created FLINK-5142:
---
Summary: Resource leak in CheckpointCoordinator
Key: FLINK-5142
URL: https://issues.apache.org/jira/browse/FLINK-5142
Project: Flink
Issue Type: Bug
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2623
Thank 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 this feature
enabled and wishes so, or if the
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689629#comment-15689629
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689638#comment-15689638
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r89283859
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689634#comment-15689634
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r89283319
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/SimpleConsumerThread.java
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r89276062
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689633#comment-15689633
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689632#comment-15689632
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689635#comment-15689635
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689636#comment-15689636
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689640#comment-15689640
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689641#comment-15689641
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r89275211
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/SimpleConsumerThread.java
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r89282863
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/Kafka08Fetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689642#comment-15689642
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689631#comment-15689631
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689639#comment-15689639
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r89275454
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
---
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689637#comment-15689637
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689630#comment-15689630
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r89284541
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-4712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689765#comment-15689765
]
ASF GitHub Bot commented on FLINK-4712:
---
Github user thvasilo commented on the issue:
Github user thvasilo commented on the issue:
https://github.com/apache/flink/pull/2838
Hello Gabor,
I like the idea of having a RankingScore, it seems like having that
hierarchy with Score, RankingScore and PairWiseScore gives us the flexibility
we need to include ranking
[
https://issues.apache.org/jira/browse/FLINK-4941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4941:
--
Fix Version/s: 1.2.0
> Show ship strategy in web interface
>
[
https://issues.apache.org/jira/browse/FLINK-4941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689818#comment-15689818
]
Robert Metzger commented on FLINK-4941:
---
This has been fixed for 1.2 in
[
https://issues.apache.org/jira/browse/FLINK-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689835#comment-15689835
]
ASF GitHub Bot commented on FLINK-5075:
---
Github user StephanEwen commented on the issue:
Github user ex00 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2840#discussion_r89277461
--- 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-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reopened FLINK-2608:
---
> Arrays.asList(..) does not work with CollectionInputFormat
>
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2855
Add Tests in StateBackendTestBase that verify Default-Value Behaviour
The tests were not checking whether all backends exhibit the same behaviour
when it comes to default values. This changes none
[
https://issues.apache.org/jira/browse/FLINK-5126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689800#comment-15689800
]
Stephan Ewen commented on FLINK-5126:
-
Not sure about that. They were added there for a purpose.
Why
[
https://issues.apache.org/jira/browse/FLINK-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5105:
-
Issue Type: Improvement (was: Bug)
> Improve ReduceState: value put into ReducingState should
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2623
---
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 bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r89291235
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java
---
@@ -0,0 +1,453 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689724#comment-15689724
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689779#comment-15689779
]
Stephan Ewen commented on FLINK-2646:
-
[~kkl0u] Please go ahead!
> Rich functions should provide a
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2854
+1, merging.
---
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-5142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689792#comment-15689792
]
Stephan Ewen commented on FLINK-5142:
-
Thanks for reporting and diagnosing that.
I'll have a look at
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2768
@shixiaogang Thanks for the swift update! The changes look very good now
though I found one last thing that could be problematic. This is changing the
behaviour of `FoldingState` when it comes to
[
https://issues.apache.org/jira/browse/FLINK-5142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-5142:
---
Assignee: Stephan Ewen
> Resource leak in CheckpointCoordinator
>
[
https://issues.apache.org/jira/browse/FLINK-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689796#comment-15689796
]
Stephan Ewen commented on FLINK-5128:
-
Sounds like a good idea, +1
> Get Kafka partitions in
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689795#comment-15689795
]
ASF GitHub Bot commented on FLINK-5023:
---
Github user aljoscha commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2822
Makes sense.
+1 to this!
---
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
[
https://issues.apache.org/jira/browse/FLINK-5124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-5124.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 4653ad388b05b3ba7e37982bb8af09e7fcbed6be.
[
https://issues.apache.org/jira/browse/FLINK-5124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689458#comment-15689458
]
ASF GitHub Bot commented on FLINK-5124:
---
Github user asfgit closed the pull request at:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r89283731
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/JobClient.java ---
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689661#comment-15689661
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689751#comment-15689751
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a diff in the pull
Github user thvasilo commented on the issue:
https://github.com/apache/flink/pull/2819
Hello @gaborhermann,
I really like the idea of introducing a `MatrixFactorization` interface
that we can then use for different specialized optimization algorithms. For the
question I'm
Timo Walther created FLINK-5144:
---
Summary: Error while applying rule AggregateJoinTransposeRule
Key: FLINK-5144
URL: https://issues.apache.org/jira/browse/FLINK-5144
Project: Flink
Issue Type:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2623
@mxm @chermenin Can we please do a followup to this, given that it is
already merged?
The tests in `GroupReduceITCase` need to be replaced by proper targeted
unit tests.
Sorry
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689820#comment-15689820
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689598#comment-15689598
]
ASF GitHub Bot commented on FLINK-4272:
---
Github user tillrohrmann commented on a diff in the pull
Timo Walther created FLINK-5143:
---
Summary: Add EXISTS to list of supported operators
Key: FLINK-5143
URL: https://issues.apache.org/jira/browse/FLINK-5143
Project: Flink
Issue Type: Bug
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r89275697
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
---
@@
Github user BorisOsipov commented on the issue:
https://github.com/apache/flink/pull/2836
@mxm Thank you for review. I ran into some issues with collecting coverage
data.
I am going to do additional tests and come back to you.
---
If your project is set up for it, you can reply
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r89284524
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r89274682
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
---
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r89276937
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010Fetcher.java
---
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r89274555
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010ITCase.java
---
@@ -131,6
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15689628#comment-15689628
]
ASF GitHub Bot commented on FLINK-5092:
---
Github user BorisOsipov commented on the issue:
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r89150327
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka010FetcherTest.java
---
@@
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r89275431
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09ITCase.java
---
@@ -110,6
1 - 100 of 320 matches
Mail list logo
