[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14565756#comment-14565756
]
ASF GitHub Bot commented on FLINK-2111:
---
GitHub user mjsax opened a pull request:
GitHub user mjsax opened a pull request:
https://github.com/apache/flink/pull/750
[FLINK-2111] Add "terminate" signal to cleanly stop streaming jobs
added TERMINATE signal
- JobManager, TaskManager, ExecutionGraph
- CliFrontend, JobManagerFrontend
- StreamTask, Stre
[
https://issues.apache.org/jira/browse/FLINK-2061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-2061.
Thanks for the fix!
> CSVReader: quotedStringParsing and includeFields yields ParseException
>
[
https://issues.apache.org/jira/browse/FLINK-2061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-2061.
--
Resolution: Fixed
Fixed with 12cd15622afbbcbb40c9dd80151f4ca459a26922
> CSVReader: quotedString
[
https://issues.apache.org/jira/browse/FLINK-2061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14565431#comment-14565431
]
ASF GitHub Bot commented on FLINK-2061:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/734
---
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
[
https://issues.apache.org/jira/browse/FLINK-1735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14565295#comment-14565295
]
ASF GitHub Bot commented on FLINK-1735:
---
Github user aalexandrov commented on the pu
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/665#issuecomment-106914608
@FelixNeutatz I think this needs to be squashed before mergning as well.
---
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-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14565275#comment-14565275
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user aalexandrov commented on the pu
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-106911412
Can anybody with more Apache insight answer to @peedeeX21 concerns?
Otherwise I suggest to merge this and open a follow-up issue that extends the
current implementati
[
https://issues.apache.org/jira/browse/FLINK-2061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14565271#comment-14565271
]
ASF GitHub Bot commented on FLINK-2061:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/734#issuecomment-106910782
Nice fix and good test case, thanks!
Will run the tests and merge it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/730#issuecomment-106910157
@rbraeunlich please squash the commits and prepare this for merging.
---
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-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14565253#comment-14565253
]
ASF GitHub Bot commented on FLINK-1979:
---
Github user aalexandrov commented on the pu
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/656#issuecomment-106907665
This needs a PR before it is merged. @jojo19893, @mguldner please cherry
pick your changes such that you have only one or two commits and force push in
this branch as
Fabian Hueske created FLINK-2118:
Summary: Table API fails on composite filter conditions
Key: FLINK-2118
URL: https://issues.apache.org/jira/browse/FLINK-2118
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-2113.
--
Resolution: Fixed
Fix Version/s: 0.9
Fixed in 7cb35ea.
> env.execute() is no longer needed after
[
https://issues.apache.org/jira/browse/FLINK-2113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14565031#comment-14565031
]
ASF GitHub Bot commented on FLINK-2113:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/749
---
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
[
https://issues.apache.org/jira/browse/FLINK-2113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14565025#comment-14565025
]
ASF GitHub Bot commented on FLINK-2113:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/749#issuecomment-106863292
Looks good to me. Will merge 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 ha
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/740#discussion_r31339216
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala
---
@@ -88,217 +55,296 @@ class GradientDescent() exte
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/740#discussion_r31338885
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala
---
@@ -88,217 +55,296 @@ class GradientDescent()
[
https://issues.apache.org/jira/browse/FLINK-2117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mikio Braun updated FLINK-2117:
---
Issue Type: New Feature (was: Improvement)
> Add a set of data generators
> -
Mikio Braun created FLINK-2117:
--
Summary: Add a set of data generators
Key: FLINK-2117
URL: https://issues.apache.org/jira/browse/FLINK-2117
Project: Flink
Issue Type: Improvement
Comp
Mikio Braun created FLINK-2116:
--
Summary: Make pipeline extension require less coding
Key: FLINK-2116
URL: https://issues.apache.org/jira/browse/FLINK-2116
Project: Flink
Issue Type: Improvement
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/740#discussion_r31337368
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala
---
@@ -88,217 +55,296 @@ class GradientDescent()
[
https://issues.apache.org/jira/browse/FLINK-2113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564987#comment-14564987
]
ASF GitHub Bot commented on FLINK-2113:
---
GitHub user andralungu opened a pull reques
GitHub user andralungu opened a pull request:
https://github.com/apache/flink/pull/749
[FLINK-2113][gelly] removed env.execute() after print()
This PR removes all the env.execute() that occur after a Dataset.print() in
gelly examples to fit the new functionality.
@uce can you h
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/740#discussion_r31336757
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala
---
@@ -88,217 +55,296 @@ class GradientDescent() exte
[
https://issues.apache.org/jira/browse/FLINK-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564930#comment-14564930
]
ASF GitHub Bot commented on FLINK-2102:
---
Github user thvasilo commented on the pull
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/744#issuecomment-106840541
@tillrohrmann I added a description for SVM and MLR
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If yo
Fabian Hueske created FLINK-2115:
Summary: TableAPI throws ExpressionException for "Dangling GroupBy
operation"
Key: FLINK-2115
URL: https://issues.apache.org/jira/browse/FLINK-2115
Project: Flink
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/744#issuecomment-106832309
OK I'm on it.
---
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-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564912#comment-14564912
]
ASF GitHub Bot commented on FLINK-2102:
---
Github user thvasilo commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1687.
-
Resolution: Implemented
Fix Version/s: 0.9
Implemented via 1c3b67e and 120bd0f.
> Streamin
[
https://issues.apache.org/jira/browse/FLINK-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-1687:
--
Comment: was deleted
(was: Implemented via 1c3b67e and 120bd0f.)
> Streaming file source/sink A
[
https://issues.apache.org/jira/browse/FLINK-2113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564842#comment-14564842
]
Andra Lungu commented on FLINK-2113:
I will do it today! I just need to go to a meetin
[
https://issues.apache.org/jira/browse/FLINK-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564843#comment-14564843
]
Márton Balassi commented on FLINK-1687:
---
Implemented via 1c3b67e and 120bd0f.
> Str
[
https://issues.apache.org/jira/browse/FLINK-2114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564840#comment-14564840
]
ASF GitHub Bot commented on FLINK-2114:
---
GitHub user ggevay opened a pull request:
GitHub user ggevay opened a pull request:
https://github.com/apache/flink/pull/748
[FLINK-2114] [streaming] Fix null check in PunctuationPolicy.toString()
Added missing parenthesis, and added a call to PunctuationPolicy.toString()
in a test.
You can merge this pull request into a G
[
https://issues.apache.org/jira/browse/FLINK-2113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564839#comment-14564839
]
Ufuk Celebi commented on FLINK-2113:
Can you fix this before the release? I think it's
Gabor Gevay created FLINK-2114:
--
Summary: PunctuationPolicy.toString() throws NullPointerException
if extractor is null
Key: FLINK-2114
URL: https://issues.apache.org/jira/browse/FLINK-2114
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-2112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-2112.
-
Resolution: Fixed
Fix Version/s: 0.9
Fixed via 0fd6023.
> Wrong package statement in Kafka
[
https://issues.apache.org/jira/browse/FLINK-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564836#comment-14564836
]
ASF GitHub Bot commented on FLINK-1687:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/738
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/521
---
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 senorcarbone commented on a diff in the pull request:
https://github.com/apache/flink/pull/747#discussion_r31325009
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCommittingOperator.java
---
@@ -18,7 +18,10 @@
package
[
https://issues.apache.org/jira/browse/FLINK-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564764#comment-14564764
]
ASF GitHub Bot commented on FLINK-2102:
---
Github user tillrohrmann commented on the p
Andra Lungu created FLINK-2113:
--
Summary: env.execute() is no longer needed after a call to print()
Key: FLINK-2113
URL: https://issues.apache.org/jira/browse/FLINK-2113
Project: Flink
Issue Typ
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/744#issuecomment-106797811
Nice work @thvasilo. The only thing which is missing is the update to the
online docs where we say which types are supported for which operation.
---
If your projec
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/740#issuecomment-106795878
I updated the PR
---
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 f
[
https://issues.apache.org/jira/browse/FLINK-2054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564688#comment-14564688
]
Aljoscha Krettek commented on FLINK-2054:
-
No, I'm working on getting the checkpoi
[
https://issues.apache.org/jira/browse/FLINK-2054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564645#comment-14564645
]
Gyula Fora commented on FLINK-2054:
---
[~aljoscha] have you started working on this?
I t
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14562654#comment-14562654
]
Mohammad Fahim Azizi edited comment on FLINK-2044 at 5/29/15 11:02 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14562654#comment-14562654
]
Mohammad Fahim Azizi edited comment on FLINK-2044 at 5/29/15 11:00 AM:
-
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/747#issuecomment-106773689
Generally looks good. I was wondering whether we could use Flink's
serialization instead of having `Serializable` as a bound - do we have always
Flink code on every side
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/747#discussion_r31314851
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCommittingOperator.java
---
@@ -18,7 +18,10 @@
package org
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/747
New operator state interfaces
This PR contains the proposed changes for the streaming operator state
interfaces as described in
https://docs.google.com/document/d/1nTn4Tpafsnt-TCT6L1vlHtGGgR
Matthias J. Sax created FLINK-2112:
--
Summary: Wrong package statement in KafkaITCase and
KafkaLocalSystemTime
Key: FLINK-2112
URL: https://issues.apache.org/jira/browse/FLINK-2112
Project: Flink
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/746
Fix handling of receiver and sender task failures
**Sender task failures** (1955)
- Produced result partition becomes erroneous with a ProducerFailedException
- Receiver cancels itself when encoun
Matthias J. Sax created FLINK-2111:
--
Summary: Add "terminate" signal to cleanly stop streaming jobs
Key: FLINK-2111
URL: https://issues.apache.org/jira/browse/FLINK-2111
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-2109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-2109.
--
Resolution: Fixed
Fix Version/s: 0.9
> CancelTaskException leads to FAILED task state
> -
[
https://issues.apache.org/jira/browse/FLINK-2109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reopened FLINK-2109:
Forgot to set the fix version.
> CancelTaskException leads to FAILED task state
> -
[
https://issues.apache.org/jira/browse/FLINK-2109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-2109.
--
Resolution: Fixed
Fixed in d594d02
> CancelTaskException leads to FAILED task state
> -
[
https://issues.apache.org/jira/browse/FLINK-2109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564434#comment-14564434
]
ASF GitHub Bot commented on FLINK-2109:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/745
---
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 thvasilo commented on the pull request:
https://github.com/apache/flink/pull/744#issuecomment-106745455
@sachingoel0101 Yes, that is partially covered by
[FLINK-2108](https://issues.apache.org/jira/browse/FLINK-2108), and an
evaluation framework (along with cross-validatio
[
https://issues.apache.org/jira/browse/FLINK-2109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564429#comment-14564429
]
ASF GitHub Bot commented on FLINK-2109:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/745#issuecomment-106747103
Merging 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 have this feature
enable
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/745#issuecomment-106746620
Good fix.
+1 to merge very soon!
---
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 proj
[
https://issues.apache.org/jira/browse/FLINK-2109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564426#comment-14564426
]
ASF GitHub Bot commented on FLINK-2109:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564420#comment-14564420
]
ASF GitHub Bot commented on FLINK-2102:
---
Github user thvasilo commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564379#comment-14564379
]
Márton Balassi commented on FLINK-2103:
---
One slight difference is that the GroupedDa
[
https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564372#comment-14564372
]
Márton Balassi commented on FLINK-2103:
---
I see that the batch API also has it, so it
[
https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564363#comment-14564363
]
Aljoscha Krettek commented on FLINK-2103:
-
For example if they want to make sure t
[
https://issues.apache.org/jira/browse/FLINK-2047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-2047.
--
Resolution: Fixed
Fixed in d1d2ccc6369a0b459a373c264da49f0a703b4aec
> Rename CoCoA to SVM
> ---
[
https://issues.apache.org/jira/browse/FLINK-2047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564354#comment-14564354
]
Till Rohrmann commented on FLINK-2047:
--
Nice catch [~chiwanpark]. Was my bad. I fixed
78 matches
Mail list logo
