[1/2] flink git commit: [FLINK-2874] Fix Avro getter/setter recognition

Repository: flink Updated Branches: refs/heads/release-0.9 96099951e -> ab694a3b2 [FLINK-2874] Fix Avro getter/setter recognition This closes #1252 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4392cf25 Tree:

[2/2] flink git commit: [hotfix] Improve handling of Window Trigger results

[hotfix] Improve handling of Window Trigger results This enhances the TriggerResult enum with methods isFire() and isPurge() that simplify the logic in WindowOperator.processTriggerResult(). Also, the operator now keeps track of the current watermark and fires immediately if a trigger registers

[1/2] flink git commit: [hotfix] Add Window Parameter in Trigger.onEventTime/onProcessingTime

Repository: flink Updated Branches: refs/heads/master c36977f76 -> e69693778 [hotfix] Add Window Parameter in Trigger.onEventTime/onProcessingTime Before these trigger methods had no information about the window that they are responsible for. This information might be required for

flink git commit: [docs] add information on how to use Kerberos

Repository: flink Updated Branches: refs/heads/release-0.9 ab694a3b2 -> 2b5f88a4b [docs] add information on how to use Kerberos Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2b5f88a4 Tree:

[2/2] flink git commit: [hotfix] Add Window Parameter in Trigger.onEventTime/onProcessingTime

[hotfix] Add Window Parameter in Trigger.onEventTime/onProcessingTime Before these trigger methods had no information about the window that they are responsible for. This information might be required for implementing more advanced trigger behaviour. Project:

flink git commit: [docs] add information on how to use Kerberos

Repository: flink Updated Branches: refs/heads/master e69693778 -> 4a3151681 [docs] add information on how to use Kerberos Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4a315168 Tree:

flink git commit: [release] update version to 1.0-SNAPSHOT

Repository: flink Updated Branches: refs/heads/master 3385fa3ab -> 0c03e9a48 [release] update version to 1.0-SNAPSHOT 0.10-SNAPSHOT continues on branch release-0.10 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/3] flink git commit: [hotfix] Fix broken copy in OperatorChain

[hotfix] Fix broken copy in OperatorChain Before, the StreamRecords was not copied, now it is. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/45ab0eb8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/45ab0eb8 Diff:

[1/3] flink git commit: Add copy() to Tuple base class.

Repository: flink Updated Branches: refs/heads/release-0.10 85b73e0fd -> 712c868eb Add copy() to Tuple base class. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c257abf7 Tree:

[2/4] flink git commit: [FLINK-2893] [runtime] Consistent naming of recovery config parameters

[FLINK-2893] [runtime] Consistent naming of recovery config parameters Rename config key prefix from 'ha.zookeeper' to 'recovery.zookeeper' Rename config key from 'state.backend.fs.dir.recovery' => 'state.backend.fs.recoverydir' Move ZooKeeper file system state backend configuration keys This

[3/4] flink git commit: [FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests

http://git-wip-us.apache.org/repos/asf/flink/blob/c0d7073a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/MatchTaskTest.java -- diff --git

[2/5] flink git commit: [FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests

[FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests Rename Match*Test to Join*Test and MapTaskTest to FlatMapTaskTest This closes #1294 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/3] flink git commit: [hotfix] Fix broken copy in OperatorChain

[hotfix] Fix broken copy in OperatorChain Before, the StreamRecords was not copied, now it is. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/256a88a1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/256a88a1 Diff:

[1/3] flink git commit: [hotfix] Fix Mutable Object window aggregator/Disable Object Copy

Repository: flink Updated Branches: refs/heads/master bbb75c599 -> c36977f76 [hotfix] Fix Mutable Object window aggregator/Disable Object Copy This fixes the aggregators to make copies of the objects so that it works with window operators that are not mutable-object safe. This also disables

[4/4] flink git commit: [FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests

[FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests Rename Match*Test to Join*Test and MapTaskTest to FlatMapTaskTest This closes #1294 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/4] flink git commit: [FLINK-2895] Duplicate immutable object creation

Repository: flink Updated Branches: refs/heads/release-0.10 712c868eb -> 15d3f10c1 [FLINK-2895] Duplicate immutable object creation Operators defer object creation when object reuse is disabled. This closes #1288 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/5] flink git commit: [FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests

Repository: flink Updated Branches: refs/heads/master 7ff071f66 -> bbb75c599 http://git-wip-us.apache.org/repos/asf/flink/blob/3c8a6588/flink-runtime/src/test/java/org/apache/flink/runtime/operators/MatchTaskTest.java -- diff

[3/5] flink git commit: [FLINK-2893] [runtime] Consistent naming of recovery config parameters

[FLINK-2893] [runtime] Consistent naming of recovery config parameters Rename config key prefix from 'ha.zookeeper' to 'recovery.zookeeper' Rename config key from 'state.backend.fs.dir.recovery' => 'state.backend.fs.recoverydir' Move ZooKeeper file system state backend configuration keys This

[4/5] flink git commit: [FLINK-2898] [build] Invert Travis CI build order

[FLINK-2898] [build] Invert Travis CI build order This closes #1290 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d2e4a27d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d2e4a27d Diff:

[3/3] flink git commit: Add copy() to Tuple base class.

Add copy() to Tuple base class. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d056f11d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d056f11d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d056f11d

flink git commit: [release] change quickstart and docs version to 1.0-SNAPSHOT

Repository: flink Updated Branches: refs/heads/master 0c03e9a48 -> 7ff071f66 [release] change quickstart and docs version to 1.0-SNAPSHOT Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7ff071f6 Tree:

flink git commit: [hotfix] Fix processing time triggering on Window Operator

Repository: flink Updated Branches: refs/heads/master cd7ed8e38 -> 3385fa3ab [hotfix] Fix processing time triggering on Window Operator Before it would only trigger if expectedTime < time. Now it is expectedTime <= time. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [hotfix] Fix processing time triggering on Window Operator

Repository: flink Updated Branches: refs/heads/release-0.10 c72eff4af -> 85b73e0fd [hotfix] Fix processing time triggering on Window Operator Before it would only trigger if expectedTime < time. Now it is expectedTime <= time. Project: http://git-wip-us.apache.org/repos/asf/flink/repo

[3/4] flink git commit: [FLINK-2874] Fix Avro getter/setter recognition

[FLINK-2874] Fix Avro getter/setter recognition This closes #1252 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/17e7b423 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/17e7b423 Diff:

[4/4] flink git commit: [FLINK-2874] Fix recognition of Scala default setters

[FLINK-2874] Fix recognition of Scala default setters Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cd7ed8e3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cd7ed8e3 Diff:

[4/4] flink git commit: [FLINK-2874] Fix recognition of Scala default setters

[FLINK-2874] Fix recognition of Scala default setters Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c72eff4a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c72eff4a Diff:

[2/4] flink git commit: [FLINK-2668] [DataSet] [api-breaking] Chained Projections are no longer appended

[FLINK-2668] [DataSet] [api-breaking] Chained Projections are no longer appended This closes #1279 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c3eb8b8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5c3eb8b8

[3/4] flink git commit: [FLINK-2874] Fix Avro getter/setter recognition

[FLINK-2874] Fix Avro getter/setter recognition This closes #1252 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/42b5ead5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/42b5ead5 Diff: