[GitHub] flink pull request: [FLINK-2874] Fix Avro getter/setter recognitio...
Github user ukarlsson commented on the pull request: https://github.com/apache/flink/pull/1252#issuecomment-149559944 @fhueske @rmetzger Hello, I have added the Jira issue: https://issues.apache.org/jira/browse/FLINK-2874 I have also added unit tests. --- 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 enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] flink pull request: Fix Avro getter/setter recognition
Github user ukarlsson commented on the pull request: https://github.com/apache/flink/pull/1252#issuecomment-148949103 Hello, thanks for your feedback, yes I will add these things. --- 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 enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] flink pull request: Fix Avro getter/setter recognition
GitHub user ukarlsson opened a pull request: https://github.com/apache/flink/pull/1252 Fix Avro getter/setter recognition You can merge this pull request into a Git repository by running: $ git pull https://github.com/ukarlsson/flink ukarlsson/fix-avro-getter-setters Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/1252.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #1252 commit c83ee8a3f7038fb86e8bf79a0a7c58a02e81c988 Author: fobeligi <faybeligia...@gmail.com> Date: 2015-06-05T21:12:43Z [FLINK-1844] [ml] Add MinMaxScaler implementation in the proprocessing package, test for the for the corresponding functionality and documentation. This closes #798. commit 80cf2c544f887532d0c5946027a2adaa481a16d0 Author: Till Rohrmann <trohrm...@apache.org> Date: 2015-06-09T08:23:09Z [ml] Makes StandardScalers state package private and reduce redundant code. Adjusts flink-ml readme. commit 348ac86406021793d257aeb6f6576d36318acca2 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Date: 2015-06-09T12:56:17Z [hotfix] Fix YARNSessionFIFOITCase When comparing the hostname, it was comparing capitalised vs. all-lowercase hostname from the yarn config. commit e0e6f59f309170e5217bdfbf5d30db87c947f8ce Author: Gyula Fora <gyf...@apache.org> Date: 2015-06-09T18:13:13Z [streaming] Optional iteration feedback partitioning added Closes #810 commit c59d291b10f743beff58a70b5bfefc2d71dff234 Author: Gabor Gevay <gga...@gmail.com> Date: 2015-06-09T13:10:35Z Fixed a few trivial issues: - The description of the input format for the graph examples showed an example input as having a newline at the end of the last line, but CsvInputFormat doesn't allow that (it says "Row too short" for the empty line). - Fixed a link to local_execution.html in a javadoc. - ConcatenatedExtract had a typo in its name. - The creation of the jar for the SessionWindowing example was missing from the pom. Closes #809 commit 1343f26f8923b80b08f042882493d9ce82596681 Author: Gyula Fora <gyf...@apache.org> Date: 2015-06-10T13:33:58Z [streaming] Allow force-enabling checkpoints for iterative jobs commit 255c5545c672af13313b5e3a8cd4ad98ad182a60 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Date: 2015-06-09T14:17:48Z [FLINK-2191] Fix inconsistent use of closure cleaner in Scala Streaming The closure cleaner still cannot be disabled for the Timestamp extractor in Time and for the delta function in Delta (windowing helpers). Closes #813 commit f3a96de1e271f64eec9eec60135a41c9f6f77cd9 Author: mbalassi <mbala...@apache.org> Date: 2015-06-10T09:32:45Z [streaming] Fixed streaming example jars packaging and termination Closes #816 commit 87988ae3b6837e5039b55ef9b147398bfb76d070 Author: Maximilian Michels <m...@apache.org> Date: 2015-06-10T16:18:02Z [scripts] remove quickstart scripts - we already decided to host them on the website - not really useful and they need maintenance - having the snapshot quickstart in the source is against Apache rules commit 77def9f518640ea10e0b4070541bea2b1f22ba5b Author: Maximilian Michels <m...@apache.org> Date: 2015-06-11T11:27:23Z [FLINK-2183][runtime] fix deadlock for concurrent slot release commit c8c2e2ca1a4755146f59d649aa44881c4d083c33 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Date: 2015-06-10T08:59:42Z [hotfix] Bring KMeansDataGenerator and KMeans quickstart in sync commit 80dd72d466e9762e6eb0884b50ca9f42ee6b5e2a Author: Fabian Hueske <fhue...@apache.org> Date: 2015-06-10T09:58:08Z [FLINK-2196] [javaAPI] Moved misplaced SortPartitionOperator class This closes #817 commit 5993e28f37dd316fb8d53b43cc2cbee09ef1eb6a Author: Fabian Hueske <fhue...@apache.org> Date: 2015-06-10T15:43:05Z [FLINK-2199] Escape UTF characters in Scala Shell welcome squirrel. This closes #821 commit 6380b95a338e1bc717ef7cebd6352da7bbd5d918 Author: mbalassi <mbala...@apache.org> Date: 2015-06-10T12:46:11Z [streaming] Logging update for checkpointed streaming topologies Also adding a log message when delaying the retry of the execution graph. Closes #819 commit 0edc0c800af22bd5f55bd9fbe71db995529ad2ab Author: mbalassi <mbala...@apache.org> Date: 2015-06-10T14:09:14Z [build] [streaming] Streaming parents dependencies pushed to children Closes #820 commit ce3bc9c0b85ef1c7c74e0a6ca61a9521610df781 Author: mbalassi <mbala...@apache.org> Date: 2015-06-11T10:27:21Z [streaming] [api-breaking] Minor DataStream cleanups - Removed unused