Greg Hogan created FLINK-3337:
-
Summary: mvn test fails on flink-runtime because curator classes
not found
Key: FLINK-3337
URL: https://issues.apache.org/jira/browse/FLINK-3337
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132650#comment-15132650
]
Aljoscha Krettek commented on FLINK-3336:
-
I'm open for suggestions on the name.
> Add
[
https://issues.apache.org/jira/browse/FLINK-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132453#comment-15132453
]
Gabor Gevay commented on FLINK-3335:
Are you sure that adding that copy is the best solution here? An
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132529#comment-15132529
]
Robert Metzger commented on FLINK-3332:
---
Here is the link to the documentation:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1428#issuecomment-179926670
I went through all the classes in the relevant modules outside `flink-core`
with @fhueske and annotated them properly.
I've rebased the changes and checked with the
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132521#comment-15132521
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user rmetzger commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-2845.
-
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed in
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/f8f747f2290ad623bd8a4f0d8ff4708fada6792a#commitcomment-15890284
So, actually is that exception comes, we can safely ignore it?
---
If your project is set up for it, you can reply to this
Aljoscha Krettek created FLINK-3336:
---
Summary: Add Semi-Rebalance Data Shipping for DataStream
Key: FLINK-3336
URL: https://issues.apache.org/jira/browse/FLINK-3336
Project: Flink
Issue
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/1587#discussion_r51909968
--- Diff:
flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/regression/RegressionData.scala
---
@@ -27,6 +27,21 @@ object RegressionData {
[
https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132672#comment-15132672
]
ASF GitHub Bot commented on FLINK-3330:
---
Github user thvasilo commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132673#comment-15132673
]
ASF GitHub Bot commented on FLINK-3330:
---
Github user thvasilo commented on a diff in the pull
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/1587#discussion_r51910120
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala
---
@@ -192,10 +190,18 @@ abstract class
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/1586
---
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-3329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132770#comment-15132770
]
ASF GitHub Bot commented on FLINK-3329:
---
Github user aljoscha closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3329.
-
Resolution: Fixed
Fixed in
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132694#comment-15132694
]
ASF GitHub Bot commented on FLINK-2213:
---
GitHub user kl0u opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132726#comment-15132726
]
Shikhar Bhushan commented on FLINK-3338:
(this is on 1.0-SNAPSHOT)
> Kafka deserialization issue
Shikhar Bhushan created FLINK-3338:
--
Summary: Kafka deserialization issue - ClassNotFoundException
Key: FLINK-3338
URL: https://issues.apache.org/jira/browse/FLINK-3338
Project: Flink
Issue
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/1588
FLINK-2213 Makes the number of vcores per YARN container configurable.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink vcores_param
[
https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shikhar Bhushan updated FLINK-3338:
---
Description:
I get this error when running a JAR submitted using the web UI on a production
[
https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132740#comment-15132740
]
Stephan Ewen commented on FLINK-3338:
-
The stack trace says that the class is cloned using the
[
https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132740#comment-15132740
]
Stephan Ewen edited comment on FLINK-3338 at 2/4/16 6:40 PM:
-
The stack trace
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132906#comment-15132906
]
ASF GitHub Bot commented on FLINK-3336:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1589#discussion_r51929634
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
---
@@ -443,6 +443,35 @@ public ExecutionConfig
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132920#comment-15132920
]
ASF GitHub Bot commented on FLINK-3336:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1589#discussion_r51930125
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/partitioner/SemiRebalancePartitionerTest.java
---
@@ -0,0 +1,202 @@
+/*
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1589#discussion_r51928539
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
---
@@ -443,6 +443,35 @@ public ExecutionConfig
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132890#comment-15132890
]
ASF GitHub Bot commented on FLINK-3336:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1589#discussion_r51929574
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
---
@@ -443,6 +443,35 @@ public ExecutionConfig
[
https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-3338:
---
Assignee: Stephan Ewen
> Kafka deserialization issue - ClassNotFoundException
>
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132894#comment-15132894
]
ASF GitHub Bot commented on FLINK-3336:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1589#discussion_r51928771
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala
---
@@ -371,6 +371,30 @@ class DataStream[T](stream:
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1589#discussion_r51929032
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
---
@@ -443,6 +443,35 @@ public ExecutionConfig
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132896#comment-15132896
]
ASF GitHub Bot commented on FLINK-3336:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132905#comment-15132905
]
ASF GitHub Bot commented on FLINK-3336:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132950#comment-15132950
]
ASF GitHub Bot commented on FLINK-3336:
---
Github user uce commented on the pull request:
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1589#issuecomment-180031529
Changes look good (including the test). I'm OK with the current name. I
understand why it is up for discussion but I can't come up with a better name
at the moment. ;)
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1590
[FLINK-3338] [kafka] Use proper classloader when cloning the
deserialization schema
Fixes a class not found exception reported by a user.
You can merge this pull request into a Git repository
[
https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132957#comment-15132957
]
ASF GitHub Bot commented on FLINK-3338:
---
GitHub user StephanEwen opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132975#comment-15132975
]
ASF GitHub Bot commented on FLINK-3338:
---
Github user rmetzger commented on the pull request:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1590#issuecomment-180038020
Change looks good.
+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
Robert Metzger created FLINK-3331:
-
Summary: Test instability:
LocalFlinkMiniClusterITCase.testLocalFlinkMiniClusterWithMultipleTaskManagers
Key: FLINK-3331
URL: https://issues.apache.org/jira/browse/FLINK-3331
[
https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chiwan Park reassigned FLINK-3234:
--
Assignee: Chiwan Park
> SortPartition does not support KeySelectorFunctions
>
101 - 144 of 144 matches
Mail list logo
