[09/25] flink git commit: [FLINK-3511] [gelly] Introduce flink-gelly-examples module

[FLINK-3511] [gelly] Introduce flink-gelly-examples module The new flink-gelly-examples module contains all Java and Scala Gelly examples. The module contains compile scope dependencies on flink-java, flink-scala and flink-clients so that the examples can be conveniently run from within the IDE.

[12/25] flink git commit: [license] Update LICENSE file for the latest version

[license] Update LICENSE file for the latest version Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/51ab77b1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/51ab77b1 Diff: http://git-wip-us.apache.org/repos/asf/flink/

[21/25] flink git commit: [hotfix] Remove remaining unused files from the old standalone web client

[hotfix] Remove remaining unused files from the old standalone web client Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0601a762 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0601a762 Diff: http://git-wip-us.apache

[05/25] flink git commit: [FLINK-3511] [gelly] Introduce flink-gelly-examples module

http://git-wip-us.apache.org/repos/asf/flink/blob/2c605d27/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/ConnectedComponents.java -- diff --git a/flink-libraries/flink-gelly/src/main/java/org/apache/flin

[2/2] flink git commit: [FLINK-3521] Make Iterable part of method signature for WindowFunction

[FLINK-3521] Make Iterable part of method signature for WindowFunction This closes #1723 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/27b5c49e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/27b5c49e Diff: http://g

[1/2] flink git commit: [FLINK-3521] Make Iterable part of method signature for WindowFunction

Repository: flink Updated Branches: refs/heads/master 64519e1c1 -> 27b5c49e7 http://git-wip-us.apache.org/repos/asf/flink/blob/27b5c49e/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/function/AllWindowFunction.scala

[1/2] flink git commit: [FLINK-3521] Make Iterable part of method signature for WindowFunction

Repository: flink Updated Branches: refs/heads/release-1.0 603f351e2 -> ba069f35b http://git-wip-us.apache.org/repos/asf/flink/blob/ba069f35/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/function/AllWindowFunction.scala ---

[2/2] flink git commit: [FLINK-3521] Make Iterable part of method signature for WindowFunction

[FLINK-3521] Make Iterable part of method signature for WindowFunction This closes #1723 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ba069f35 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ba069f35 Diff: http://g

flink git commit: Commit for release 1.0.0

Repository: flink Updated Branches: refs/heads/release-1.0.0-rc2 [created] 6895fd923 Commit for release 1.0.0 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6895fd92 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree

flink git commit: Bump version to 1.1-SNAPSHOT

Repository: flink Updated Branches: refs/heads/master e840bbf71 -> 512c84ff6 Bump version to 1.1-SNAPSHOT Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/512c84ff Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/512

flink git commit: [FLINK-3540] Shade org.htrace in flink-shaded-hadoop to get rid of its Guava dependency

Repository: flink Updated Branches: refs/heads/master 9922d10a0 -> 51fc29812 [FLINK-3540] Shade org.htrace in flink-shaded-hadoop to get rid of its Guava dependency This closes #1737 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/fl

flink git commit: [FLINK-3540] Shade org.htrace in flink-shaded-hadoop to get rid of its Guava dependency

Repository: flink Updated Branches: refs/heads/release-1.0 ae5b4573b -> 74c62b0b8 [FLINK-3540] Shade org.htrace in flink-shaded-hadoop to get rid of its Guava dependency This closes #1737 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/a

flink git commit: Commit for release 1.0.0

Repository: flink Updated Branches: refs/heads/release-1.0.0-rc3 [created] 41451e22b Commit for release 1.0.0 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/41451e22 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree

flink git commit: Commit for release 1.0.0

Repository: flink Updated Branches: refs/heads/release-1.0.0-rc4 [created] 1b0a8c4e9 Commit for release 1.0.0 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1b0a8c4e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree

flink git commit: [maven] add module to force execution of Shade plugin

Repository: flink Updated Branches: refs/heads/master f0f93c276 -> 072da7def [maven] add module to force execution of Shade plugin This ensures that all properties of the root pom are properly resolved by running the Shade plugin. Thus, our root pom does not have to depend on a Scala version j

flink git commit: [maven] add module to force execution of Shade plugin

Repository: flink Updated Branches: refs/heads/release-1.0 b862fd0b3 -> 3adc51487 [maven] add module to force execution of Shade plugin This ensures that all properties of the root pom are properly resolved by running the Shade plugin. Thus, our root pom does not have to depend on a Scala vers

flink git commit: [hotfix] Make 'force-shading' deployable

