flink.git
15 hours ago[hotfix] [docs] Correct the field name in Connect to External Systems doc master
Yangze Guo [Fri, 14 Dec 2018 11:59:20 +0000 (19:59 +0800)] 
[hotfix] [docs] Correct the field name in Connect to External Systems doc

This closes #7311.

15 hours ago[hotfix] [docs] Improve the correctness in Detecting Patterns doc
Yangze Guo [Fri, 14 Dec 2018 05:29:48 +0000 (13:29 +0800)] 
[hotfix] [docs] Improve the correctness in Detecting Patterns doc

This closes #7307.

17 hours ago[FLINK-10566] Fix exponential planning time of large programs
Maximilian Michels [Tue, 11 Dec 2018 13:52:54 +0000 (14:52 +0100)] 
[FLINK-10566] Fix exponential planning time of large programs

The traversal of the DAG is not efficient enough at some places which can lead
to very long plan creation times.

This introduces caching for the traversal to avoid traversing nodes multiple
times. Caching is performed at two places:

- when registering Kryo types
- when determining the maximum parallelism

19 hours ago[FLINK-11040][docs] fixed the Incorrect generic type of output in broadcast_state.md
Yangze Guo [Fri, 14 Dec 2018 11:48:10 +0000 (19:48 +0800)] 
[FLINK-11040][docs] fixed the Incorrect generic type of output in broadcast_state.md

34 hours ago[FLINK-11145] Fix Hadoop version handling in binary release script
Thomas Weise [Tue, 11 Dec 2018 15:21:14 +0000 (07:21 -0800)] 
[FLINK-11145] Fix Hadoop version handling in binary release script

36 hours ago[FLINK-11152][core] Use asm 6 in ClosureCleaner
Gary Yao [Thu, 13 Dec 2018 18:37:28 +0000 (19:37 +0100)] 
[FLINK-11152][core] Use asm 6 in ClosureCleaner

41 hours ago[FLINK-11144][tests] Make tests runnable on Java 9
Gary Yao [Wed, 12 Dec 2018 14:01:47 +0000 (15:01 +0100)] 
[FLINK-11144][tests] Make tests runnable on Java 9

This enables to run tests on Java 9. However, not all tests are passing at
the moment.

This closes #7293.

41 hours ago[hotfix][core] Fix typo in WrappingProxyUtil Javadoc
Gary Yao [Wed, 12 Dec 2018 08:50:59 +0000 (09:50 +0100)] 
[hotfix][core] Fix typo in WrappingProxyUtil Javadoc

41 hours ago[FLINK-11122][core] Change signature of WrappingProxyUtil#stripProxy(T)
Gary Yao [Mon, 10 Dec 2018 15:58:21 +0000 (16:58 +0100)] 
[FLINK-11122][core] Change signature of WrappingProxyUtil#stripProxy(T)

Changed signature so that the method expects a WrappingProxy<T>. This fixes a
type inference ambiguity by the compiler.

Make the method throw a runtime exception of it needs to strip more than 128
proxies.

Change AbstractCloseableRegistryTest so that no mocks are used.

This closes #7273.

41 hours ago[hotfix] [docs] Add notice about buggy dateFormat() function
Timo Walther [Thu, 13 Dec 2018 13:03:52 +0000 (14:03 +0100)] 
[hotfix] [docs] Add notice about buggy dateFormat() function

41 hours ago[hotfix] [docs] Add notice about buggy DATE_FORMAT function
Timo Walther [Thu, 13 Dec 2018 12:52:02 +0000 (13:52 +0100)] 
[hotfix] [docs] Add notice about buggy DATE_FORMAT function

2 days ago[FLINK-11001] [table] Fix alias on window rowtime attribute in Java Table API.
hequn8128 [Wed, 12 Dec 2018 10:28:49 +0000 (18:28 +0800)] 
[FLINK-11001] [table] Fix alias on window rowtime attribute in Java Table API.

This closes 7289.

2 days ago[FLINK-11136] [table] Fix the merge logic of DISTINCT aggregates.
Dian Fu [Mon, 10 Dec 2018 13:33:02 +0000 (21:33 +0800)] 
[FLINK-11136] [table] Fix the merge logic of DISTINCT aggregates.

This closes #7284.

