commits
Thread
Date
Earlier messages
Later messages
Messages by Thread
(flink) branch test-doc created (now e08af201a22)
guoweijie
(flink) 01/01: try to downgrade maven-javadoc-plugin to `2.10.4`
guoweijie
(flink) branch release-1.20 updated: [FLINK-34543][docs] Add document of full partition processing on non-keyed datastream
guoweijie
(flink) branch master updated: [FLINK-35227][rest] Remove execution-mode in ExecutionConfigInfo (#25080)
fanrui
(flink) branch master updated: [FLINK-35837][test] InitOutputPathTest.testErrorOccursUnSynchronized failed in JDK21 (#25097)
gongzhongqiang
(flink-cdc) branch master updated: [minor][cdc-connector][sqlserver] Fix some typos (#3421)
gongzhongqiang
(flink) branch master updated: [FLINK-28984][checkpoint] Fix concurrency issue between close and flushToFile in FsCheckpointStateOutputStream (#25095)
zakelly
(flink-cdc) branch master updated: [minor][cdc-connector][mysql] Code optimization for constants
leonard
(flink-cdc) branch master updated: [FLINK-35758][doc][cdc-connector][mysql] Add missed scan.startup.timestamp-millis option for mysql connector
leonard
(flink-cdc) branch master updated: [minor][cdc-connector][postgres] PostgresDialect removes useless code
leonard
(flink) branch master updated: [FLINK-35154][docs] Update maven-javadoc-plugin to fix render issue
guoweijie
(flink) branch master updated: [FLINK-35812] Move tuple interfaces to flink-core-api (#25074)
zakelly
(flink-cdc) branch master updated: [FLINK-34883] Fix postgres uuid column as PK (#3282)
gongzhongqiang
(flink) branch master updated (0050e426bc0 -> 48f352208b5)
zakelly
(flink-cdc) branch master updated: [build][CI] Introduce automated PR governance workflows
leonard
(flink-cdc) branch master updated: [hotfix][docs][postgres] Remove unsupported erroneous example code
leonard
(flink) branch release-1.18 updated: [hotfix] Set Opensearch connector version to v1.2
martijnvisser
(flink) branch release-1.19 updated: [hotfix] Set Opensearch connector version to v1.2
martijnvisser
(flink) branch release-1.19 updated: [hotfix] Set latest available connector version for Opensearch
martijnvisser
(flink) branch release-1.18 updated: [hotfix] Set correct available connector version numbers
martijnvisser
(flink) branch release-1.19 updated: [hotfix] Set correct available connector version numbers
martijnvisser
(flink-connector-mongodb) branch main updated: [FLINK-35616][Connectors/MongoDB] Support upsert into sharded collections (#37)
jiabaosun
(flink-cdc) branch master updated: [FLINK-34990][cdc-connector][oracle] Oracle cdc support newly add table (#3203)
gongzhongqiang
(flink) branch master updated: [FLINK-35799][table] Add CompiledPlan annotations to BatchExecCalc
twalthr
(flink) annotated tag release-1.20.0-rc1 updated (5328519f36d -> 0bb6592a09e)
guoweijie
svn commit: r70314 - in /dev/flink/flink-1.20.0-rc1: ./ python/
guoweijie
(flink) branch master updated (fd4b4005c93 -> 91a11acc2a8)
guoweijie
[I] java.lang.IllegalStateException: Failed to send request to coordinator: com.ververica.cdc.runtime.operators.schema.event.ReleaseUpstreamRequest@5b433541 [flink-cdc]
via GitHub
Re: [I] java.lang.IllegalStateException: Failed to send request to coordinator: com.ververica.cdc.runtime.operators.schema.event.ReleaseUpstreamRequest@5b433541 [flink-cdc]
via GitHub
Re: [I] java.lang.IllegalStateException: Failed to send request to coordinator: com.ververica.cdc.runtime.operators.schema.event.ReleaseUpstreamRequest@5b433541 [flink-cdc]
via GitHub
Re: [I] java.lang.IllegalStateException: Failed to send request to coordinator: com.ververica.cdc.runtime.operators.schema.event.ReleaseUpstreamRequest@5b433541 [flink-cdc]
via GitHub
Re: [I] java.lang.IllegalStateException: Failed to send request to coordinator: com.ververica.cdc.runtime.operators.schema.event.ReleaseUpstreamRequest@5b433541 [flink-cdc]
via GitHub
Re: [I] java.lang.IllegalStateException: Failed to send request to coordinator: com.ververica.cdc.runtime.operators.schema.event.ReleaseUpstreamRequest@5b433541 [flink-cdc]
via GitHub
(flink) branch master updated: [FLINK-35095][test] Fix unstable tests in `ExecutionEnvironmentImplTest`
guoweijie
(flink) branch release-1.20 updated: [FLINK-35804][table-planner] Fix incorrect calc merge during decorrelate phase
lincoln
(flink-cdc) branch master updated: [minor][cdc][docs] Optimize markdown formats in doris quickstart doc
leonard
(flink) branch master updated: [FLINK-35318][table-planner] Use UTC time zone for TIMESTAMP_LTZ type in RexNodeToExpressionConverter
leonard
(flink-kubernetes-operator) branch main updated: [FLINK-35126] Rework default checkpoint progress check window
gyfora
(flink-kubernetes-operator) branch main updated: [FLINK-35831] Rotate jobId for both savepoint and stateless deploys
gyfora
(flink-connector-jdbc) branch main updated: [hotfix][test] Change the modifier visibility of JUnit5.
fanrui
(flink) branch release-1.17 updated: [FLINK-35750][runtime/metrics] Fix that the latency marker metrics aren't updated after failover.
fanrui
(flink) branch release-1.18 updated: [FLINK-35750][runtime/metrics] Fix that the latency marker metrics aren't updated after failover.
fanrui
(flink) branch master updated: [FLINK-35804][table-planner] Fix incorrect calc merge during decorrelate phase
lincoln
(flink) branch release-1.20 updated: [FLINK-35829][table-planner] The requireWatermark property of StreamPhysicalWindowTableFunction needs to check the window's time type
lincoln
(flink) branch release-1.20 updated: [FLINK-35816][table-planner] Non-mergeable proctime tvf window aggregate needs to fallback to group aggregate
lincoln
(flink) branch master updated: [FLINK-35816][table-planner] Non-mergeable proctime tvf window aggregate needs to fallback to group aggregate
lincoln
(flink) branch master updated: [FLINK-35829][table-planner] The requireWatermark property of StreamPhysicalWindowTableFunction needs to check the window's time type
lincoln
(flink-connector-aws) branch main updated (f81473e -> 4258ec4)
hong
(flink) branch master updated: [FLINK-35820] Converting Duration to String fails for big values (#25077)
dwysakowicz
(flink-cdc) branch master updated: [FLINK-35781][cli] Provide a default parallelism 1 for pipeline jobs
leonard
(flink-cdc) branch master updated: [FLINK-35647][route] Support symbol replacement to enrich routing rules
leonard
(flink-connector-jdbc) branch main updated: [FLINK-35824] Polish JDBC documentation : fix link and add back to top button (#88)
gongzhongqiang
(flink) branch master updated: [FLINK-25537][JUnit5 Migration] Module: flink-core (#24939)
gongzhongqiang
(flink) branch master updated (765467f94ee -> a056e0230e8)
pnowojski
(flink) 07/08: [FLINK-35768][state,rocksdb] Use fast files download in RocksdBStateDownloader
pnowojski
(flink) 01/08: [hotfix] Create ConfigOptions for s3 access/secret keys and endpoint
pnowojski
(flink) 04/08: [FLINK-35767][filesystems] Add PathsCopyingFileSystem
pnowojski
(flink) 06/08: [FLINK-35768][state,rocksdb] Refactor RocksDBStateDownloader
pnowojski
(flink) 08/08: [FLINK-35768][tests] Add an ITCase for s5cmd
pnowojski
(flink) 02/08: [hotfix] Move CompressionUtils to flink-core
pnowojski
(flink) 03/08: [hotfix] Use newly defined ConfigOptions in MinioTestContainer
pnowojski
(flink) 05/08: [FLINK-35767][s3] Use s5cmd for fast files download from the s3
pnowojski
(flink) branch release-1.19 updated: [FLINK-33730][doc] Update the Flink upgrade savepoint compatibility table doc for chinese version
fanrui
(flink) branch release-1.20 updated: [FLINK-33730][doc] Update the Flink upgrade savepoint compatibility table doc for chinese version
fanrui
(flink) branch master updated: [hotfix][runtime] Avoid duplicating broadcast records redundantly for hybrid shuffle
guoweijie
(flink) branch master updated: [FLINK-35240][Connectors][format] Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record for csv format (#24730)
gongzhongqiang
(flink) branch release-1.20 updated (c8b46b09087 -> 8244941ed18)
ron
(flink) 01/02: [FLINK-35754][e2e] Fix SqlGatewayE2ECase.testMaterializedTableInFullMode failed due to Internal Server Error
ron
(flink) 02/02: [FLINK-35754][doc] Fix typo in materialized table docs
ron
(flink) branch master updated: [hotfix][table] Apply uppercase for URL_ENCODE/URL_DECODE remove logging from function class
snuyanzin
(flink-connector-aws) branch main updated: [FLINK-32324][Connectors/AWS] Implement support for watermark alignment in FLIP-27 sources for KDS and DDB streams
hong
(flink-connector-kafka) branch main updated: [FLINK-35749] Kafka sink component will lose data when kafka cluster is unavailable for a while (#107)
arvid
(flink) branch release-1.20 updated: [FLINK-35801] Fix SnapshotFileMergingCompatibilityITCase, wait for file deletion before quit (#25067)
zakelly
(flink) branch master updated: [FLINK-35801] Fix SnapshotFileMergingCompatibilityITCase, wait for file deletion before quit (#25066)
zakelly
(flink) branch master updated: [FLINK-35717][table] Allow defining partition keys and table distribution in CREATE TABLE AS (CTAS)
twalthr
(flink) branch release-1.20 updated: [FLINK-35803][checkpoint] Fix the wrong file reuse in cp file-merging (#25070)
zakelly
(flink) branch master updated: [FLINK-35803][checkpoint] Fix the wrong file reuse in cp file-merging (#25069)
zakelly
(flink) branch master updated (c00fcfb293d -> d04c70fae03)
ron
(flink) 01/02: [FLINK-35754][e2e] Fix SqlGatewayE2ECase.testMaterializedTableInFullMode failed due to Internal Server Error
ron
(flink) 02/02: [FLINK-35754][doc] Fix typo in materialized table docs
ron
(flink-connector-aws) branch main updated: [hotfix][ci] Update builds to test against 1.19.1
hong
(flink) branch master updated: [FLINK-33730][doc] Update the Flink upgrade savepoint compatibility table doc for chinese version
fanrui
(flink) branch master updated: [FLINK-35789][table] Allow defining watermarks & PRIMARY KEY in CREATE TABLE AS (CTAS)
twalthr
(flink-web) branch asf-site updated: Rebuild website
martijnvisser
(flink) branch master updated: [FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function
snuyanzin
(flink) branch master updated (b95c11803b7 -> 0bf2aaac0e3)
arvid
(flink) branch master updated: [hotfix] [docs] Fix broken link to "Anatomy of the Flink distribution"
hong
[I] When restoring a task from a savepoint, tables that were previously synchronized but later deleted still exist in a state [flink-cdc]
via GitHub
Re: [I] When restoring a task from a savepoint, tables that were previously synchronized but later deleted still exist in a state [flink-cdc]
via GitHub
Re: [I] When restoring a task from a savepoint, tables that were previously synchronized but later deleted still exist in a state [flink-cdc]
via GitHub
Re: [I] When restoring a task from a savepoint, tables that were previously synchronized but later deleted still exist in a state [flink-cdc]
via GitHub
(flink) branch master updated: [FLINK-35793][tests] Remove hybrid shuffle types from BatchSQLTest temporarily
guoweijie
(flink) branch master updated: [hotfix][checkpoint] Rename file-merging options in documents (#25048)
leiyanfei
(flink) branch release-1.19 updated: [FLINK-35786] Fix NPE BlobServer / shutdownHook
roman
(flink) branch master updated (3d793876048 -> 4e86d984374)
zakelly
(flink) branch release-1.18 updated: [hotfix] Fix the broken link of standalone deployment
zakelly
(flink) branch release-1.19 updated: [hotfix] Fix the broken link of standalone deployment
zakelly
(flink) branch release-1.20 updated: [hotfix] Fix the broken link of standalone deployment
zakelly
(flink) branch release-1.20 updated: [FLINK-35784][checkpoint] Fix the missing shared state registration of file-merging directories (#25052)
zakelly
(flink) branch master updated: [FLINK-35784][checkpoint] Fix the missing shared state registration of file-merging directories (#25051)
zakelly
(flink) branch release-1.20 updated: [hotfix][checkpoint] Rename file-merging options in documents (#25049)
leiyanfei
(flink-benchmarks) branch master updated: [hotfix] Update shaded 19.0
dwysakowicz
(flink-shaded) branch master updated: [hoftix] Update 20.0 version (#139)
dwysakowicz
(flink-cdc) branch master updated: [FLINK-35354] Support host mapping in Flink tikv cdc (#3336)
gongzhongqiang
(flink) branch master updated: [FLINK-35786] Fix NPE BlobServer / shutdownHook
roman
(flink) branch ngn346 deleted (was 81ea19f5b19)
pnowojski
(flink) branch master updated: [FLINK-35707][table] Allow column definition in CREATE TABLE AS (CTAS) (#24987)
twalthr
(flink) branch ngn346 created (now 81ea19f5b19)
pnowojski
(flink) branch ngn346 created (now 81ea19f5b19)
pnowojski
(flink) branch master updated: [FLINK-35778][checkpoint] Escape URI reserved characters when creating file-merging directories (#25030)
zakelly
(flink) branch release-1.20 updated: [FLINK-35778][checkpoint] Escape URI reserved characters when creating file-merging directories (#25031)
zakelly
(flink) branch release-1.20 updated: [FLINK-35750][runtime/metrics] Fix that the latency marker metrics aren't updated after failover.
fanrui
(flink) branch release-1.19 updated: [FLINK-35750][runtime/metrics] Fix that the latency marker metrics aren't updated after failover.
fanrui
(flink) branch release-1.20 updated: [FLINK-33192][runtime] Fix Memory Leak in WindowOperator due to Improper Timer Cleanup
hong
(flink) branch release-1.19 updated: [FLINK-33192][runtime] Fix Memory Leak in WindowOperator due to Improper Timer Cleanup
hong
(flink) branch master updated (f41927c5a9b -> 1bf0e347966)
hong
(flink) 02/02: FLINK-35657: fix for all loadMetrics with parseFloat
hong
(flink) 01/02: FLINK-35657: use parseFloat for metric value
hong
(flink) branch release-1.19 updated: [FLINK-35731][runtime] Fix incorrect parallelism configured detection for Sink V2.
zhuzh
(flink) branch release-1.18 updated: [BP-1.18] [FLINK-33192][runtime] Fix Memory Leak in WindowOperator due to Improper Timer Cleanup (#25032)
leiyanfei
(flink) branch master updated: [FLINK-33211][table] support flink table lineage (#25012)
zjureel
[I] flinkcdc3 [flink-cdc]
via GitHub
Re: [I] flinkcdc3 [flink-cdc]
via GitHub
Re: [I] flinkcdc3 official website operation error [flink-cdc]
via GitHub
Re: [I] flinkcdc3 official website operation error [flink-cdc]
via GitHub
Re: [I] flinkcdc3 official website operation error [flink-cdc]
via GitHub
Re: [I] flinkcdc3 official website operation error [flink-cdc]
via GitHub
Re: [I] flinkcdc3 official website operation error [flink-cdc]
via GitHub
(flink) branch master updated: [FLINK-33192][runtime] Fix Memory Leak in WindowOperator due to Improper Timer Cleanup (#24917)
leiyanfei
(flink) branch master updated: [FLINK-35750][runtime/metrics] Fix that the latency marker metrics aren't updated after failover.
fanrui
(flink) branch master updated: [FLINK-34130][core] Mark setBytes and getBytes of Configuration as @Internal (#24999)
fanrui
(flink) branch master updated: [hotfix] Fix merge conflicts in ParquetColumnarRowSplitReaderTest
lzljs3620320
(flink) branch master updated: [FLINK-35641] ParquetSchemaConverter supports required fields (#24956)
lzljs3620320
(flink) branch master updated: [FLINK-35696] JSON_VALUE/QUERY functions incorrectly map floating numbers (#25026)
dwysakowicz
(flink) branch release-1.20 updated (2b3a47d98bf -> cab08d95a85)
ron
(flink) 02/03: [FLINK-35643][doc] Add materialized table statement doc
ron
(flink) 03/03: [FLINK-35645][doc] Add quickstart for materialized table
ron
(flink) 01/03: [FLINK-35643][table] Fix incorrect comment in AlterMaterializedTableResumeOperation
ron
(flink) branch master updated (59769b7eaa5 -> 90fc679df07)
ron
(flink) 03/03: [FLINK-35645][doc] Add quickstart for materialized table
ron
(flink) 02/03: [FLINK-35643][doc] Add materialized table statement doc
ron
(flink) 01/03: [FLINK-35643][table] Fix incorrect comment in AlterMaterializedTableResumeOperation
ron
(flink) branch release-1.20 updated: [FLINK-35731][runtime] Fix incorrect parallelism configured detection for Sink V2.
zhuzh
(flink) branch master updated (6b08eb15d09 -> 59769b7eaa5)
dwysakowicz
(flink) 02/02: [FLINK-35755] Upgrade to flink-shaded 19.0
dwysakowicz
(flink-cdc) branch master updated: [FLINK-35281][cdc-common] FlinkEnvironmentUtils#addJar add each jar only once (#3301)
ruanhang1993
(flink) branch master updated: [FLINK-35731][runtime] Fix incorrect parallelism configured detection for Sink V2.
zhuzh
Re: [I] oracle-connector实时读取只读备库的问题 [flink-cdc]
via GitHub
(flink) branch release-1.19 updated: [FLINK-35498][table] Fix unexpected argument name conflicts when extracting method parameter names from UDF
lincoln
(flink) branch release-1.20 updated: [FLINK-35498][table] Fix unexpected argument name conflicts when extracting method parameter names from UDF
lincoln
(flink) branch ngn346 deleted (was 47ce6a97aaf)
pnowojski
(flink) branch master updated: [FLINK-34268] Removing exclusions for FLINK-33676 33805
martijnvisser
[I] lost data when gtid with Multiple transaction id on mgr cluster [flink-cdc]
via GitHub
Re: [I] lost data when gtid with Multiple transaction id on mgr cluster [flink-cdc]
via GitHub
Re: [I] lost data when gtid with Multiple transaction id on mgr cluster [flink-cdc]
via GitHub
Re: [I] lost data when gtid with Multiple transaction id on mgr cluster [flink-cdc]
via GitHub
Re: [I] lost data when gtid with Multiple transaction id on mgr cluster [flink-cdc]
via GitHub
(flink) branch master updated: [FLINK-35553][runtime] Wire-up RescaleManager with CheckpointStatsListener in Executing state
mapohl
(flink-kubernetes-operator) branch main updated: [FLINK-35357][docs] Add kubernetes.operator.plugins.listeners config (#845)
fanrui
(flink) branch master updated (482969aa24d -> 0b0158b4df9)
roman
(flink) 02/02: [hotfix] Propagate cancellation to RocksDBWriteBatchWrapper during recovery
roman
(flink) 01/02: [FLINK-35742] Don't create RocksDB Column Families if task cancellation is in progress
roman
(flink-web) branch asf-site updated (abf0b0fe8 -> dd795eecb)
dwysakowicz
(flink-web) 01/02: Release flink-shaded 19.0
dwysakowicz
(flink-shaded) annotated tag release-19.0 updated (26473c0 -> e686c1a)
dwysakowicz
svn commit: r70114 - /dev/flink/flink-shaded-19.0-rc1/ /release/flink/flink-shaded-19.0/
dwysakowicz
(flink) branch master updated (0b60bba6715 -> 482969aa24d)
mapohl
(flink) 01/06: [hotfix][runtime] Removes unused method
mapohl
(flink) 02/06: [hotfix][runtime] Remove no longer used CheckpointCoordinator#failUnacknowledgedPendingCheckpointsFor method.
mapohl
(flink) 03/06: [hotfix][runtime] Adds missing @Nullable annotation
mapohl
(flink) 05/06: [hotfix][runtime] Extracts CheckpointStatsTracker into interface
mapohl
(flink) 06/06: [FLINK-35552][runtime] Rework how CheckpointStatsTracker is constructed.
mapohl
(flink) 04/06: [hotfix][runtime] Make CheckpointStatsTracker not rely on numberOfTotalSubtasks
mapohl
(flink) branch master updated: Revert "[FLINK-33211][table] support flink table lineage (#24618)"
mapohl
(flink) branch master updated (af3e39fa4ce -> b782acfb9c0)
fanrui
(flink) 02/02: [FLINK-35733][tools] Add the Nonnull & Nullable annotations check rule.
fanrui
(flink) 01/02: [FLINK-35733] Change org.jetbrains.annotations.NotNull/Nullable to javax.annotation.Nonnull/Nullable
fanrui
(flink) branch master updated: [FLINK-35735][sql-gateway] Don't list all catalogs when closing session (#25010)
shengkai
(flink) branch master updated: [FLINK-33211][table] support flink table lineage (#24618)
zjureel
Re: [I] [ERROR] Could not execute SQL statement. Reason: java.io.StreamCorruptedException: unexpected block data [flink-cdc]
via GitHub
Re: [I] [ERROR] Could not execute SQL statement. Reason: java.io.StreamCorruptedException: unexpected block data [flink-cdc]
via GitHub
(flink) branch master updated (e56b54db40a -> c75248e48f4)
mapohl
(flink) 02/02: [FLINK-34582] Updates cibuildwheel to support cpython 3.11 wheel package
mapohl
(flink) 01/02: [FLINK-34487][ci] Adds Python Wheels nightly GHA workflow
mapohl
(flink-web) branch asf-site updated (207acb652 -> e4817ed04)
gyfora
(flink-web) 01/02: Flink Kubernetes Operator 1.9.0
gyfora
(flink) branch master updated: [FLINK-35625][cli] Merge "flink run" and "flink run-application" functionality, deprecate "run-application"
gaborgsomogyi
(flink-kubernetes-operator) annotated tag release-1.9.0-rc1 deleted (was c06634eb)
gyfora
(flink-kubernetes-operator) annotated tag release-1.9.0 updated (17129ff2 -> 05404db9)
gyfora
svn commit: r70088 - /release/flink/flink-kubernetes-operator-1.6.1/
gyfora
svn commit: r70087 - /dev/flink/flink-kubernetes-operator-1.9.0-rc1/ /release/flink/flink-kubernetes-operator-1.9.0/
gyfora
(flink) branch release-1.19 updated: [FLINK-35728][python] Move conda url from repo.continuum.io to repo.anaconda.com (#25008)
rmetzger
(flink) branch release-1.18 updated: [FLINK-35728][python] Move conda url from repo.continuum.io to repo.anaconda.com (#25007)
rmetzger
(flink) branch release-1.20 updated: [FLINK-35728][python] Move conda url from repo.continuum.io to repo.anaconda.com
rmetzger
(flink) branch master updated (99cb5c7addc -> c226ea938ad)
rmetzger
(flink) branch master updated: [FLINK-33212][core] add job status changed listener for lineage (#24754)
zjureel
(flink) branch master updated (84165b23cfc -> cfa09e27041)
lzljs3620320
(flink) branch release-1.20 updated (7f40c35fc74 -> d147bbf33d2)
ron
(flink) 02/02: [FLINK-35734][table] Do not override the user-defined checkpoint interval in continuous mode
ron
(flink) 01/02: [FLINK-35734][table] Fix periodic refresh job naming
ron
Earlier messages
Later messages