Repository: flink Updated Branches: refs/heads/release-1.0 3adc51487 -> a79521fba [hotfix] Make 'force-shading' deployable Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a79521fb Tree: http://git-wip-us.apache.org/repos/a

flink git commit: Commit for release 1.0.0

Repository: flink Updated Branches: refs/heads/release-1.0.0-rc5 [created] 94cd554ae Commit for release 1.0.0 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/94cd554a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree

flink git commit: [hotfix] Make 'force-shading' deployable

Repository: flink Updated Branches: refs/heads/master 7b2f54067 -> dbe9e596e [hotfix] Make 'force-shading' deployable Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dbe9e596 Tree: http://git-wip-us.apache.org/repos/asf/fl

svn commit: r12624 - /release/flink/flink-1.0.0/

Author: rmetzger Date: Fri Mar 4 19:30:14 2016 New Revision: 12624 Log: Add files for Flink 1.0.0 release Added: release/flink/flink-1.0.0/ release/flink/flink-1.0.0/flink-1.0.0-bin-hadoop1-scala_2.10.tgz (with props) release/flink/flink-1.0.0/flink-1.0.0-bin-hadoop1-scala_2.10

[2/4] flink git commit: [FLINK-1964] Reimplement TwitterSource

[FLINK-1964] Reimplement TwitterSource This closes #1796 This closes #666 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e70d49ec Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e70d49ec Diff: http://git-wip-us.apach

[4/4] flink git commit: [hotfix][examples] Add zookeeper.connect to usage line

[hotfix][examples] Add zookeeper.connect to usage line Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/edafb3e6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/edafb3e6 Diff: http://git-wip-us.apache.org/repos/asf/flin

[1/4] flink git commit: [FLINK-1964] Reimplement TwitterSource

Repository: flink Updated Branches: refs/heads/master 33f43114d -> edafb3e6c http://git-wip-us.apache.org/repos/asf/flink/blob/e70d49ec/flink-streaming-connectors/flink-connector-twitter/src/test/java/org/apache/flink/streaming/connectors/twitter/examples/TwitterFilterSourceExample.java ---

[3/4] flink git commit: [hotfix][docs] fs.hdfs.hadoopconf typo

[hotfix][docs] fs.hdfs.hadoopconf typo Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d8dcfac7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d8dcfac7 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d8dcfac7

flink git commit: [hotfix][Kafka 0.9] Avoid committing offsets to closed consumer

Repository: flink Updated Branches: refs/heads/master 607892314 -> 35892ed14 [hotfix][Kafka 0.9] Avoid committing offsets to closed consumer Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/35892ed1 Tree: http://git-wip-us.

flink git commit: FLINK-3115: Update ElasticSearch connector to 2.x

Repository: flink Updated Branches: refs/heads/master 76da44283 -> f7a3c8104 FLINK-3115: Update ElasticSearch connector to 2.x This closes #1792 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f7a3c810 Tree: http://git-wi

flink git commit: [FLINK-3129] Bring infrastructure for ensuring interface stability in place

Repository: flink Updated Branches: refs/heads/release-1.0 cd5773ed3 -> 1909bdb41 [FLINK-3129] Bring infrastructure for ensuring interface stability in place Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1909bdb4 Tree: h

flink git commit: [FLINK-3658][Kafka] Allow producing into multiple topics

Repository: flink Updated Branches: refs/heads/master f0b6ba46d -> c77e5ece5 [FLINK-3658][Kafka] Allow producing into multiple topics This closes #1832 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c77e5ece Tree: http:/

[2/2] flink git commit: [hotfix] Register signal handler for JobManager and TaskManager

[hotfix] Register signal handler for JobManager and TaskManager This closes #1400 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/008060f1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/008060f1 Diff: http://git-wip-

flink git commit: [FLINK-3067] Enforce zkclient 0.7 for Kafka

Repository: flink Updated Branches: refs/heads/master 008060f16 -> 2c507f933 [FLINK-3067] Enforce zkclient 0.7 for Kafka This closes #1399 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2c507f93 Tree: http://git-wip-us.a

flink git commit: [FLINK-3067] Enforce zkclient 0.7 for Kafka

Repository: flink Updated Branches: refs/heads/release-0.10 86b6605d6 -> 0b6adc4c5 [FLINK-3067] Enforce zkclient 0.7 for Kafka This closes #1399 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0b6adc4c Tree: http://git-wi

[1/2] flink git commit: [FLINK-3000] Adds shutdown hook to clean up lingering yarn sessions

Repository: flink Updated Branches: refs/heads/master 90c76ad1c -> 008060f16 [FLINK-3000] Adds shutdown hook to clean up lingering yarn sessions This closes #1354 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aad99f25 T