2 days ago[hotfix] [docs] Improve DataSet.partitionCustom() documentation.
KarmaGYZ [Mon, 10 Dec 2018 10:26:21 +0000 (18:26 +0800)] 
[hotfix] [docs] Improve DataSet.partitionCustom() documentation.

This closes #7282.

2 days ago[hotfix] [docs] Fix typos in Table and SQL docs
Alexander Fedulov [Wed, 12 Dec 2018 18:58:05 +0000 (19:58 +0100)] 
[hotfix] [docs] Fix typos in Table and SQL docs

This closes #7297.

2 days ago[FLINK-11085][build] Fix inheritance of shading filters
zentol [Fri, 7 Dec 2018 13:11:49 +0000 (14:11 +0100)] 
[FLINK-11085][build] Fix inheritance of shading filters

3 days ago[FLINK-11125] clean up useless imports
hequn8128 [Tue, 11 Dec 2018 04:10:16 +0000 (12:10 +0800)] 
[FLINK-11125] clean up useless imports

This closes #7272

3 days ago[hotfix] [docs] Fix typo in dynamic tables documentation
zhangzhanchun [Tue, 11 Dec 2018 12:43:54 +0000 (20:43 +0800)] 
[hotfix] [docs] Fix typo in dynamic tables documentation

This closes #7275.

3 days ago[FLINK-11080][ES] Rework shade-plugin filters
zentol [Wed, 5 Dec 2018 14:46:05 +0000 (15:46 +0100)] 
[FLINK-11080][ES] Rework shade-plugin filters

3 days ago[hotfix][build] Add Aliyun FS dependency to flink-dist
zentol [Tue, 11 Dec 2018 15:00:47 +0000 (16:00 +0100)] 
[hotfix][build] Add Aliyun FS dependency to flink-dist

3 days ago[hotfix][docs][table] Fix string concatenation in avro example
maqingxiang [Tue, 11 Dec 2018 13:58:56 +0000 (21:58 +0800)] 
[hotfix][docs][table] Fix string concatenation in avro example

3 days ago[hotfix][metrics][tests] Refactor MetricQueryServiceTest
zentol [Thu, 6 Dec 2018 12:59:23 +0000 (13:59 +0100)] 
[hotfix][metrics][tests] Refactor MetricQueryServiceTest

- use UnregisteredMetricGroups instead
- simplify metrics
- encapsulate TestActor fields

3 days ago[hotfix][metrics][tests] Ensure ActorSystem is terminated
zentol [Fri, 7 Dec 2018 14:58:34 +0000 (15:58 +0100)] 
[hotfix][metrics][tests] Ensure ActorSystem is terminated

3 days ago[FLINK-10252][metrics] Handle oversized metric messages
yanghua [Thu, 18 Oct 2018 05:07:53 +0000 (13:07 +0800)] 
[FLINK-10252][metrics] Handle oversized metric messages

3 days ago[FLINK-10252][metrics] Pass akkaFrameSize to MetricQueryService
yanghua [Thu, 18 Oct 2018 05:07:53 +0000 (13:07 +0800)] 
[FLINK-10252][metrics] Pass akkaFrameSize to MetricQueryService

3 days ago[FLINK-11090][streaming api] Remove unused parameter in WindowedStream.aggregate()
hequn8128 [Tue, 11 Dec 2018 06:40:37 +0000 (14:40 +0800)] 
[FLINK-11090][streaming api] Remove unused parameter in WindowedStream.aggregate()

3 days ago[FLINK-11041][test] ReinterpretDataStreamAsKeyedStreamITCase source should hold check...
Stefan Richter [Mon, 10 Dec 2018 15:52:02 +0000 (16:52 +0100)] 
[FLINK-11041][test] ReinterpretDataStreamAsKeyedStreamITCase source should hold checkpointing lock

3 days ago[hotfix][test][streaming] Fix invalid testNotSideOutputXXX in WindowOperatorTest
blueszheng [Mon, 3 Dec 2018 07:23:07 +0000 (15:23 +0800)] 
[hotfix][test][streaming] Fix invalid testNotSideOutputXXX in WindowOperatorTest

3 days ago[FLINK-10359] [docs] Scala example in DataSet docs is broken
yanghua [Mon, 10 Dec 2018 03:00:29 +0000 (11:00 +0800)] 
[FLINK-10359] [docs] Scala example in DataSet docs is broken

