apache / flink

35 Pull requests merged by 22 people

• [FLINK-22424][network] Prevent releasing PipelinedSubpartition while Task can still write to it

  #15734 merged Apr 26, 2021

• [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there exists custom MapData

  #15758 merged Apr 26, 2021

• [FLINK-22444][docs] Drop async checkpoint description of state backends in Chinese docs

  #15743 merged Apr 26, 2021

• [FLINK-18199] [chinese-translation]: translate FileSystem SQL Connector page into Chinese

  #13459 merged Apr 26, 2021

• [FLINK-19449][table-planner] LEAD/LAG cannot work correctly in streaming mode

  #15747 merged Apr 26, 2021

• [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there…

  #15569 merged Apr 26, 2021

• [FLINK-12351][DataStream] Fix AsyncWaitOperator to deep copy StreamElement when object reuse is enabled

  #8321 merged Apr 24, 2021

• [hotfix][docs] Fix some typos and sample codes syntax issues in sever…

  #15691 merged Apr 23, 2021

• [hotfix][docs] Fix typo in jdbc execution options

  #15737 merged Apr 23, 2021

• [FLINK-20723][cassandra][tests] Retry on NoHostAvailableException

  #15707 merged Apr 23, 2021

• [FLINK-21659][coordination] Properly expose checkpoint settings for initializing jobs

  #15708 merged Apr 23, 2021

• [FLINK-22384][docs]Chinese typos in "fault-tolerance/state/" page

  #15694 merged Apr 23, 2021

• [FLINK-22398][runtime]fix incorrect comments in InputOutputFormatVertex

  #15705 merged Apr 23, 2021

• [FLINK-22000] Set a default character set in InputStreamReader to sol…

  #15438 merged Apr 22, 2021

• [FLINK-22168][table] Partition insert can not work with union all

  #15666 merged Apr 22, 2021

• [FLINK-22168][table] Partition insert can not work with union all

  #15608 merged Apr 22, 2021

• [FLINK-20722][hive] HiveTableSink should copy the record when convert…

  #15696 merged Apr 22, 2021

• [hotfix] Regenerate html configuration after 4be9aff3eccb3808df1f10ef…

  #15719 merged Apr 22, 2021

• [FLINK-20654] Fix double recycling of Buffers in case of an exception on persisting

  #15714 merged Apr 22, 2021

• [FLINK-22092][hive] Ignore static conf file URLs in HiveConf

  #15692 merged Apr 21, 2021

• [FLINK-22349][table-api] Throw Exception for unsupported Zone ID instead of using wrong value.

  #15678 merged Apr 21, 2021

• [FLINK-22369][rocksdb] RocksDB state backend might occur ClassNotFoundException when deserializing on TM side

  #15688 merged Apr 21, 2021

• [hotfix] fix typo, assign processedData to currentProcessedData rather than currentPersistedData.

  #15403 merged Apr 21, 2021

• [hotfix] remove redundant config#setCheckpointStorage.

  #15381 merged Apr 21, 2021

• [FLINK-22372][table] Rename LogicalTypeCasts class variables in the castTo method.

  #15686 merged Apr 21, 2021

• [BP-1.13][FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

  #15690 merged Apr 20, 2021

• [FLINK-21329][tests] Increase timeout and delay in local test_local_recovery_and_scheduling.sh

  #15628 merged Apr 20, 2021

• [FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

  #15636 merged Apr 20, 2021

• [FLINK-22346][sql-client] Remove sql-client-defaults.yaml

  #15670 merged Apr 20, 2021

• [FLINK-21106][docs] Updates Flink docs to refer to the plugin's page

  #15685 merged Apr 20, 2021

• [FLINK-22352][mesos] Deprecates Mesos support

  #15673 merged Apr 20, 2021

• [FLINK-22338][table-planner] Clear watermark output when test finished for FromElementSourceFunctionWithWatermark

  #15672 merged Apr 20, 2021

• [FLINK-22021][table-planner-blink] Fix exception when PushFilterIntoLegacyTableSourceScanRule is faced with INTERVAL types

  #15615 merged Apr 20, 2021

• [FLINK-22092][hive] Ignore static conf file URLs in HiveConf

  #15483 merged Apr 20, 2021

• [FLINK-21073][docs] Mention that RocksDB would ignore java's equals/hashCode during comparing objects

  #15527 merged Apr 20, 2021

44 Pull requests opened by 36 people

• [FLINK-22358][connector base] Add stability annotations to connector base and iterator sources.

  #15679 opened Apr 19, 2021

• [FLINK-22362]Don't appear target address when taskmanager connect to jobmanager error

  #15683 opened Apr 20, 2021

• [FLINK-20899][table-planner-blink][hotfix] use cost factory in RelOptCluster to create HepPlanner.

  #15684 opened Apr 20, 2021

• [FLINK-22373][docs] Add Flink 1.13 release notes

  #15687 opened Apr 20, 2021

• [FLINK-21967] Add documentation on the operation of blocking shuffle

  #15701 opened Apr 21, 2021

• [FLINK-22275][table] Support random past for timestamp types in datagen connector

  #15703 opened Apr 21, 2021

• [FLINK-19519] [Runtime/Configuration] Support port range for Taskmanager data port configuration

  #15704 opened Apr 21, 2021

• [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

  #15712 opened Apr 21, 2021

• [FLINK-22368] Deque channel after releasing on EndOfPartition

  #15716 opened Apr 21, 2021

• [FLINK-22289] Update JDBC XA sink docs

  #15720 opened Apr 22, 2021

• [FLINK-22408]Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

  #15722 opened Apr 22, 2021

• [FLINK-21389] determine parquet schema from file instead of taking it from user

  #15725 opened Apr 22, 2021

• [BP-1.12][FLINK-22368] Deque channel after releasing on EndOfPartition

  #15726 opened Apr 22, 2021

• [BP-1.13][FLINK-22368] Deque channel after releasing on EndOfPartition

  #15727 opened Apr 22, 2021

• [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

  #15728 opened Apr 22, 2021

• [FLINK-22234][runtime] Read savepoint before creating ExecutionGraph

  #15729 opened Apr 23, 2021

• [FLINK-22378][table] Fix timestamp handling in toDataStream

  #15730 opened Apr 23, 2021

• [hotfix]: fix FileSystem.class default file system schema string synt…

  #15731 opened Apr 23, 2021

• [FLINK-22432] Update upgrading.md with 1.13.x

  #15735 opened Apr 23, 2021

• modify annotation

  #15738 opened Apr 23, 2021

• [FLINK-22419][coordination][tests] Rework RpcEndpoint delay tests

  #15741 opened Apr 23, 2021

• [FLINK-22442][CEP] Fix Using scala api to change the TimeCharacteristic o…

  #15742 opened Apr 24, 2021

• [FLINK-22113][table-planner-blink] Implement the column uniqueness checking for TableSourceTable

  #15744 opened Apr 25, 2021

• [FLINK-22304][table] Refactor some interfaces for TVF based window to…

  #15745 opened Apr 25, 2021

• [FLINK-17783][Table SQL/Ecosystem]Add array,map,row types support for orc row writer

  #15746 opened Apr 25, 2021

• [hotfix][coordination] Add log for slot allocation in FineGrainedSlot…

  #15748 opened Apr 25, 2021

• [hotfix][docs] Fix typo.

  #15749 opened Apr 25, 2021

• [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

  #15750 opened Apr 25, 2021

• [FLINK-22074][test] Harden FineGrainedSlotManagerTest#testRequirement…

  #15751 opened Apr 25, 2021

• [FLINK-19606][table-runtime-blink] Refactor JoinConditionWithFullFilters from an inner class in AbstractStreamingJoinOperator to a common utility class.

  #15752 opened Apr 25, 2021

• [FLINK-22428][docs][table] Translate timezone page into Chinese

  #15753 opened Apr 25, 2021

• [hotfix][hive / test]Add an ITCase that check partition-time commit pretty well

  #15754 opened Apr 25, 2021

• [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

  #15755 opened Apr 25, 2021

• [hotfix][docs] Removed duplicate 'is'

  #15756 opened Apr 25, 2021

• [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

  #15760 opened Apr 26, 2021

• [FLINK-16077][docs-zh] Translate Custom State Serialization page into Chinese

  #15761 opened Apr 26, 2021

• [FLINK-22469][runtime-web] Fix NoSuchFileException in HistoryServer

  #15762 opened Apr 26, 2021

• [FLINK-22364][doc] Translate the page of "Data Sources" to Chinese.

  #15763 opened Apr 26, 2021

• [FLINK-22471][flink-table][flink-connectors] Improvements to ConfigOption descriptions

  #15764 opened Apr 26, 2021

• [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all cases

  #15765 opened Apr 26, 2021

• [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all cases

  #15766 opened Apr 26, 2021

• [FLINK-22393][docs-zh] Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

  #15767 opened Apr 26, 2021

• [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

  #15768 opened Apr 26, 2021

• [FLINK-18952][python][docs] Add "10 minutes to DataStream API" documentation

  #15769 opened Apr 26, 2021

23 Unresolved conversations

Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.

• [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

  #15599 commented on Apr 26, 2021 • 55 new comments

• [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

  #15501 commented on Apr 23, 2021 • 41 new comments

• [FLINK-17857][test] Make K8s e2e tests could run on Mac

  #14012 commented on Apr 26, 2021 • 8 new comments

• [FLINK-21445][kubernetes] Application mode does not set the configuration when building PackagedProgram

  #15020 commented on Apr 21, 2021 • 7 new comments

• [FLINK-19606][table-runtime-blink] Implement streaming window join operator

  #15479 commented on Apr 26, 2021 • 7 new comments

• [FLINK-22329][hive] Inject current ugi credentials into jobconf when getting file split in hive connector

  #15653 commented on Apr 26, 2021 • 5 new comments

• [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

  #15131 commented on Apr 20, 2021 • 4 new comments

• [FLINK-22136][e2e] Console output changed to exception in DataStreamA…

  #15598 commented on Apr 26, 2021 • 4 new comments

• [FLINK-22311] [connector/jdbc] Validate maxRetries for XA Sink

  #15674 commented on Apr 23, 2021 • 4 new comments

• [FLINK-22018][Connectors/JDBC] Remove error log on retries in JdbcBatchingOutputFormat

  #15419 commented on Apr 22, 2021 • 3 new comments

• [FLINK-20895][flink-table-planner-blink] support local aggregate push down in blink planner

  #14894 commented on Apr 25, 2021 • 2 new comments

• [FLINK-22065] [sql-client]Beautify the parse error exception

  #15585 commented on Apr 20, 2021 • 2 new comments

• [FLINK-10911][scala-shell] Enable flink-scala-shell with Scala 2.12

  #11895 commented on Apr 25, 2021 • 1 new comment

• [FLINK-18202][PB format] New Format of protobuf

  #14376 commented on Apr 26, 2021 • 1 new comment

• [FLINK-21393] [formats] Implement ParquetAvroInputFormat

  #15156 commented on Apr 21, 2021 • 1 new comment

• [FLINK-22109][table-planner-blink] Resolve misleading exception message in invalid nested function

  #15523 commented on Apr 22, 2021 • 1 new comment

• [FLINK-20695][ha] Clean up ha data for job if globally terminated

  #15561 commented on Apr 23, 2021 • 1 new comment

• [FLINK-22272][table/catalog]Some scenes can't drop table by hive catalog

  #15638 commented on Apr 25, 2021 • 1 new comment

• The method $(String) is undefined for the type TableExample

  #15121 commented on Apr 26, 2021 • 0 new comments

• [hotfix][docs] Remove redundant import

  #15404 commented on Apr 21, 2021 • 0 new comments

• [FLINK-15571][connector] Redis Stream connector for Flink

  #15487 commented on Apr 21, 2021 • 0 new comments

• [FLINK-10052][ha] Tolerate temporarily suspended ZooKeeper connections

  #15675 commented on Apr 22, 2021 • 0 new comments

• [FLINK-22178][csv] Support ignore-first-line option in new csv format

  #15676 commented on Apr 19, 2021 • 0 new comments