[
https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14368248#comment-14368248
]
ASF GitHub Bot commented on FLINK-1739:
---
Github user matadorhong commented on the pu
Github user matadorhong commented on the pull request:
https://github.com/apache/flink/pull/499#issuecomment-83238963
Have modified the port range of TaskManager in [0, 65535]
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as we
[
https://issues.apache.org/jira/browse/FLINK-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14368121#comment-14368121
]
ASF GitHub Bot commented on FLINK-1688:
---
Github user miguel0afd commented on the pul
Github user miguel0afd commented on the pull request:
https://github.com/apache/flink/pull/484#issuecomment-83221889
Documentation patch sent: https://issues.apache.org/jira/browse/FLINK-1688
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Miguel Angel Fernandez Diaz updated FLINK-1688:
---
Attachment: improvement.patch
Added text to the documentation.
Related
[
https://issues.apache.org/jira/browse/FLINK-1734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Waury closed FLINK-1734.
---
Resolution: Not a Problem
Bug in user code caused the problem (see mailing list)
> Insufficient memor
[
https://issues.apache.org/jira/browse/FLINK-1744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14368071#comment-14368071
]
Henry Saputra commented on FLINK-1744:
--
Simple grep in the source code repo:
{code}
Henry Saputra created FLINK-1744:
Summary: Change the reference of slaves to workers to match the
description of the system
Key: FLINK-1744
URL: https://issues.apache.org/jira/browse/FLINK-1744
Projec
[
https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14368001#comment-14368001
]
ASF GitHub Bot commented on FLINK-1740:
---
Github user senorcarbone commented on the p
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/501#issuecomment-83197775
Indeed, cool. Good to know
---
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
[
https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367993#comment-14367993
]
ASF GitHub Bot commented on FLINK-1740:
---
Github user mbalassi commented on the pull
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/501#issuecomment-83196855
Sure, rebasing to master does that.
---
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 n
[
https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367990#comment-14367990
]
ASF GitHub Bot commented on FLINK-1740:
---
Github user senorcarbone commented on the p
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/501#issuecomment-83196555
Thanks @mbalassi! If you merge can you remove the quickfix (2872308)? It
looks like @hsaputra pushed it already
---
If your project is set up for it, you can reply
Github user senorcarbone commented on a diff in the pull request:
https://github.com/apache/flink/pull/501#discussion_r26711053
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupCombineITCase.java
---
@@ -58,7 +58,7 @@
*/
public class GroupC
[
https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367986#comment-14367986
]
ASF GitHub Bot commented on FLINK-1740:
---
Github user senorcarbone commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367978#comment-14367978
]
ASF GitHub Bot commented on FLINK-1740:
---
Github user mbalassi commented on the pull
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/501#issuecomment-83193360
Added a comment to the JIRA issue, but the suggestion make sense,
@senorcarbone. Let me add a bit of doc and merge this.
---
If your project is set up for it, you can re
[
https://issues.apache.org/jira/browse/FLINK-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367962#comment-14367962
]
ASF GitHub Bot commented on FLINK-1669:
---
Github user mbalassi commented on the pull
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/496#issuecomment-83186250
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
[
https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367905#comment-14367905
]
Márton Balassi commented on FLINK-1740:
---
That is actually a good question whether we
[
https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367883#comment-14367883
]
Andra Lungu commented on FLINK-1741:
Hi Alex,
Thanks for the tip! I'd like to believ
[
https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367867#comment-14367867
]
Alexander Alexandrov commented on FLINK-1741:
-
I think we had some similar cod
[
https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367847#comment-14367847
]
ASF GitHub Bot commented on FLINK-1740:
---
Github user hsaputra commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367846#comment-14367846
]
ASF GitHub Bot commented on FLINK-1740:
---
Github user hsaputra commented on a diff in
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/501#discussion_r26704856
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupCombineITCase.java
---
@@ -58,7 +58,7 @@
*/
public class GroupCombi
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/501#discussion_r26704861
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupCombineITCase.java
---
@@ -276,7 +276,7 @@ public void
testPartialReduceWith
[
https://issues.apache.org/jira/browse/FLINK-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Péter Szabó closed FLINK-1701.
--
Resolution: Fixed
Anonymous inner classes are serializable only if the enclosing class is
serilizable.
[
https://issues.apache.org/jira/browse/FLINK-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Péter Szabó reassigned FLINK-1701:
--
Assignee: Péter Szabó
> Serialization problems with TestStreamEnvironment
> ---
[
https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367799#comment-14367799
]
ASF GitHub Bot commented on FLINK-1739:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/499#issuecomment-83150196
+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
GitHub user senorcarbone opened a pull request:
https://github.com/apache/flink/pull/501
Flink 1740
We now use the config parameter for numberofExecutionRetries on the
generated job graph.
Also piggypacked a minor fix for a compilation error that currently occurs
in flink-test
Till Rohrmann created FLINK-1743:
Summary: Add multinomial logistic regression to machine learning
library
Key: FLINK-1743
URL: https://issues.apache.org/jira/browse/FLINK-1743
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367666#comment-14367666
]
ASF GitHub Bot commented on FLINK-1739:
---
Github user matadorhong commented on a diff
Github user matadorhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/499#discussion_r26695073
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -1274,9 +1274,10 @@ object TaskManager {
Till Rohrmann created FLINK-1742:
Summary: Sample data points for MultipleLinearRegression to
support proper SGD
Key: FLINK-1742
URL: https://issues.apache.org/jira/browse/FLINK-1742
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1718:
-
Issue Type: New Feature (was: Improvement)
> Add sparse vector and sparse matrix types to machine
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1731:
-
Issue Type: New Feature (was: Improvement)
> Add kMeans clustering algorithm to machine learning
[
https://issues.apache.org/jira/browse/FLINK-1728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1728:
-
Issue Type: New Feature (was: Improvement)
> Add random forest ensemble method to machine learnin
[
https://issues.apache.org/jira/browse/FLINK-1716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1716:
-
Issue Type: New Feature (was: Improvement)
> Add CoCoA algorithm to flink-ml
> --
[
https://issues.apache.org/jira/browse/FLINK-1735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1735:
-
Issue Type: New Feature (was: Improvement)
> Add FeatureHasher to machine learning library
>
[
https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1733:
-
Issue Type: New Feature (was: Improvement)
> Add PCA to machine learning library
> --
[
https://issues.apache.org/jira/browse/FLINK-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1729:
-
Issue Type: New Feature (was: Improvement)
> Assess performance of classification algorithms
> --
[
https://issues.apache.org/jira/browse/FLINK-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1736:
-
Issue Type: New Feature (was: Improvement)
> Add CountVectorizer to machine learning library
> --
[
https://issues.apache.org/jira/browse/FLINK-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1723:
-
Issue Type: New Feature (was: Improvement)
> Add cross validation for parameter selection and val
[
https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1719:
-
Issue Type: New Feature (was: Improvement)
> Add naive Bayes classification algorithm to machine
[
https://issues.apache.org/jira/browse/FLINK-1717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1717:
-
Issue Type: New Feature (was: Improvement)
> Add support to read libSVM and SVMLight input files
[
https://issues.apache.org/jira/browse/FLINK-1738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1738:
-
Issue Type: New Feature (was: Improvement)
> Add mean centering transformation to machine learnin
[
https://issues.apache.org/jira/browse/FLINK-1732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1732:
-
Issue Type: New Feature (was: Improvement)
> Add Gaussian mixture model to machine learning libra
[
https://issues.apache.org/jira/browse/FLINK-1727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1727:
-
Issue Type: New Feature (was: Improvement)
> Add decision tree to machine learning library
>
[
https://issues.apache.org/jira/browse/FLINK-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1737:
-
Issue Type: New Feature (was: Improvement)
> Add statistical whitening transformation to machine
Andra Lungu created FLINK-1741:
--
Summary: Add Jaccard Similarity Metric Example
Key: FLINK-1741
URL: https://issues.apache.org/jira/browse/FLINK-1741
Project: Flink
Issue Type: Task
Co
[
https://issues.apache.org/jira/browse/FLINK-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367597#comment-14367597
]
ASF GitHub Bot commented on FLINK-1669:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/496#issuecomment-83105563
I'll do a pass over this and merge it today or tomorrow...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as we
[
https://issues.apache.org/jira/browse/FLINK-1709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367578#comment-14367578
]
ASF GitHub Bot commented on FLINK-1709:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/498#issuecomment-83104224
The test looks good.
One question: Why are you not simply using the `Client` to submit the
JobGraph to the JobManager. This has the nice benefit that we test t
[
https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367575#comment-14367575
]
ASF GitHub Bot commented on FLINK-1739:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/499#discussion_r26690147
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -1274,9 +1274,10 @@ object TaskManager {
[
https://issues.apache.org/jira/browse/FLINK-1679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367570#comment-14367570
]
ASF GitHub Bot commented on FLINK-1679:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/488#issuecomment-83102692
With 236 files, that is hard to assess...
That is a point, in general, with humongous pull requests that touch 10
projects at the same time.
I would person
[
https://issues.apache.org/jira/browse/FLINK-1679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367568#comment-14367568
]
ASF GitHub Bot commented on FLINK-1679:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/488#issuecomment-83100904
Are we sure that this is breaking no existing API. No method on DataSet or
any descendant of it has been renamed? Also not on other user facing types?
---
If your pr
[
https://issues.apache.org/jira/browse/FLINK-1679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367559#comment-14367559
]
ASF GitHub Bot commented on FLINK-1679:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/488#issuecomment-83095571
Any objections against merging 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 h
[
https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367553#comment-14367553
]
Paris Carbone commented on FLINK-1740:
--
Indeed, we did not get the numberOfExecutionR
[
https://issues.apache.org/jira/browse/FLINK-1621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-1621.
---
Resolution: Fixed
Assignee: Maximilian Michels
Resolved by implementing a GroupC
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-1622.
---
Resolution: Implemented
Fix Version/s: 0.9
> Add GroupReducePartial Operator
>
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-1622:
-
Assignee: Maximilian Michels
> Add GroupReducePartial Operator
>
[
https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paris Carbone reassigned FLINK-1740:
Assignee: Paris Carbone
> StreamExecutionEnvironment is not respecting the setNumberOfExecu
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/500#discussion_r26687763
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaITCase.java
---
@@ -0,0 +1,
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/500#discussion_r26687518
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/kafka/api/simple/iterator/KafkaOnePartition
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/500#discussion_r26687379
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/kafka/api/simple/SimpleKafkaSource.java
--
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/500#discussion_r26686592
--- Diff: flink-staging/flink-streaming/flink-streaming-connectors/pom.xml
---
@@ -46,9 +53,13 @@ under the License.
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/500#discussion_r26686494
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/StreamCheckpointCoordinator.scala
---
@@ -75,17 +75,17 @@ class StreamCheckpointCo
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/500#discussion_r26686341
--- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java
---
@@ -182,7 +182,6 @@ protected void fillInType(TypeInformation typeInfo) {
[
https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367521#comment-14367521
]
ASF GitHub Bot commented on FLINK-1739:
---
Github user hsaputra commented on a diff in
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/500
Improvements to Kafka Source/Sink & some bugfixes in Flink Streaming
Hi,
I've spend the last two days on improving the Kafka connectors and the
streaming fault tolerance.
Since its the first
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/499#discussion_r26686143
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -1274,9 +1274,10 @@ object TaskManager {
"'
Márton Balassi created FLINK-1740:
-
Summary: StreamExecutionEnvironment is not respecting the
setNumberOfExecutionRetries()
Key: FLINK-1740
URL: https://issues.apache.org/jira/browse/FLINK-1740
Projec
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/499#issuecomment-83065881
Looks good.
+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 n
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/496#issuecomment-83065828
I would not suspect that as the batch is using the same config on paper.
---
If your project is set up for it, you can reply to this email and have your
reply appear on G
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1622:
--
Labels: (was: Local)
> Add GroupReducePartial Operator
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367505#comment-14367505
]
ASF GitHub Bot commented on FLINK-1669:
---
Github user mbalassi commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1622:
--
Component/s: Local Runtime
> Add GroupReducePartial Operator
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367506#comment-14367506
]
ASF GitHub Bot commented on FLINK-1739:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1622:
--
Labels: Local (was: )
> Add GroupReducePartial Operator
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367496#comment-14367496
]
ASF GitHub Bot commented on FLINK-1622:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367493#comment-14367493
]
ASF GitHub Bot commented on FLINK-1739:
---
GitHub user matadorhong opened a pull reque
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/466
---
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 enabl
GitHub user matadorhong opened a pull request:
https://github.com/apache/flink/pull/499
[FLINK-1739]Fix the bug of JobManager and TaskManager Port Check.
The IPC port of JobManager and IPC port of TaskManager must be great than 0
and less than 65535.
It must have check the port
Sibao Hong created FLINK-1739:
-
Summary: Fix the bug of JobManager and TaskManager Port Check.
Key: FLINK-1739
URL: https://issues.apache.org/jira/browse/FLINK-1739
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367450#comment-14367450
]
ASF GitHub Bot commented on FLINK-1709:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/498
[FLINK-1709] [wip] Add SlotCountExceedingParallelismTest
This is the initial simple case. I'll push the other variants to this
branch.
You can merge this pull request into a Git repository by running:
[
https://issues.apache.org/jira/browse/FLINK-1350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367443#comment-14367443
]
ASF GitHub Bot commented on FLINK-1350:
---
Github user uce closed the pull request at:
Github user uce closed the pull request at:
https://github.com/apache/flink/pull/471
---
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 enabled
[
https://issues.apache.org/jira/browse/FLINK-1732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1732:
-
Description:
For clustering purposes a distribution-based clustering algorithm such as the
Gaussi
[
https://issues.apache.org/jira/browse/FLINK-1350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367422#comment-14367422
]
ASF GitHub Bot commented on FLINK-1350:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/471#issuecomment-83049370
Thanks for the comments. I'll address the generateSequence comment and open
an issue for the optimizer deadlock detection and pipeline breaking stuff after
merging this.
---
[
https://issues.apache.org/jira/browse/FLINK-1709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-1709:
---
Summary: Add support for programs with slot count exceeding parallelism
(was: Add support for program
[
https://issues.apache.org/jira/browse/FLINK-1503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367368#comment-14367368
]
Gyula Fora commented on FLINK-1503:
---
Hey,
As you can probably tell from the description
1 - 100 of 185 matches
Mail list logo
