Commits

Branch selector

 master

User selector

FangYongs

Datepicker

All time

Commit History

Commits on Mar 14, 2018

• [FLINK-7521] Add config option to set the content length limit of REST server and client

  

  FangYongs

  authored and

  tillrohrmann

  committed
  6f46d6d

  Copy full SHA for 6f46d6d

Commits on Mar 2, 2018

• [FLINK-6352] [kafka] Support to set offset of Kafka with specific date

  

  FangYongs

  authored and

  tzulitai

  committed
  57ffdde

  Copy full SHA for 57ffdde

Commits on Feb 17, 2018

• [FLINK-7857][flip6] Port JobVertexDetailsHandler to REST endpoint

  

  FangYongs

  authored and

  tillrohrmann

  committed
  2c02786

  Copy full SHA for 2c02786

Commits on Feb 6, 2018

• [FLINK-7856][flip6] Port JobVertexBackPressureHandler to REST endpoint

  

  FangYongs

  authored and

  tillrohrmann

  committed
  7137d61

  Copy full SHA for 7137d61

Commits on Jan 25, 2018

• [FLINK-7858][flip6] Port JobVertexTaskManagersHandler to REST endpoint

  Show description for 056c72a
  

  FangYongs

  authored and

  tillrohrmann

  committed
  056c72a

  Copy full SHA for 056c72a

Commits on Nov 28, 2017

• [FLINK-6864] [core] Fix confusing "invalid POJO type" messages from TypeExtractor

  Show description for 450b424
  

  FangYongs

  authored and

  greghogan

  committed
  450b424

  Copy full SHA for 450b424

Commits on Oct 20, 2017

• [FLINK-7855] [flip6] Port JobVertexAccumulatorsHandler to REST endpoint

  

  FangYongs

  authored and

  tillrohrmann

  committed
  1348839

  Copy full SHA for 1348839

Commits on Oct 18, 2017

• [FLINK-7703] Port JobExceptionsHandler to new REST endpoint

  Show description for cb528a1
  

  FangYongs

  authored and

  zentol

  committed
  cb528a1

  Copy full SHA for cb528a1

Commits on Oct 16, 2017

• [FLINK-7495] Call to AbstractUdfStreamOperator#initializeState() in the beginning

  

  FangYongs

  authored and

  aljoscha

  committed
  0214e80

  Copy full SHA for 0214e80

Commits on Oct 14, 2017

• [FLINK-7419] [build] Shade jackson dependency in flink-avro

  Show description for dbaf262
  

  FangYongs

  authored and

  StephanEwen

  committed
  dbaf262

  Copy full SHA for dbaf262

Commits on Sep 15, 2017

• [FLINK-7402] [runtime] Fix null check in NettyMessage#write

  Show description for 312e085
  

  FangYongs

  authored and

  greghogan

  committed
  312e085

  Copy full SHA for 312e085

Commits on Aug 31, 2017

• [FLINK-6787] Fix Job-/StoppableException extend FlinkException

  

  FangYongs

  authored and

  aljoscha

  committed
  ddf62b1

  Copy full SHA for ddf62b1

Commits on Aug 19, 2017

• [FLINK-7269] Refactor passing of dynamic properties

  Show description for bd70a00
  

  FangYongs

  authored and

  tillrohrmann

  committed
  bd70a00

  Copy full SHA for bd70a00

Commits on Aug 11, 2017

• [FLINK-7396] Fix don't put multiple directories in HADOOP_CONF_DIR in config.sh

  

  FangYongs

  authored and

  aljoscha

  committed
  1de8acc

  Copy full SHA for 1de8acc

Commits on Aug 10, 2017

• [FLINK-6494] [RM][Yarn][Mesos] Migrate ResourceManager/Yarn/Mesos configuration options

  Show description for d63d704
  

  FangYongs

  authored and

  zentol

  committed
  d63d704

  Copy full SHA for d63d704

Commits on Jul 23, 2017

• [FLINK-6665] [FLINK-6667] [distributed coordination] Use a callback and a ScheduledExecutor for ExecutionGraph restarts

  Show description for 65400bd
  

  FangYongs

  authored and

  StephanEwen

  committed
  65400bd

  Copy full SHA for 65400bd

Commits on Jul 19, 2017

• [FLINK-7222] [kafka] Fix invalid symbol * when create directory on windows

  Show description for 2ee6ff5
  

  FangYongs

  authored and

  zentol

  committed
  2ee6ff5

  Copy full SHA for 2ee6ff5

Commits on Jul 11, 2017

• [FLINK-6058] Don't read DEFAULT_PARALLELISM from GlobalConfiguration

  

  FangYongs

  authored and

  aljoscha

  committed
  4aa2ffc

  Copy full SHA for 4aa2ffc

Commits on Jul 10, 2017

• [FLINK-7099] Replace usages of deprecated JOB_MANAGER_IPC_PORT_KEY and JOB_MANAGER_IPC_ADDRESS_KEY

  Show description for fb48dc2
  

  FangYongs

  authored and

  zentol

  committed
  fb48dc2

  Copy full SHA for fb48dc2

Commits on Jul 6, 2017

• [FLINK-6499] [config] Migrate state configuration options

  Show description for 10f5069
  

  FangYongs

  authored and

  tzulitai

  committed
  10f5069

  Copy full SHA for 10f5069

Commits on Jul 3, 2017

• [FLINK-6310] Use correct lock for synchronization in LocalExecutor

  

  FangYongs

  authored and

  aljoscha

  committed
  084bb4f

  Copy full SHA for 084bb4f

Commits on Jul 1, 2017

• [FLINK-6498] Migrate Zookeeper configuration options

  Show description for f839018
  

  FangYongs

  authored and

  zentol

  committed
  f839018

  Copy full SHA for f839018

• [FLINK-5488] Close YarnClient on error in AbstractYarnClusterDescriptor

  Show description for 3d2f3f6
  

  FangYongs

  authored and

  zentol

  committed
  3d2f3f6

  Copy full SHA for 3d2f3f6

Commits on May 22, 2017

• [FLINK-6495] Migrate Akka configuration options

  Show description for 302c674
  

  FangYongs

  authored and

  zentol

  committed
  302c674

  Copy full SHA for 302c674

Commits on May 19, 2017

• [FLINK-6439] Fix close OutputStream && InputStream in OperatorSnapshotUtil

  Show description for 65fdada
  

  FangYongs

  authored and

  zentol

  committed
  65fdada

  Copy full SHA for 65fdada

• [FLINK-6288] [kafka] New custom partitioner API that correctly handles multiple Kafka sink topics

  

  FangYongs

  authored and

  tzulitai

  committed
  9ed9b68

  Copy full SHA for 9ed9b68