issues  

Messages by Thread

• • 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
• [jira] [Comment Edited] (FLINK-37753) Improve error handling for UNIX_TIMESTAMP david radley (Jira)
• [jira] [Commented] (FLINK-37753) Improve error handling for UNIX_TIMESTAMP david radley (Jira)
  • [jira] [Commented] (FLINK-37753) Improve error handling for UNIX_TIMESTAMP Martijn Visser (Jira)
• [PR] [hotfix][docs] Fix some issue in DataStream API (V1) / Data Sinks [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix some issue in DataStream API (V1) / Data Sinks [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix some issue in DataStream API (V1) / Data Sinks [flink] via GitHub
• [jira] [Assigned] (FLINK-37730) Collect job exceptions as kubernetes events Fabian Hueske (Jira)
• [PR] [FLINK-37730][rest] Add client method for getting JM exception history [flink] via GitHub
  • Re: [PR] [FLINK-37730][rest] Add client method for getting JM exception history [flink] via GitHub
  • Re: [PR] [FLINK-37730][rest] Add client method for getting JM exception history [flink] via GitHub
  • Re: [PR] [FLINK-37730][rest] Add client method for getting JM exception history [flink] via GitHub
  • Re: [PR] [FLINK-37730][rest] Add client method for getting JM exception history [flink] via GitHub
• [jira] [Comment Edited] (FLINK-37730) Collect job exceptions as kubernetes events Santwana Verma (Jira)
  • [jira] [Comment Edited] (FLINK-37730) Collect job exceptions as kubernetes events Santwana Verma (Jira)
• Re: [PR] [FLINK-26939][Table SQL/API] Add TRANSLATE supported in SQL & Table API [flink] via GitHub
  • Re: [PR] [FLINK-26939][Table SQL/API] Add TRANSLATE supported in SQL & Table API [flink] via GitHub
• [jira] [Updated] (FLINK-37753) Improve error handling for UNIX_TIMESTAMP Martijn Visser (Jira)
• [jira] [Created] (FLINK-37753) Improve error handling for UNIX_TIMESTAMP Martijn Visser (Jira)
• Re: [PR] [FLINK-25521][docs] Fix the composition description of 'INTERVAL DAY TO SECOND' in the data type [flink] via GitHub
• [PR] [FLINK-37662][helm] Support init and side car containers [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37662][helm] Support init and side car containers [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37662][helm] Support init and side car containers [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37662][helm] Support init and side car containers [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37662][helm] Support init and side car containers [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-37662][helm] Support init and side car containers [flink-kubernetes-operator] via GitHub
• Re: [PR] Bump vite and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] via GitHub
  • [PR] Bump vite and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump vite and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump vite and @angular-devkit/build-angular in /flink-runtime-web/web-dashboard [flink] via GitHub
• [jira] [Resolved] (FLINK-37078) Update jackson-mapper-asl dependency Robert Metzger (Jira)
• Re: [PR] [FLINK-36146][connector] Fix SingleThreadFetcherManager race condition [flink] via GitHub
• [PR] [hotfix] Update META-INF/NOTICE files [flink-connector-aws] via GitHub
• [jira] [Resolved] (FLINK-37695) Parsing for a JSON() function call fail to its position Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-37695) Parsing for a JSON() function call fail to its position Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-37695) Parsing for a JSON() function call fail to its position Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-37435) Kryo related perf regression since March 5th david radley (Jira)
• [jira] [Commented] (FLINK-36181) Drop support for Java 8 and use Java 17 by default Daren Wong (Jira)
• [PR] [FLINK-36181] Upgrade java version to 11 [flink-connector-shared-utils] via GitHub
• [jira] [Updated] (FLINK-36166) testJoinDisorderChangeLog failed on AZP ASF GitHub Bot (Jira)
• [PR] [FLINK-36166][table-planner] Make the test 'testJoinDisorderChangeLog' work again [flink] via GitHub
  • Re: [PR] [FLINK-36166][table-planner] Make the test 'testJoinDisorderChangeLog' work again [flink] via GitHub
  • Re: [PR] [FLINK-36166][table-planner] Make the test 'testJoinDisorderChangeLog' work again [flink] via GitHub
  • Re: [PR] [FLINK-36166][table-planner] Make the test 'testJoinDisorderChangeLog' work again [flink] via GitHub
