Github user mlipkovich commented on the issue:
https://github.com/apache/flink/pull/4683
@aljoscha @haohui ,
thank you for your comments. Marked hadoop dependency as provided, set
Hadoop codec as default one
---
Github user mlipkovich commented on a diff in the pull request:
https://github.com/apache/flink/pull/4683#discussion_r141424281
--- Diff: flink-core/pom.xml ---
@@ -52,6 +52,12 @@ under the License.
flink-shaded-asm
Github user mlipkovich commented on a diff in the pull request:
https://github.com/apache/flink/pull/4683#discussion_r140833786
--- Diff: flink-core/pom.xml ---
@@ -52,6 +52,12 @@ under the License.
flink-shaded-asm
Github user mlipkovich commented on a diff in the pull request:
https://github.com/apache/flink/pull/4683#discussion_r140652438
--- Diff: flink-core/pom.xml ---
@@ -52,6 +52,12 @@ under the License.
flink-shaded-asm
Github user mlipkovich commented on the issue:
https://github.com/apache/flink/pull/4655
Thanks! Closing it
---
Github user mlipkovich closed the pull request at:
https://github.com/apache/flink/pull/4655
---
Github user mlipkovich commented on the issue:
https://github.com/apache/flink/pull/4655
Hi @aljoscha
It turned out that exclude filter works if we escape dollar signs. I
commited these changes, but I believe it still should be fixed by japicmp
What do you think about merging
Github user mlipkovich commented on the issue:
https://github.com/apache/flink/pull/4630
@zentol thanks for your comment. As I understand I can't merge it without a
formal review. May I ask you to review it?
---
GitHub user mlipkovich opened a pull request:
https://github.com/apache/flink/pull/4683
[FLINK-5944] Support reading of Snappy files
## What is the purpose of the change
Support reading of Snappy compressed text files (both Xerial and Hadoop
snappy)
## Brief
Github user mlipkovich commented on the issue:
https://github.com/apache/flink/pull/4655
Thansk, Aljoscha
Probably I've forgotten to run `clean`.
The method `iterate$default$3` is a method which automatically created by
Scala for calculation of default value for parameter
Github user mlipkovich commented on the issue:
https://github.com/apache/flink/pull/4655
The local build works fine. If you mean `mvn verify` by compatibility
plugin it also worked with no issues
---
Github user mlipkovich commented on the issue:
https://github.com/apache/flink/pull/4655
As I understand the build has failed because of changed API method. The
method which was changed has annotation PublicEvolving so there should be a way
to change it. As was mentioned by @aljoscha
GitHub user mlipkovich opened a pull request:
https://github.com/apache/flink/pull/4655
[FLINK-7567]: Removed keepPartitioning parameter from iterate method
## What is the purpose of the change
Removed parameter keepPartitioning from DataStream#iterate method since
it's
Github user mlipkovich commented on the issue:
https://github.com/apache/flink/pull/4630
The build has failed but it seems like Travis issue. My changes could not
break it
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
GitHub user mlipkovich opened a pull request:
https://github.com/apache/flink/pull/4630
[FLINK-6733] Remove commented out AvgAggregationFunction.java
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community
15 matches
Mail list logo
