Commits

Commits on May 22, 2019

[FLINK-12447][build] Set minimum maven version to 3.1.1

rmetzger
authored and
zentol
committedMay 22, 2019
[FLINK-12566][table] Remove row interval type
twalthr
committedMay 22, 2019
[FLINK-12331][network] Refactor NetworkEnvironment#setupInputGate() to InputGate#setup()

azagrebin
authored and
pnowojski
committedMay 22, 2019
[FLINK-12331][network] Refactor NetworkEnvironment#setupPartition() to ResultPartitionWriter#setup()

azagrebin
authored and
pnowojski
committedMay 22, 2019
[hotfix][network] Move MemorySegmentProvider from SingleInputGate to RemoteInputChannel

azagrebin
authored and
pnowojski
committedMay 22, 2019
[hotfix][network] Introduce MemorySegmentProvider for RemoteInputChannel to assign exclusive segments

azagrebin
authored and
pnowojski
committedMay 22, 2019
[hotfix][network] Introduce SingleInputGateFactory

azagrebin
authored and
pnowojski
committedMay 22, 2019
[hotfix][network] Introduce ResultPartitionFactory

azagrebin
authored and
pnowojski
committedMay 22, 2019
[hotfix][tests][network] Introduce NetworkEnvironment.create factory method

azagrebin
authored and
pnowojski
committedMay 22, 2019
[hotfix][tests][network] Introduce InputChannelBuilder for creation of InputChannels in tests

azagrebin
authored and
pnowojski
committedMay 22, 2019
[hotfix][tests][network] Introduce ResultPartitionBuilder for creation of ResultPartition in tests

zhijiangW
authored and
pnowojski
committedMay 22, 2019
[hotfix][tests][network] Introduce SingleInputGateBuilder for creation of SingleInputGate in tests

zhijiangW
authored and
pnowojski
committedMay 22, 2019
[FLINK-12439][python] Add FileSystem Connector with CSV format support in Python Table API

WeiZhong94
authored and
sunjincheng121
committedMay 22, 2019
[FLINK-12578][build] Use https URL for Maven repositories

HeartSaVioR
authored and
zentol
committedMay 22, 2019
[FLINK-12483][runtime] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks.
StefanRRichter
committedMay 22, 2019
[FLINK-12478, FLINK-12480][runtime] Introduce mailbox to StreamTask main-loop.
StefanRRichter
committedMay 22, 2019
[FLINK-12241][hive] Support Flink functions in catalog function APIs of HiveCatalog
bowenli86
committedMay 22, 2019
[FLINK-12509] [table-planner-blink] Introduce planner rules about non semi/anti join, which includes:

godfreyhe
authored and
KurtYoung
committedMay 22, 2019
[FLINK-12524] [table-planner-blink] Introduce CalcRankTransposeRule & RankNumberColumnRemoveRule

godfreyhe
authored and
KurtYoung
committedMay 22, 2019

Commits on May 21, 2019

[FLINK-12580][hive] Rename GenericHiveMetastoreCatalogTest to HiveCatalogFlinkMetadataTest, and HiveCatalogTest to HiveCatalogHiveMetadataTest
bowenli86
committedMay 21, 2019
[hotfix][table] Reformat method signature of GenericInMemoryCatalog
bowenli86
committedMay 21, 2019
[FLINK-12496][table-planner-blink] Support translation from StreamExecGroupWindowAggregate to StreamTransformation

beyond1920
authored and
wuchong
committedMay 21, 2019
[FLINK-12552][table]: Combine HiveCatalog and GenericHiveMetastoreCatalog

Xuefu Zhang
authored and
bowenli86
committedMay 21, 2019
[FLINK-12560][docs] Documentation language build flags

sjwiesman
authored and
wuchong
committedMay 21, 2019
[FLINK-12553][table-runtime-blink] Fix bug that SqlDateTimeUtils#parseToTimeMillis doesn't parse millisecond correctly

liyafan82
authored and
wuchong
committedMay 21, 2019

Commits on May 20, 2019

[hotfix][python] Fix the bug of test base class runs twice
sunjincheng121
committedMay 20, 2019

Commits on May 19, 2019

[FLINK-12407][python] Add all table operators for align Java Table API.

WeiZhong94
authored and
sunjincheng121
committedMay 19, 2019
[FLINK-11051][table] Add flatAggregate api on WindowGroupedTable

hequn8128
authored and
sunjincheng121
committedMay 19, 2019
[FLINK-12534][travis][python] Reduce the test cost for Python API

WeiZhong94
authored and
sunjincheng121
committedMay 19, 2019
[hotfix][table][docs] correct distinct operator doc for table API.
sunjincheng121
committedMay 19, 2019

Commits on May 18, 2019

[FLINK-12519] [table-planner-blink] Introduce transpose rules about semi/anti join

godfreyhe
authored and
KurtYoung
committedMay 18, 2019
[FLINK-12424] [table-planner-blink] Supports query optimization with multiple sinks

godfreyhe
authored and
KurtYoung
committedMay 18, 2019

Commits on May 17, 2019