issues  

Messages by Thread

• • Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
  • Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
  • Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
  • Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
  • Re: [PR] [FLINK-38338][runtime] Introduce the abstraction to describe a rescale event. [flink] via GitHub
• [jira] [Updated] (FLINK-38338) Introduce the abstraction to describe a rescale event. ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-37981) TableAsyncExecutionController does not send the watermark Long.MAX downstream lincoln lee (Jira)
• [jira] [Updated] (FLINK-38349) Bugs caused by floating-point operations Huny (Jira)
• [jira] [Updated] (FLINK-37955) StreamingJoinOperator should not OOM due to collecting all matching records in memory lincoln lee (Jira)
• [jira] [Updated] (FLINK-37892) SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown azure cron ci failed lincoln lee (Jira)
  • [jira] [Updated] (FLINK-37892) SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown azure cron ci failed ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-38175) Start End of Life discussion thread for now outdated Flink minor version dalongliu (Jira)
• [jira] [Created] (FLINK-38349) Bugs caused by floating-point operations Huny (Jira)
• [jira] [Updated] (FLINK-38094) Introduce pyflink.__version__ lincoln lee (Jira)
• [jira] [Created] (FLINK-38350) Update Hadoop Library to 3.4.2 Paul Ashley (Jira)
• [jira] [Updated] (FLINK-37826) Some serde-related perfs regression since May 19th lincoln lee (Jira)
• [jira] [Closed] (FLINK-38165) Promote release 2.1 dalongliu (Jira)
• [jira] [Updated] (FLINK-38172) Update japicmp configuration dalongliu (Jira)
• [jira] [Closed] (FLINK-38016) [Release-2.1] Verify that no exclusions were erroneously added to the japicmp plugin dalongliu (Jira)
• [jira] [Updated] (FLINK-38228) To ensure consistent aggregation results in the window operator, we need to consider state TTL; otherwise, we must send messages to downstream operators to prevent their state from expiring prematurely. lincoln lee (Jira)
  • [jira] [Updated] (FLINK-38228) To ensure consistent aggregation results in the window operator, we need to consider state TTL; otherwise, we must send messages to downstream operators to prevent their state from expiring prematurely. lincoln lee (Jira)
• [jira] [Resolved] (FLINK-38206) Update Paimon Table based on upstream schema to avoid inconsistent table structures Yanquan Lv (Jira)
• [jira] [Updated] (FLINK-38019) TestValuesModelFactory$AsyncValuesPredictFunction fails with NPE lincoln lee (Jira)
  • [jira] [Updated] (FLINK-38019) TestValuesModelFactory$AsyncValuesPredictFunction fails with NPE lincoln lee (Jira)
• [jira] [Updated] (FLINK-37986) CoordinatedSourceRescaleITCase.testDownscaling: JUnit5 fails to delete a directory on AZP lincoln lee (Jira)
• [jira] [Updated] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN lincoln lee (Jira)
  • [jira] [Updated] (FLINK-37946) correct the example sql on page Table API SQL EXPLAIN lincoln lee (Jira)
• [jira] [Updated] (FLINK-37948) ChangelogDelegateEmbeddedRocksDBStateBackendTest causes JVM crash in azure ci pipeline lincoln lee (Jira)
• [jira] [Updated] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE lincoln lee (Jira)
  • [jira] [Updated] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE lincoln lee (Jira)
  • [jira] [Updated] (FLINK-38020) NonTimeRangeUnboundedPrecedingFunction failing with NPE lincoln lee (Jira)
• [jira] [Updated] (FLINK-38349) Incorrect calculation of scale in SpillingThread#mergeChannelList may cause divide-by-zero exception Huny (Jira)
  • [jira] [Updated] (FLINK-38349) Incorrect calculation of scale in SpillingThread#mergeChannelList may cause divide-by-zero exception Huny (Jira)
  • [jira] [Updated] (FLINK-38349) Incorrect calculation of scale in SpillingThread#mergeChannelList may cause divide-by-zero exception Huny (Jira)