[1/2] flink-web git commit: Add link to powered by wiki page; reactive GA tracking

Repository: flink-web Updated Branches: refs/heads/asf-site 0e401f755 -> a7ea99b1d http://git-wip-us.apache.org/repos/asf/flink-web/blob/a7ea99b1/content/news/2015/01/06/december-in-flink.html -- diff --git a/content/news/2015/

[2/2] flink-web git commit: Add link to powered by wiki page; reactive GA tracking

Add link to powered by wiki page; reactive GA tracking Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/a7ea99b1 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/a7ea99b1 Diff: http://git-wip-us.apache.org/re

svn commit: r11318 - in /release/flink: flink-0.8.1/ flink-0.9.0-milestone-1/ flink-0.9.0/ flink-0.9.1/

Author: rmetzger Date: Thu Nov 26 13:44:22 2015 New Revision: 11318 Log: remove old releases (they are in the archive) Removed: release/flink/flink-0.8.1/ release/flink/flink-0.9.0/ release/flink/flink-0.9.0-milestone-1/ release/flink/flink-0.9.1/

svn commit: r11321 - /release/flink/flink-0.10.1/

Author: rmetzger Date: Thu Nov 26 14:08:01 2015 New Revision: 11321 Log: Add flink 0.10.1 release binaries Added: release/flink/flink-0.10.1/ release/flink/flink-0.10.1/flink-0.10.1-bin-hadoop1-scala_2.10.tgz (with props) release/flink/flink-0.10.1/flink-0.10.1-bin-hadoop1

[2/2] flink-web git commit: Update download links for the 0.10.1 release

Update download links for the 0.10.1 release Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/dd40d1d6 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/dd40d1d6 Diff: http://git-wip-us.apache.org/repos/asf/fl

[1/2] flink-web git commit: Update download links for the 0.10.1 release

Repository: flink-web Updated Branches: refs/heads/asf-site a7ea99b1d -> dd40d1d68 http://git-wip-us.apache.org/repos/asf/flink-web/blob/dd40d1d6/content/news/2015/09/01/release-0.9.1.html -- diff --git a/content/news/2015/09/0

flink-web git commit: Add 0.10.1 release news

Repository: flink-web Updated Branches: refs/heads/asf-site dd40d1d68 -> e36fdf822 Add 0.10.1 release news Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/e36fdf82 Tree: http://git-wip-us.apache.org/repos/asf/flink

flink git commit: [FLINK-3054] Remove R (return) type variable from SerializationSchema

Repository: flink Updated Branches: refs/heads/master 76913686c -> 09ea3dd0f [FLINK-3054] Remove R (return) type variable from SerializationSchema This closes #1406 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/09ea3dd0

flink git commit: [hotfix] Fix SimpleStringSchema serialization issue

Repository: flink Updated Branches: refs/heads/master 09ea3dd0f -> e9a2bc9d0 [hotfix] Fix SimpleStringSchema serialization issue Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e9a2bc9d Tree: http://git-wip-us.apache.org/r

flink git commit: [FLINK-3081] Properly stop periodic Kafka committer

Repository: flink Updated Branches: refs/heads/master e9a2bc9d0 -> a997dd615 [FLINK-3081] Properly stop periodic Kafka committer This closes #1410 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a997dd61 Tree: http://git-

flink git commit: [FLINK-3081] Properly stop periodic Kafka committer

Repository: flink Updated Branches: refs/heads/release-0.10 d6e118b8e -> 961adea59 [FLINK-3081] Properly stop periodic Kafka committer Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/961adea5 Tree: http://git-wip-us.apache

flink git commit: [FLINK-3061] Properly fail Kafka Consumer if broker is not available

Repository: flink Updated Branches: refs/heads/master 3e9d33ee5 -> 209ae6c91 [FLINK-3061] Properly fail Kafka Consumer if broker is not available This closes #1395 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/209ae6c9

flink git commit: [FLINK-2954] Add config parameter for passing environment variables to YARN

Repository: flink Updated Branches: refs/heads/master 9849a5769 -> b9639eb54 [FLINK-2954] Add config parameter for passing environment variables to YARN This closes #1409 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b9

flink git commit: [docker-flink] Bumped the docker container to the latest version.

Repository: flink Updated Branches: refs/heads/master 526e5af53 -> fe5e2e11f [docker-flink] Bumped the docker container to the latest version. This closes #1366 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fe5e2e11 Tre

flink git commit: [FLINK-2963] Forbid commons lang 3 SerializationUtils as well