This closes #7266.

3 days ago[FLINK-11029] [docs] Fixed incorrect parameter in Working with state doc
KarmaGYZ [Thu, 29 Nov 2018 13:02:54 +0000 (21:02 +0800)] 
[FLINK-11029] [docs] Fixed incorrect parameter in Working with state doc

This closes #7198.

3 days ago[hotfix] [docs] Correct the parameter in Operators Overview doc
KarmaGYZ [Mon, 3 Dec 2018 11:09:28 +0000 (19:09 +0800)] 
[hotfix] [docs] Correct the parameter in Operators Overview doc

This closes #7219.

3 days ago[hotfix] [docs] Fix tEnv in tableApi docs
unknown [Thu, 6 Dec 2018 13:38:42 +0000 (21:38 +0800)] 
[hotfix] [docs] Fix tEnv in tableApi docs

This closes #7254.

3 days ago[hotfix] [docs] Fix typo in Joining documentation
zhangzhanchun [Tue, 11 Dec 2018 03:00:49 +0000 (11:00 +0800)] 
[hotfix] [docs] Fix typo in Joining documentation

This closes #7270.

3 days ago[FLINK-11087] [docs] Amend compatibility table to notify issue with restoring 1.5...
Tzu-Li (Gordon) Tai [Thu, 6 Dec 2018 16:34:46 +0000 (00:34 +0800)] 
[FLINK-11087] [docs] Amend compatibility table to notify issue with restoring 1.5.x braodcast state in later versions.

This closes #7256.

3 days ago[FLINK-11087] [state] Incorrect broadcast state K/V serializer snapshot association...
Tzu-Li (Gordon) Tai [Thu, 6 Dec 2018 16:14:13 +0000 (00:14 +0800)] 
[FLINK-11087] [state] Incorrect broadcast state K/V serializer snapshot association when restoring from 1.5.x

When restoring a broadcast state's meta information from a 1.5.x
savepoint, the
LegacyStateMetaInfoReaders.OperatorBackendStateMetaInfoReaderV2V3
incorrectly associates the first restored serializer as the value
serializer, and the second restored serializer as the key serializer.
The actual order of this should be the other way around.

This bug prevents successful broadcast state restores from 1.5, both for
Flink 1.6.x and 1.7.0.

The commit also modifies the StatefulJobWBroadcastStateMigrationITCase
to have different key / value types for its tested broadcast tests,
which otherwise would not have caught this bug.

3 days ago[hotfix] Cleanup unused methods / appropriate method renames in StateMetaInfoSnapshot
Tzu-Li (Gordon) Tai [Sun, 9 Dec 2018 08:10:31 +0000 (16:10 +0800)] 
[hotfix] Cleanup unused methods / appropriate method renames in StateMetaInfoSnapshot

This commit removes the `restoreTypeSerializer(...)` method.
That method is no longer used after the series of changes in
FLINK-11094. This also corresponds to the new principle that the restore
serializer is only accessed, when the state backends attempt request it
from their state meta infos. We do not create restore serializers
eagerly when creating meta infos from a StateMetaInfoSnapshot.

It also removes "config" from names of methods and fields
related to serializer snapshotting.
This corresponds to the abstraction rework of retiring
TypeSerializerConfigSnapshot to be replaced by TypeSerializerSnapshot.
The related fields / methods should not mention "config" anymore.

3 days ago[hotfix] [tests] Remove unused enum from StateBackendTestBase
Tzu-Li (Gordon) Tai [Sun, 9 Dec 2018 08:08:07 +0000 (16:08 +0800)] 
[hotfix] [tests] Remove unused enum from StateBackendTestBase

3 days ago[FLINK-11094] [state backends] State backends no longer need separate map for restore...
Tzu-Li (Gordon) Tai [Mon, 10 Dec 2018 07:07:47 +0000 (15:07 +0800)] 
[FLINK-11094] [state backends] State backends no longer need separate map for restored StateMetaInfoSnapshots

Since now all restored state meta info snapshots are handled so that we
always eagerly create the corresponding RegisteredStateMetaInfoBase for
it, the information is already part of the registered state infos map.

As can be seen in the changes, those maps are no longer queried and can
therefore be safely removed.

