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: http://git-wip-us.apache.org/re
Repository: flink
Updated Branches:
refs/heads/release-0.10 856b27837 -> ec1730bf5
[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/ec1730bf
Tree: http://git-wip-us.apache.org/r
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: http://git-wip-us.apache.org/repos/a
Repository: flink
Updated Branches:
refs/heads/release-0.10 15d3f10c1 -> 856b27837
[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
[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: http://git-wip-us.apache.org/repos/a
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
implementing
[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 a
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: http://git-
[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: http://git-wip-us.apache.org/repos/asf/flink/commit/c0d707
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
a/flink-runtime/src/test/java/org/apache/flink/runtime/operators/MatchTaskT
[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 cl
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: http://git-wip-us.apache.org/repos/asf/flink
[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: ht
[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 object copy in WindowOperator and
NonKeyedWindowOperator.
Project: http://git-wi
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
Branch
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 o
[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: ht
[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: http://git-wip-us.apache.org/
[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: http://git-wip-us.apache.org/repos/asf/flink/commit/3c8a65
[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: http://git-wip-us.apache.org/repos/asf/flink/commit/bbb75c59
Tree: http://git-wip-us.apache.org/re
[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 cl
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 -
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: http://git-wip-us.apa
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: http://git-wip-us.apache.org/repos/asf/flink/commit/0c03e9a4
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
Commit
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: http
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: http://git
[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/ab694a3b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ab694a3b
Diff: http://git-wip-us.apache.org/repos/asf/flink
[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
Diff
[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: http://git-wip-us.apache.org/repos/asf/flink
[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: http://git-wip-us.apache.org/re
Repository: flink
Updated Branches:
refs/heads/release-0.10 e340f839a -> c72eff4af
[FLINK-2206] [webui] Fix incorrect counts of finished, canceled, and failed
jobs in new web dashboard
This closes #1287
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apa
[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: http://git-wip-us.apache.org/re
Repository: flink
Updated Branches:
refs/heads/master 201f55b85 -> cd7ed8e38
[FLINK-2206] [webui] Fix incorrect counts of finished, canceled, and failed
jobs in new web dashboard
This closes #1287
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.or
[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: http://git-wip-us.apache.org/repos/asf/flink
[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/32b0dfd1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/32b0dfd1
Diff
36 matches
Mail list logo