Commits

Breadcrumbs

History for

onb80d419

User selector

All users

Datepicker

All time

Commit History

Commits on Mar 18, 2022

• [FLINK-26689][table] Replace TableConfig with ReadableConfig

  Show description for 7fba24a
  

  matriv

  authored and

  twalthr

  committed
  7fba24a

• [FLINK-26536][python] Fix RemoteKeyedStateBackend#merge_namespaces to handle properly for the timerservice

  Show description for a54c110
  

  vancior98

  authored and

  dianfu

  committed
  a54c110

Commits on Mar 17, 2022

• [FLINK-26482][python] Support WindowedStream.reduce in Python DataStream API

  Show description for 7a7a406
  

  vancior98

  authored and

  dianfu

  committed
  7a7a406

• [FLINK-26607][python] Correct the MAX_LONG_VALUE/MIN_LONG_VALUE in several places

  Show description for d2d0065
  

  cun8cun8

  authored and

  dianfu

  committed
  d2d0065

Commits on Mar 15, 2022

• [FLINK-26421] Use only EnvironmentSettings to configure the environment

  Show description for 57742b8
  

  matriv

  authored and

  twalthr

  committed
  57742b8

• [FLINK-26444][python] Move all window tests into test_window.py

  Show description for d6a990d
  

  cun8cun8

  authored and

  dianfu

  committed
  d6a990d

• [FLINK-26506][python] Support StreamExecutionEnvironment.registerCachedFile in Python DataStream API

  Show description for eac5b97
  

  SteNicholas

  authored and

  dianfu

  committed
  eac5b97

• [FLINK-26444][python] Align the WindowAssigners with the Java DataStream API

  Show description for c3244c3
  

  cun8cun8

  authored and

  dianfu

  committed
  c3244c3

Commits on Mar 14, 2022

• Update version to 1.16-SNAPSHOT

  gaoyunhaii

  committed
  5c3bca5

Commits on Mar 9, 2022

• [FLINK-26543][python] Fix the issue that exceptions generated during startup are lost in Python loopback mode

  Show description for 23f5fe2
  HuangXingBo

  committed
  23f5fe2

Commits on Mar 7, 2022

• [FLINK-26504][python] Fix the incorrect type error in unbounded Python UDAF

  Show description for 8746017
  HuangXingBo

  committed
  8746017

• [FLINK-20633][python] Add retry times to download avro

  Show description for 34e6895
  HuangXingBo

  committed
  34e6895

Commits on Mar 2, 2022

• [FLINK-26434][table] Remove 'table.planner' config option and remaining Blink references

  Show description for 92eb824
  

  slinkydeveloper

  authored and

  twalthr

  committed
  92eb824

Commits on Feb 25, 2022

• [FLINK-26287][table] Add convenience method TableConfig.set

  twalthr

  committed
  d2e9473

Commits on Feb 23, 2022

• [FLINK-26042][python][doc] Raise exception when python version does not meet requirements.

  Show description for d33ba96
  HuangXingBo

  committed
  d33ba96

Commits on Feb 22, 2022

• [FLINK-26278][table-api-java] Add Expressions.col to Table API

  Show description for ec46816
  twalthr

  committed
  ec46816

Commits on Feb 21, 2022

• [FLINK-25856][python] Fix use of UserDefinedType in from_elements

  Show description for 6056680
  HuangXingBo

  committed
  6056680

Commits on Feb 16, 2022

• [FLINK-24385][table] Introduce TRY_CAST

  Show description for 3cf0393
  

  slinkydeveloper

  authored and

  twalthr

  committed
  3cf0393

• [FLINK-26060][table-planner] Remove persisted plan feature support for Python UDFs

  Show description for 010891a
  

  slinkydeveloper

  authored and

  twalthr

  committed
  010891a

• [FLINK-26089][table-api-java] Introduce TablePipeline

  Show description for 20a1b88
  

  slinkydeveloper

  authored and

  twalthr

  committed
  20a1b88

• [FLINK-26020][connector/pulsar] Unified Pulsar Connector config model for Pulsar source and sink.

  Show description for 36de46d
  

  syhily

  authored and

  fapaul

  committed
  36de46d

Commits on Feb 15, 2022

• [FLINK-25906][streaming] check explicit env allowed on StreamExecutionEnvironment own.

  

  JingGe

  authored and

  fapaul

  committed
  daff5df

• [FLINK-26090][table] Remove pre FLIP-84 APIs

  Show description for 17aed84
  

  slinkydeveloper

  authored and

  twalthr

  committed
  17aed84

Commits on Feb 14, 2022

• [FLINK-25940][python] Fix the unstable test test_keyed_process_function_with_state in PyFlink

  Show description for c92cda9
  HuangXingBo

  committed
  c92cda9

• [FLINK-25883][python] Set the default value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S to 30 days

  dianfu

  committed
  26bde8b

• [FLINK-24880][python] Fix PeriodicThread to handle properly for negative wait timeout value

  Show description for 7fb7bdf
  dianfu

  committed
  7fb7bdf

Commits on Feb 11, 2022

• [hotfix][build] Move one-off properties into using modules

  zentol

  committed
  5df6c4a

• [FLINK-25530][python][connectors/pulsar] Support Pulsar source connector in Python DataStream API. (apache#18388)

  a49a

  authored
  e44332c

Commits on Feb 9, 2022

• [FLINK-25841][table] Introduce new APIs for FLIP-190 single statement plan compilation

  

  slinkydeveloper

  authored and

  twalthr

  committed
  2cda6b7

Commits on Feb 8, 2022

• [FLINK-25984][core] Remove deprecated API usages

  matriv

  authored
  e921c4c

Commits on Feb 2, 2022

• [FLINK-25575][streaming] Expose transformations currently held by the StreamExecutionEnvironment

  Show description for 107390f
  

  fapaul

  and

  Arvid Heise

  committed
  107390f

Commits on Jan 28, 2022

• [FLINK-25776][build] sync netty versions

  zentol

  committed
  4a93582

Commits on Jan 27, 2022

• [FLINK-25836][python] Fix the unstable test test_keyed_process_function_with_state in PyFlink

  Show description for 13c8d4d
  HuangXingBo

  committed
  13c8d4d

• [FLINK-25719][python] Support General Python UDF in Thread Mode

  Show description for 51eb386
  HuangXingBo

  committed
  51eb386

Commits on Jan 19, 2022

• [FLINK-25609][table] Anonymous/inline tables don't require ObjectIdentifier anymore

  Show description for 50ff508
  

  slinkydeveloper

  authored and

  twalthr

  committed
  50ff508

Pagination

PreviousNext