This closes #7264.

3 days ago[FLINK-11094] [state backends] Let meta infos always lazily access restore serializer
Tzu-Li (Gordon) Tai [Sun, 9 Dec 2018 07:15:04 +0000 (15:15 +0800)] 
[FLINK-11094] [state backends] Let meta infos always lazily access restore serializer

This commit introduces StateSerializerProvider that
wraps logic on how to obtain serializers for registered state,
either with the previous schema of state in checkpoints or
the current schema of state.

All state meta info subclasses use
StateSerializerProviders to replace direct serializer instances. This
allows meta infos that were instantiated with restored serializer
snapshots to not eagerly access the restore serializer when restoring
state. This needs to be avoided since when restoring from 1.6, the
restore serializer might not be available; for RocksDB, this should be
tolerable.

3 days ago[FLINK-11094] [rocksdb] Eagerly create meta infos for restored state in RocksDBKeyedS...
Tzu-Li (Gordon) Tai [Sun, 9 Dec 2018 07:51:59 +0000 (15:51 +0800)] 
[FLINK-11094] [rocksdb] Eagerly create meta infos for restored state in RocksDBKeyedStateBackend

This ensures that all restored state, even non-accessed ones after the
restore, have a meta info available on future snapshots.

3 days ago[hotfix] [state backends, tests] Make StateBackendMigrationTestBase more understandable
Tzu-Li (Gordon) Tai [Sat, 8 Dec 2018 10:28:13 +0000 (18:28 +0800)] 
[hotfix] [state backends, tests] Make StateBackendMigrationTestBase more understandable

The StateBackendMigrationTestBase previously mocked user behaviour of
upgrading serializers by using a single serializer class, that can be
configured with different target compatibility results when they are
checked for compatibility.

This is a bit hard to understand, also doesn't really reflect how a user
would actually approach the feature. Instead, instead of configuring a
single serializer class with different compatibility "personalities",
this commit uses actual different classes, V1TestTypeSerializer,
V2TestTypeSerializer, and IncompatibleTestTypeSerializer, to simulate
the compatibility cases in tests.

This commit also refactors the serializer migration related test
serializers / types / snapshots to the testutil package, so that it can
be shared by other state migration related tests in the future.

3 days ago[hotfix] [state backends] New namespace serializer in HeapKeyedStateBackend should...
Tzu-Li (Gordon) Tai [Fri, 7 Dec 2018 12:47:30 +0000 (20:47 +0800)] 
[hotfix] [state backends] New namespace serializer in HeapKeyedStateBackend should always be compatible

Previously, we were only checking if the new namespace serializer is
incompatible, while properly we should be checking that it is strictly
compatible.

This doesn't affect any user expected behaviour, since the namespace
serializer is never exposed to users.

3 days ago[hotfix] [state backend, tests] Certain StateBackendMigrationTestBase tests should...
Tzu-Li (Gordon) Tai [Fri, 7 Dec 2018 12:42:52 +0000 (20:42 +0800)] 
[hotfix] [state backend, tests] Certain StateBackendMigrationTestBase tests should fail if exception isn't thrown

This commit strengthens tests in StateBackendMigrationTestBase that
depend on a certain state operation (restoring state, accessing state,
etc.) to be failing to assert correct behaviour. However, we previously
do not really fail the test if no exception was thrown when there should
be.

This also caught some bugs in the test itself which had the tests
verifying incorrect behaviour.

3 days ago[FLINK-10743] [runtime] Use 0 processExitCode for ApplicationStatus.CANCELED
Ufuk Celebi [Wed, 31 Oct 2018 21:10:05 +0000 (22:10 +0100)] 
[FLINK-10743] [runtime] Use 0 processExitCode for ApplicationStatus.CANCELED

This closes #7004.

4 days ago[FLINK-11123][docs] fix the import of the class is missing in ml quick start document.
sunjincheng121 [Tue, 11 Dec 2018 00:37:27 +0000 (08:37 +0800)] 
[FLINK-11123][docs] fix the import of the class is missing in ml quick start document.

This closes #7269

4 days ago[FLINK-9552][iterations] fix not syncing on checkpoint lock before emitting records
Nico Kruber [Tue, 30 Oct 2018 12:05:55 +0000 (13:05 +0100)] 
[FLINK-9552][iterations] fix not syncing on checkpoint lock before emitting records

