issues
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: [PR] [FLINK-34565] Enhance flink kubernetes configMap to accommodate additional configuration files [flink]
via GitHub
Re: [PR] [FLINK-34565] Enhance flink kubernetes configMap to accommodate additional configuration files [flink]
via GitHub
Re: [PR] [FLINK-34331][ci] Adds reusable workflow that is used to load the runner configuration based on the projects owner [flink]
via GitHub
Re: [PR] [FLINK-34331][ci] Adds reusable workflow that is used to load the runner configuration based on the projects owner [flink]
via GitHub
Re: [PR] [FLINK-34508][ci] Migrates S3 ITCases to Minio tests [flink]
via GitHub
Re: [PR] [FLINK-34508][ci] Migrates S3 ITCases to Minio tests [flink]
via GitHub
Re: [PR] [FLINK-34542][docs] improved example quickstart build.gradle [flink]
via GitHub
Re: [PR] [FLINK-34542][docs] improved example quickstart build.gradle [flink]
via GitHub
Re: [PR] [FLINK-34480] support user jar class overwrite flink inner when meet the same. [flink]
via GitHub
Re: [PR] [FLINK-34480] support user jar class overwrite flink inner when meet the same. [flink]
via GitHub
Re: [PR] [FLINK-34535] Support JobPlanInfo for the explain result [flink]
via GitHub
Re: [PR] [FLINK-34535] Support JobPlanInfo for the explain result [flink]
via GitHub
Re: [PR] [FLINK-34522] Changing the Time to Duration for StateTtlConfig.Builder.cleanupInRocksdbCompactFilter [flink]
via GitHub
Re: [PR] [FLINK-34522] Changing the Time to Duration for StateTtlConfig.Builder.cleanupInRocksdbCompactFilter [flink]
via GitHub
Re: [PR] [FLINK-34477][table] Support capture groups in REGEXP_REPLACE [flink]
via GitHub
Re: [PR] [FLINK-34477][table] Support capture groups in REGEXP_REPLACE [flink]
via GitHub
Re: [PR] [FLINK-34264[plugins] add pushgateway http basic auth [flink]
via GitHub
Re: [PR] [FLINK-34264[plugins] add pushgateway http basic auth [flink]
via GitHub
Re: [PR] [FLINK-34147][table-planner] Enhance the java doc of TimestampData to distinguish the different usage of Instant and LocalDateTime [flink]
via GitHub
Re: [PR] [FLINK-34147][table-planner] Enhance the java doc of TimestampData to distinguish the different usage of Instant and LocalDateTime [flink]
via GitHub
Re: [PR] [FLINK-34463] Open catalog in CatalogManager should use proper context classloader [flink]
via GitHub
Re: [PR] [FLINK-34463] Open catalog in CatalogManager should use proper context classloader [flink]
via GitHub
Re: [PR] [FLINK-34045][ci] Refactors docs build scripts and adds CI for pushing docs changes [flink]
via GitHub
Re: [PR] [FLINK-34045][ci] Refactors docs build scripts and adds CI for pushing docs changes [flink]
via GitHub
Re: [PR] [WIP] Extend error labeling to avoid restart loops. [flink]
via GitHub
Re: [PR] [WIP] Extend error labeling to avoid restart loops. [flink]
via GitHub
Re: [PR] Chore: Change metric types, "numSplitsProcessed" in metrics.md [flink]
via GitHub
Re: [PR] Chore: Change metric types, "numSplitsProcessed" in metrics.md [flink]
via GitHub
Re: [PR] [FLINK-34447][test] Hardens ActiveResourceManagerTest#testWorkerRegistrationTimeoutNotCountingAllocationTime [flink]
via GitHub
Re: [PR] [FLINK-34447][test] Hardens ActiveResourceManagerTest#testWorkerRegistrationTimeoutNotCountingAllocationTime [flink]
via GitHub
Re: [PR] [FLINK-34427][runtime] Adds state check to requirementsCheck logic [flink]
via GitHub
Re: [PR] [FLINK-34427][runtime] Adds state check to requirementsCheck logic [flink]
via GitHub
Re: [PR] [FLINK-34431] Move static BlobWriter methods to separate util [flink]
via GitHub
Re: [PR] [FLINK-34431] Move static BlobWriter methods to separate util [flink]
via GitHub
Re: [PR] [FLINK-34421] Skip post-compile checks if 'fast' profile is active [flink]
via GitHub
Re: [PR] [FLINK-34421] Skip post-compile checks if 'fast' profile is active [flink]
via GitHub
Re: [PR] [FLINK-33396][table-planner] Fix table alias not be cleared in subquery [flink]
via GitHub
Re: [PR] [FLINK-33396][table-planner] Fix table alias not be cleared in subquery [flink]
via GitHub
Re: [PR] [FLINK-34060][table] Migrate UserDefinedTableAggFunctions to JavaUserDefinedTableAggFunctions [flink]
via GitHub
Re: [PR] [FLINK-34060][table] Migrate UserDefinedTableAggFunctions to JavaUserDefinedTableAggFunctions [flink]
via GitHub
Re: [PR] [FLINK-34372][table-api] Support DESCRIBE CATALOG [flink]
via GitHub
Re: [PR] [FLINK-34372][table-api] Support DESCRIBE CATALOG [flink]
via GitHub
Re: [PR] [FLINK-34366][table] Add support to group rows by column ordinals [flink]
via GitHub
Re: [PR] [FLINK-34366][table] Add support to group rows by column ordinals [flink]
via GitHub
Re: [PR] [FLINK-33549][table-runtime] Enable BatchMultipleInputStreamOperatorFactory to support YieldingOperatorFactory interface [flink]
via GitHub
Re: [PR] [FLINK-33549][table-runtime] Enable BatchMultipleInputStreamOperatorFactory to support YieldingOperatorFactory interface [flink]
via GitHub
Re: [PR] [FLINK-34094] Adds documentation for AsyncScalarFunction [flink]
via GitHub
Re: [PR] [FLINK-34094] Adds documentation for AsyncScalarFunction [flink]
via GitHub
Re: [PR] [hotfix] Fix spelling of RowTimeMiniBatchAssignerOperator class [flink]
via GitHub
Re: [PR] [hotfix] Fix spelling of RowTimeMiniBatchAssignerOperator class [flink]
via GitHub
Re: [PR] [Draft][bugfix] Move the deserialization of shuffleDescriptor to a separate … [flink]
via GitHub
Re: [PR] [Draft][bugfix] Move the deserialization of shuffleDescriptor to a separate … [flink]
via GitHub
Re: [PR] Update operators link in First Steps documentation [flink]
via GitHub
Re: [PR] Update operators link in First Steps documentation [flink]
via GitHub
Re: [PR] [WIP] [FLINK-21573][table-planner] Support expression reuse in codegen [flink]
via GitHub
Re: [PR] [WIP] [FLINK-21573][table-planner] Support expression reuse in codegen [flink]
via GitHub
Re: [PR] [DRAFT] new implementation of FLIP-403 [flink]
via GitHub
Re: [PR] [DRAFT] new implementation of FLIP-403 [flink]
via GitHub
Re: [PR] [FLINK-34210][Runtime/Checkpointing] Fix DefaultExecutionGraphBuilder#isCheckpointingEnabled return wrong value when checkpoint disabled [flink]
via GitHub
Re: [PR] [FLINK-34210][Runtime/Checkpointing] Fix DefaultExecutionGraphBuilder#isCheckpointingEnabled return wrong value when checkpoint disabled [flink]
via GitHub
Re: [PR] [FLINK-34133][table-planner] fix incorrect inference of minibatch interval traits [flink]
via GitHub
Re: [PR] [FLINK-34133][table-planner] fix incorrect inference of minibatch interval traits [flink]
via GitHub
Re: [PR] [FLINK-34110] Bump janino from 3.1.10 to 3.1.11 [flink]
via GitHub
Re: [PR] [FLINK-34110] Bump janino from 3.1.10 to 3.1.11 [flink]
via GitHub
Re: [PR] [FLINK-34109][connectors] FileSystem sink connector restore job from historical checkpoint bugfix [flink]
via GitHub
Re: [PR] [FLINK-34109][connectors] FileSystem sink connector restore job from historical checkpoint bugfix [flink]
via GitHub
Re: [PR] Some refactoring in StreamCommonSubGraphBasedOptimizer. [flink]
via GitHub
Re: [PR] Some refactoring in StreamCommonSubGraphBasedOptimizer. [flink]
via GitHub
Re: [PR] [FLINK-23687][table-planner] Introduce partitioned lookup join to enforce input of LookupJoin to hash shuffle by lookup keys [flink]
via GitHub
Re: [PR] [FLINK-23687][table-planner] Introduce partitioned lookup join to enforce input of LookupJoin to hash shuffle by lookup keys [flink]
via GitHub
Re: [PR] [FLINK-25054][table-planner] Extend the exception message for SHA2 function [flink]
via GitHub
Re: [PR] [FLINK-25054][table-planner] Extend the exception message for SHA2 function [flink]
via GitHub
Re: [PR] [FLINK-27455][tests] Migrate SnapshotMigrationTestBase to JUnit5 [flink]
via GitHub
Re: [PR] [FLINK-27455][tests] Migrate SnapshotMigrationTestBase to JUnit5 [flink]
via GitHub
Re: [PR] [FLINK-33686][client] Reuse ClusterDescriptor in AbstractSessionClusterExecutor [flink]
via GitHub
Re: [PR] [FLINK-33686][client] Reuse ClusterDescriptor in AbstractSessionClusterExecutor [flink]
via GitHub
Re: [PR] [FLINK-33688][client] Reuse connections in RestClient to save connection establish time [flink]
via GitHub
Re: [PR] [FLINK-33688][client] Reuse connections in RestClient to save connection establish time [flink]
via GitHub
Re: [PR] [FLINK-32756][ha] Implement reusable ClientHAServices and reuse it when creating RestClusterClient [flink]
via GitHub
Re: [PR] [FLINK-32756][ha] Implement reusable ClientHAServices and reuse it when creating RestClusterClient [flink]
via GitHub
Re: [PR] [FLINK-33809] HiveCatalog load hivemetastore-site.xml [flink]
via GitHub
Re: [PR] [FLINK-33809] HiveCatalog load hivemetastore-site.xml [flink]
via GitHub
Re: [PR] [FLINK-33687][client] Reuse RestClusterClient in StandaloneClusterDescriptor [flink]
via GitHub
Re: [PR] [FLINK-33687][client] Reuse RestClusterClient in StandaloneClusterDescriptor [flink]
via GitHub
Re: [PR] [hotfix] [tests] Per-class the lifecycle of mini-cluster in `ClientHeartbeatTest`. [flink]
via GitHub
Re: [PR] [hotfix] [tests] Per-class the lifecycle of mini-cluster in `ClientHeartbeatTest`. [flink]
via GitHub
Re: [PR] [FLINK-33685][client] Refactor StandaloneClusterId to distinguish different remote clusters [flink]
via GitHub
Re: [PR] [FLINK-33685][client] Refactor StandaloneClusterId to distinguish different remote clusters [flink]
via GitHub
Re: [PR] [FLINK-33797] Change log level for Application CANCELED/FAILED logs to WARN [flink]
via GitHub
Re: [PR] [FLINK-33797] Change log level for Application CANCELED/FAILED logs to WARN [flink]
via GitHub
Re: [PR] [DRAFT][FLINK-32667] Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster [flink]
via GitHub
Re: [PR] [DRAFT][FLINK-32667] Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster [flink]
via GitHub
Re: [PR] [DOC]Update watermark column type [flink]
via GitHub
Re: [PR] [DOC]Update watermark column type [flink]
via GitHub
Re: [PR] [FLINK-33472][Client] Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded [flink]
via GitHub
Re: [PR] [FLINK-33472][Client] Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded [flink]
via GitHub
Re: [PR] [FLINK-33728][k8s] do not rewatch when KubernetesResourceManagerDrive… [flink]
via GitHub
Re: [PR] [FLINK-33728][k8s] do not rewatch when KubernetesResourceManagerDrive… [flink]
via GitHub
Re: [PR] [FLINK-27681] RocksdbStatebackend verify incremental sst file checksum during checkpoint [flink]
via GitHub
Re: [PR] [FLINK-27681] RocksdbStatebackend verify incremental sst file checksum during checkpoint [flink]
via GitHub
Re: [PR] [FLINK-33212][core] Introduce job status changed listener for lineage [flink]
via GitHub
Re: [PR] [FLINK-33212][core] Introduce job status changed listener for lineage [flink]
via GitHub
Re: [PR] [FLINK-33524][ API / DataStream] fix IntervalJoinOperator 's judgment on isLate function bug [flink]
via GitHub
Re: [PR] [FLINK-33524][ API / DataStream] fix IntervalJoinOperator 's judgment on isLate function bug [flink]
via GitHub
Re: [PR] [FLINK-33719][table] Cleanup the usage of deprecated StreamTableEnvir… [flink]
via GitHub
Re: [PR] [FLINK-33719][table] Cleanup the usage of deprecated StreamTableEnvir… [flink]
via GitHub
Re: [PR] [FLINK-33500][Runtime] Run storing the JobGraph an asynchronous operation [flink]
via GitHub
Re: [PR] [FLINK-33500][Runtime] Run storing the JobGraph an asynchronous operation [flink]
via GitHub
Re: [PR] [FLINK-33500][Runtime] Run storing the JobGraph an asynchronous operation [flink]
via GitHub
Re: [PR] [FLINK-33500][Runtime] Run storing the JobGraph an asynchronous operation [flink]
via GitHub
Re: [PR] [FLINK-33751] use modules correctly when deserializing json plan [flink]
via GitHub
Re: [PR] [FLINK-33751] use modules correctly when deserializing json plan [flink]
via GitHub
Re: [PR] [DRAFT] Experiment of bulk sync task states [flink]
via GitHub
Re: [PR] [DRAFT] Experiment of bulk sync task states [flink]
via GitHub
Re: [PR] [hotfix][sql-client] remove duplicated code in CliUtils [flink]
via GitHub
Re: [PR] [hotfix][sql-client] remove duplicated code in CliUtils [flink]
via GitHub
Re: [PR] [FLINK-33684][datastream] Use IncrementalDelayRetryStrategy in CollectResultFetcher [flink]
via GitHub
Re: [PR] [FLINK-33684][datastream] Use IncrementalDelayRetryStrategy in CollectResultFetcher [flink]
via GitHub
Re: [PR] Clarity And Impact: Revamped Flink Feature Descriptions [flink]
via GitHub
Re: [PR] Clarity And Impact: Revamped Flink Feature Descriptions [flink]
via GitHub
Re: [PR] Bump @adobe/css-tools from 4.0.1 to 4.3.2 in /flink-runtime-web/web-dashboard [flink]
via GitHub
Re: [PR] Bump @adobe/css-tools from 4.0.1 to 4.3.2 in /flink-runtime-web/web-dashboard [flink]
via GitHub
Re: [PR] Bump @adobe/css-tools from 4.0.1 to 4.3.2 in /flink-runtime-web/web-dashboard [flink]
via GitHub
Re: [PR] Draft FLINK-32898 [CI] [flink]
via GitHub
Re: [PR] Draft FLINK-32898 [CI] [flink]
via GitHub
Re: [PR] [FLINK-33700] CustomSSLEngineProvider supports SHA-256 [flink]
via GitHub
Re: [PR] [FLINK-33700] CustomSSLEngineProvider supports SHA-256 [flink]
via GitHub
Re: [PR] [FLINK-33680][docs]Failed to build document with docker [flink]
via GitHub
Re: [PR] [FLINK-33680][docs]Failed to build document with docker [flink]
via GitHub
Re: [PR] [FLINK-33689][table-runtime] Fix JsonObjectAggFunction can't retract records when enabling LocalGlobal. [flink]
via GitHub
Re: [PR] [FLINK-33689][table-runtime] Fix JsonObjectAggFunction can't retract records when enabling LocalGlobal. [flink]
via GitHub
Re: [PR] [FLINK-33674][table-runtime][table-planner] In the wmassigners module… [flink]
via GitHub
Re: [PR] [FLINK-33674][table-runtime][table-planner] In the wmassigners module… [flink]
via GitHub
Re: [PR] [hotfix] Fix wrong flink-conf.yaml file path [flink]
via GitHub
Re: [PR] [hotfix] Fix wrong flink-conf.yaml file path [flink]
via GitHub
Re: [PR] [FLINK-33628][runtime] Upgrades default ZooKeeper version from 3.7.1 to 3.8.3 [flink]
via GitHub
Re: [PR] [FLINK-33628][runtime] Upgrades default ZooKeeper version from 3.7.1 to 3.8.3 [flink]
via GitHub
Re: [PR] Bump com.squareup.okio:okio from 1.17.2 to 1.17.6 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink]
via GitHub
Re: [PR] Bump com.squareup.okio:okio from 1.17.2 to 1.17.6 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink]
via GitHub
Re: [PR] Bump com.squareup.okio:okio from 1.17.2 to 1.17.6 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink]
via GitHub
Re: [PR] [FLINK-33507][json]Support zero-timestamp.behavior option for JSON fo… [flink]
via GitHub
Re: [PR] [FLINK-33507][json]Support zero-timestamp.behavior option for JSON fo… [flink]
via GitHub
Re: [PR] [FLINK-33508] [HistoryServer] Support for wildcard paths in Flink History Server for multi cluster environment [flink]
via GitHub
Re: [PR] [FLINK-33508] [HistoryServer] Support for wildcard paths in Flink History Server for multi cluster environment [flink]
via GitHub
Re: [PR] [FLINK-33053][runtime] Refactoring of workaround to fix thread leakage on the ZooKeeper server side. [flink]
via GitHub
Re: [PR] [FLINK-33053][runtime] Refactoring of workaround to fix thread leakage on the ZooKeeper server side. [flink]
via GitHub
Re: [PR] [FLINK-33536] Fix Flink Table API CSV streaming sink fails with IOException: Stream closed [flink]
via GitHub
Re: [PR] [FLINK-33536] Fix Flink Table API CSV streaming sink fails with IOException: Stream closed [flink]
via GitHub
Re: [PR] [FLINK-33509] Fix flaky test testNodeAffinity() in InitTaskManagerDecoratorTest.java [flink]
via GitHub
Re: [PR] [FLINK-33509] Fix flaky test testNodeAffinity() in InitTaskManagerDecoratorTest.java [flink]
via GitHub
Re: [PR] [hotfix] [docs] modify the Chinese translation content [flink]
via GitHub
Re: [PR] [hotfix] [docs] modify the Chinese translation content [flink]
via GitHub
Re: [PR] [FLINK-32763][streaming-java] Uncaught exceptions cause retry does not … [flink]
via GitHub
Re: [PR] [FLINK-32763][streaming-java] Uncaught exceptions cause retry does not … [flink]
via GitHub
Re: [PR] [FLINK-33428] Flink SQL CEP support 'followed','notNext' and 'notFollowedBy' semantics [flink]
via GitHub
Re: [PR] [FLINK-33428] Flink SQL CEP support 'followed','notNext' and 'notFollowedBy' semantics [flink]
via GitHub
Re: [PR] [FLINK-33373][build] Capture build scans on ge.apache.org to benefit from deep build insights [flink]
via GitHub
Re: [PR] [FLINK-33373][build] Capture build scans on ge.apache.org to benefit from deep build insights [flink]
via GitHub
Re: [PR] [FLINK-23598] [core] Fix a bug that caused position to be updated twice when writing a string to a byte array [flink]
via GitHub
Re: [PR] [FLINK-23598] [core] Fix a bug that caused position to be updated twice when writing a string to a byte array [flink]
via GitHub
Re: [PR] fix: missing serialVersionUID of serializable classes [flink]
via GitHub
Re: [PR] fix: missing serialVersionUID of serializable classes [flink]
via GitHub
Re: [PR] [FLINK-33882] UT/IT for checkpointing statistics [flink]
via GitHub
Re: [PR] [FLINK-33882] UT/IT for checkpointing statistics [flink]
via GitHub
Re: [PR] [FLINK-32175] [docs-zh] translate doc(datagen.md) into chinese [flink]
via GitHub
Re: [PR] [FLINK-32175] [docs-zh] translate doc(datagen.md) into chinese [flink]
via GitHub
Re: [PR] [FLINK-33871][HIVE]Reduce getTable call for hive client and optimize graph generation time [flink]
via GitHub
Re: [PR] [FLINK-33402] 2 CONTINUED [flink]
via GitHub
Re: [PR] [FLINK-33402] 2 CONTINUED [flink]
via GitHub
Re: [PR] Bump follow-redirects from 1.15.1 to 1.15.4 in /flink-runtime-web/web-dashboard [flink]
via GitHub
Re: [PR] Bump follow-redirects from 1.15.1 to 1.15.4 in /flink-runtime-web/web-dashboard [flink]
via GitHub
Re: [PR] Bump follow-redirects from 1.15.1 to 1.15.4 in /flink-runtime-web/web-dashboard [flink]
via GitHub
Re: [PR] [hotfix][docs] fix typo in ddl data type [flink]
via GitHub
Re: [PR] [hotfix][docs] fix typo in ddl data type [flink]
via GitHub
Re: [PR] [FLINK-33996][table-planner]: Avoid merging projects if leads to redundant computation [flink]
via GitHub
Re: [PR] [FLINK-33996][table-planner]: Avoid merging projects if leads to redundant computation [flink]
via GitHub
Re: [PR] [FLINK-34004] Harden TestingCheckpointIDCounter [flink]
via GitHub
Re: [PR] [FLINK-34004] Harden TestingCheckpointIDCounter [flink]
via GitHub
Re: [PR] [hotfix] [docs, RestartStrategyOptions]: update the default value of "restart-strategy.fixed-delay.attempts" to 1 in docs [flink]
via GitHub
Re: [PR] [hotfix] [docs, RestartStrategyOptions]: update the default value of "restart-strategy.fixed-delay.attempts" to 1 in docs [flink]
via GitHub
Re: [PR] [FLINK-33951][table] Use aggCallNeedRetractions instead of needRetrac… [flink]
via GitHub
Re: [PR] [FLINK-33951][table] Use aggCallNeedRetractions instead of needRetrac… [flink]
via GitHub
Re: [PR] [FLINK-33950][table] Update max aggregate functions to new type system [flink]
via GitHub
Re: [PR] [FLINK-33950][table] Update max aggregate functions to new type system [flink]
via GitHub
Re: [PR] [hotfix] Static import removed [flink]
via GitHub
Re: [PR] [hotfix] Static import removed [flink]
via GitHub
Re: [PR] [FLINK-33784][table] Support Configuring CatalogStoreFactory via StreamExecutionEnvironment [flink]
via GitHub
Re: [PR] [FLINK-33784][table] Support Configuring CatalogStoreFactory via StreamExecutionEnvironment [flink]
via GitHub
Re: [PR] [FLINK-33856][checkpointing] Add metrics for interaction performance with external storage system in the process of checkpoint making [flink]
via GitHub
Re: [PR] [FLINK-33856][checkpointing] Add metrics for interaction performance with external storage system in the process of checkpoint making [flink]
via GitHub
Re: [PR] [FLINK-33932][checkpointing] Add retry mechanism in RocksDBStateUploader [flink]
via GitHub
Re: [PR] [FLINK-33932][checkpointing] Add retry mechanism in RocksDBStateUploader [flink]
via GitHub
Re: [PR] Update content.zh/docs/dev/table/overview.md [flink]
via GitHub
Re: [PR] Update content.zh/docs/dev/table/overview.md [flink]
via GitHub
Re: [PR] [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function. [flink]
via GitHub
Re: [PR] [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function. [flink]
via GitHub
Re: [PR] [FLIP-278][connector] Add hybrid source connector for table & sql [flink]
via GitHub
Re: [PR] [FLIP-278][connector] Add hybrid source connector for table & sql [flink]
via GitHub
Re: [PR] [hotfix] Fix typo DataStream [flink]
via GitHub
Re: [PR] [hotfix] Fix typo DataStream [flink]
via GitHub
Earlier messages
Later messages