Commits

Commits on Jul 13, 2017

[FLINK-7161] Fix misusage of Float.MIN_VALUE and Double.MIN_VALUE
KurtYoung
committedJul 13, 2017

Commits on May 8, 2017

[FLINK-6394] [runtime] Respect object reuse configuration when executing group combining function
KurtYoung
committedMay 8, 2017

Commits on Apr 28, 2017

[FLINK-6398] RowSerializer's duplicate should always return a new instance
KurtYoung
committedApr 28, 2017

Commits on Apr 19, 2017

[FLINK-6149] [table] Add additional flink logical relation nodes and separate current optimization to logical and physical optimize
KurtYoung
committedApr 19, 2017

Commits on Apr 7, 2017

[FLINK-5545] [table] Remove FlinkAggregateExpandDistinctAggregatesRule after bumping Calcite to v1.12.

KurtYoung
authored and
fhueske
committedApr 7, 2017

Commits on Apr 6, 2017

[FLINK-5435] [table] Remove FlinkAggregateJoinTransposeRule and FlinkRelDecorrelator after bumping Calcite to v1.12.

KurtYoung
authored and
fhueske
committedApr 6, 2017

Commits on Mar 17, 2017

[FLINK-3849] [table] Add FilterableTableSource interface and rules for pushing it (2)
KurtYoung
committedMar 17, 2017

Commits on Mar 4, 2017

[FLINK-5586] [table] Extend TableProgramsClusterTestBase for object reuse mode
KurtYoung
committedMar 4, 2017

Commits on Mar 2, 2017

[FLINK-5524] [table] Support early out for code generated AND/OR conditions

KurtYoung
authored and
twalthr
committedMar 2, 2017

Commits on Feb 27, 2017

[FLINK-5907] [java] Fix handling of trailing empty fields in CsvInputFormat.

KurtYoung
authored and
fhueske
committedFeb 27, 2017

Commits on Feb 7, 2017

[FLINK-5727] [table] Unify API of batch and stream TableEnvironments.

KurtYoung
authored and
fhueske
committedFeb 7, 2017

Commits on Jan 19, 2017

[FLINK-5452] [table] Fix SortITCase which fails under cluster mode.

KurtYoung
authored and
fhueske
committedJan 19, 2017

Commits on Jan 17, 2017

[FLINK-5144] [table] Fix error while applying rule AggregateJoinTransposeRule

KurtYoung
authored and
twalthr
committedJan 17, 2017

Commits on Dec 23, 2016

[FLINK-4839] [cluster management] JobManager handle TaskManager's slot offering

KurtYoung
authored and
StephanEwen
committedDec 23, 2016
[hotfix] Treat taskManager's rpc address and location separately

KurtYoung
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4351] [cluster management] JobManager handle TaskManager's registration

KurtYoung
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4689] [cluster management] Implement a simple slot provider for the new job manager

KurtYoung
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4339] [cluster management] Implement Slot Pool core on JobManager side

KurtYoung
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4375] [distributed coordination] Implement new JobManager creation, initialization, and basic RPC methods

KurtYoung
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4735] [cluster management] Implements some job execution related RPC calls on the JobManager

KurtYoung
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4657] Implement HighAvailabilityServices based on ZooKeeper

KurtYoung
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4406] [cluster management] Implement job master registration at resource manager

KurtYoung
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4408] [JobManager] Introduce JobMasterRunner and implement job submission & setting up the ExecutionGraph

KurtYoung
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4347][cluster management] Implement SlotManager core

KurtYoung
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4373] [cluster management] Introduce SlotID, improve and test ResourceProfile

KurtYoung
authored and
StephanEwen
committedDec 23, 2016

Commits on Dec 15, 2016

[FLINK-5266] [table] Inject projection of unused fields before aggregations.

KurtYoung
authored and
fhueske
committedDec 15, 2016

Commits on Dec 6, 2016

[FLINK-5251] [table] Decouple StreamTableSourceScan from TableSourceTable.

KurtYoung
authored and
fhueske
committedDec 6, 2016
[FLINK-5257] [table] Include optimized logical plan in explain().

KurtYoung
authored and
fhueske
committedDec 6, 2016

Commits on Sep 27, 2016

[FLINK-4690] Replace SlotAllocationFuture with flink's own future

KurtYoung
authored and
tillrohrmann
committedSep 27, 2016

Commits on Sep 4, 2016

[FLINK-4459] [distributed runtime] Introduce SlotProvider for Scheduler

KurtYoung
authored and
StephanEwen
committedSep 4, 2016