Biao Liu created FLINK-5141:
---
Summary: Implement MiniClusterStreamEnvironment to run new mini
cluster in flip-6 branch
Key: FLINK-5141
URL: https://issues.apache.org/jira/browse/FLINK-5141
Project: Flink
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 enab
[
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&focusedCommentId=15689458#comment-15689458
]
ASF GitHub Bot commented on FLINK-5124:
---
Github user asfgit closed the pull request
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 DataSet
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689481#comment-15689481
]
ASF GitHub Bot commented on FLINK-4832:
---
Github user ex00 commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-5105:
Assignee: Fabian Hueske
> Improve ReduceState: value put into ReducingState should always b
[
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 alw
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 feat
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
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689530#comment-15689530
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user mxm commented on the issue:
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 enab
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689549#comment-15689549
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-2608.
-
Resolution: Fixed
Assignee: Alexander Chermenin
Fix Version/s: 1.2.0
Fixed
[
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
> ---
[
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 CollectionInputFo
[
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 tag
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 Founda
[
https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689598#comment-15689598
]
ASF GitHub Bot commented on FLINK-4272:
---
Github user tillrohrmann commented on a dif
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 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.
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}
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689613#comment-15689613
]
ASF GitHub Bot commented on FLINK-5092:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689611#comment-15689611
]
ASF GitHub Bot commented on FLINK-5092:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689615#comment-15689615
]
ASF GitHub Bot commented on FLINK-5092:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689612#comment-15689612
]
ASF GitHub Bot commented on FLINK-5092:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689614#comment-15689614
]
ASF GitHub Bot commented on FLINK-5092:
---
Github user mxm commented on a diff in the
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 t
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
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
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689628#comment-15689628
]
ASF GitHub Bot commented on FLINK-5092:
---
Github user BorisOsipov commented on the is
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
---
@@ -2
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
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689641#comment-15689641
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
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&focusedCommentId=15689631#comment-15689631
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689639#comment-15689639
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689629#comment-15689629
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689638#comment-15689638
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
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&focusedCommentId=15689634#comment-15689634
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
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&focusedCommentId=15689633#comment-15689633
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
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-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689642#comment-15689642
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689632#comment-15689632
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689635#comment-15689635
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689636#comment-15689636
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689640#comment-15689640
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
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&focusedCommentId=15689637#comment-15689637
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689630#comment-15689630
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689647#comment-15689647
]
ASF GitHub Bot commented on FLINK-3123:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2687
I'll review this PR once https://github.com/apache/flink/pull/2509 has been
merged.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. I
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2836#discussion_r89284152
--- Diff: flink-streaming-connectors/flink-connector-kafka-0.9/pom.xml ---
@@ -193,9 +192,7 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689661#comment-15689661
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a dif
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r89285857
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollector.java
---
@@ -0,0 +1,103 @@
+/*
+ * Li
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r89289557
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollector.java
---
@@ -0,0 +1,103 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689702#comment-15689702
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user tillrohrmann commented on a dif
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-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689706#comment-15689706
]
Kostas Kloudas commented on FLINK-2646:
---
Can I take the issue? It seems inactive for
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689709#comment-15689709
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a dif
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2852
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 the feat
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&focusedCommentId=15689724#comment-15689724
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a dif
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.
[
https://issues.apache.org/jira/browse/FLINK-5143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689734#comment-15689734
]
ASF GitHub Bot commented on FLINK-5143:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689747#comment-15689747
]
ASF GitHub Bot commented on FLINK-4712:
---
Github user thvasilo commented on a diff in
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/2838#discussion_r89292988
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/pipeline/Predictor.scala
---
@@ -72,14 +77,142 @@ trait Predictor[Self] extends Estima
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r89293393
--- 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&focusedCommentId=15689751#comment-15689751
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 an
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 a
[
https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689779#comment-15689779
]
Stephan Ewen commented on FLINK-2646:
-
[~kkl0u] Please go ahead!
> Rich functions sho
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 the
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689781#comment-15689781
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a dif
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r89294937
--- 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-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-5142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689792#comment-15689792
]
Stephan Ewen commented on FLINK-5142:
-
Thanks for reporting and diagnosing that.
I'll
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 th
[
https://issues.apache.org/jira/browse/FLINK-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689796#comment-15689796
]
Stephan Ewen commented on FLINK-5128:
-
Sounds like a good idea, +1
> Get Kafka partit
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689795#comment-15689795
]
ASF GitHub Bot commented on FLINK-5023:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689800#comment-15689800
]
Stephan Ewen commented on FLINK-5126:
-
Not sure about that. They were added there for
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
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 afr
[
https://issues.apache.org/jira/browse/FLINK-4961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689805#comment-15689805
]
ASF GitHub Bot commented on FLINK-4961:
---
Github user thvasilo commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689818#comment-15689818
]
Robert Metzger commented on FLINK-4941:
---
This has been fixed for 1.2 in 3a4fc537dcff
[
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-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689820#comment-15689820
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user StephanEwen commented on the is
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 f
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/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
enable
1 - 100 of 323 matches
Mail list logo