Repository: flink Updated Branches: refs/heads/master e8734b245 -> 868f97cf8 [FLINK-2963] Forbid commons lang 3 SerializationUtils as well Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/868f97cf Tree: http://git-wip-us.ap

[1/2] flink git commit: [FLINK-3102] Allow reading from multiple topics with one FlinkKafkaConsumer instance

Repository: flink Updated Branches: refs/heads/master 4dbb10f52 -> fc8be1ca6 http://git-wip-us.apache.org/repos/asf/flink/blob/fc8be1ca/flink-streaming-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerPartitionAssignmentTest.java --

[2/2] flink git commit: [FLINK-3102] Allow reading from multiple topics with one FlinkKafkaConsumer instance

[FLINK-3102] Allow reading from multiple topics with one FlinkKafkaConsumer instance This closes #1437 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fc8be1ca Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fc8be1ca

flink git commit: [FLINK-3074] Add config option to start YARN AM on port range

Repository: flink Updated Branches: refs/heads/master 1190f3b1d -> 74b535d56 [FLINK-3074] Add config option to start YARN AM on port range This closes #1416 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/74b535d5 Tree: h

flink git commit: [FLINK-3156] Fix NPE in KafkaConsumer when reading from SOME empty topics/partitions

Repository: flink Updated Branches: refs/heads/master 74b535d56 -> c4a2d60c3 [FLINK-3156] Fix NPE in KafkaConsumer when reading from SOME empty topics/partitions Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c4a2d60c Tr

flink git commit: [FLINK-3023][web-dashboard] Display version and commit information on Overview Page.

Repository: flink Updated Branches: refs/heads/master 6bd5714d2 -> 0f98a8ed5 [FLINK-3023][web-dashboard] Display version and commit information on Overview Page. This closes #1422 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink

flink git commit: [FLINK-3077][cli] Add version option(-v, --version) to Cli.

Repository: flink Updated Branches: refs/heads/master 0f98a8ed5 -> 61cff8e33 [FLINK-3077][cli] Add version option(-v, --version) to Cli. This closes #1418 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/61cff8e3 Tree: htt

flink git commit: [FLINK-3188] Pass deletes to KeyedDeserializationSchema

Repository: flink Updated Branches: refs/heads/master 47cd9fd8a -> dcf86c27b [FLINK-3188] Pass deletes to KeyedDeserializationSchema This closes #1484 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dcf86c27 Tree: http://

[2/2] flink git commit: [FLINK-3093] Introduce annotations for interface stability in flink-core

[FLINK-3093] Introduce annotations for interface stability in flink-core This closes #1427 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c674a655 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c674a655 Diff: http:/

flink git commit: [docs] set version to 0.10.1

Repository: flink Updated Branches: refs/heads/release-0.10 06a87f2d9 -> 1d05dbe54 [docs] set version to 0.10.1 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1d05dbe5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tr

