[
https://issues.apache.org/jira/browse/FLINK-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568721#comment-14568721
]
Maximilian Michels commented on FLINK-2127:
---
[~uce] Actually I cannot because I
[
https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568786#comment-14568786
]
Aljoscha Krettek commented on FLINK-2069:
-
Yes, you are right but I think in the
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/743#issuecomment-107875574
While merging realized, that it is missing from the windowed and connected
datastreams and the from the scala API. Also adding those.
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568664#comment-14568664
]
ASF GitHub Bot commented on FLINK-1731:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-2132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568805#comment-14568805
]
Ufuk Celebi commented on FLINK-2132:
Openjdk 7 version string looks as expected:
[
https://issues.apache.org/jira/browse/FLINK-2132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-2132:
--
Assignee: Ufuk Celebi
Java version parsing is not working for OpenJDK
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/743#issuecomment-107853134
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
[
https://issues.apache.org/jira/browse/FLINK-2080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2080:
--
Component/s: Documentation
Execute Flink with sbt
--
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/744#issuecomment-107897490
LGTM. I will merge it as a temporary solution for the manual evaluation.
---
If your project is set up for it, you can reply to this email and have your
reply
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/700#issuecomment-107831123
Hey guys. You might wanna look at the initialization schemes here:
https://github.com/apache/flink/pull/757
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-2132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-2132:
---
Fix Version/s: 0.9
Java version parsing is not working for OpenJDK
[
https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568754#comment-14568754
]
ASF GitHub Bot commented on FLINK-2103:
---
Github user mbalassi commented on the pull
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/743#issuecomment-107854661
Good point, will do that anyway because of the renaming discussed on the
mailing list.
---
If your project is set up for it, you can reply to this email and have your
Ufuk Celebi created FLINK-2132:
--
Summary: Java version parsing is not working for OpenJDK
Key: FLINK-2132
URL: https://issues.apache.org/jira/browse/FLINK-2132
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568850#comment-14568850
]
ASF GitHub Bot commented on FLINK-2102:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568750#comment-14568750
]
ASF GitHub Bot commented on FLINK-2103:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/743#issuecomment-107853775
We should first update the documentation.
---
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
[
https://issues.apache.org/jira/browse/FLINK-1884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1884:
--
Component/s: Documentation
Outdated Spargel docs
-
Key:
[
https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568742#comment-14568742
]
ASF GitHub Bot commented on FLINK-2103:
---
Github user mbalassi commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568812#comment-14568812
]
ASF GitHub Bot commented on FLINK-2103:
---
Github user mbalassi commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568825#comment-14568825
]
Matthias J. Sax commented on FLINK-2132:
Is anyone working on this? I could take
[
https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568766#comment-14568766
]
ASF GitHub Bot commented on FLINK-2098:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/742#issuecomment-107860292
I addressed the problem with the race conditions and re-enabled the twitter
source.
Which exceptions are you referring to? I don't think I touched any of the
[
https://issues.apache.org/jira/browse/FLINK-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-2127.
---
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Maximilian Michels
[
https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568847#comment-14568847
]
Aljoscha Krettek commented on FLINK-2069:
-
Could you maybe share your code? I now
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/762#discussion_r31559688
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java ---
@@ -21,10 +21,16 @@
import java.io.IOException;
import
[
https://issues.apache.org/jira/browse/FLINK-1981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569601#comment-14569601
]
ASF GitHub Bot commented on FLINK-1981:
---
Github user rmetzger commented on a diff in
Github user sekruse commented on a diff in the pull request:
https://github.com/apache/flink/pull/762#discussion_r31562256
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java ---
@@ -628,9 +692,10 @@ public void open(FileInputSplit fileSplit)
[
https://issues.apache.org/jira/browse/FLINK-1981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569625#comment-14569625
]
ASF GitHub Bot commented on FLINK-1981:
---
Github user sekruse commented on a diff in
GitHub user andralungu opened a pull request:
https://github.com/apache/flink/pull/763
[docs/javadoc][hotfix] Corrected Join hint and misleadling pointer to
Spargel
This PR adds the following patches:
- in the Iteration programming guide, there was a misleading link to
[
https://issues.apache.org/jira/browse/FLINK-1981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569638#comment-14569638
]
ASF GitHub Bot commented on FLINK-1981:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569589#comment-14569589
]
ASF GitHub Bot commented on FLINK-1981:
---
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/762#discussion_r31562955
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java ---
@@ -628,9 +692,10 @@ public void open(FileInputSplit fileSplit)
[
https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569675#comment-14569675
]
ASF GitHub Bot commented on FLINK-2069:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/759#issuecomment-108083643
Are there any tests for the streaming output formats?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569669#comment-14569669
]
ASF GitHub Bot commented on FLINK-1319:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/729#issuecomment-108081964
How about extending the `UDF contains obvious errors` message with some
notes on how to completely disable the SCA.
I fear that the message appears (blocks the
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/729#issuecomment-108093699
I agree with Robert, but for the initial version it won't matter as it
should be disabled anyways.
---
If your project is set up for it, you can reply to this email and
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/759#issuecomment-108093780
Not enough. `writeAsText` is covered a number of times in the integration
tests and ITCases, but there is no test for other output formats.
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569725#comment-14569725
]
ASF GitHub Bot commented on FLINK-2069:
---
Github user mbalassi commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569723#comment-14569723
]
ASF GitHub Bot commented on FLINK-1319:
---
Github user uce commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sachin Goel reassigned FLINK-2108:
--
Assignee: Sachin Goel
Add score function for Predictors
-
GitHub user mfahimazizi opened a pull request:
https://github.com/apache/flink/pull/765
Hits
HITS algorithm in Gelly.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mfahimazizi/flink HITS
Alternatively you can review and apply
Márton Balassi created FLINK-2138:
-
Summary: PartitionCustom for streaming
Key: FLINK-2138
URL: https://issues.apache.org/jira/browse/FLINK-2138
Project: Flink
Issue Type: New Feature
GitHub user mbalassi opened a pull request:
https://github.com/apache/flink/pull/764
[contrib] Storm compatibility
This is an updated version of #573.
@mjsax addressed a number of comments since then and added Readmes, @szape
did a code review and added an extra interface
Márton Balassi created FLINK-2139:
-
Summary: Test Streaming Outputformats
Key: FLINK-2139
URL: https://issues.apache.org/jira/browse/FLINK-2139
Project: Flink
Issue Type: Test
Márton Balassi created FLINK-2136:
-
Summary: Test the streaming scala API
Key: FLINK-2136
URL: https://issues.apache.org/jira/browse/FLINK-2136
Project: Flink
Issue Type: Test
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/764#issuecomment-108118618
Oh, and one more info for @mjsax: I added you as collaborator to my repo,
so you can directly push to this branch.
---
If your project is set up for it, you can reply
Márton Balassi created FLINK-2137:
-
Summary: Expose partitionByHash for WindowedDataStream
Key: FLINK-2137
URL: https://issues.apache.org/jira/browse/FLINK-2137
Project: Flink
Issue Type:
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/759#issuecomment-108122772
Added a JIRA for the
[issue](https://issues.apache.org/jira/browse/FLINK-2139).
---
If your project is set up for it, you can reply to this email and have your
reply
GitHub user hsaputra opened a pull request:
https://github.com/apache/flink/pull/766
Remove extra HTML tags in TypeInformation JavaDoc class header.
Simple clean up PR remove extra ```li``` HTML tags in TypeInformation
JavaDoc class header.
You can merge this pull request into a
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568988#comment-14568988
]
ASF GitHub Bot commented on FLINK-1319:
---
Github user rmetzger commented on the pull
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/753
---
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
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/729#issuecomment-107924813
I understand that concern.
But using sysoutput will also be interleaved with the Client sysout
printing and the regular system logging.
Also, I think its
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568994#comment-14568994
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user mjsax commented on the pull
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/758
[ml] Rework of the optimization framework
This PR reworks the current optimization framework to make the
regularization part of the optimization algorithm. Furthermore, it consolidates
the
[
https://issues.apache.org/jira/browse/FLINK-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-2102.
--
Resolution: Fixed
Added via d163a817fa2e330e86384d0bbcd104f051a6fb48
Add predict operation
[
https://issues.apache.org/jira/browse/FLINK-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568966#comment-14568966
]
ASF GitHub Bot commented on FLINK-2102:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/744
---
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
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/740
---
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
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/740#issuecomment-107903012
I closed this PR to open it as a proper PR again.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568874#comment-14568874
]
ASF GitHub Bot commented on FLINK-1430:
---
Github user asfgit closed the pull request
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/758#issuecomment-107905323
This PR is the new PR for #740.
---
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
[
https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568999#comment-14568999
]
Faye Beligianni commented on FLINK-2069:
Hello, I am using a timeout of 1 in
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569150#comment-14569150
]
ASF GitHub Bot commented on FLINK-1319:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/729#discussion_r31527840
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/UdfAnalysisMode.java ---
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569154#comment-14569154
]
ASF GitHub Bot commented on FLINK-1319:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569132#comment-14569132
]
Robert Metzger commented on FLINK-2130:
---
I would let the source fail. All the other
[
https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569137#comment-14569137
]
Aljoscha Krettek commented on FLINK-2069:
-
Ha! I can finally reproduce it. No fix
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/729#discussion_r31527970
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/UdfAnalysisMode.java ---
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569184#comment-14569184
]
Aljoscha Krettek commented on FLINK-2069:
-
I think I finally fixed it. Could you
[
https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569183#comment-14569183
]
ASF GitHub Bot commented on FLINK-2069:
---
GitHub user aljoscha opened a pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/729#discussion_r31530742
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/SingleInputUdfOperator.java
---
@@ -54,8 +54,11 @@
private MapString,
[
https://issues.apache.org/jira/browse/FLINK-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2130:
--
Component/s: Streaming Connectors
Streaming
RabbitMQ source does not fail
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569152#comment-14569152
]
ASF GitHub Bot commented on FLINK-1319:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569202#comment-14569202
]
ASF GitHub Bot commented on FLINK-1319:
---
Github user uce commented on a diff in the
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/750#issuecomment-107926235
Hi,
after thinking about the signal name again, I disagree. terminate does
not mean kill, but is a request to gracefully shut down. stop from my point
of view is too
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/729#discussion_r31528084
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/UdfAnalysisMode.java ---
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569179#comment-14569179
]
ASF GitHub Bot commented on FLINK-2069:
---
Github user aljoscha closed the pull
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/759
[FLINK-2069] Fix Scala CSV Output Format
Before, the Scala Streaming API used the Java CsvOutputFormat. This is not
compatible with Scala Tuples. The FileSinkFunction would silently swallow the
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/758
---
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-2133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569035#comment-14569035
]
Aljoscha Krettek commented on FLINK-2133:
-
Also, this is on my
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569042#comment-14569042
]
ASF GitHub Bot commented on FLINK-1319:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569062#comment-14569062
]
Ufuk Celebi commented on FLINK-2133:
I've looked at the ExecutionGraph and this seems
[
https://issues.apache.org/jira/browse/FLINK-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569096#comment-14569096
]
Márton Balassi commented on FLINK-2130:
---
This was a conscious design choice, so we
[
https://issues.apache.org/jira/browse/FLINK-2133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569032#comment-14569032
]
Aljoscha Krettek commented on FLINK-2133:
-
This was the whole travis run:
[
https://issues.apache.org/jira/browse/FLINK-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1430.
-
Resolution: Implemented
Fix Version/s: 0.9
Implemented via 50c818d
Add test for
Aljoscha Krettek created FLINK-2133:
---
Summary: Possible deadlock in ExecutionGraph
Key: FLINK-2133
URL: https://issues.apache.org/jira/browse/FLINK-2133
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-2134:
--
Summary: Deadlock in SuccessAfterNetworkBuffersFailureITCase
Key: FLINK-2134
URL: https://issues.apache.org/jira/browse/FLINK-2134
Project: Flink
Issue Type:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/729#issuecomment-107941730
Naming UDF. The feedback of committers giving talks about Flink some time
ago was that the name UDF was sometimes confusing. @rmetzger, can you confirm
this? We might
[
https://issues.apache.org/jira/browse/FLINK-2128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi resolved FLINK-2128.
Resolution: Duplicate
ScalaShellITSuite failing
-
Key:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/729#discussion_r31531993
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/SingleInputUdfOperator.java
---
@@ -54,8 +54,11 @@
private MapString,
[
https://issues.apache.org/jira/browse/FLINK-1993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569220#comment-14569220
]
ASF GitHub Bot commented on FLINK-1993:
---
GitHub user tillrohrmann opened a pull
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/729#discussion_r31532320
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/sca/UdfAnalyzer.java ---
@@ -0,0 +1,431 @@
+/*
+ * Licensed to the Apache Software Foundation
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/729#discussion_r31532974
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/UdfOperatorUtils.java
---
@@ -0,0 +1,94 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569242#comment-14569242
]
ASF GitHub Bot commented on FLINK-1319:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569218#comment-14569218
]
ASF GitHub Bot commented on FLINK-1319:
---
Github user uce commented on a diff in the
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/760
[FLINK-1993] [ml] Replaces custom SGD in MultipleLinearRegression with
optimizer's SGD
This PR replaces the custom SGD implementation with the optimization
framework's SGD implementation.
You
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569271#comment-14569271
]
ASF GitHub Bot commented on FLINK-1319:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/729#discussion_r31535397
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/UdfOperatorUtils.java
---
@@ -0,0 +1,94 @@
+/*
+ * Licensed to the Apache Software
1 - 100 of 123 matches
Mail list logo
