Commits

Branch selector

 40c978b

User selector

All users

Datepicker

All time

Commit History

Commits on Sep 23, 2016

• [FLINK-4668] [clients] Fix positive random int generation

  Show description for 40c978b
  

  apivovarov

  authored and

  greghogan

  committed
  40c978b

  Copy full SHA for 40c978b

• [FLINK-4664] [gelly] Add translator to NullValue

  Show description for dd90abe
  greghogan

  committed
  dd90abe

  Copy full SHA for dd90abe

• [FLINK-4482] [checkpoints] Make numUnsuccessfulCheckpointsTriggers an atomic integer

  Show description for 5d0358a
  

  tedyu

  authored and

  StephanEwen

  committed
  5d0358a

  Copy full SHA for 5d0358a

• [FLINK-4549] [table] Test and document implicitly supported SQL functions

  Show description for 9a1bc02
  twalthr

  committed
  9a1bc02

  Copy full SHA for 9a1bc02

• [FLINK-4550] [table] Clearly define SQL operator table

  Show description for ecbccd9
  twalthr

  committed
  ecbccd9

  Copy full SHA for ecbccd9

• [hotfix] Replace registerTimer/getTime by TimeServiceProvider in Context

  aljoscha

  committed
  51a5048

  Copy full SHA for 51a5048

• [FLINK-4494] Expose the TimeServiceProvider from the Task to each Operator.

  

  kl0u

  authored and

  aljoscha

  committed
  ffff299

  Copy full SHA for ffff299

• [FLINK-4496] Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable.

  

  kl0u

  authored and

  aljoscha

  committed
  4779c7e

  Copy full SHA for 4779c7e

• [FLINK-4666] [core] Declare constants as final in ParameterTool

  Show description for 568845a
  

  apivovarov

  authored and

  StephanEwen

  committed
  568845a

  Copy full SHA for 568845a

• [FLINK-4665] [misc] Remove unnecessary boxing/unboxing of primitive types in various places

  Show description for 37c9512
  

  apivovarov

  authored and

  StephanEwen

  committed
  37c9512

  Copy full SHA for 37c9512

• [FLINK-4663] [jdbc] Fix JDBCOutputFormat log message

  Show description for 335a282
  

  pm-swapnil-chougule

  authored and

  StephanEwen

  committed
  335a282

  Copy full SHA for 335a282

• [FLINK-4556] [distributed runtime] Make Queryable State Key-Group Aware

  Show description for 181b545
  

  StefanRRichter

  authored and

  StephanEwen

  committed
  181b545

  Copy full SHA for 181b545

Commits on Sep 22, 2016

• [hotfix] Minor code cleanup in StreamTask

  StephanEwen

  committed
  4ee048b

  Copy full SHA for 4ee048b

• [FLINK-4628] [core] Provide user class loader during input split assignment

  Show description for 345b252
  

  mxm

  authored and

  StephanEwen

  committed
  345b252

  Copy full SHA for 345b252

• [FLINK-4603] [checkpoints] Fix user code classloading in KeyedStateBackend

  Show description for 3b8fe95
  

  StefanRRichter

  authored and

  StephanEwen

  committed
  3b8fe95

  Copy full SHA for 3b8fe95

• [FLINK-3580] [table] Add OVERLAPS function

  Show description for e6fbda9
  twalthr

  committed
  e6fbda9

  Copy full SHA for e6fbda9

• [FLINK-4248] [core] [table] CsvTableSource does not support reading SqlTimeTypeInfo types

  Show description for 3507d59
  twalthr

  committed
  3507d59

  Copy full SHA for 3507d59

Commits on Sep 21, 2016

• [docs] Update docs on data types and serialization, to include type hints, type registration, and serializer registration.

  StephanEwen

  committed
  b516056

  Copy full SHA for b516056

• [hotfix] [tests] Fix race condition in RescalingITCase that could make the test stuck in a blocking call until timeout

  Show description for 5f67b54
  

  StefanRRichter

  authored and

  StephanEwen

  committed
  5f67b54

  Copy full SHA for 5f67b54

• [FLINK-4640] [streaming api] Ensure that the state descriptors properly initialize the serializers.

  StephanEwen

  committed
  4d4eb64

  Copy full SHA for 4d4eb64

• [FLINK-4645] [core] Adjust signatures of 'registerTypeWithKryoSerializer(...)' methods to allow simpler passing of

  Show description for 82ef021
  StephanEwen

  committed
  82ef021

  Copy full SHA for 82ef021

• [hotfix] [streaming api] Add proper deprecation JavaDocs

  Show description for 349d06d
  StephanEwen

  committed
  349d06d

  Copy full SHA for 349d06d

• [hotfix] [docs] Parametrized version of quickstart script and artifacts in the quickstart docs

  Show description for db45da7
  

  chobeat

  authored and

  StephanEwen

  committed
  db45da7

  Copy full SHA for db45da7

• [FLINK-4654] [docs] Small improvements to the docs.

  Show description for 7212202
  

  alpinegizmo

  authored and

  greghogan

  committed
  7212202

  Copy full SHA for 7212202

• [FLINK-3042] [FLINK-3060] [types] Define a way to let types create their own TypeInformation

  Show description for 4cc38fd
  twalthr

  committed
  4cc38fd

  Copy full SHA for 4cc38fd

Commits on Sep 20, 2016

• [FLINK-3929] additional fixes for keytab security

  Show description for 68709b0
  mxm

  committed
  68709b0

  Copy full SHA for 68709b0

• [FLINK-3929] conditionally skip RollingSinkSecuredITCase

  Show description for 285b6f7
  mxm

  committed
  285b6f7

  Copy full SHA for 285b6f7

• [FLINK-3929] Added Keytab based Kerberos support to enable secure Flink cluster deployment(addresses HDHS, Kafka and ZK services)

  Show description for 25a622f
  

  vijikarthi

  authored and

  mxm

  committed
  25a622f

  Copy full SHA for 25a622f

• [FLINK-2662] [dataSet] [optimizer] Fix merging of unions with multiple outputs.

  Show description for 303f6fe
  fhueske

  committed
  303f6fe

  Copy full SHA for 303f6fe

• [FLINK-4268] [core] Add a parsers for BigDecimal/BigInteger

  Show description for 5c02988
  twalthr

  committed
  5c02988

  Copy full SHA for 5c02988

• [FLINK-4572] [gelly] Convert to negative in LongValueToIntValue

  Show description for e58fd6e
  greghogan

  committed
  e58fd6e

  Copy full SHA for e58fd6e

• [FLINK-4594] [core] Validate lower bound in MathUtils.checkedDownCast

  Show description for 4f84a02
  greghogan

  committed
  4f84a02

  Copy full SHA for 4f84a02

• [FLINK-4609] [java-api] Remove redundant check for null in CrossOperator

  Show description for 470b752
  

  apivovarov

  authored and

  greghogan

  committed
  470b752

  Copy full SHA for 470b752

• [FLINK-4638] [core] Fix exception message for MemorySegment

  Show description for 7a25bf5
  

  lw-lin

  authored and

  greghogan

  committed
  7a25bf5

  Copy full SHA for 7a25bf5

• [FLINK-4247] [table] CsvTableSource.getDataSet() expects Java ExecutionEnvironment

  Show description for 0975d9f
  twalthr

  committed
  0975d9f

  Copy full SHA for 0975d9f

Pagination

Previous

Next