GitHub user Fokko opened a pull request:
https://github.com/apache/flink/pull/3280
[Flink-5724] Error in documentation zipping elements
Because the Scala tab is defined twice, it is not possible to open
the Python tab.
Please look at the documentation page itself
Github user Fokko commented on the pull request:
https://github.com/apache/flink/commit/32e1675aa38eec4a15272d62977dfe3ddbe92401#commitcomment-20632930
Did not know this, thanks.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Github user Fokko commented on the issue:
https://github.com/apache/flink/pull/3077
@tillrohrmann I've added documentation about the algorithm. Can you check?
Cheers, Fokko
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user Fokko commented on the issue:
https://github.com/apache/flink/pull/3081
I've rebased both branches with master.
---
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
Github user Fokko commented on the issue:
https://github.com/apache/flink/pull/3081
Hi @tillrohrmann, did you find any time to check #3077 and this 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
Github user Fokko commented on the issue:
https://github.com/apache/flink/pull/3077
Thanks @tillrohrmann, excellent idea regarding the documentation. I'll also
process the code comments, good feedback. Somewhere today or tomorrow I will
fix this.
Cheers, Fokko
---
If your
Github user Fokko commented on a diff in the pull request:
https://github.com/apache/flink/pull/3077#discussion_r96290195
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/outlier/StochasticOutlierSelection.scala
---
@@ -0,0 +1,367 @@
+/*
+ * Licensed
Github user Fokko commented on a diff in the pull request:
https://github.com/apache/flink/pull/3077#discussion_r96290218
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/outlier/StochasticOutlierSelection.scala
---
@@ -0,0 +1,367 @@
+/*
+ * Licensed
Github user Fokko commented on a diff in the pull request:
https://github.com/apache/flink/pull/3077#discussion_r96290365
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/outlier/StochasticOutlierSelection.scala
---
@@ -0,0 +1,367 @@
+/*
+ * Licensed
Github user Fokko closed the pull request at:
https://github.com/apache/flink/pull/3052
---
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 Fokko commented on the issue:
https://github.com/apache/flink/pull/3052
Alright, just rebased with master. Looks like that the Travis is working
again, good job!
Cheers!
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user Fokko commented on the issue:
https://github.com/apache/flink/pull/2442
Looks good, please merge. Should have been fixed long ago :-)
---
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
Github user Fokko closed the pull request at:
https://github.com/apache/flink/pull/3048
---
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 Fokko opened a pull request:
https://github.com/apache/flink/pull/3081
[FLINK-5426] Clean up the Flink Machine Learning library
Hi guys,
I would like to contribute to the Flink ML library. I took the liberty to
clean up some of the code and improve the scaladoc
Github user Fokko commented on the issue:
https://github.com/apache/flink/pull/3081
I think we have some flakey tests, since it passes on my own travis:
https://travis-ci.org/Fokko/flink/builds/189855914
---
If your project is set up for it, you can reply to this email and have
Github user Fokko commented on the issue:
https://github.com/apache/flink/pull/3081
I think we have some flakey tests, since it passes on my own travis:
https://travis-ci.org/Fokko/flink/builds/189854940
---
If your project is set up for it, you can reply to this email and have
Github user Fokko commented on the issue:
https://github.com/apache/flink/pull/3077
I think we have some flakey tests, since it passes on my own travis:
https://travis-ci.org/Fokko/flink/builds/189855914
---
If your project is set up for it, you can reply to this email and have
GitHub user Fokko opened a pull request:
https://github.com/apache/flink/pull/3052
Swap the pattern matching order
Swap the pattern matching order, because `EuclideanDistanceMetric extends
SquaredEuclideanDistanceMetric extends DistanceMetric`, otherwise the
EuclideanDistance
GitHub user Fokko opened a pull request:
https://github.com/apache/flink/pull/3077
[FLINK-5423] Implement Stochastic Outlier Selection
Implemented the Stochastic Outlier Selection algorithm in the Machine
Learning library, including the test code. Added documentation
Github user Fokko commented on the issue:
https://github.com/apache/flink/pull/3048
Locally the tests just pass. Looking at the error logs, it doesn't have to
do with the changes in the PR, for example:
```
java.io.FileNotFoundException: build-target/lib/flink-dist-*.jar
GitHub user Fokko opened a pull request:
https://github.com/apache/flink/pull/3048
Clarified the import path of the Breeze DenseVector
Guys,
I'm working on an extension of the ml library on Flink, but I stumbled upon
this. Since it is such a trivial fix, I didn't created
Github user Fokko commented on the issue:
https://github.com/apache/flink/pull/4072
Hi @tzulitai,
I fully agree. Give me some time to work on the other Scala examples, I
need to make sure that they are working properly. I'll wrap it up this week.
I'll update the commit
GitHub user Fokko opened a pull request:
https://github.com/apache/flink/pull/4072
[FLINK-6848] Update managed state docs
Hi guys,
I would like to add an example of how to work with managed state in Scala.
The code is tested locally and might be a nice addition to the docs
Github user Fokko commented on the issue:
https://github.com/apache/flink/pull/4072
Hi @tzulitai,
I've added some more Scala examples. If you are still missing something,
please let me know.
Kind regards, Fokko
---
If your project is set up for it, you can reply
Fokko Driesprong created FLINK-5724:
---
Summary: Error in the 'Zipping Elements' docs
Key: FLINK-5724
URL: https://issues.apache.org/jira/browse/FLINK-5724
Project: Flink
Issue Type: Bug
Fokko Driesprong created FLINK-5426:
---
Summary: Clean up the Flink Machine Learning library
Key: FLINK-5426
URL: https://issues.apache.org/jira/browse/FLINK-5426
Project: Flink
Issue Type
Fokko Driesprong created FLINK-5423:
---
Summary: Implement Stochastic Outlier Selection
Key: FLINK-5423
URL: https://issues.apache.org/jira/browse/FLINK-5423
Project: Flink
Issue Type
Fokko Driesprong created FLINK-6848:
---
Summary: Extend the managed state docs with a Scala example
Key: FLINK-6848
URL: https://issues.apache.org/jira/browse/FLINK-6848
Project: Flink
Issue
Fokko Driesprong created FLINK-11347:
Summary: Optimize the ParquetAvroWriters factory
Key: FLINK-11347
URL: https://issues.apache.org/jira/browse/FLINK-11347
Project: Flink
Issue Type
Fokko Driesprong created FLINK-11371:
Summary: Close the AvroParquetReader after use
Key: FLINK-11371
URL: https://issues.apache.org/jira/browse/FLINK-11371
Project: Flink
Issue Type
Fokko Driesprong created FLINK-11322:
Summary: Use try-with-resource for FlinkKafkaConsumer010
Key: FLINK-11322
URL: https://issues.apache.org/jira/browse/FLINK-11322
Project: Flink
Fokko Driesprong created FLINK-11321:
Summary: Clarify the NPE on fetching an nonexistent Kafka topic
Key: FLINK-11321
URL: https://issues.apache.org/jira/browse/FLINK-11321
Project: Flink
Fokko Driesprong created FLINK-11339:
Summary: Bump exec-maven-plugin from 1.5.0 to 1.6.0
Key: FLINK-11339
URL: https://issues.apache.org/jira/browse/FLINK-11339
Project: Flink
Issue
Fokko Driesprong created FLINK-11338:
Summary: Bump maven-enforcer-plugin from 3.0.0-M1 to 3.0.0-M2
Key: FLINK-11338
URL: https://issues.apache.org/jira/browse/FLINK-11338
Project: Flink
Fokko Driesprong created FLINK-11340:
Summary: Bump commons-configuration from 1.7 to 1.10
Key: FLINK-11340
URL: https://issues.apache.org/jira/browse/FLINK-11340
Project: Flink
Issue
Fokko Driesprong created FLINK-11401:
Summary: Allow compression on ParquetBulkWriter
Key: FLINK-11401
URL: https://issues.apache.org/jira/browse/FLINK-11401
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-11401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749744#comment-16749744
]
Fokko Driesprong commented on FLINK-11401:
--
Thanks for the comment [~StephanEwen
Fokko Driesprong created FLINK-11265:
Summary: Invalid reference to AvroSinkWriter in example
AvroKeyValueSinkWriter
Key: FLINK-11265
URL: https://issues.apache.org/jira/browse/FLINK-11265
Fokko Driesprong created FLINK-11258:
Summary: Add badge to the README
Key: FLINK-11258
URL: https://issues.apache.org/jira/browse/FLINK-11258
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-11260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fokko Driesprong updated FLINK-11260:
-
Description: Bump the Janino depdency:
http://janino-compiler.github.io/janino
[
https://issues.apache.org/jira/browse/FLINK-11260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fokko Driesprong updated FLINK-11260:
-
Description: Bump the Janino dependency:
http://janino-compiler.github.io/janino
Fokko Driesprong created FLINK-11262:
Summary: Bump jython-standalone to 2.7.1
Key: FLINK-11262
URL: https://issues.apache.org/jira/browse/FLINK-11262
Project: Flink
Issue Type
Fokko Driesprong created FLINK-11259:
Summary: Bump Zookeeper dependency to 3.4.13
Key: FLINK-11259
URL: https://issues.apache.org/jira/browse/FLINK-11259
Project: Flink
Issue Type
Fokko Driesprong created FLINK-11260:
Summary: Bump Janino compiler dependency
Key: FLINK-11260
URL: https://issues.apache.org/jira/browse/FLINK-11260
Project: Flink
Issue Type
Fokko Driesprong created FLINK-11306:
Summary: Bump derby from 10.10.1.1 to 10.14.2.0
Key: FLINK-11306
URL: https://issues.apache.org/jira/browse/FLINK-11306
Project: Flink
Issue Type
Fokko Driesprong created FLINK-11992:
Summary: Update Apache Parquet 1.10.1
Key: FLINK-11992
URL: https://issues.apache.org/jira/browse/FLINK-11992
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-11378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785587#comment-16785587
]
Fokko Driesprong edited comment on FLINK-11378 at 3/6/19 12:55 PM
[
https://issues.apache.org/jira/browse/FLINK-11378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785587#comment-16785587
]
Fokko Driesprong commented on FLINK-11378:
--
FLINK-11378 should supersede this ticket.
> Al
Fokko Driesprong created FLINK-11838:
Summary: Create RecoverableWriter for GCS
Key: FLINK-11838
URL: https://issues.apache.org/jira/browse/FLINK-11838
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-11883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fokko Driesprong updated FLINK-11883:
-
Summary: Harmonize the version of maven-shade-plugin (was: Harmonize the
versions
[
https://issues.apache.org/jira/browse/FLINK-11883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fokko Driesprong updated FLINK-11883:
-
Affects Version/s: 1.7.2
> Harmonize the version of maven-shade-plu
[
https://issues.apache.org/jira/browse/FLINK-11883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fokko Driesprong updated FLINK-11883:
-
Component/s: Build System
> Harmonize the version of maven-shade-plu
Fokko Driesprong created FLINK-11883:
Summary: Harmonize the versions of the
Key: FLINK-11883
URL: https://issues.apache.org/jira/browse/FLINK-11883
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-11883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fokko Driesprong reassigned FLINK-11883:
Assignee: Fokko Driesprong
> Harmonize the version of maven-shade-plu
[
https://issues.apache.org/jira/browse/FLINK-11911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fokko Driesprong updated FLINK-11911:
-
Affects Version/s: (was: 1.7.2)
1.8.0
> KafkaTopicPartit
Fokko Driesprong created FLINK-11911:
Summary: KafkaTopicPartition is not a valid POJO
Key: FLINK-11911
URL: https://issues.apache.org/jira/browse/FLINK-11911
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-11883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fokko Driesprong closed FLINK-11883.
Resolution: Won't Fix
> Harmonize the version of maven-shade-plu
[
https://issues.apache.org/jira/browse/FLINK-11992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fokko Driesprong closed FLINK-11992.
Resolution: Won't Fix
> Update Apache Parquet 1.1
[
https://issues.apache.org/jira/browse/FLINK-12250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fokko Driesprong updated FLINK-12250:
-
Description: While debugging some code, I've noticed assembleNewPartPath
does
Fokko Driesprong created FLINK-12250:
Summary: Rewrite assembleNewPartPath to let it return a new
PartPath
Key: FLINK-12250
URL: https://issues.apache.org/jira/browse/FLINK-12250
Project: Flink
Fokko Driesprong created FLINK-12338:
Summary: Update Apache Avro test to use try-with-resources
Key: FLINK-12338
URL: https://issues.apache.org/jira/browse/FLINK-12338
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-12330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825818#comment-16825818
]
Fokko Driesprong commented on FLINK-12330:
--
Python2 is EOL end this year. Many projects
Fokko Driesprong created FLINK-12225:
Summary: Simplify the interface of the PartFileWriter
Key: FLINK-12225
URL: https://issues.apache.org/jira/browse/FLINK-12225
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-12225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fokko Driesprong reassigned FLINK-12225:
Assignee: Fokko Driesprong
> Simplify the interface of the PartFileWri
[
https://issues.apache.org/jira/browse/FLINK-12330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826702#comment-16826702
]
Fokko Driesprong commented on FLINK-12330:
--
My personal preference is using Docker
Fokko Driesprong created FLINK-13796:
Summary: Remove unused variable
Key: FLINK-13796
URL: https://issues.apache.org/jira/browse/FLINK-13796
Project: Flink
Issue Type: Task
Fokko Driesprong created FLINK-13797:
Summary: Add missing format argument
Key: FLINK-13797
URL: https://issues.apache.org/jira/browse/FLINK-13797
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-9749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fokko Driesprong updated FLINK-9749:
Description:
The BucketingSink has a series of deficits at the moment.
Due to the long
68 matches
Mail list logo
