[
https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420674#comment-15420674
]
Ufuk Celebi commented on FLINK-4387:
Temporarily ignored the test in 79cc30 (master).
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2362
@wuchong Thanks for the fix! Will 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
[
https://issues.apache.org/jira/browse/FLINK-4385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420682#comment-15420682
]
ASF GitHub Bot commented on FLINK-4385:
---
Github user twalthr commented on the issue:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2362
---
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-4385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4385.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 83c4b9707dd24425391bd5759f12878ad2f19175.
[
https://issues.apache.org/jira/browse/FLINK-4385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420693#comment-15420693
]
ASF GitHub Bot commented on FLINK-4385:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing reassigned FLINK-4348:
Assignee: zhangjing
> implement communication from ResourceManager to TaskManager
> ---
Dominik Bruhn created FLINK-4394:
Summary: RMQSource: The QueueName is not accessible to subclasses
Key: FLINK-4394
URL: https://issues.apache.org/jira/browse/FLINK-4394
Project: Flink
Issue
GitHub user theomega opened a pull request:
https://github.com/apache/flink/pull/2373
[FLINK-4394] RMQSource: QueueName accessible for subclasses
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-4394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420704#comment-15420704
]
ASF GitHub Bot commented on FLINK-4394:
---
GitHub user theomega opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420708#comment-15420708
]
Robert Metzger commented on FLINK-4387:
---
I saw this assertion error also in another
Till Rohrmann created FLINK-4395:
Summary: Eager processing of late arrivals in CEP operator
Key: FLINK-4395
URL: https://issues.apache.org/jira/browse/FLINK-4395
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420743#comment-15420743
]
Chesnay Schepler commented on FLINK-3950:
-
The idea behind the Meter view is to re
[
https://issues.apache.org/jira/browse/FLINK-4394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420750#comment-15420750
]
Robert Metzger commented on FLINK-4394:
---
Thank you for opening a pull request. I gav
[
https://issues.apache.org/jira/browse/FLINK-4394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4394:
--
Assignee: Dominik Bruhn
> RMQSource: The QueueName is not accessible to subclasses
> ---
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2373
I'm going to merge the change once travis gives green light.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420752#comment-15420752
]
ASF GitHub Bot commented on FLINK-4394:
---
Github user rmetzger commented on the issue
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2297
@StephanEwen I renamed `EMPTY_STRING` to `EMPTY_COLUMN`. All parsers that
have a "format" (like Double, Boolean, Integer etc.) return `-1` and set
`EMPTY_COLUMN`. The `StringParser` returns the Strin
[
https://issues.apache.org/jira/browse/FLINK-4081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420758#comment-15420758
]
ASF GitHub Bot commented on FLINK-4081:
---
Github user twalthr commented on the issue:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2365#discussion_r74737756
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaInvocationHandler.java
---
@@ -25,33 +25,42 @@
import org.apache.flink.
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420766#comment-15420766
]
ASF GitHub Bot commented on FLINK-4383:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2365#discussion_r74737803
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/messages/RemoteRpcInvocation.java
---
@@ -0,0 +1,187 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420763#comment-15420763
]
ASF GitHub Bot commented on FLINK-4383:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420770#comment-15420770
]
ASF GitHub Bot commented on FLINK-4383:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2365#discussion_r74737963
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaInvocationHandler.java
---
@@ -25,33 +25,42 @@
import org.apache.flink.
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2365
Thanks for the review @StephanEwen. I've addressed your comments. Once
Travis gives green light, I'll merge it.
---
If your project is set up for it, you can reply to this email and have your
r
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420798#comment-15420798
]
ASF GitHub Bot commented on FLINK-4383:
---
Github user tillrohrmann commented on the i
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2288
The associated issue for this can be found here:
https://issues.apache.org/jira/browse/FLINK-4228.
+1 to the points Stephan raised in his earlier comment.
---
If your project is set up fo
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420812#comment-15420812
]
ASF GitHub Bot commented on FLINK-4228:
---
Github user uce commented on the issue:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74742684
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -46,12 +47,13 @@ public void run() {
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74743009
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -62,4 +64,34 @@ public void run() {
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74743234
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java
---
@@ -62,4 +64,34 @@ public void run() {
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74743269
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/HDFSCopyUtilitiesTest.java
---
@@ -19,18 +19,18 @@
import org.apache.flin
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74743303
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/HDFSCopyUtilitiesTest.java
---
@@ -70,6 +70,85 @@ public void testCopyFromLocal() th
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2288#discussion_r74743404
--- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java ---
@@ -255,4 +257,33 @@ private Utils() {
}
return result;
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2288
Thank you for contributing. All in all, this looks good and is an important
fix. We would have to address the inline comments I've raised before merging it
though. Do you have time to address them?
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2372#discussion_r74747473
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/FlinkPlannerImpl.scala
---
@@ -68,12 +68,16 @@ class FlinkPlannerImpl(
[
https://issues.apache.org/jira/browse/FLINK-4281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420850#comment-15420850
]
ASF GitHub Bot commented on FLINK-4281:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4393:
--
Description:
Dear Team,
I am getting the below exception while trying to use the Table API by
[
https://issues.apache.org/jira/browse/FLINK-4393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420868#comment-15420868
]
Robert Metzger commented on FLINK-4393:
---
What's the DataSet size you are trying to c
RWenden created FLINK-4396:
--
Summary: MetricRegistry class not found at startup of jobmanager
Key: FLINK-4396
URL: https://issues.apache.org/jira/browse/FLINK-4396
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420931#comment-15420931
]
ASF GitHub Bot commented on FLINK-4273:
---
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/2313#discussion_r74756158
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClient.java ---
@@ -118,27 +138,168 @@ public static JobExecutionResult submitJobAnd
[
https://issues.apache.org/jira/browse/FLINK-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420945#comment-15420945
]
ASF GitHub Bot commented on FLINK-4273:
---
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/2313#discussion_r74757666
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClient.java ---
@@ -118,27 +138,168 @@ public static JobExecutionResult submitJobAnd
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2313#discussion_r74757794
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClientActor.java
---
@@ -198,10 +211,47 @@ else if (message instanceof SubmitJobAnd
[
https://issues.apache.org/jira/browse/FLINK-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420946#comment-15420946
]
ASF GitHub Bot commented on FLINK-4273:
---
Github user rmetzger commented on a diff in
Github user cresny commented on the issue:
https://github.com/apache/flink/pull/2288
I just returned from vacation so I have some catching up to do, but I'll
take care of this today or tomorrow.
On Aug 15, 2016 6:22 AM, "Ufuk Celebi" wrote:
> Thank you for contrib
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2313
I did a quick pass over the code. I think this change needs another review
by our Actor expert @tillrohrmann ;)
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420953#comment-15420953
]
ASF GitHub Bot commented on FLINK-4273:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420960#comment-15420960
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2314
Thanks a lot for the contribution @mushketyk.
It seems like the Flink community prefers to have put the majority of
connector modules to Apache Bahir. We are currently in the process of figuring
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2314#discussion_r74760042
--- Diff: flink-streaming-connectors/flink-connector-activemq/pom.xml ---
@@ -0,0 +1,104 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2141#discussion_r74760105
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandler.java
---
@@ -292,7 +296,11 @@ else if (bufferListen
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2314#discussion_r74760157
--- Diff: flink-streaming-connectors/flink-connector-activemq/pom.xml ---
@@ -0,0 +1,104 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+
[
https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420965#comment-15420965
]
ASF GitHub Bot commented on FLINK-4021:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420966#comment-15420966
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420964#comment-15420964
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user rmetzger commented on a diff in
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2141
Very impressive that you made it through that part of the system. It's very
poorly documented and overly complex. The change looks good and ensures that a
staged buffer that cannot be decoded because of
[
https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420973#comment-15420973
]
ASF GitHub Bot commented on FLINK-4021:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2288
Thank you! :+1:
---
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-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420981#comment-15420981
]
ASF GitHub Bot commented on FLINK-3298:
---
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/2314#discussion_r74762137
--- Diff:
flink-streaming-connectors/flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSink.java
---
@@ -0,0 +1,155 @
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420982#comment-15420982
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420983#comment-15420983
]
ASF GitHub Bot commented on FLINK-3298:
---
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/2314#discussion_r74762401
--- Diff:
flink-streaming-connectors/flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSink.java
---
@@ -0,0 +1,155 @
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2314#discussion_r74762673
--- Diff:
flink-streaming-connectors/flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSink.java
---
@@ -0,0 +1,155 @
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420988#comment-15420988
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user rmetzger commented on a diff in
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2075
I agree. +1 to link in 3rd party packages if this is up to date and close
this PR. What do you think @rmetzger and @jneuff?
---
If your project is set up for it, you can reply to this email and have you
[
https://issues.apache.org/jira/browse/FLINK-3867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420980#comment-15420980
]
ASF GitHub Bot commented on FLINK-3867:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421000#comment-15421000
]
Till Rohrmann commented on FLINK-4055:
--
Another instance:
https://s3.amazonaws.com/a
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2314#discussion_r74762300
--- Diff:
flink-streaming-connectors/flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSink.java
---
@@ -0,0 +1,155 @
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4383.
Resolution: Fixed
Fixed via e8a434647bac8009b11779a3943c5d63871fcb14
> Check parameters for seriali
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2314#discussion_r74766399
--- Diff:
flink-streaming-connectors/flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java
---
@@ -0,0 +1,258
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421004#comment-15421004
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421009#comment-15421009
]
ASF GitHub Bot commented on FLINK-3298:
---
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/2314#discussion_r74766651
--- Diff:
flink-streaming-connectors/flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java
---
@@ -0,0 +1,258
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2314#discussion_r74766852
--- Diff:
flink-streaming-connectors/flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java
---
@@ -0,0 +1,258
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421011#comment-15421011
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2314
Thank you for this contribution. I did an initial check of the code.
Once all my comments are addressed, I'll do another check.
Did you test the code on a cluster? Were there any any depe
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2265
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-3097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421014#comment-15421014
]
ASF GitHub Bot commented on FLINK-3097:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421015#comment-15421015
]
ASF GitHub Bot commented on FLINK-3298:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421021#comment-15421021
]
ASF GitHub Bot commented on FLINK-4394:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2373
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 th
[
https://issues.apache.org/jira/browse/FLINK-4397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4397:
--
Assignee: Ufuk Celebi
> Unstable test SlotCountExceedingParallelismTest.tearDown
> -
Kostas Kloudas created FLINK-4398:
-
Summary: Unstable test KvStateServerHandlerTest.testSimpleQuery
Key: FLINK-4398
URL: https://issues.apache.org/jira/browse/FLINK-4398
Project: Flink
Issue
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2265
---
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 tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2370#discussion_r74768392
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java
---
@@ -0,0 +1,47 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-4394.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Thank you for the contribution.
Resolved in http
[
https://issues.apache.org/jira/browse/FLINK-4398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4398:
--
Labels: test-stability (was: )
> Unstable test KvStateServerHandlerTest.testSimpleQuery
> -
[
https://issues.apache.org/jira/browse/FLINK-3097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-3097.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 90fdae452b6a03fafd4ec7827030d78ae87dbcd3.
[
https://issues.apache.org/jira/browse/FLINK-4397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4397:
--
Labels: test-stability (was: )
> Unstable test SlotCountExceedingParallelismTest.tearDown
> ---
[
https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421031#comment-15421031
]
ASF GitHub Bot commented on FLINK-4373:
---
Github user tillrohrmann commented on a dif
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2094
I will shepherd this PR. I think I can review it this week.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not ha
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2370#discussion_r74768700
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java
---
@@ -0,0 +1,47 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421039#comment-15421039
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user twalthr commented on the issue:
Github user ggevay commented on the issue:
https://github.com/apache/flink/pull/2094
Thanks!
---
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
[
https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421040#comment-15421040
]
ASF GitHub Bot commented on FLINK-4373:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421042#comment-15421042
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user ggevay commented on the issue:
1 - 100 of 200 matches
Mail list logo