[09/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/twitter/util/TwitterStreamData.java -- diff --git a/flink-examples/flink-examples

[25/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/recommendation/ALS.scala -- diff --git a/flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/recommendation

[11/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/wordcount/WordCountPojo.java -- diff --git a/flink-examples/flink-examples-batch/src/main/

[42/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/common/ParameterMap.scala -- diff --git a/flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/common/Pa

[30/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopReduceFunction.java -- diff --git a/flink-staging/flink-hadoop-com

[16/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-tez/src/main/java/org/apache/flink/tez/examples/TransitiveClosureNaiveStep.java -- diff --git a/flink-staging/flink-tez/src/main/java/org/apache/flink/

[22/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-table/src/main/scala/org/apache/flink/api/java/table/JavaStreamingTranslator.scala -- diff --git a/flink-staging/flink-table/src/main/scala/org/apache/

[37/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/Table.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/Tab

[35/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/typeinfo/RenameOperator.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/f

[31/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-avro/src/test/java/org/apache/flink/api/io/avro/AvroPojoTest.java -- diff --git a/flink-staging/flink-avro/src/test/java/org/apache/flink/api/io/avro/A

[38/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/regression/RegressionData.scala -- diff --git a/flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/reg

[08/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-examples/flink-examples-streaming/src/test/java/org/apache/flink/streaming/test/exampleJavaPrograms/socket/SocketTextStreamWordCountITCase.java -- diff --git a/flink

[07/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-examples/flink-java-examples/src/main/java/org/apache/flink/examples/java/graph/EnumTrianglesBasic.java -- diff --git a/flink-examples/flink-java-examples/src/main/j

[01/50] flink git commit: [FLINK-3195] Rework quickstart example & some cleanups on the new examples

Repository: flink Updated Branches: refs/heads/master 62938c110 -> e9bf13d86 [FLINK-3195] Rework quickstart example & some cleanups on the new examples Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b7520a53 Tree: http://

[19/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-table/src/test/java/org/apache/flink/api/java/table/test/AggregationsITCase.java -- diff --git a/flink-staging/flink-table/src/test/java/org/apache/fli

[32/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellLocalStartupITCase.scala -- diff --git a/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/

[28/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java -- diff --git a/flink-staging/flink-jdbc/src/test/java/org/apache/flink/a

[03/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/twitter/TwitterStream.java -- diff --git a/flink-streaming-examples/src/main/java/org/apache/fli

[48/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-batch-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopReduceCombineFunction.java -- diff --git a/flink-batch-co

[21/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/codegen/GenerateJoin.scala -- diff --git a/flink-staging/flink-table/src/main/scala/org/apache/flink/ap

[27/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/Breeze.scala -- diff --git a/flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/Breeze.scala b/

[39/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/math/DenseVectorSuite.scala -- diff --git a/flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/math/De

[34/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/JoinITCase.java -- diff --git a/flink-libraries/flink-table/src/test/java/org/apache/flink/a

[20/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/parser/ExpressionParser.scala -- diff --git a/flink-staging/flink-table/src/main/scala/org/apache/flink

[36/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/analysis/SelectionAnalyzer.scala -- diff --git a/flink-libraries/flink-table/src/main/sca

[50/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

[FLINK-1712] Remove "flink-staging" module This closes #1492 This closes #1482 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e9bf13d8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e9bf13d8 Diff: http://git-wip-us.

[45/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-contrib/flink-tez/src/main/java/org/apache/flink/tez/dag/FlinkVertex.java -- diff --git a/flink-contrib/flink-tez/src/main/java/org/apache/flink/tez/dag/FlinkVertex.

[15/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-tez/src/main/java/org/apache/flink/tez/runtime/output/TezOutputEmitter.java -- diff --git a/flink-staging/flink-tez/src/main/java/org/apache/flink/tez/

[13/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/graph/EnumTrianglesBasic.java -- diff --git a/flink-examples/flink-examples-batch/src/main

[18/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/CastingITCase.scala -- diff --git a/flink-staging/flink-table/src/test/scala/org/apache/flin

[43/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-contrib/flink-tez/src/test/resources/log4j-test.properties -- diff --git a/flink-contrib/flink-tez/src/test/resources/log4j-test.properties b/flink-contrib/flink-tez

[17/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-tez/src/main/java/org/apache/flink/tez/client/TezExecutor.java -- diff --git a/flink-staging/flink-tez/src/main/java/org/apache/flink/tez/client/TezExe

[23/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-scala-shell/src/main/java/org/apache/flink/api/java/JarHelper.java -- diff --git a/flink-staging/flink-scala-shell/src/main/java/org/apache/flink/api/j

[47/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java -- diff --git a/flink-batch-connectors/flink-hbase/src/main/java/org/a

[24/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/math/SparseVectorSuite.scala -- diff --git a/flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/math/Spars

[02/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-streaming-examples/src/test/java/org/apache/flink/streaming/test/exampleJavaPrograms/join/WindowJoinITCase.java -- diff --git a/flink-streaming-examples/src/test/jav

[29/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseFlinkTestConstants.java -- diff --git a/flink-staging/flink-hbase/src/test/java/org/apac

[33/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/SqlExplainITCase.scala -- diff --git a/flink-libraries/flink-table/src/test/scala/org/apac

[06/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-examples/flink-java-examples/src/main/java/org/apache/flink/examples/java/relational/TPCHQuery10.java -- diff --git a/flink-examples/flink-java-examples/src/main/jav

[41/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala -- diff --git a/flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/

[10/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/relational/TPCHQuery3.scala -- diff --git a/flink-examples/flink-examples-batch/src/main

[04/50] flink git commit: [FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project

http://git-wip-us.apache.org/repos/asf/flink/blob/d0e1d635/flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/relational/TPCHQuery10.scala -- diff --git a/flink-examples/flink-scala-examples/src/mai

[44/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-contrib/flink-tez/src/main/java/org/apache/flink/tez/runtime/TezTask.java -- diff --git a/flink-contrib/flink-tez/src/main/java/org/apache/flink/tez/runtime/TezTask.

[40/50] flink git commit: [FLINK-1712] Remove "flink-staging" module

http://git-wip-us.apache.org/repos/asf/flink/blob/e9bf13d8/flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala -- diff --git a/flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/

<    1   2   3   4   5   6   7   8   9   10   >