[
https://issues.apache.org/jira/browse/FLINK-1698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reopened FLINK-1698:
---
Add polynomial base feature mapper to ML library
[
https://issues.apache.org/jira/browse/FLINK-1721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14366935#comment-14366935
]
Stephan Ewen commented on FLINK-1721:
-
Can you work around it for the time being, like
[
https://issues.apache.org/jira/browse/FLINK-1698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1698.
---
Resolution: Fixed
Fix Version/s: 0.9
Add polynomial base feature mapper to ML library
[
https://issues.apache.org/jira/browse/FLINK-1697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reopened FLINK-1697:
---
Add alternating least squares algorithm for matrix factorization to ML library
[
https://issues.apache.org/jira/browse/FLINK-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1696.
---
Resolution: Fixed
Fix Version/s: 0.9
Add multiple linear regression to ML library
[
https://issues.apache.org/jira/browse/FLINK-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reopened FLINK-1696:
---
Add multiple linear regression to ML library
Aljoscha Krettek created FLINK-1720:
---
Summary: Integrate ScalaDoc in Scala sources into overall JavaDoc
Key: FLINK-1720
URL: https://issues.apache.org/jira/browse/FLINK-1720
Project: Flink
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/466#issuecomment-82879313
Any further comments?
---
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
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14366925#comment-14366925
]
ASF GitHub Bot commented on FLINK-1622:
---
Github user mxm commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14366923#comment-14366923
]
ASF GitHub Bot commented on FLINK-1669:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1695.
---
Resolution: Fixed
Fix Version/s: 0.9
Create machine learning library
[
https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1719:
-
Component/s: Machine Learning Library
Add naive Bayes classification algorithm to machine
Till Rohrmann created FLINK-1719:
Summary: Add naive Bayes classification algorithm to machine
learning library
Key: FLINK-1719
URL: https://issues.apache.org/jira/browse/FLINK-1719
Project: Flink
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/496#issuecomment-82878482
Maybe, the `execution-retries.delay` is set too high?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Stephan Ewen created FLINK-1721:
---
Summary: Flakey Yarn Tests
Key: FLINK-1721
URL: https://issues.apache.org/jira/browse/FLINK-1721
Project: Flink
Issue Type: Bug
Components: YARN
[
https://issues.apache.org/jira/browse/FLINK-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14366933#comment-14366933
]
Aljoscha Krettek commented on FLINK-1710:
-
It is executed on the same data sets as
Ufuk Celebi created FLINK-1724:
--
Summary: TestingCluster uses local communication with multiple
task managers
Key: FLINK-1724
URL: https://issues.apache.org/jira/browse/FLINK-1724
Project: Flink
Till Rohrmann created FLINK-1717:
Summary: Add support to read libSVM and SVMLight input files
Key: FLINK-1717
URL: https://issues.apache.org/jira/browse/FLINK-1717
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-1721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14366928#comment-14366928
]
Robert Metzger commented on FLINK-1721:
---
I suspect this issue is caused by
[
https://issues.apache.org/jira/browse/FLINK-1679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-1679:
--
Fix Version/s: 0.9
Document how degree of parallelism / parallelism / slots are
[
https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1719:
-
Description: Add naive Bayes algorithm to Flink's machine learning library
as a basic
[
https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-1486:
--
Fix Version/s: 0.9
Add a string to the print method to identify output
[
https://issues.apache.org/jira/browse/FLINK-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14366920#comment-14366920
]
ASF GitHub Bot commented on FLINK-1669:
---
GitHub user mbalassi opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14366946#comment-14366946
]
ASF GitHub Bot commented on FLINK-1622:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-1721:
Attachment: 1.log
Flakey Yarn Tests
-
Key: FLINK-1721
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/466#issuecomment-82886862
I would say it's good to go now.
---
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
Till Rohrmann created FLINK-1723:
Summary: Add cross validation for parameter selection and
validation
Key: FLINK-1723
URL: https://issues.apache.org/jira/browse/FLINK-1723
Project: Flink
Till Rohrmann created FLINK-1716:
Summary: Add CoCoA algorithm to flink-ml
Key: FLINK-1716
URL: https://issues.apache.org/jira/browse/FLINK-1716
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-1679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14366843#comment-14366843
]
ASF GitHub Bot commented on FLINK-1679:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/488#issuecomment-82825369
Thank you for the huge change! Our users will appreciate the more concise
naming and improved documentation.
+1 to merge
---
If your project is set up for it,
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-82885499
I updated this PR.
* Change method of obtaining `Field` object from using `PojoTypeInfo` to
saving field names. (Thanks @fhueske for advice!)
*
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14366938#comment-14366938
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user chiwanpark commented on the
[
https://issues.apache.org/jira/browse/FLINK-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14366939#comment-14366939
]
Stephan Ewen commented on FLINK-1710:
-
This compilation overhead is pretty massive.
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/477#issuecomment-82930555
Can we merge this before handling
[FLINK-1712](https://issues.apache.org/jira/browse/FLINK-1712)?
I can open a separate PR that adds the suffixes and
[
https://issues.apache.org/jira/browse/FLINK-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367034#comment-14367034
]
ASF GitHub Bot commented on FLINK-1712:
---
Github user aalexandrov commented on the
Till Rohrmann created FLINK-1727:
Summary: Add decision tree to machine learning library
Key: FLINK-1727
URL: https://issues.apache.org/jira/browse/FLINK-1727
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-1652.
--
Resolution: Fixed
Wrong superstep number in VertexCentricIteration in Collection mode
[
https://issues.apache.org/jira/browse/FLINK-1576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-1576:
-
Fix Version/s: 0.9
Change the Gelly examples to be consistent with the other Flink examples
Anis Nasir created FLINK-1725:
-
Summary: New Partitioner for better load balancing for skewed data
Key: FLINK-1725
URL: https://issues.apache.org/jira/browse/FLINK-1725
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1719:
-
Description: Add naive Bayes algorithm to Flink's machine learning library
as a basic
[
https://issues.apache.org/jira/browse/FLINK-1724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367140#comment-14367140
]
Stephan Ewen commented on FLINK-1724:
-
I think that there is actually too much too
[
https://issues.apache.org/jira/browse/FLINK-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-1632.
--
Resolution: Implemented
Use DataSet's count() and collect() to simplify Gelly methods
Till Rohrmann created FLINK-1728:
Summary: Add random forest ensemble method to machine learning
library
Key: FLINK-1728
URL: https://issues.apache.org/jira/browse/FLINK-1728
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-1652:
-
Fix Version/s: 0.9
Wrong superstep number in VertexCentricIteration in Collection mode
[
https://issues.apache.org/jira/browse/FLINK-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-1632:
-
Fix Version/s: 0.9
Use DataSet's count() and collect() to simplify Gelly methods
Andra Lungu created FLINK-1726:
--
Summary: Add Community Detection Library and Example
Key: FLINK-1726
URL: https://issues.apache.org/jira/browse/FLINK-1726
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-1576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-1576.
--
Resolution: Fixed
Change the Gelly examples to be consistent with the other Flink examples
[
https://issues.apache.org/jira/browse/FLINK-1576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-1576:
-
Affects Version/s: (was: 0.8.0)
0.9
Change the Gelly examples to be
[
https://issues.apache.org/jira/browse/FLINK-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367151#comment-14367151
]
ASF GitHub Bot commented on FLINK-1641:
---
Github user gyfora commented on the pull
Till Rohrmann created FLINK-1733:
Summary: Add PCA to machine learning library
Key: FLINK-1733
URL: https://issues.apache.org/jira/browse/FLINK-1733
Project: Flink
Issue Type: Improvement
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/497#discussion_r26671432
--- Diff: pom.xml ---
@@ -416,6 +416,65 @@ under the License.
iddocs-and-source/id
build
[
https://issues.apache.org/jira/browse/FLINK-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367273#comment-14367273
]
Aljoscha Krettek commented on FLINK-1710:
-
The more important problem could be
Till Rohrmann created FLINK-1737:
Summary: Add statistical whitening transformation to machine
learning library
Key: FLINK-1737
URL: https://issues.apache.org/jira/browse/FLINK-1737
Project: Flink
Robert Waury created FLINK-1734:
---
Summary: Insufficient memory allocation in Gelly
Key: FLINK-1734
URL: https://issues.apache.org/jira/browse/FLINK-1734
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367213#comment-14367213
]
Aljoscha Krettek commented on FLINK-1710:
-
It is currently being compiled in one
[
https://issues.apache.org/jira/browse/FLINK-1720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367270#comment-14367270
]
ASF GitHub Bot commented on FLINK-1720:
---
Github user rmetzger commented on a diff in
Till Rohrmann created FLINK-1729:
Summary: Assess performance of classification algorithms
Key: FLINK-1729
URL: https://issues.apache.org/jira/browse/FLINK-1729
Project: Flink
Issue Type:
Till Rohrmann created FLINK-1731:
Summary: Add kMeans clustering algorithm to machine learning
library
Key: FLINK-1731
URL: https://issues.apache.org/jira/browse/FLINK-1731
Project: Flink
Till Rohrmann created FLINK-1732:
Summary: Add Gaussian mixture model to machine learning library
Key: FLINK-1732
URL: https://issues.apache.org/jira/browse/FLINK-1732
Project: Flink
Issue
Till Rohrmann created FLINK-1736:
Summary: Add CountVectorizer to machine learning library
Key: FLINK-1736
URL: https://issues.apache.org/jira/browse/FLINK-1736
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367272#comment-14367272
]
ASF GitHub Bot commented on FLINK-1720:
---
Github user rmetzger commented on a diff in
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/477#issuecomment-83019386
Agree. The project re-structuring is not urgent. I would do it shortly
before the release.
---
If your project is set up for it, you can reply to this email and have
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/489
---
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-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367344#comment-14367344
]
ASF GitHub Bot commented on FLINK-1641:
---
Github user asfgit closed the pull request
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-1192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-1192.
-
Resolution: Invalid
Streaming source fault tolerance
[
https://issues.apache.org/jira/browse/FLINK-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-1641.
---
Resolution: Implemented
Make projection operator chainable
--
[
https://issues.apache.org/jira/browse/FLINK-1709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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:
Till Rohrmann created FLINK-1738:
Summary: Add mean centering transformation to machine learning
library
Key: FLINK-1738
URL: https://issues.apache.org/jira/browse/FLINK-1738
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-1196.
-
Resolution: Invalid
Interfaces wrapping the persistence layer for source fault tolerance
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
[
https://issues.apache.org/jira/browse/FLINK-1184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-1184.
---
Resolution: Implemented
Streaming stateful computation support
[
https://issues.apache.org/jira/browse/FLINK-1350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367422#comment-14367422
]
ASF GitHub Bot commented on FLINK-1350:
---
Github user uce commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367368#comment-14367368
]
Gyula Fora commented on FLINK-1503:
---
Hey,
As you can probably tell from the description
[
https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367521#comment-14367521
]
ASF GitHub Bot commented on FLINK-1739:
---
Github user hsaputra commented on a diff in
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(TypeInformationT typeInfo) {
[
https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367493#comment-14367493
]
ASF GitHub Bot commented on FLINK-1739:
---
GitHub user matadorhong opened a pull
[
https://issues.apache.org/jira/browse/FLINK-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367496#comment-14367496
]
ASF GitHub Bot commented on FLINK-1622:
---
Github user asfgit closed the pull request
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
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
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/500#discussion_r26687518
--- Diff:
[
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-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-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
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
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 {
'
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
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 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
[
https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367575#comment-14367575
]
ASF GitHub Bot commented on FLINK-1739:
---
Github user StephanEwen commented on a diff
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
[
https://issues.apache.org/jira/browse/FLINK-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14367597#comment-14367597
]
ASF GitHub Bot commented on FLINK-1669:
---
Github user StephanEwen commented on the
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:
1 - 100 of 160 matches
Mail list logo
