Commits

Branch selector

 master

User selector

twalthr

Datepicker

All time

Commit History

Commits on Nov 5, 2021

• [hotfix][table-common] Fix nullability for DataTypeUtils.appendRowFields

  twalthr

  committed
  2a582f3

  Copy full SHA for 2a582f3

Commits on Nov 3, 2021

• [FLINK-24714][table-api-java] Validate partition keys for ResolvedCatalogTable

  Show description for 664fdae
  twalthr

  committed
  664fdae

  Copy full SHA for 664fdae

Commits on Oct 4, 2021

• [hotfix][table-planner] Disable IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs until FLINK-24443 is fixed

  twalthr

  committed
  9ab85e1

  Copy full SHA for 9ab85e1

Commits on Oct 1, 2021

• [hotfix][docs] Mention that modules can provide table source/sink factories

  twalthr

  committed
  04d0c1c

  Copy full SHA for 04d0c1c

• [hotfix][table-common] Fix grammar mistake in FunctionDefinition

  twalthr

  committed
  86ef3eb

  Copy full SHA for 86ef3eb

• [hotfix][table-api-scala] Unwrap Expression args for jsonObject and jsonArray

  twalthr

  committed
  55a1067

  Copy full SHA for 55a1067

Commits on Sep 30, 2021

• [hotfix][hive] Use consistent relocation pattern for Parque in Hive

  twalthr

  committed
  ce7481a

  Copy full SHA for ce7481a

• [FLINK-21142][connector-hive] Hide Guava from Hadoop and security tools

  Show description for 79e4c4c
  twalthr

  committed
  79e4c4c

  Copy full SHA for 79e4c4c

Commits on Sep 15, 2021

• [hotfix][docs] Add glossary entry for 'Table program'

  

  twalthr

  authored and

  dawidwys

  committed
  113956f

  Copy full SHA for 113956f

• [FLINK-21589][docs] Document table pipeline upgrades

  Show description for 1f17e33
  

  twalthr

  authored and

  dawidwys

  committed
  1f17e33

  Copy full SHA for 1f17e33

Commits on Sep 7, 2021

• [FLINK-23832][docs] Update DataStream API Integration page

  Show description for 6563270
  twalthr

  committed
  6563270

  Copy full SHA for 6563270

Commits on Sep 2, 2021

• [FLINK-24130][python] Fix RowDataSerializerTest after FLINK-24054

  Show description for e5b88a3
  twalthr

  committed
  e5b88a3

  Copy full SHA for e5b88a3

• [FLINK-24054][table-runtime] Let SinkUpsertMaterializer produce +U's when possible

  Show description for 35f6375
  twalthr

  committed
  35f6375

  Copy full SHA for 35f6375

Commits on Aug 31, 2021

• [FLINK-23895][table] Upsert materializer is not inserted for all sink providers

  Show description for db5af67
  twalthr

  committed
  db5af67

  Copy full SHA for db5af67

• [hotfix][table-common] Improve source and sink provider docs

  twalthr

  committed
  7d8af8f

  Copy full SHA for 7d8af8f

Commits on Aug 30, 2021

• [FLINK-24033][table-planner] Propagate unique keys for fromChangelogStream

  Show description for 93c5357
  twalthr

  committed
  93c5357

  Copy full SHA for 93c5357

Commits on Aug 26, 2021

• [FLINK-23915][table] Fix catalog and primary key resolution of temporary tables

  Show description for 1d2c565
  twalthr

  committed
  1d2c565

  Copy full SHA for 1d2c565

Commits on Aug 25, 2021

• [FLINK-23920][table-common] Keep primary key when inferring schema with SchemaTranslator

  Show description for cd52056
  twalthr

  committed
  cd52056

  Copy full SHA for cd52056

• [hotfix][table-common] Provide Schema.derived() for convenience

  twalthr

  committed
  3510e26

  Copy full SHA for 3510e26

• [hotfix][table-common] Fix minor issues in Schema class

  twalthr

  committed
  a3f6821

  Copy full SHA for a3f6821

• [FLINK-16769][table] Use new type inference in Table.flatMap()

  Show description for 90fb71e
  twalthr

  committed
  90fb71e

  Copy full SHA for 90fb71e

Commits on Aug 17, 2021

• [FLINK-23330][table-api] Deprecate old fromDataStream, toAppendStream, toRetractStream

  Show description for cff00f5
  twalthr

  committed
  cff00f5

  Copy full SHA for cff00f5

Commits on Aug 16, 2021

• [FLINK-18840][table-api] Add StreamStatementSet.attachAsDataStream()

  Show description for 7ff4cbd
  twalthr

  committed
  7ff4cbd

  Copy full SHA for 7ff4cbd

Commits on Aug 13, 2021

• [FLINK-20897][table-planner] Support batch mode in StreamTableEnvironment

  Show description for 0875db3
  twalthr

  committed
  0875db3

  Copy full SHA for 0875db3

• [FLINK-20897][table-planner] Derive boundedness in TransformationScanProvider

  twalthr

  committed
  17963e7

  Copy full SHA for 17963e7

• [FLINK-20897][table-planner] Add FlinkContext.isBatchMode flag

  twalthr

  committed
  e23498d

  Copy full SHA for e23498d

• [FLINK-20897][streaming-java] Make boundedness mutable in LegacySourceTransformation

  Show description for 21df58a
  twalthr

  committed
  21df58a

  Copy full SHA for 21df58a

• [hotfix][table] Improve signature of Executor

  twalthr

  committed
  6353f62

  Copy full SHA for 6353f62

Commits on Aug 12, 2021

• [FLINK-23707][streaming-java] Use consistent managed memory weights for StreamNode

  Show description for 3e62364
  twalthr

  committed
  3e62364

  Copy full SHA for 3e62364

Commits on Aug 11, 2021

• [FLINK-23646][streaming-java][table] Use pipeline name consistently across DataStream API and Table API

  Show description for 0f072a2
  twalthr

  committed
  0f072a2

  Copy full SHA for 0f072a2

Commits on Aug 5, 2021

• Revert "[FLINK-23487][s3] Update aws and presto-hive dependencies"

  Show description for 452fb67
  twalthr

  committed
  452fb67

  Copy full SHA for 452fb67

Commits on Aug 4, 2021

• [FLINK-23402][streaming-java] Simplify shuffle mode for batch execution

  Show description for de7a00b
  twalthr

  committed
  de7a00b

  Copy full SHA for de7a00b

• [FLINK-23498][table] Introduce a full planner configuration

  Show description for 7790702
  twalthr

  committed
  7790702

  Copy full SHA for 7790702

• [hotfix][table-planner] Remove unused field from PlannerBase

  twalthr

  committed
  d19d044

  Copy full SHA for d19d044

• [FLINK-23498][streaming-java] Expose an easier StreamExecutionEnvironment.configure()

  twalthr

  committed
  5b2535b

  Copy full SHA for 5b2535b

Pagination

Previous

Next