Commits

Commits on Oct 20, 2020

[FLINK-19728][yarn][test] Disable external resource related tests in TaskExecutorProcessSpecContainerResourcePriorityAdapterTest.
xintongsong
committedOct 20, 2020
[FLINK-19728] Revert "[FLINK-19689][yarn][test] Fix TaskExecutorProcessSpecContainerResourcePriorityAdapterTest failure for Hadoop 2.10+."
xintongsong
committedOct 20, 2020
[FLINK-19707][table-runtime] Refactor table streaming file sink
JingsongLi
committedOct 20, 2020
[FLINK-19664][e2e] Upload logs before tests time out
rmetzger
committedOct 20, 2020
[FLINK-19695][table-runtime-blink] Fix ClassCastException when writing table with rowtime attribute
wuchong
committedOct 20, 2020
[FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL (apache#13577 )
danny0405
committedOct 20, 2020
[FLINK-19579] Add the SideOutputTransformation translator
kl0u
committedOct 20, 2020
[FLINK-19578] Add PartitionTransformation translator
kl0u
committedOct 20, 2020
[FLINK-19577] Add the UnionTransformation translator
kl0u
committedOct 20, 2020
[FLINK-19575] Add LegacySourceTransformation translator
kl0u
committedOct 20, 2020
[FLINK-19576] Add LegacySinkTransformation translator
kl0u
committedOct 20, 2020
[FLINK-19574] Add SourceTransformation translator
kl0u
committedOct 20, 2020
[FLINK-19368][hive] TableEnvHiveConnectorITCase fails with Hive-3.x
lirui-apache
committedOct 20, 2020
[FLINK-19716][Kinesis][EFO] Unable to use Assume Role with EFO record publisher

dannycranmer
authored and
tzulitai
committedOct 20, 2020
[hotfix][yarn] Remove unused function in YarnResourceManagerDriver

KarmaGYZ
authored and
xintongsong
committedOct 20, 2020
[FLINK-19649][sql-parser] Fix unparse method of sql create table without columns (apache#13651 )
gsralex
committedOct 20, 2020
[FLINK-18836][python] Support Python UDTF return types which are not generator

HuangXingBo
authored and
dianfu
committedOct 20, 2020
[FLINK-19643][python][docs] Add Pandas UDAF documentation

HuangXingBo
authored and
dianfu
committedOct 20, 2020
[FLINK-19623][table-planner] Introduce ExecEdge to describe information on input edges for ExecNode (apache#13625 )
tsreaper
committedOct 20, 2020

Commits on Oct 19, 2020

[hotfix][connector-kafka] Deprecate old Kafka table sources and sinks
twalthr
committedOct 19, 2020
[FLINK-19672][connector-kafka] Update Kafka table sources and sinks
twalthr
committedOct 19, 2020
[FLINK-19672][connector-kafka] Merge internal and internals package
twalthr
committedOct 19, 2020
[FLINK-19672][connector-kafka] Merge connector-kafka-base and connector-kafka
twalthr
committedOct 19, 2020
[FLINK-19619][e2e] Pin CloudSDK version to have access to pubsub emulator in test
rmetzger
committedOct 19, 2020
[FLINK-13553] Ignore KvStateServerHandlerTest because it is unstable
tillrohrmann
committedOct 19, 2020
[FLINK-13553] Disable TRACE console logging for queryable state
tillrohrmann
committedOct 19, 2020
[FLINK-19617][runtime] Introduced new metric for monitoring the JVM Metaspace.

XComp
authored and
zentol
committedOct 19, 2020
[hotfix][runtime] Added missing test MetricUtilsTest.testNonHeapMetricUsageNotStatic and renamed testHeapMetric to make it more descriptive.

XComp
authored and
zentol
committedOct 19, 2020
[FLINK-19450][python][tests] Optimize the Python CI Test to reduce execution time

HuangXingBo
authored and
dianfu
committedOct 19, 2020
[hotfix][python][tests] Set the parallelism of Python DataStream API tests to 2
dianfu
committedOct 19, 2020
[FLINK-18937][python][docs] Add an "Environment Setup" section to the Installation documentation (apache#13170 )
HuangXingBo
committedOct 19, 2020
[FLINK-19625][table-planner] Introduce multi-input exec node (apache#13671 )
godfreyhe
committedOct 19, 2020
[FLINK-19689][yarn][test] Fix TaskExecutorProcessSpecContainerResourcePriorityAdapterTest failure for Hadoop 2.10+.
xintongsong
committedOct 19, 2020

Commits on Oct 18, 2020