Hotfix remove unreachedexception - #2

Open

lamberken wants to merge 147 commits into

fix-xfrom

hotfix-remove-unreachedexception

Commits on Jan 2, 2019

[FLINK-11246][table] Fix distinct AGG visibility issue

dianfu
authored and
sunjincheng121
committed
3d88137
[FLINK-11217][docs] Add missing back-to-top buttons

leesf
authored and
zentol
committed
7ca3e04
[FLINK-10779][tests] Update Java / Scala StatefulJobSavepointMigrationITCase for 1.7

hequn8128
authored and
zentol
committed
a4c09d3
Merge pull request #7242 from hequn8128/flink-10781

hequn8128
authored and
zentol
committed
50f4196
[FLINK-10780][tests] Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.7

hequn8128
authored and
zentol
committed
7bb63f6
[FLINK-11235][es] Close transportclient if no connection could be established

lamberken
authored and
zentol
committed
4febcdc

Commits on Jan 3, 2019

[FLINK-11181][tests] Fix SimpleRecoveryFailureRateStrategyITBase test error

hequn8128
authored and
sunjincheng121
committed
f6995f0
[FLINK-11163][tests] Use random port in RestClusterClientTest
zentol
committed
903a909
[hotfix][tests] Remove mocks from RestClusterClientTest
zentol
committed
7ce6375
[FLINK-11023] Add LICENSE & NOTICE files for flink-connector-cassandra
zentol
committed
9f99d4b
[FLINK-11023] Add LICENSE & NOTICE files for flink-connector-elasticsearch
zentol
committed
842e424
[hotfix][ES2] Set findbugs to provided
zentol
committed
da57ce7
[FLINK-11023] Add LICENSE & NOTICE files for flink-connector-elasticsearch2
zentol
committed
4d1fd44
[FLINK-11023] Add LICENSE & NOTICE files for flink-connector-elasticsearch5
zentol
committed
6e774a2
[FLINK-11023] Add LICENSE & NOTICE files for flink-connector-kinesis
zentol
committed
89f8f47
[FLINK-10761][metrics] Do not acquire lock for getAllVariables()
zentol
authored
aa92438
[FLINK-11079][storm] Skip deployment of storm-examples
zentol
committed
9e0ea45
[FLINK-11194][hbase] Use type instead of classifier
zentol
committed
7a0a525
[FLINK-11023][ES] Add NOTICE file
zentol
authored
c28250b

Commits on Jan 4, 2019

[hotfix][docs][kafka] Fix typo

wangzzu
authored and
zentol
committed
96d6979
[FLINK-11234] [table] Fix ExternalTableCatalogBuilder unable to build a batch-only table

EronWright
authored and
twalthr
committed
04035ce
[hotfix][ES6][SQL] Remove unused version property
zentol
committed
71f8564
[FLINK-11026][kafka][SQL] Rework kafka sql-client jar creation
zentol
committed
b623768
[hotfix] [table] Fix typos in Table javadoc.

EronWright
authored and
twalthr
committed
cef75fe
[hotfix][docs] Fix incorrect example in cep doc

KarmaGYZ
authored and
dawidwys
committed
1ee2a88
[FLINK-11119][docs] Correct Scala example for Table Function in User-defined Functions docs.

wenhuitang
authored and
twalthr
committed
d3f0075
[FLINK-11227] [table] Fix bound checking errors in DescriptorProperties

xccui
authored and
twalthr
committed
1c3c663
[FLINK-11173][table] Fix the exception message of proctime attribute validation in TableSourceUtil#validateTableSource

wenhuitang
authored and
twalthr
committed
c09dc96
[FLINK-11001] [table] Update exception message for time attributes on aliases
twalthr
committed
038dc00
[FLINK-11124][table] Add private[flink] to TemporalTableFunction.create()

hequn8128
authored and
twalthr
committed
b82b24d
[hotfix] [docs] Update docs regarding missing 'sql-jar' suffix
twalthr
committed
c8675b8
[FLINK-10848][YARN] properly remove YARN ContainerRequest upon container allocation success
Shuyi Chen
committed
e26d90f

