Commits

Branch selector

 72f18dc

User selector

All users

Datepicker

All time

Commit History

Commits on Mar 1, 2017

• [FLINK-5402] [tests] Increase JUnit timeouts in AkkaRpcServiceTest

  Show description for 72f18dc
  uce

  committed
  72f18dc

  Copy full SHA for 72f18dc

• [FLINK-5389] [tests] Increate ask timeout in JobSubmitTest

  uce

  committed
  b59c14e

  Copy full SHA for b59c14e

Commits on Feb 28, 2017

• [FLINK-5921] [table] Add custom data types for rowtime and proctime.

  Show description for 2a1a9c1
  fhueske

  committed
  2a1a9c1

  Copy full SHA for 2a1a9c1

• [hotfix] [tests] Fix test instability in SavepointITCase

  StephanEwen

  committed
  3086af5

  Copy full SHA for 3086af5

• [FLINK-5928] [checkpoints] Add CheckpointCoordinatorExternalizedCheckpointsTest

  Show description for c477d87
  

  uce

  authored and

  StephanEwen

  committed
  c477d87

  Copy full SHA for c477d87

• [FLINK-5822] [state backends] Make JobManager / Checkpoint Coordinator aware of the root state backend

  Show description for 3446e66
  StephanEwen

  committed
  3446e66

  Copy full SHA for 3446e66

• [FLINK-5897] [checkpoints] Make checkpoint externalization not depend strictly on FileSystems

  Show description for 5b7f21d
  StephanEwen

  committed
  5b7f21d

  Copy full SHA for 5b7f21d

• [FLINK-5133] [core] Followups for ResourceSpec on DataSet / DataStream API

  Show description for 9912de2
  StephanEwen

  committed
  9912de2

  Copy full SHA for 9912de2

• [FLINK-5133] [core] Add new setResource API for DataStream and DataSet

  Show description for f37ed02
  

  淘江

  authored and

  StephanEwen

  committed
  f37ed02

  Copy full SHA for f37ed02

• [FLINK-5929] [tests] Fix SavepointITCase instability

  Show description for c24c7ec
  

  uce

  authored and

  StephanEwen

  committed
  c24c7ec

  Copy full SHA for c24c7ec

• [FLINK-5501] [runtime] Make config key for ZooKeeper path for running registry consistent with other keys

  StephanEwen

  committed
  7f244b8

  Copy full SHA for 7f244b8

• [FLINK-5501] [runtime] Followups and improvements to RunningJobsRegistry

  Show description for e0dede9
  StephanEwen

  committed
  e0dede9

  Copy full SHA for e0dede9

• [FLINK-5501] [runtime] Extend RunningJobRegistry to job status created/running/done

  Show description for e7011d7
  

  tiemsn

  authored and

  StephanEwen

  committed
  e7011d7

  Copy full SHA for e7011d7

• [hotfix] [runtime] Reduce the gazillion deprecation warnings from the backwards-compatible savepoint path

  StephanEwen

  committed
  40743aa

  Copy full SHA for 40743aa

• [FLINK-5420] [cep] Make the CEP operators rescalable

  Show description for daf0ccd
  kl0u

  committed
  daf0ccd

  Copy full SHA for daf0ccd

• [FLINK-5157] [streaming] Introduce ProcessAllWindowFunction

  

  VenturaDelMonte

  authored and

  aljoscha

  committed
  788b839

  Copy full SHA for 788b839

• [FLINK-3903] [docs] Add Homebrew installation docs

  Show description for 87b9077
  

  p16i

  authored and

  uce

  committed
  87b9077

  Copy full SHA for 87b9077

• [FLINK-5871] [cep] Enforce uniqueness of pattern names in CEP.

  kl0u

  committed
  a92d787

  Copy full SHA for a92d787

Commits on Feb 27, 2017

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

  Show description for 1a062b7
  

  KurtYoung

  authored and

  fhueske

  committed
  1a062b7

  Copy full SHA for 1a062b7

• [FLINK-3475] [table] Add support for DISTINCT aggregates in SQL queries.

  Show description for 36c9348
  

  docete

  authored and

  fhueske

  committed
  36c9348

  Copy full SHA for 36c9348

• [hotfix] [kafka] Cleanup star / unused imports in all Flink Kafka tests

  tzulitai

  committed
  8bcb2ae

  Copy full SHA for 8bcb2ae

• [FLINK-5849] [kafka] Move FlinkKafkaConsumer start offset determination to open()

  Show description for ed68fed
  tzulitai

  committed
  ed68fed

  Copy full SHA for ed68fed

• [FLINK-5772] [elasticsearch] Allow Elasticsearch 1.x tests to rerun on failure

  Show description for 72f56d1
  tzulitai

  committed
  72f56d1

  Copy full SHA for 72f56d1

Commits on Feb 26, 2017

• [FLINK-5896][docs] improve readability of event time docs

  Show description for c57f07b
  

  David Anderson

  authored and

  uce

  committed
  c57f07b

  Copy full SHA for c57f07b

Commits on Feb 24, 2017

• [FLINK-5899] [table] Fix translation of batch event-time tumbling windows with non-partial aggregation functions.

  Show description for 0a97cd2
  

  shaoxuan-wang

  authored and

  fhueske

  committed
  0a97cd2

  Copy full SHA for 0a97cd2

• [FLINK-5710] [table] Add proctime() function to indicate processing time in Stream SQL.

  Show description for a755de2
  

  Haohui Mai

  authored and

  fhueske

  committed
  a755de2

  Copy full SHA for a755de2

• [hotfix] [core] Changing PublicEvolving anntoation of Archiveable to Internal.

  fhueske

  committed
  8c78aba

  Copy full SHA for 8c78aba

• [FLINK-5487] [elasticsearch] At-least-once Elasticsearch Sink

  Show description for 2437da6
  tzulitai

  committed
  2437da6

  Copy full SHA for 2437da6

• [FLINK-5353] [elasticsearch] User-provided failure handler for ElasticsearchSink

  Show description for 3743e89
  tzulitai

  committed
  3743e89

  Copy full SHA for 3743e89

• [FLINK-5122] [elasticsearch] Retry temporary Elasticsearch request errors.

  Show description for aaac7c2
  

  static-max

  authored and

  tzulitai

  committed
  aaac7c2

  Copy full SHA for aaac7c2

• [FLINK-5799] [rpc] Let RpcService.scheduleRunnable return a ScheduledFuture

  Show description for 0ba08b4
  tillrohrmann

  committed
  0ba08b4

  Copy full SHA for 0ba08b4

• [FLINK-5798] [rpc] Let the RpcService provide a ScheduledExecutorService

  Show description for ccf458d
  tillrohrmann

  committed
  ccf458d

  Copy full SHA for ccf458d

• [FLINK-5743] Mark WindowedStream.aggregate() methods as PublicEvolving

  aljoscha

  committed
  5983069

  Copy full SHA for 5983069

• [FLINK-5885] [docs] Fix Cassandra Scala snippet

  Show description for 6f3723e
  

  Andrea Sella

  authored and

  StephanEwen

  committed
  6f3723e

  Copy full SHA for 6f3723e

• [FLINK-5854] [core] Add base Flink Exception classes

  Show description for 813c258
  StephanEwen

  committed
  813c258

  Copy full SHA for 813c258

Pagination

Previous

Next