Github user soniclavier closed the pull request at:
https://github.com/apache/flink/pull/4422
---
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 soniclavier commented on the issue:
https://github.com/apache/flink/pull/4422
@aljoscha Thanks for taking a look. I have modified the test.
---
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 soniclavier commented on the issue:
https://github.com/apache/flink/pull/4422
Link to passed Travis build :
https://travis-ci.org/soniclavier/flink/builds/259243850
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
GitHub user soniclavier opened a pull request:
https://github.com/apache/flink/pull/4422
[FLINK-7299][AVRO] Write GenericRecord using AvroOutputFormat
## What is the purpose of the change
Allow writing Avro GenericRecord using AvroOutputFormat.
## Brief change log
Github user soniclavier closed the pull request at:
https://github.com/apache/flink/pull/3763
---
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 soniclavier opened a pull request:
https://github.com/apache/flink/pull/3763
[FLINK-6372][scripts] Fix change scala version of flink-gelly-examples
- changed change-scala-version.sh
You can merge this pull request into a Git repository by running:
$ git pull https
Github user soniclavier commented on the issue:
https://github.com/apache/flink/pull/2736
I don't think I can edit a closed issue, could you please make the edit.
---
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
Github user soniclavier commented on the issue:
https://github.com/apache/flink/pull/2736
Thank you for your guidance @aljoscha ð. Could you please tell me what
Fix version I should keep for these JIRAs
---
If your project is set up for it, you can reply to this email and have
Github user soniclavier closed the pull request at:
https://github.com/apache/flink/pull/2736
---
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 soniclavier commented on the issue:
https://github.com/apache/flink/pull/2736
@aljoscha made the changes as per your comments, could you please review 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 soniclavier commented on a diff in the pull request:
https://github.com/apache/flink/pull/2355#discussion_r86656836
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java
---
@@ -236,6 +236,6 @@ public int compare
Github user soniclavier commented on the issue:
https://github.com/apache/flink/pull/2736
@aljoscha I have made the changes, could you please review 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
Github user soniclavier commented on a diff in the pull request:
https://github.com/apache/flink/pull/2736#discussion_r86462637
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/EvictingWindowOperator.java
---
@@ -273,32 +284,93
GitHub user soniclavier opened a pull request:
https://github.com/apache/flink/pull/2736
[FLINK-4174] Enhance evictor functionality
The PR implements
[FLINK-4174](https://issues.apache.org/jira/browse/FLINK-4174) Enhance window
evictor as proposed in
[FLIP-4](https
Github user soniclavier commented on the issue:
https://github.com/apache/flink/pull/2051
One more question, is it possible to configure the JobManager Actor path
that the client connects to, it looks like it default to
`akka://flink/user/jobmanager`.
In that way I can create
Github user soniclavier commented on the issue:
https://github.com/apache/flink/pull/2051
Sorry, the compilation error was because the Tuple2 was scala.Tuple2 not
flink Tuple2. Changing to `org.apache.flink.api.java.tuple.Tuple2` fixed the
issue.
---
If your project is set up
Github user soniclavier commented on the issue:
https://github.com/apache/flink/pull/2051
Thanks Ufuk & Stephen for the reply,
I tried the serializers suggested by you
```
val typeHint = new TypeHint[Tuple2[Long,String]](){}
val serializer = TypeInformatio
Github user soniclavier commented on the issue:
https://github.com/apache/flink/pull/2051
Never mind, I was hitting with wrong key, it works now! Cheers.
---
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
Github user soniclavier commented on the issue:
https://github.com/apache/flink/pull/2051
Hi,
Continuing the discussion from the mailing list, I was able to go past the
NettyConfig problem once I ran Flink in cluster mode ( I would still like to
know if there is a way to run
19 matches
Mail list logo