• [jira] [Updated] (FLINK-38056) Flink doesn't wait for s5cmd to finish when it is being cancelled lincoln lee (Jira)
  • [jira] [Updated] (FLINK-38056) Flink doesn't wait for s5cmd to finish when it is being cancelled lincoln lee (Jira)
• Re: [PR] [FLINK-36975][Connectors/AWS] Fix the AWS Config Option AWS_ROLE_CREDENTIALS_PROVIDER_OPTION to pick the right key [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36975][Connectors/AWS] Fix the AWS Config Option AWS_ROLE_CREDENTIALS_PROVIDER_OPTION to pick the right key [flink-connector-aws] via GitHub
• Re: [PR] [FLINK-36296][Connectors/DynamoDB] Add support for incremental shard discovery for DynamoDB Streams Source [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-36296][Connectors/DynamoDB] Add support for incremental shard discovery for DynamoDB Streams Source [flink-connector-aws] via GitHub
• [PR] [BP-2.0][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• [PR] [BP-2.1][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [BP-2.1][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [BP-2.1][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• [PR] [BP-1.20][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• [jira] [Assigned] (FLINK-38329) Add labels to PRs showing the targeted version Ferenc Csaky (Jira)
• [jira] [Closed] (FLINK-38329) Add labels to PRs showing the targeted version Ferenc Csaky (Jira)
• [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-38245] Initial contribution to Flink repository [flink-connector-http] via GitHub
• [I] [Tech Debt] Refactoring CI of test cases in integration module [flink-agents] via GitHub
• [jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging Zakelly Lan (Jira)
  • [jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging Zakelly Lan (Jira)
  • [jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging Grzegorz Liter (Jira)
• [jira] [Created] (FLINK-38348) Fix flushing issue for append write with buffer sort and bounded source Shuo Cheng (Jira)
• [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
  • Re: [PR] [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager [flink] via GitHub
• [I] [Tech Debt] Specify model to be used in ChatModelSetup. [flink-agents] via GitHub
• [jira] [Closed] (FLINK-38348) Fix flushing issue for append write with buffer sort and bounded source Shuo Cheng (Jira)
• [jira] [Updated] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost Zakelly Lan (Jira)
  • [jira] [Commented] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost Zakelly Lan (Jira)
• Re: [PR] [improve] Remove repeated dependency. [flink-cdc] via GitHub
  • Re: [PR] [improve] Remove repeated dependency. [flink-cdc] via GitHub
• [jira] [Created] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost Zakelly Lan (Jira)
• [jira] [Created] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext Matt Cuento (Jira)
• [PR] [python][examples] Add quickstart workflow examples [flink-agents] via GitHub
  • Re: [PR] [python][examples] Add quickstart workflow examples [flink-agents] via GitHub
  • Re: [PR] [python][examples] Add quickstart workflow examples [flink-agents] via GitHub
  • Re: [PR] [python][examples] Add quickstart workflow examples [flink-agents] via GitHub
  • Re: [PR] [python][examples] Add quickstart workflow examples [flink-agents] via GitHub
  • Re: [PR] [python][examples] Add quickstart workflow examples [flink-agents] via GitHub
• [I] [Feature] Introduce new module `integrations` [flink-agents] via GitHub
  • Re: [I] [Feature] Introduce new module `integrations` [flink-agents] via GitHub
• [jira] [Closed] (FLINK-38346) JSON_QUERY returns ARRAY<STRING> of incorrect format dylanhz (Jira)
• [I] [Feature] [integrations][java] Add support for OllamaChatModel [flink-agents] via GitHub
  • Re: [I] [Feature] [integrations][java] Add support for OllamaChatModel [flink-agents] via GitHub
• [PR] [docs] Set up Flink Agents Document Website [flink-agents] via GitHub
  • Re: [PR] [docs] Set up Flink Agents Document Website [flink-agents] via GitHub
  • Re: [PR] [docs] Set up Flink Agents Document Website [flink-agents] via GitHub
  • Re: [PR] [docs] Set up Flink Agents Document Website [flink-agents] via GitHub
• [I] [Feature] [Docs] Set up Flink Agents Document Website [flink-agents] via GitHub
  • Re: [I] [Feature] [Docs] Set up Flink Agents Document Website [flink-agents] via GitHub
• [jira] [Commented] (FLINK-38346) JSON_QUERY returns ARRAY<STRING> of incorrect format dylanhz (Jira)
• [PR] [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
  • Re: [PR] [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
  • Re: [PR] [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
  • Re: [PR] [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
  • Re: [PR] [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
  • Re: [PR] [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
  • Re: [PR] [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
  • Re: [PR] [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
  • Re: [PR] [FLINK-38344][runtime-web] Fix the bug that The local files of the HistoryServer may risk never being deleted. [flink] via GitHub
• [jira] [Updated] (FLINK-38346) JSON_QUERY returns ARRAY<STRING> of incorrect format dylanhz (Jira)
  • [jira] [Updated] (FLINK-38346) JSON_QUERY returns ARRAY<STRING> of incorrect format dylanhz (Jira)
  • [jira] [Updated] (FLINK-38346) JSON_QUERY returns ARRAY<STRING> of incorrect format dylanhz (Jira)
  • [jira] [Updated] (FLINK-38346) JSON_QUERY returns ARRAY<STRING> of incorrect format dylanhz (Jira)
  • [jira] [Updated] (FLINK-38346) JSON_QUERY returns ARRAY<STRING> of incorrect format dylanhz (Jira)
• [jira] [Created] (FLINK-38346) JSON_QUERY returns ARRAY<STRING> dylanhz (Jira)
• [PR] [FLINK-38345][flink-connector-base] Unit test to replicate null previousEnumerator for HybridSource on checkpoint recovery [flink] via GitHub
  • Re: [PR] [FLINK-38345][flink-connector-base] Unit test to replicate null previousEnumerator for HybridSource on checkpoint recovery [flink] via GitHub
• [jira] [Updated] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext Matt Cuento (Jira)
  • [jira] [Updated] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext Matt Cuento (Jira)
  • [jira] [Updated] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext Matt Cuento (Jira)
• [jira] [Created] (FLINK-38336) Unexpected data copy during failover for ForSt statebackend Zakelly Lan (Jira)
• [I] [Feature] Replay-based Per Action State Consistency [flink-agents] via GitHub
• [PR] [FLINK-35280] Migrate HBase Sink to use Async Sink API [flink-connector-hbase] via GitHub
• [jira] [Updated] (FLINK-35280) Migrate HBase Sink connector to use the ASync Sink API ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
  • [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
  • [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
  • [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
  • [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
  • [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
  • [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
  • [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
  • [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
  • [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. Xuannan Su (Jira)
  • [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
  • [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
  • [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
  • [jira] [Updated] (FLINK-38344) The local files of the HistoryServer may risk never being deleted. RocMarshal (Jira)
• [jira] [Updated] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields Maximilian Michels (Jira)
  • [jira] [Updated] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields Maximilian Michels (Jira)
• [jira] [Created] (FLINK-38341) Introduce the rescale history configuration option. RocMarshal (Jira)
• [jira] [Updated] (FLINK-38341) Introduce the rescale history configuration option. RocMarshal (Jira)
• [jira] [Comment Edited] (FLINK-38331) Support displaying the hash keys on edges in web ui Rion Williams (Jira)
  • [jira] [Comment Edited] (FLINK-38331) Support displaying the hash keys on edges in web ui Rion Williams (Jira)
  • [jira] [Comment Edited] (FLINK-38331) Support displaying the hash keys on edges in web ui Rion Williams (Jira)
• [jira] [Commented] (FLINK-37417) Implement better exception message to explain why KinesisSource doesn't support partial recovery Lorenzo Nicora (Jira)
• [jira] [Created] (FLINK-38342) Support record rescale information RocMarshal (Jira)
• [jira] [Created] (FLINK-38340) Introduce the rescale timeline related abstraction for performing rescale operations RocMarshal (Jira)
• [jira] [Commented] (FLINK-38331) Support displaying the hash keys on edges in web ui Rion Williams (Jira)
• [jira] [Created] (FLINK-38337) Chinese translation for document PR Scott Fauerbach (Jira)
• [I] [Feature] Introduce ActionState related APIs [flink-agents] via GitHub
  • Re: [I] [Feature] Introduce ActionState related APIs [flink-agents] via GitHub
• [jira] [Closed] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields Maximilian Michels (Jira)
• [jira] [Updated] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file Feifan Wang (Jira)
• Re: [PR] [FLINK-37245] Add tests for FieldGetters to test null value handling in BinaryRowData [flink] via GitHub
  • Re: [PR] [FLINK-37245] Add tests for FieldGetters to test null value handling in BinaryRowData [flink] via GitHub
  • Re: [PR] [FLINK-37245] Add tests for FieldGetters to test null value handling in BinaryRowData [flink] via GitHub
  • Re: [PR] [FLINK-37245] Add tests for FieldGetters to test null value handling in BinaryRowData [flink] via GitHub
• [jira] [Commented] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields Maximilian Michels (Jira)
• [jira] [Updated] (FLINK-38335) SplitEnumeratorContext supports fixed delay async call. Hongshun Wang (Jira)
  • [jira] [Updated] (FLINK-38335) SplitEnumeratorContext supports fixed delay async call. lincoln lee (Jira)
• [jira] [Created] (FLINK-38335) SplitEnumeratorContext supports fixed delay async call. Hongshun Wang (Jira)
• [jira] [Resolved] (FLINK-35725) Translate new DISTRIBUTED BY documentation into Chinese Leonard Xu (Jira)
• [jira] [Updated] (FLINK-35725) Translate new DISTRIBUTED BY documentation into Chinese ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-35725) Translate new DISTRIBUTED BY documentation into Chinese Leonard Xu (Jira)
  • [jira] [Updated] (FLINK-35725) Translate new DISTRIBUTED BY documentation into Chinese Leonard Xu (Jira)
  • [jira] [Updated] (FLINK-35725) Translate new DISTRIBUTED BY documentation into Chinese Leonard Xu (Jira)
• Re: [PR] [FLINK-35725][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink] via GitHub
• [jira] [Comment Edited] (FLINK-38327) NPE during recovery from file-merged checkpoint after FO Zakelly Lan (Jira)
• [I] [Feature] [Integration] Add built-in ollma embedding model support in python [flink-agents] via GitHub
  • Re: [I] [Feature] [Integration] Add Embedding Model abstraction and provide a built-in Ollama embedding model implementation [flink-agents] via GitHub
• [jira] [Updated] (FLINK-38332) Upgrade pemja to 0.6.1 ASF GitHub Bot (Jira)
• Re: [I] [Tech Debt] [api][python] Support Event containing Row field can be json serializable [flink-agents] via GitHub
• [PR] [hotfix] Adapt get list/map from short memory after upgrade pemja to 0.6.1. [flink-agents] via GitHub
  • Re: [PR] [hotfix] Adapt get list/map from short memory after upgrade pemja to 0.6.1. [flink-agents] via GitHub
  • Re: [PR] [hotfix] Adapt get list/map from short memory after upgrade pemja to 0.6.1. [flink-agents] via GitHub
• [jira] [Comment Edited] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink Dian Fu (Jira)
• [jira] [Commented] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink Dian Fu (Jira)
  • [jira] [Commented] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink Kaiqi Dong (Jira)
  • [jira] [Commented] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink Kaiqi Dong (Jira)
• [jira] [Commented] (FLINK-38334) MySQL CDC source may get stuck in the INITIAL_ASSIGNING state Sergei Morozov (Jira)
• [jira] [Created] (FLINK-38334) MySQL CDC source may get stuck in the INITIAL_ASSIGNING state Sergei Morozov (Jira)
• [jira] [Updated] (FLINK-38334) MySQL CDC source may get stuck in the INITIAL_ASSIGNING state Sergei Morozov (Jira)
  • [jira] [Updated] (FLINK-38334) MySQL CDC source may get stuck in the INITIAL_ASSIGNING state Sergei Morozov (Jira)

• Earlier messages
• Later messages