• [PR] [FLINK-37752][json] Make configuration 'json.decode.json-parser.enabled' take effect [flink] via GitHub
  • Re: [PR] [FLINK-37752][json] Make configuration 'json.decode.json-parser.enabled' take effect [flink] via GitHub
  • Re: [PR] [FLINK-37752][json] Make configuration 'json.decode.json-parser.enabled' take effect [flink] via GitHub
  • Re: [PR] [FLINK-37752][json] Make configuration 'json.decode.json-parser.enabled' take effect [flink] via GitHub
  • Re: [PR] [FLINK-37752][json] Make configuration 'json.decode.json-parser.enabled' take effect [flink] via GitHub
  • Re: [PR] [FLINK-37752][json] Make configuration 'json.decode.json-parser.enabled' take effect [flink] via GitHub
• [jira] [Commented] (FLINK-36628) OpenTelemetryTestBase.eventuallyConsumeJson failed on AZP Robert Metzger (Jira)
• [jira] [Commented] (FLINK-37752) Make configuration 'json.decode.json-parser.enabled' take effect Hangxiang Yu (Jira)
• [jira] [Assigned] (FLINK-37752) Make configuration 'json.decode.json-parser.enabled' take effect Hangxiang Yu (Jira)
• [jira] [Updated] (FLINK-37752) Make configuration 'json.decode.json-parser.enabled' take effect Hongjia Liang (Jira)
  • [jira] [Updated] (FLINK-37752) Make configuration 'json.decode.json-parser.enabled' take effect Hongjia Liang (Jira)
  • [jira] [Updated] (FLINK-37752) Make configuration 'json.decode.json-parser.enabled' take effect Hongjia Liang (Jira)
  • [jira] [Updated] (FLINK-37752) Make configuration 'json.decode.json-parser.enabled' take effect ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-37752) Make 'json.decode.json-parser.enabled' take effect Hongjia Liang (Jira)
• [jira] [Updated] (FLINK-37730) Collect job exceptions as kubernetes events Robert Metzger (Jira)
  • [jira] [Updated] (FLINK-37730) Collect job exceptions as kubernetes events ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-37752) Make 'json.decode.json-parser.enabled' take effect Hongjia Liang (Jira)
• [jira] [Updated] (FLINK-37674) Add generalized type information to SQL state connector ASF GitHub Bot (Jira)
• [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
  • Re: [PR] [FLINK-37674][state] Add generic type information handling for state SQL [flink] via GitHub
• [jira] [Resolved] (FLINK-37745) ChangelogModeJsonSerializer doesn't handle partial deletes Dawid Wysakowicz (Jira)
• Re: [PR] [FLINK-37078] Fix for jackson-mapper-asl 1.9.13 vulnerability [flink] via GitHub
  • Re: [PR] [FLINK-37078] Fix for jackson-mapper-asl 1.9.13 vulnerability [flink] via GitHub
  • Re: [PR] [FLINK-37078] Fix for jackson-mapper-asl 1.9.13 vulnerability [flink] via GitHub
  • Re: [PR] [FLINK-37078] Fix for jackson-mapper-asl 1.9.13 vulnerability [flink] via GitHub
• [jira] [Closed] (FLINK-37734) Update version to 3.5-SNAPSHOT and update related docs Yanquan Lv (Jira)
• [jira] [Assigned] (FLINK-37734) Update version to 3.5-SNAPSHOT and update related docs Yanquan Lv (Jira)
• [jira] [Reopened] (FLINK-37728) Incorrect import in EmbeddedPythonWindowOperator.java Shuyi Chen (Jira)
• [jira] [Resolved] (FLINK-37728) Incorrect import in EmbeddedPythonWindowOperator.java Shuyi Chen (Jira)
• [jira] [Comment Edited] (FLINK-37370) [Observer] Finished batch jobs throw ReconciliationException and never reach FINISHED in the CR Jakob Homan (Jira)
• [jira] [Commented] (FLINK-37370) [Observer] Finished batch jobs throw ReconciliationException and never reach FINISHED in the CR Jakob Homan (Jira)
• [jira] [Updated] (FLINK-37751) Add vertex name to autoscaler metrics Sai Sharath Dandi (Jira)
• [jira] [Created] (FLINK-37751) Add vertex name to autoscaler metrics Sai Sharath Dandi (Jira)
• [jira] [Commented] (FLINK-37751) Add vertex name to autoscaler metrics Sai Sharath Dandi (Jira)
• Re: [PR] [hotfix] Update high-availability configs to newer syntax [flink-kubernetes-operator] via GitHub
  • Re: [PR] [hotfix] Update high-availability configs to newer syntax [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-36666) CI/CD should check NOTICE files for discrepancies. ASF GitHub Bot (Jira)

• Earlier messages
• Later messages