[GitHub] flink pull request: [FLINK-2874] Fix Avro getter/setter recognitio...

2015-10-20 Thread ukarlsson
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

2015-10-17 Thread ukarlsson
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

2015-10-10 Thread ukarlsson
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