https://github.com/apache/flink

sort by:
Revision Author Date Message Commit Date
69e8126 Commit for release 1.15.2 17 August 2022, 12:58:06 UTC
9791850 [FLINK-28861][table][docs] Update "upgrading" documentation to include notice regarding the Table API operator issue 16 August 2022, 18:15:36 UTC
44c6496 [FLINK-28994][runtime-web] Enable withCredentials for outgoing HTTP requests Some environments require cookies to authenticate the Flink UI. By enabling the withCredentials flag, Angular will send cookies along with the request. Signed-off-by: Ingo Bürk <airblader@apache.org> This closes #20593. 16 August 2022, 12:54:09 UTC
c90d0d5 [FLINK-28978][kinesis] Update AWS Regions validation to allow for future AWS regions 16 August 2022, 10:40:20 UTC
105d7c9 [FLINK-28861][table] Make UID generation behavior configurable and plan-only by default Before this commit, due to changes for FLIP-190, every operator generated by the planner got a UID assigned. However, the UID is based on a static counter that might return different results depending on the environment. Thus, UIDs are not deterministic and make stateful restores impossible e.g. when going from 1.15.0 -> 1.15.1. This PR restores the old pre-1.15 behavior for regular Table API. It only adds UIDs if the operator has been created from a compiled plan. A compiled plan makes the UIDs static and thus deterministic. table.exec.uid.generation=ALWAYS exists for backwards compatibility and could make stateful upgrades possible even with invalid UIDs on best effort basis. This closes #20586. 16 August 2022, 07:24:50 UTC
65f7913 [BK-1.15][FLINK-27199][Connector/Pulsar] Bump pulsar to 2.10.0 (#20582) * [FLINK-27199][Connector/pulsar] Use mocked pulsar runtime instead of embedded runtime and enable tests. * [FLINK-27199][Connector/Pulsar] Bump the pulsar-client-all to latest 2.10.0. * [FLINK-27199][Connector/Pulsar] Pulsar 2.10.0 deprecated the queue length, add new memory-based options. * [FLINK-27199][Connector/Pulsar] Move mocked Pulsar runtime to new local memory based metastore. Drop embedded Pulsar runtime. Add a bootstrap script for Pulsar docker runtime. 16 August 2022, 06:09:08 UTC
63c1c1b [FLINK-28908][python] Fix LIST type in Python DataStream API This closes #20539. 15 August 2022, 04:36:17 UTC
ded03b7 [FLINK-28878][tests] Increase slot request timeout of PipelinedRegionSchedulingITCase This helps to make the tests more stable. This closes #20559. 15 August 2022, 03:43:51 UTC
5f842cb [FLINK-27399][Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint. (#19972) (#20564) * Change the initial start cursor and stop cursor to better handle the consuming behaviors. * Create the initial subscription instead seek every time. This should fix the wrong position setting. * Fix the wrong stop cursor, make sure it stops at the correct space * Drop Consumer.seek() for https://github.com/apache/pulsar/pull/16171 14 August 2022, 14:49:32 UTC
e5570e3 [FLINK-28817][connector/common] NullPointerException in HybridSource when restoring from checkpoint 14 August 2022, 00:07:26 UTC
3d910dc [FLINK-27856][k8s] Fix the NPE when no spec is configured in pod template This closes #20558. 12 August 2022, 08:30:51 UTC
b24c516 [FLINK-27570][runtime] Count checkpoint finalization failures in CheckpointFailureManager 12 August 2022, 07:20:19 UTC
718bd1e [hotfix][python][dcos] Fix the typos in the Metrics Doc 12 August 2022, 04:46:07 UTC
d22c52f [FLINK-28027][connectors] Implement slow start for AIMDRateLimitingStrategy 11 August 2022, 10:10:26 UTC
c124872 [FLINK-28094][kinesis][glue] Updating AWS SDK versions for Kinesis connectors and Glue Schema Registry formats 09 August 2022, 21:36:52 UTC
979371c [FLINK-28094][kinesis] Removing references to Regions enum and instead using RegionUtils so that we include future AWS Regions as well 09 August 2022, 21:36:52 UTC
6eced8a [FLINK-28880][docs][cep] Fix wrong result of strict contiguity of looping patterns 09 August 2022, 03:36:46 UTC
39a737f [FLINK-28835][docs] Fix unaligned checkpoints documented compatibility It looks like there was a typo and we initially merged version conflicting with what was agreed in FLIP-203. 05 August 2022, 12:11:23 UTC
8db40ce [FLINK-28140][python][docs] Improve the documentation connector pages and metrics pages This closes #20385. 30 July 2022, 06:43:14 UTC
d5dc354 [FLINK-28602][state/changelog] Close stream of StateChangeFsUploader normally while enabling compression 29 July 2022, 07:04:08 UTC
64038da [FLINK-28577][web] Fix the null error of reading checkpointed_size in checkpoint tab 27 July 2022, 11:44:37 UTC
f9ece8b Update version to 1.15.1 27 July 2022, 08:51:00 UTC
28bb487 [FLINK-28680] Revisit 'free_disk_space.sh' to free up more space 26 July 2022, 12:30:22 UTC
7cd5fe9 [FLINK-23528][connectors/kinesis]Graceful shutdown of Kinesis Consumer in EFO mode 25 July 2022, 08:57:52 UTC
8fb2c3a [FLINK-23528][connectors/kinesis] Reenable FlinkKinesisITCase and rewrite stopWithSavepoint. 25 July 2022, 08:57:52 UTC
803dcad [FLINK-23528][connectors/kinesis] Gracefully shutdown shard consumer to avoid InterruptionExceptions. 25 July 2022, 08:57:52 UTC
f2e265f [FLINK-23528][connectors/kinesis] Use proper mock of ExecutorService in KinesisDataFetcherTest. Mockito makes it so much harder to debug tests. Here, we replace Mockito with a small test class that emulates the previously dispersed functionality in a simpler way. 25 July 2022, 08:57:52 UTC
ac60071 [FLINK-23528][datastream] Let CollectSinkOperator publish results in #close. DataStream#executeAndCollect expects the CollectSinkOperator to register the accumulator at the end of the application or fails with some exception. However, a stop-with-savepoint without drain would not trigger CollectSinkOperator#finish and thus skip the registration. 25 July 2022, 08:57:52 UTC
dbf1d62 [FLINK-28544][python][e2e] Clean up python environment after e2e tests This closes #20301. 20 July 2022, 06:14:44 UTC
adbf09f [FLINK-28250][Connector/Kafka] Fix exactly-once Kafka Sink out of memory 18 July 2022, 08:43:19 UTC
54c8d5a [FLINK-28140][python][docs] Improve the documentation by adding Python examples in several pages This closes #20290. 18 July 2022, 06:23:39 UTC
23381ad [FLINK-28486][docs-zh] Flink FileSystem SQL Connector Doc is not right This closes #20255 14 July 2022, 03:08:55 UTC
9ffb796 [FLINK-28454][kafka][docs] Fix the wrong timestamp unit of KafkaSource 13 July 2022, 08:38:18 UTC
31fca4a [FLINK-26621][tests] Close delegate keyed state backend 11 July 2022, 17:45:25 UTC
3e19fa2 Update japicmp configuration for 1.15.1 11 July 2022, 07:13:08 UTC
5c1d412 [FLINK-28357][datastream] Disallow null elements in StreamNode#typeSerializersIn Otherwise tasks can not correctly determine number of inputs. This was causing an issue where restored as finished OneInputStreamTask was waiting for MAX_WATERMARK from two inputs, where the second one was null. The problem was that {{FinishedOnRestoreInput#FinishedOnRestoreInput}} was being constructed with wrong number of inputs, because of some accidental {{null}} passed from the {{StreamGraphGenerator}}. 07 July 2022, 19:18:16 UTC
21f66c0 [hotfix] Remove unused methods in StreamGraph 07 July 2022, 19:18:16 UTC
e75bfae [FLINK-28140][python][docs] Improve the documentation by adding Python examples in Time Attributes page (#20194) 07 July 2022, 11:27:09 UTC
1dc4c5b [FLINK-28334][table-planner] Fix PushProjectIntoTableSourceScanRule: covers the case when table source SupportsReadingMetadata and not SupportsProjectionPushDown This closes #20118 (cherry picked from commit fb9843af5ffeb6d7561876704d463dea1fcdc153) 07 July 2022, 06:33:12 UTC
0c4ea69 [FLINK-28329][Tests] Output the top 15 directories in terms of used disk space (cherry picked from commit a33970455712b9d5a67cc66bb049d94ad4c4b543) 06 July 2022, 14:12:02 UTC
d0b181e [FLINK-26600][tests] Wait with savepoint until job is running 06 July 2022, 09:39:04 UTC
ef84a06 [FLINK-28404][tests] Invert isAssignableFrom order 06 July 2022, 08:56:15 UTC
20596b6 [FLINK-26323][tests] Allow CREATED state 06 July 2022, 07:07:55 UTC
5cc8796 [FLINK-27865][docs] Add example for configuring SASL and SSL in Kafka DataStream and SQL connector (#19904) 06 July 2022, 02:33:06 UTC
57c48a9 [FLINK-28322][table-api] DataStreamScan(Sink)Provider's new method is not compatible This closes #20119 06 July 2022, 02:06:52 UTC
2307064 [FLINK-28355][python][e2e] Clean up python environment after e2e tests 06 July 2022, 01:54:21 UTC
95f4b6f [FLINK-28240][network] Fix the bug that NetworkBufferPool#getRequestedSegmentsUsage may throw ArithmeticException. 05 July 2022, 07:08:51 UTC
013d6ff [hotfix][connector][pulsar] Address Spotless violation from FLINK-26931 04 July 2022, 13:58:46 UTC
56f8c0e [FLINK-26931][Connector/Pulsar] Add producer name for testing the unique producer in Pulsar. 01 July 2022, 11:35:08 UTC
68bb946 [FLINK-26931][Connector/pulsar] Make the producer name and consumer name unique for each instance. 01 July 2022, 11:35:08 UTC
898dc49 [FLINK-28140][python][docs] Improve the documentation by adding Python examples in DataStream API Integration page This closes #20121. 01 July 2022, 05:37:03 UTC
012a360 [FLINK-27031][runtime] Assign even empty old state to the task if the upstream has output states since the task should be prepared to filter these old incoming states from upstream 30 June 2022, 12:10:43 UTC
8295356 [FLINK-28269][Kubernetes] Install cri-dockerd and crictl so that we can continue to use Kubernetes 1.24+ and the `none` driver, since Kubernetes 1.24 has dropped support for Dockershim. 29 June 2022, 16:53:15 UTC
7557a28 [FLINK-28263][TPCDS][Tests] Clean-up generated data folder by TPCDS test 28 June 2022, 19:03:18 UTC
1e47430 [FLINK-25097][table-planner] Fix bug in inner join when the filter condition is boolean type This closes #19579 (cherry picked from commit 686634aa05aadc33cc7b655d25ad162fe59e41fd) 27 June 2022, 12:05:04 UTC
1d0dac0 [FLINK-27794][connectors/jdbc] Fix the wrong primary key for MysqlCatalog when there are tables with same name in different databases This closes #19741. 27 June 2022, 09:25:02 UTC
af0a415 [FLINK-28226][python] Limit grpcio<1.47 27 June 2022, 02:31:55 UTC
5b60be4 [FLINK-28239][table] Add commons-math3 to owner classpath 24 June 2022, 13:47:45 UTC
4885177 [hotfix][ci] Update libssl download link 22 June 2022, 09:31:12 UTC
efee740 [FLINK-27734][runtime-web] fix checkpoint interval in WebUI 20 June 2022, 07:25:41 UTC
921b608 [FLINK-28019][table] fix error when retract a staled record if state ttl enabled in RetractableTopNFunction This closes #19996 20 June 2022, 02:12:37 UTC
da05d0f [FLINK-28114][python] Fix the issue that the Python client interpreter could not point to an archive file in distributed file system 20 June 2022, 01:07:51 UTC
5439b42 [FLINK-27041][connector/kafka] Catch IllegalStateException in KafkaPartitionSplitReader.fetch() to handle no valid partition case This closes ##19980. 17 June 2022, 02:47:36 UTC
b6d5e3d [FLINK-27881][Connector/Pulsar] Never return null for PulsarMessageBuilder. 16 June 2022, 14:57:44 UTC
3e86cf2 [FLINK-26993][tests] Wait until checkpoint was actually triggered (cherry picked from commit a9a7d22b74479510a21cb2237def32c17a1980f0) 16 June 2022, 13:12:41 UTC
a5c0c87 [FLINK-27762][connector/kafka] Catch WakeupException and retry KafkaConsumer invocations in split assignment This closes #19981. 16 June 2022, 08:29:40 UTC
c9a706b [FLINK-28018][core] correct the start index for creating empty splits in BinaryInputFormat#createInputSplits This closes #19946. 15 June 2022, 03:03:36 UTC
ace5f3c [hotfix] Rework BinaryInputFormatTest to be based on AssertJ 15 June 2022, 03:02:12 UTC
96c400c [FLINK-24960][yarn-tests] change order of statements to avoid race condition 14 June 2022, 14:35:14 UTC
90b8e82 [FLINK-27999][hive] Fix Hive3 VirtualColumn NoSuchMethodError VirtualColumn.VIRTUAL_COLUMN_NAMES has a different type in hive2 vs hive3, causing NoSuchFieldErrors since our code is only compiled against hive2 14 June 2022, 08:32:11 UTC
6fcec2c [FLINK-27890][examples] Fix the bug introduced By [FLINK-19317] to use the return result after assignTimestampsAndWatermarks 13 June 2022, 08:23:04 UTC
0cd291d [FLINK-27933][rest] OperationResult implements Serializable 10 June 2022, 14:16:40 UTC
52b3569 [FLINK-27968][e2e] Fix PlannerScalaFreeITCase - only run the test in e2e profile - remove unnecessary dependencies 10 June 2022, 13:09:17 UTC
4b3121c [FLINK-27935][python][docs] Add Pyflink example of create temporary view document This closes #19918. 10 June 2022, 10:58:58 UTC
ce23d63 [FLINK-27418][table-planner] Fix topN retraction for previously deleted record This closes #19912 09 June 2022, 08:37:52 UTC
499ca04 [FLINK-27955][python] Fix the problem of windows installation failure in PyFlink This closes #19908. 08 June 2022, 12:25:11 UTC
ca05ad9 [FLINK-27606][table] Fix CompileException when using UDAF with merge() method (#19902) This closes #19902 08 June 2022, 09:56:37 UTC
a9905e2 [FLINK-27910][connector/filesystem] Register the timer to enforce rolling policy when file sink starts from scratch. This closes #19889. 08 June 2022, 07:41:41 UTC
e0af037 [FLINK-27683][table-planner] Fix SQL hints can't work with targetColumns This closes #19847 (cherry picked from commit 9bcc7fd20420bbf90f4b67d98c521a8ddf775d4e) 06 June 2022, 06:13:09 UTC
d5edd4c [FLINK-27797][python] Fix the issue that PythonTableUtils.getCollectionInputFormat cannot correctly handle None values This closes #19834. 01 June 2022, 12:48:12 UTC
73a33ab [FLINK-27848][runtime] Fix the problem that ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid. This closes #19853 01 June 2022, 07:36:43 UTC
1b2fb4f [hotfix][doc] fix typo and enlarge image This closes #19848. 01 June 2022, 01:43:40 UTC
177e8a7 [FLINK-27450][hive] Upgrade default hive version to fix Hive SessionState initialization issue with jdk11 This closes #19806. 26 May 2022, 10:01:38 UTC
9708f57 [FLINK-27776][python] Throw meaningful exceptions when UDAF doesn't override method 'merge' is used in cases where 'merge' is used This closes #19817. 26 May 2022, 08:35:55 UTC
6490cd5 [FLINK-27760][python] Fix the issue that NPE is thrown when executing PyFlink Table API jobs in batch mode This closes #19816. 26 May 2022, 01:09:14 UTC
c028c00 [FLINK-27174][connector/kafka] Fix checking of bootstrapServers when already provided in producer Properties 24 May 2022, 11:42:57 UTC
7b04b24 [FLINK-27751][build] Disable jboss repository 24 May 2022, 08:51:35 UTC
f413c40 [FLINK-27733][python] Rework on_timer output behind watermark bug fix This closes #19788. 24 May 2022, 02:16:40 UTC
9a4ca4c [FLINK-24735][sql-client] Catch Throwable rather than Exception in LocalExecutor to avoid client crash This closes #19793. 23 May 2022, 11:29:51 UTC
73590f4 [hotfix][python][connector/pulsar] Improve PulsarDeserializationSchema.flink_type_info set execution_config default to None 21 May 2022, 09:49:33 UTC
454f351 [FLINK-27711][python][connector/pulsar] Fix the typo of the method name from set_topics_pattern to set_topic_pattern This closes #19774. 21 May 2022, 09:01:39 UTC
3171cb0 [FLINK-26788][core] Add cause when AbstractDeserializationSchema throw exception This closes #19241. 20 May 2022, 08:57:57 UTC
f26831b [FLINK-27676][python] Fix on_timer output behind triggering watermark This closes #19765. 19 May 2022, 12:09:45 UTC
34d7bdc [FLINK-27167][test] change the junit-jupiter dependency scope to compile (cherry picked from commit 45afc031a222ec8ff1b02fb9a1d8b2826e43dc4f) 17 May 2022, 16:06:36 UTC
5f2c9c7 [FLINK-26909][Client/Job Submission] Allow to set parallelism to be -1 from Cli This closes #19651. 17 May 2022, 04:01:05 UTC
f97738c [FLINK-24433][Tests][Buildsystem] Remove additional pre-installed packages to clean up more diskspace before starting the E2E tests. Also removing the line that removes `^ghc-8.*` since that doesn't exist anymore on the machines. (cherry picked from commit db6baf47130872ccdcd56949510704bbdf69c387) 16 May 2022, 19:54:39 UTC
6d68fd7 [FLINK-27534][build] Ignore scalafmt commit in .git-blame-ignore-revs 16 May 2022, 12:57:43 UTC
5d5d4ae [FLINK-27534][build] Format code with Spotless/scalafmt 16 May 2022, 12:49:42 UTC
bea6baf [FLINK-27317][build] Don't fork build for attaching sources 16 May 2022, 12:46:10 UTC
09293d6 [FLINK-27317][build] Use absolute paths to .scalafmt.conf 16 May 2022, 12:46:10 UTC
back to top