Commits on Jan 7, 2019

[FLINK-10845] [table] Support multiple different DISTINCT aggregates for batch

xueyumusic
authored and
twalthr
committed
c0a37f8
[hotfix] Improve performance of GenericArraySerializer.copy()
StefanRRichter
committed
28e0b83
[hotfix] Remove unused generic parameter from RocksDB states
StefanRRichter
committed
6f9a884
[FLINK-9702] Improvement in (de)serialization of keys and values for RocksDB state

StefanRRichter
and
klion26
committed
54ef382
[FLINK-11265][docs] AvroSinkWriter → AvroKeyValueSinkWriter

Fokko
authored and
dawidwys
committed
ec48bea
[hotfix][runtime] Remove redundant suppression

tisonkun
authored and
dawidwys
committed
11aa9b6
[FLINK-11073] [core] Add COMPATIBLE_WITH_RECONFIGURED_SERIALIZER to TypeSerializerSchemaCompatibility
tzulitai
committed
1794ea0
[FLINK-11073] [state backends] Respect serializer reconfiguration in state backends
tzulitai
committed
e03cea5
[hotfix] Rename keySerializerConfigSnapshot to keySerializerSnapshot in KeyedBackendSerializationProxy
tzulitai
committed
29174f8
[hotfix] [doc] Fix an error in state_backends

blueszheng
authored and
tzulitai
committed
583b3a2
[hotfix] [doc] Fix incorrect http port in Elasticsearch 6.x Scala doc

lamberken
authored and
tzulitai
committed
3d5b6b1
[FLINK-11165] Refine the task deploying log for easier finding of task locations

zhuzhurk
authored and
aljoscha
committed
35d16f9
[FLINK-11189] Deprecated documentation for readSequenceFile function

leesf
authored and
aljoscha
committed
fe489bd
[FLINK-11273][state] Fix shared InputView object between event processing and queryable state thread
StefanRRichter
committed
0b28bfd

Commits on Jan 8, 2019

Commits on Jan 9, 2019

[FLINK-11232][rest] Fix subtask start-time field name

eaglewatcherwb
authored and
zentol
committed
9ab04da
[FLINK-11251][metrics] Exclude variable values from logical scope of generic groups

tony810430
authored and
zentol
committed
9742ef7
[hotfix][cep] Change contract of cep TimerContext#timestamp to never
dawidwys
committed
5e46487
[hotfix][cep] Introduced nfa test harness
dawidwys
committed
abe7ae2
[FLINK-10596][cep] Added access to timer service in IterativeCondition
dawidwys
committed
60f8826
[hotfix][cep] Renamed TimerContext to TimeContext
dawidwys
committed
0a46510
[FLINK-10596][cep, docs] Added description of TimeContext to docs
dawidwys
committed
47e9ccf
[FLINK-11056] [mesos] Remove MesosApplicationMasterRunner

tisonkun
authored and
tillrohrmann
committed
52dd89d
[hotfix][docs] Sync formatting for cli usage examples

intsmaze
authored and
zentol
committed
64f766f
[hotfix][test] Remove usage of deprecated method

tisonkun
authored and
zentol
committed
9323ef6
[hotfix][test] Reduce test timeout to a reasonable value

tisonkun
authored and
zentol
committed
5b5ec59
[hotfix][test] Adjust suppressWarnings

tisonkun
authored and
zentol
committed
4782236
[hotfix][docs] Update addShutdownHookThread javadocs

leesf
authored and
zentol
committed
a93e91a
[hotfix][docs] Fix javadocs of RandomFibonacciSource

DreamsZM
authored and
zentol
committed
6a4bc90
[FLINK-11140][fs-connector] Fix empty child path check in Buckets.

Matrix42
authored and
kl0u
committed
3702029
[FLINK-11197][tests] Improve migration test comments about how to generate snapshots