We need to make sure that concurrent access to the RecordWriter is protected by
a lock. It seems that everything but the StreamIterationHead was synchronizing
on the checkpoint lock and hence we sync here as well.

4 days ago[hotfix][docs] Add and update description of local-recovery config options
KarmaGYZ [Sun, 2 Dec 2018 08:49:23 +0000 (09:49 +0100)] 
[hotfix][docs] Add and update description of local-recovery config options

This closes #7211.

4 days ago[hotfix] Rename keys-as-allowed-values-help-text to keys->allowed-values-help-text
Gary Yao [Mon, 26 Nov 2018 11:04:09 +0000 (12:04 +0100)] 
[hotfix] Rename keys-as-allowed-values-help-text to keys->allowed-values-help-text

4 days ago[hotfix] Move code from nemesis to generator
Gary Yao [Mon, 26 Nov 2018 12:24:12 +0000 (13:24 +0100)] 
[hotfix] Move code from nemesis to generator

4 days ago[hotfix] Remove redundant keyword conversion when validating CLI args
Gary Yao [Mon, 26 Nov 2018 10:31:42 +0000 (11:31 +0100)] 
[hotfix] Remove redundant keyword conversion when validating CLI args

4 days ago[FLINK-10986][tests] Add example on how to run a Jepsen test with Kafka
Gary Yao [Mon, 26 Nov 2018 21:07:49 +0000 (22:07 +0100)] 
[FLINK-10986][tests] Add example on how to run a Jepsen test with Kafka

This closes #7173.

4 days ago[FLINK-10986][tests] Implement DB to setup Apache Kafka
Gary Yao [Mon, 26 Nov 2018 10:57:13 +0000 (11:57 +0100)] 
[FLINK-10986][tests] Implement DB to setup Apache Kafka

4 days ago[FLINK-10986][tests] Enable fine-grained configuration of required dbs
Gary Yao [Mon, 26 Nov 2018 10:43:15 +0000 (11:43 +0100)] 
[FLINK-10986][tests] Enable fine-grained configuration of required dbs

This enables toggling the setup of test dependencies, such as Hadooop, Mesos,
and, ZooKeeper through the --test-spec edn file. The type of the Flink cluster
can also be specified via: :flink-yarn-job :flink-yarn-session
:flink-mesos-session, and :flink-standalone-session.

Retryable operations that exhausted all attempts, now propagate the exception by
default. This is to fail fast if during the db/setup!, an operation, such as
Flink job submission, fails to complete.