hequn8128
authored and
zentol
committed
6650d74
[FLINK-11262][py] Bump jython-standalone to 2.7.1

Fokko
authored and
zentol
committed
e4bc287
[FLINK-10783][tests] Update WindowOperatorMigrationTest for 1.7

boshu Zheng
authored and
zentol
committed
78cc9bc
[FLINK-11207][build] Bump commons-compress to 1.18

NicoK
authored and
zentol
committed
f817537
[FLINK-10326] Simplify ZooKeeperSubmittedJobGraphStore#constructor
tillrohrmann
committed
0315f20
[FLINK-10436] Add ConfigOption#withFallbackKeys (#6872)

tisonkun
authored and
tillrohrmann
committed
1e2aa8e
[FLINK-11287] [rocksdb] RocksDBListState should be using registered serializer in state meta infos
tzulitai
committed
e5ed8c8
[FLINK-11073] [state backends, tests] Activate ignored testKeyedListStateSerializerReconfiguration test in StateBackendMigrationTestBase
tzulitai
committed
cad0509
[hotfix][docs] Add missing config option descriptions

KarmaGYZ
authored and
zentol
committed
43a7497
[FLINK-10571][storm] Remove topology support
zentol
committed
7a9a6ad
[FLINK-11267][release] Only create hadoop-free binary by default
zentol
committed
ca9460b
[FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.
kl0u
committed
4ec77d6
[hotfix] Avoid redundant state access in TemporalProcessTimeJoin.
kl0u
committed
81ec2d7
[FLINK-10584][table] Add State Retention support to TemporalRowtimeJoin.
kl0u
committed
f828031
[FLINK-10583][table] Add State Retention support to TemporalProcessTimeJoin.
kl0u
committed
120c4fc

Commits on Jan 10, 2019

[FLINK-11278] [docs] Add documentation for TableAPI&SQL in scala-shell.

仲炜
authored and
sunjincheng121
committed
6826c67
[hotfix][docs] Reverse paragraphs in cli.md to cli enumeration (#7443)

KarmaGYZ
authored and
tillrohrmann
committed
85dff90
[FLINK-10866] Only load queryable state when explicitly configured

eaglewatcherwb
authored and
aljoscha
committed
e8182dc
[FLINK-11272][flink-yarn] Support for parsing multiple --yarnship parameters

leesf
authored and
aljoscha
committed
f692d37
[FLINK-11134][rest] Do not log stacktrace for handled exceptions
zentol
committed
c06e7a5
[hotfix][rest] Centralize REST error logging
zentol
committed
1f47c0a
[hotfix][rest] Remove unnecessary instanceof check
zentol
committed
4adf23d
[FLINK-11268][release] Deploy multiple flink-shaded-hadoop2 artifacts
zentol
committed
5fe918c
[FLINK-11253] Add shutdown hook for yarn session client

Tao Yang
authored and
tillrohrmann
committed
1abf8d1
[FLINK-11253] Factor out application report logging
tillrohrmann
committed
a07ce7f

Commits on Jan 11, 2019

[FLINK-10509][storm] Remove flink-storm

zentol
authored and
tillrohrmann
committed
2294cdd
Fix queryable-state nightly test
aljoscha
committed
157a267
[FLINK-11084][datastream] Forbid using two consecutive split transformations

Clarkkkkk
authored and
dawidwys
committed
e0efabe
[FLINK-11224][scala-shell] Log is missing in scala-shell

zjffdu
authored and
dawidwys
committed
be47061
[hotfix][docs] Fix NullPointerException

intsmaze
authored and
zentol
committed
1a4eb09
[FLINK-11306][jdcs] Bump derby from 10.10.1.1 to 10.14.2.0

Fokko
authored and
zentol
committed
205f906
[FLINK-10848] Remove container requests after successful container allocation
tillrohrmann
committed
3903b81

Commits on Jan 14, 2019

[hotfix] [docs] Fix kafka doc mistake classname
sunjincheng121
committed
43ec81f
[FLINK-11312][docs] Fix broken link to Zookeeper getting started

ifndef-SleePy
authored and
tillrohrmann
committed
6c8abc1
[hotfix] Add dependency snippet for RocksDBStateBackend to state_backends.md

intsmaze
authored and
tillrohrmann
committed
f305b64
[hotfix] Fix typo in restart strategies documenation (#7479)

libenchao
authored and
tillrohrmann
committed
7206d20
[hotfix][docs] Fix typo in classloading doc

KarmaGYZ
authored and
tillrohrmann
committed
c9af982
[FLINK-11304][docs][table] Fix typo in time attributes doc

JaryZhen
authored and
twalthr
committed
2be178c
[hotfix][docs][table] Fix more typos in time attributes doc
twalthr
committed
1325599

Commits on Jan 15, 2019

[hotfix] [docs] Fix typo in Table SQL doc

JaryZhen
authored and
tzulitai
committed
e5e6274
[hotfix] [datastream] Remove irrelevant comments and fix typo in SourceStreamTask

leesf
authored and
tzulitai
committed
baea9a3
[hotfix] [fs] Add clock as an argument in Javadocs

Fokko
authored and
tzulitai
committed
e7b02b4
[FLINK-11156][tests, runtime] Reconcile ZooKeeperCompletedCheckpointStoreMockitoTest with JDK 9

tisonkun
authored and
GJL
committed
02078e0
[FLINK-11156][tests, runtime] Simplify ZooKeeperCompletedCheckpointStore constructor
GJL
committed
eff261e
Add link to KeyedProcessFunction to side output documentation
aljoscha
committed
3846928

Commits on Jan 16, 2019

[FLINK-11331][table][docs] Fix errors in tableApi.md and functions.md

hequn8128
authored and
sunjincheng121
committed
ea0f283
[hotfix][docs] fix some typos

Nico Kruber
authored and
NicoK
committed
ecb57a9
[FLINK-9222][docs] add documentation for setting up Gradle projects

Nico Kruber
authored and
NicoK
committed
bfd1302
[hotfix][quickstart] make the note about IDE memory requirements non-specific to MacOS X users

Nico Kruber
authored and
NicoK
committed
bfbf986
[FLINK-11023][kafka] Add NOTICE files
zentol
committed
a1c64b9
[FLINK-11187] [s3] Use file over stream for writes

Addison Higham
authored and
aljoscha
committed
9c07822
[hotfix][build] Append shade-plugin transformers in child modules
zentol
committed
b56197a
[FLINK-11289][examples] Rework examples to account for licensing
zentol
committed
979ebd2
[FLINK-11174][prometheus] Add option to not filter label values

tisonkun
authored and
zentol
committed
53034cd
[hotfix][docs] Update references to deprecated SinkFunction#invoke(Object)

intsmaze
authored and
zentol
committed
4863bc1
[hotfix] Fix parameter name KeyedCoProcessOperator constructor

leesf
authored and
zentol
committed
9a21cc0
[FLINK-11012][tests] Introduce abstract superclass for filesystem IT cases.

wujinhu
authored and
StefanRRichter
committed
c08db3f
[FLINK-10945] Add an InputDependencyConstraint to avoid resource deadlocks for finite stream jobs when resources are limited

zhuzhurk
authored and
tillrohrmann
committed
171a3b1
[FLINK-10945] Mark InputDependencyConstraint as PublicEvolving
tillrohrmann
committed
94647f1
[FLINK-11295][conf] Rename configuration options of queryable-state from query.x to queryable-state.x

eaglewatcherwb
authored and
aljoscha
committed
f61d112
[FLINK-11302][fs-connector] Correctly parse tmp dirs in FlinkS3FileSystem.

art4ul
authored and
kl0u
committed
291373a
[hotfix][docs] Remove stray character

leesf
authored and
zentol
committed
86e06bc
[hotfix][runtime] remove RejectedExecutionException code in executeAsyncCallRunnable method
lamberken
committed
e683ba4