4 days ago[FLINK-10985][tests] Enable submission of multiple jobs. (#7166)
Gary Yao [Mon, 10 Dec 2018 10:52:04 +0000 (11:52 +0100)] 
[FLINK-10985][tests] Enable submission of multiple jobs. (#7166)

This enables submission of multiple jobs in the Jepsen tests. The job
specifications are in an .edn file that must be passed as command line
arguments. The checker verifies that all jobs are running at the end of the
test. The job cancellation function now cancels all jobs at once.

Delete script/run-tests.sh and move code to docker/run-tests.sh.

4 days ago[FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies
jinhu.wjh [Fri, 16 Nov 2018 10:34:22 +0000 (18:34 +0800)] 
[FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies

This closes #7123.

5 days ago[FLINK-10543][table] Leverage efficient timer deletion in relational operators
hequn8128 [Wed, 24 Oct 2018 05:46:26 +0000 (13:46 +0800)] 
[FLINK-10543][table] Leverage efficient timer deletion in relational operators

This closes #6918

7 days ago[hotfix][documentation] Mention limitation of local recovery with RocksDB in multi...
Stefan Richter [Fri, 7 Dec 2018 15:15:58 +0000 (16:15 +0100)] 
[hotfix][documentation] Mention limitation of local recovery with RocksDB in multi device setups.

8 days ago[FLINK-10482] Fix double counting of checkpoint stat
Andrey Zagrebin [Thu, 15 Nov 2018 17:51:43 +0000 (18:51 +0100)] 
[FLINK-10482] Fix double counting of checkpoint stat

8 days ago[FLINK-11011][E2E][JM] Log error messages about null CheckpointCoordinator only if...
azagrebin [Thu, 6 Dec 2018 11:09:07 +0000 (12:09 +0100)] 
[FLINK-11011][E2E][JM] Log error messages about null CheckpointCoordinator only if job is running (#7216)

8 days ago[FLINK-10987] Add LICENSE & NOTICE files for flink-avro-confluent-registry
zentol [Tue, 27 Nov 2018 15:07:33 +0000 (16:07 +0100)] 
[FLINK-10987] Add LICENSE & NOTICE files for flink-avro-confluent-registry

8 days ago[FLINK-10997][formats] Bundle kafka-scheme-registry-client
zentol [Fri, 23 Nov 2018 14:57:02 +0000 (15:57 +0100)] 
[FLINK-10997][formats] Bundle kafka-scheme-registry-client

8 days ago[hotfix][docs] Fix invalid link in schema_evolution doc
KarmaGYZ [Sun, 2 Dec 2018 13:27:27 +0000 (21:27 +0800)] 
[hotfix][docs] Fix invalid link in schema_evolution doc

9 days ago[FLINK-9555][scala-shell] Support table api in scala shell.
chensq [Fri, 16 Nov 2018 07:33:23 +0000 (15:33 +0800)] 
[FLINK-9555][scala-shell] Support table api in scala shell.

This closes #7121

9 days ago[hotfix][docs] Fix typo in Windows documentation
KarmaGYZ [Wed, 5 Dec 2018 07:45:38 +0000 (15:45 +0800)] 
[hotfix][docs] Fix typo in Windows documentation

9 days ago[hotfix] Fixing the broken code examples
Igal Shilman [Tue, 4 Dec 2018 15:45:54 +0000 (16:45 +0100)] 
[hotfix] Fixing the broken code examples

The code examples for Scala and Java are both broken,
and set a bad example in terms of efficiency.

This closes #7232.

9 days ago[FLINK-10522][fs-connector] Check if RecoverableWriter supportsResume() and act accor...
Kostas Kloudas [Tue, 4 Dec 2018 16:35:42 +0000 (17:35 +0100)] 
[FLINK-10522][fs-connector] Check if RecoverableWriter supportsResume() and act accordingly.

This closes #7047.

10 days ago[FLINK-11045][table] Set correct UserCodeClassLoader for RuntimeUDFContext in Collect...
hequn8128 [Sun, 2 Dec 2018 11:05:49 +0000 (19:05 +0800)] 
[FLINK-11045][table] Set correct UserCodeClassLoader for RuntimeUDFContext in CollectionExecutor

This closes #7213

10 days ago[FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in...
Kostas Kloudas [Thu, 22 Nov 2018 10:03:13 +0000 (11:03 +0100)] 
[FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files.

This closes #7161.

10 days ago[hotfix] Method renaming in the RecoverableMultiPartUploadImpl.
Kostas Kloudas [Thu, 22 Nov 2018 09:54:05 +0000 (10:54 +0100)] 
[hotfix] Method renaming in the RecoverableMultiPartUploadImpl.

10 days ago[hotfix] Consolidated all S3 accesses under the S3AccessHelper.
Kostas Kloudas [Thu, 22 Nov 2018 09:46:10 +0000 (10:46 +0100)] 
[hotfix] Consolidated all S3 accesses under the S3AccessHelper.

10 days ago[hotfix][s3-connector] Renamed S3MultiPartUploader to S3AccessHelper.
Kostas Kloudas [Wed, 21 Nov 2018 10:11:10 +0000 (11:11 +0100)] 
[hotfix][s3-connector] Renamed S3MultiPartUploader to S3AccessHelper.

10 days ago[hotfix][fs-connector] Refactor Bucket to statically import Preconditions.
Kostas Kloudas [Wed, 21 Nov 2018 09:43:55 +0000 (10:43 +0100)] 
[hotfix][fs-connector] Refactor Bucket to statically import Preconditions.

10 days ago[hotfix][fs-connector] Refactor PartFileWriter to take stream.
Kostas Kloudas [Wed, 21 Nov 2018 09:35:58 +0000 (10:35 +0100)] 
[hotfix][fs-connector] Refactor PartFileWriter to take stream.

10 days ago[FLINK-11044] [docs] Fix registerTableSink docs
kgorman [Fri, 30 Nov 2018 22:29:41 +0000 (16:29 -0600)] 
[FLINK-11044] [docs] Fix registerTableSink docs

This closes #7208.

10 days ago[FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API suite
Shimin Yang [Fri, 23 Nov 2018 07:54:44 +0000 (15:54 +0800)] 
[FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API suite

This closes #7168

10 days ago[FLINK-11047] Fix CoGroupGroupSortTranslationTest by specyfing types
Till Rohrmann [Mon, 3 Dec 2018 10:46:13 +0000 (11:46 +0100)] 
[FLINK-11047] Fix CoGroupGroupSortTranslationTest by specyfing types

Adding the parameter types is necessary to compile the CoGroupGroupSortTranslationTest
with Scala 2.12.

11 days ago[FLINK-7603] [docs] Update documentation with WITHIN clause for MATCH_RECOGNIZE
Dawid Wysakowicz [Wed, 28 Nov 2018 13:29:14 +0000 (14:29 +0100)] 
[FLINK-7603] [docs] Update documentation with WITHIN clause for MATCH_RECOGNIZE

This closes #7187.

11 days ago[FLINK-7603] [table] Support WITHIN clause in MATCH_RECOGNIZE
Dawid Wysakowicz [Wed, 28 Nov 2018 12:31:59 +0000 (13:31 +0100)] 
[FLINK-7603] [table] Support WITHIN clause in MATCH_RECOGNIZE

Introduces support for WITHIN clause in MATCH_RECOGNIZE that
allows adding a time constraint for a pattern. It reuses the
within function of Pattern in the CEP library. The behavior
is such that the difference between first row in a match and
last row in a match must be smaller than the given period. The
WITHIN clause accepts only a constant millisecond interval value.

11 days ago[FLINK-10874][kafka-docs] Document likely cause of UnknownTopicOrPartitionException
Piotr Nowojski [Wed, 14 Nov 2018 12:57:44 +0000 (13:57 +0100)] 
[FLINK-10874][kafka-docs] Document likely cause of UnknownTopicOrPartitionException

11 days ago[FLINK-10689] [table] Improve docs and fix bugs of ported classes
Timo Walther [Fri, 30 Nov 2018 16:05:58 +0000 (17:05 +0100)] 
[FLINK-10689] [table] Improve docs and fix bugs of ported classes

11 days ago[FLINK-10689] [table] Port UDF interfaces to flink-table-common
xueyu [Sat, 24 Nov 2018 16:21:31 +0000 (00:21 +0800)] 
[FLINK-10689] [table] Port UDF interfaces to flink-table-common

This commit ports all UDF extension points to Java and relocates them
to flink-table-common. Projects that just want to provide functions
don't need to import flink-table and thus Scala anymore.

This closes #7059.

11 days ago[FLINK-11013] [table] Fix distinct aggregates for group window in Table API
Dian Fu [Tue, 27 Nov 2018 14:02:31 +0000 (22:02 +0800)] 
[FLINK-11013] [table] Fix distinct aggregates for group window in Table API

This closes #7181

11 days ago[FLINK-10149][mesos] Simplify assertions in LaunchableMesosWorkerTest
Gary Yao [Fri, 30 Nov 2018 10:50:39 +0000 (11:50 +0100)] 
[FLINK-10149][mesos] Simplify assertions in LaunchableMesosWorkerTest

Use Set equality to simplify test assertions.

Change type of field LaunchableMesosWorker#TM_PORT_KEYS to Set<String>.

11 days ago[FLINK-10149][mesos] Make returned port keys set immutable.
Gary Yao [Fri, 30 Nov 2018 10:20:18 +0000 (11:20 +0100)] 
[FLINK-10149][mesos] Make returned port keys set immutable.

11 days ago[FLINK-10149][mesos] Replace string concatenation with slf4j placeholders
Gary Yao [Fri, 30 Nov 2018 10:17:14 +0000 (11:17 +0100)] 
[FLINK-10149][mesos] Replace string concatenation with slf4j placeholders

11 days ago[FLINK-10149][mesos] Don't allocate extra mesos port for TM unless configured to...
Rune Skou Larsen [Wed, 15 Aug 2018 10:33:54 +0000 (12:33 +0200)] 
[FLINK-10149][mesos] Don't allocate extra mesos port for TM unless configured to do so.

This closes #7203.

12 days ago[FLINK-10798] Add the version number of Flink 1.7 to MigrationVersion
yanghua [Tue, 6 Nov 2018 02:49:55 +0000 (10:49 +0800)] 
[FLINK-10798] Add the version number of Flink 1.7 to MigrationVersion

This closes #7026.

2 weeks ago[hotfix][docs] Fix typo in StreamTableSoureFactory
Piotr Nowojski [Fri, 30 Nov 2018 15:49:09 +0000 (16:49 +0100)] 
[hotfix][docs] Fix typo in StreamTableSoureFactory

2 weeks ago[FLINK-10597] Enabled UDFs support in MATCH_RECOGNIZE
Dawid Wysakowicz [Tue, 27 Nov 2018 10:58:53 +0000 (11:58 +0100)] 
[FLINK-10597] Enabled UDFs support in MATCH_RECOGNIZE

2 weeks ago[hotfix][cep] Enabled distributed cache for CEP functions
Dawid Wysakowicz [Thu, 29 Nov 2018 10:06:31 +0000 (11:06 +0100)] 
[hotfix][cep] Enabled distributed cache for CEP functions

2 weeks ago[FLINK-11015] Remove deprecated code for format-specific Kafka table connectors
yanghua [Wed, 28 Nov 2018 09:29:09 +0000 (17:29 +0800)] 
[FLINK-11015] Remove deprecated code for format-specific Kafka table connectors

This commit removes all classes and methods that have been deprecated in
Flink 1.6 for separating Kafka connectors from Avro and JSON formats.

This closes #7182.

2 weeks ago[hotfix] [table] Fix the misuse of assertEquals
blueszheng [Wed, 28 Nov 2018 15:13:15 +0000 (23:13 +0800)] 
[hotfix] [table] Fix the misuse of assertEquals

This closes #7190.

2 weeks ago[hotfix] [docs] Fix typos in MATCH_RECOGNIZE docs
Matrix42 [Thu, 29 Nov 2018 07:13:26 +0000 (15:13 +0800)] 
[hotfix] [docs] Fix typos in MATCH_RECOGNIZE docs

This closes #7194.

2 weeks ago[FLINK-11017][table] Throw exception if constant with YEAR TO MONTH resolution was...
Dawid Wysakowicz [Fri, 30 Nov 2018 08:11:12 +0000 (09:11 +0100)] 
[FLINK-11017][table] Throw exception if constant with YEAR TO MONTH resolution was used for group windows

This closes #7200.

2 weeks ago[hotfix][table] Check if expected exception was thrown
Dawid Wysakowicz [Fri, 30 Nov 2018 08:10:16 +0000 (09:10 +0100)] 
[hotfix][table] Check if expected exception was thrown

2 weeks ago[hotfix] Bump japicmp Flink reference version to 1.7.0
Till Rohrmann [Fri, 30 Nov 2018 10:13:28 +0000 (11:13 +0100)] 
[hotfix] Bump japicmp Flink reference version to 1.7.0

2 weeks ago[hotfix] Add 1.7 to previous docs in docs/_config.yml
Till Rohrmann [Thu, 29 Nov 2018 16:02:38 +0000 (17:02 +0100)] 
[hotfix] Add 1.7 to previous docs in docs/_config.yml

2 weeks ago[hotfix] Add release notes 1.7 and 1.8 to documentation front page
Till Rohrmann [Thu, 29 Nov 2018 16:01:45 +0000 (17:01 +0100)] 
[hotfix] Add release notes 1.7 and 1.8 to documentation front page

2 weeks ago[hotfix] Let CoGroupGroupSortTranslationTest extend TestLogger and fix testGroupSortT...
Till Rohrmann [Thu, 29 Nov 2018 14:38:02 +0000 (15:38 +0100)] 
[hotfix] Let CoGroupGroupSortTranslationTest extend TestLogger and fix testGroupSortTuplesDefaultCoGroup

2 weeks ago[hotfix] Remove flink-metrics-ganglia from flink-dist/pom.xml
Till Rohrmann [Wed, 28 Nov 2018 17:55:54 +0000 (18:55 +0100)] 
[hotfix] Remove flink-metrics-ganglia from flink-dist/pom.xml