issues  

Messages by Thread

• • Re: [PR] [FLINK-35599] Introduce JDBC pipeline sink connector [flink-cdc] via GitHub
  • Re: [PR] [FLINK-35599] Introduce JDBC pipeline sink connector [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-34554) FLIP-511: Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint Arvid Heise (Jira)
  • [jira] [Updated] (FLINK-34554) FLIP-511: Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint Arvid Heise (Jira)
  • [jira] [Updated] (FLINK-34554) FLIP-511: Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint Arvid Heise (Jira)
• Re: [PR] [hotfix] typo in the javadoc of the functions in KeyedStateStore [flink] via GitHub
  • Re: [PR] [hotfix] typo in the javadoc of the functions in KeyedStateStore [flink] via GitHub
• Re: [PR] Update filesystem.md [flink] via GitHub
  • Re: [PR] Update filesystem.md [flink] via GitHub
• Re: [PR] [Improve] Use 'isEmpty()' replace '<= 0'. [flink] via GitHub
  • Re: [PR] [Improve] Use 'isEmpty()' replace '<= 0'. [flink] via GitHub
• [jira] [Updated] (FLINK-37596) Close metric groups for finished splits ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-31192][connectors/dataGen] Fix dataGen takes too long to initi… [flink] via GitHub
  • Re: [PR] [FLINK-31192][connectors/dataGen] Fix dataGen takes too long to initi… [flink] via GitHub
• Re: [PR] [FLINK-27815] batch sql rule optimize [flink] via GitHub
  • Re: [PR] [FLINK-27815] batch sql rule optimize [flink] via GitHub
• Re: [PR] [FLINK-31336][table] fix interval type info lost in sql and table api. [flink] via GitHub
  • Re: [PR] [FLINK-31336][table] fix interval type info lost in sql and table api. [flink] via GitHub
• Re: [PR] [FLINK-31161][build] bump versions-maven-plugin to 2.14.2. [flink] via GitHub
  • Re: [PR] [FLINK-31161][build] bump versions-maven-plugin to 2.14.2. [flink] via GitHub
• Re: [PR] [FLINK-31528] [table-planner] Move SqlXXXCatalog conversion logic to SqlNodeConverter [flink] via GitHub
  • Re: [PR] [FLINK-31528] [table-planner] Move SqlXXXCatalog conversion logic to SqlNodeConverter [flink] via GitHub
• Re: [PR] [FLINK-30166][Connector/FileSystem] Refactor tests that use the deprecated StreamingFileSink instead of FileSink [flink] via GitHub
  • Re: [PR] [FLINK-30166][Connector/FileSystem] Refactor tests that use the deprecated StreamingFileSink instead of FileSink [flink] via GitHub
• Re: [PR] [FLINK-30459][sql-client] SQL Client supports "SET 'property'" [flink] via GitHub
  • Re: [PR] [FLINK-30459][sql-client] SQL Client supports "SET 'property'" [flink] via GitHub
• Re: [PR] [FLINK-29177][hive] Shade org.apache.commons.lang3 in flink-sql-connector-hive to avoid potential class conflict [flink] via GitHub
  • Re: [PR] [FLINK-29177][hive] Shade org.apache.commons.lang3 in flink-sql-connector-hive to avoid potential class conflict [flink] via GitHub
• Re: [PR] [FLINK-30505][runtime] Close the connection between TM and JM when cl… [flink] via GitHub
  • Re: [PR] [FLINK-30505][runtime] Close the connection between TM and JM when cl… [flink] via GitHub
• Re: [PR] [WIP][FLINK-30975][filesystem][s3] upgrade dependencies to aws sdk v2 [flink] via GitHub
  • Re: [PR] [WIP][FLINK-30975][filesystem][s3] upgrade dependencies to aws sdk v2 [flink] via GitHub
• Re: [PR] [FLINK-29541][table-planner][JUnit5 Migration] Module: flink-table-planner: Introduce new test base class for ITCase and migrate partial java ITCase [flink] via GitHub
  • Re: [PR] [FLINK-29541][table-planner][JUnit5 Migration] Module: flink-table-planner: Introduce new test base class for ITCase and migrate partial java ITCase [flink] via GitHub
• Re: [PR] [FLINK-30274] Bump commons-collections 3.x to commons-collections4 [flink] via GitHub
  • Re: [PR] [FLINK-30274] Bump commons-collections 3.x to commons-collections4 [flink] via GitHub
• Re: [PR] [hotfix][docs] Update Zookeper version infromation [flink] via GitHub
  • Re: [PR] [hotfix][docs] Update Zookeper version infromation [flink] via GitHub
• Re: [PR] Update broadcast_state.md [flink] via GitHub
  • Re: [PR] Update broadcast_state.md [flink] via GitHub
• Re: [PR] [FLINK-32176][config] create default option for scheduler-mode [flink] via GitHub
  • Re: [PR] [FLINK-32176][config] create default option for scheduler-mode [flink] via GitHub
• Re: [PR] [FLINK-29940][runtime] ExecutionGraph logs job state change at WARN level when job fails [flink] via GitHub
  • Re: [PR] [FLINK-29940][runtime] ExecutionGraph logs job state change at WARN level when job fails [flink] via GitHub
• Re: [PR] [FLINK-32776][flink-metrics]Add HTTP basic authentication support to PrometheusPushGatewayReporter [flink] via GitHub
  • Re: [PR] [FLINK-32776][flink-metrics]Add HTTP basic authentication support to PrometheusPushGatewayReporter [flink] via GitHub
• Re: [PR] [FLINK-32897][table-runtime]Fix RowToRowCastRule get wrong result error while cast Array(Row()) type [flink] via GitHub
  • Re: [PR] [FLINK-32897][table-runtime]Fix RowToRowCastRule get wrong result error while cast Array(Row()) type [flink] via GitHub
• Re: [PR] [BP-1.17][FLINK-32260][table] Add built-in ARRAY_SLICE function. [flink] via GitHub
  • Re: [PR] [BP-1.17][FLINK-32260][table] Add built-in ARRAY_SLICE function. [flink] via GitHub
• Re: [PR] [FLINK-32564][table]bytes-to-number & number-to-bytes [flink] via GitHub
  • Re: [PR] [FLINK-32564][table]bytes-to-number & number-to-bytes [flink] via GitHub
• [PR] [FLINK-37596][metrics] Close metric group of a finished split [flink] via GitHub
  • Re: [PR] [FLINK-37596][metrics] Close metric group of a finished split [flink] via GitHub
  • Re: [PR] [FLINK-37596][metrics] Close metric group of a finished split [flink] via GitHub
  • Re: [PR] [FLINK-37596][metrics] Close metric group of a finished split [flink] via GitHub
  • Re: [PR] [FLINK-37596][metrics] Close metric group of a finished split [flink] via GitHub
  • Re: [PR] [FLINK-37596][metrics] Close metric group of a finished split [flink] via GitHub
  • Re: [PR] [FLINK-37596][metrics] Close metric group of a finished split [flink] via GitHub
• Re: [PR] [FLINK-31499] [table-planner] Move SqlCreateTable conversion logic to SqlCreateTableConverter [flink] via GitHub
  • Re: [PR] [FLINK-31499] [table-planner] Move SqlCreateTable conversion logic to SqlCreateTableConverter [flink] via GitHub
• Re: [PR] [FLINK-31390][table-planner] use scala view to avoid unnecessary trav… [flink] via GitHub
  • Re: [PR] [FLINK-31390][table-planner] use scala view to avoid unnecessary trav… [flink] via GitHub
• Re: [PR] [FLINK-32887][connector/common] ExecutorNotifier#notifyReadyAsync wil… [flink] via GitHub
  • Re: [PR] [FLINK-32887][connector/common] ExecutorNotifier#notifyReadyAsync wil… [flink] via GitHub
• Re: [PR] [FLINK-32740][core] added literal null value support for flink-conf [flink] via GitHub
  • Re: [PR] [FLINK-32740][core] added literal null value support for flink-conf [flink] via GitHub
• Re: [PR] [FLINK-31500][table-planner] Move SqlAlterTableSchema conversion logic to SqlAlterTableSchemaConverter [flink] via GitHub
  • Re: [PR] [FLINK-31500][table-planner] Move SqlAlterTableSchema conversion logic to SqlAlterTableSchemaConverter [flink] via GitHub
• Re: [PR] [FLINK-31259][sql-gateway] SqlGateway supports initializing catalog with init file [flink] via GitHub
  • Re: [PR] [FLINK-31259][sql-gateway] SqlGateway supports initializing catalog with init file [flink] via GitHub
• Re: [PR] [FLINK-31520] [table-planner] Move SqlXXXModel conversion logic to SqlNodeConverter [flink] via GitHub
  • Re: [PR] [FLINK-31520] [table-planner] Move SqlXXXModel conversion logic to SqlNodeConverter [flink] via GitHub
• Re: [PR] Update local_installation.md [flink] via GitHub
  • Re: [PR] Update local_installation.md [flink] via GitHub
• Re: [PR] [BP-1.17][FLINK-32259][table] Add built-in ARRAY_JOIN function. [flink] via GitHub
  • Re: [PR] [BP-1.17][FLINK-32259][table] Add built-in ARRAY_JOIN function. [flink] via GitHub
• Re: [PR] [BP-1.17][FLINK-32564][table]bytes-to-number & number-to-bytes [flink] via GitHub
  • Re: [PR] [BP-1.17][FLINK-32564][table]bytes-to-number & number-to-bytes [flink] via GitHub
• Re: [PR] [FLINK-31366][filesystem][s3] Fix NoSuchMethodError when s3a and s3p plugins are used together [flink] via GitHub
  • Re: [PR] [FLINK-31366][filesystem][s3] Fix NoSuchMethodError when s3a and s3p plugins are used together [flink] via GitHub
• Re: [PR] [FLINK-31377][table] Fix array_contains ArrayData.ElementGetter shoul… [flink] via GitHub
  • Re: [PR] [FLINK-31377][table] Fix array_contains ArrayData.ElementGetter shoul… [flink] via GitHub
• Re: [PR] [FLINK-28825] Add K8S pod scheduler into Kubernetes options [FLINK-28829] Support prepreparing K8S resources before JM creation [FLINK-28831][k8s]Support pluginable decorators mechanism - part 1st [flink] via GitHub
  • Re: [PR] [FLINK-28825] Add K8S pod scheduler into Kubernetes options [FLINK-28829] Support prepreparing K8S resources before JM creation [FLINK-28831][k8s]Support pluginable decorators mechanism - part 1st [flink] via GitHub
• Re: [PR] [FLINK-30444] Add failing test case ApplicationDispatcherBootstrapITC… [flink] via GitHub
  • Re: [PR] [FLINK-30444] Add failing test case ApplicationDispatcherBootstrapITC… [flink] via GitHub
• Re: [PR] [FLINK-31296][table-planner] Add JoinConditionEqualityTransferRule to… [flink] via GitHub
  • Re: [PR] [FLINK-31296][table-planner] Add JoinConditionEqualityTransferRule to… [flink] via GitHub
• Re: [PR] [FLINK-31174][doc] fix inconsistent data format between Learn-Flink Doc and flink-training-repo [flink] via GitHub
  • Re: [PR] [FLINK-31174][doc] fix inconsistent data format between Learn-Flink Doc and flink-training-repo [flink] via GitHub
• Re: [PR] [FLINK-31335][sql-gateway] When submit job to yarn, support kerberos [flink] via GitHub
  • Re: [PR] [FLINK-31335][sql-gateway] When submit job to yarn, support kerberos [flink] via GitHub
• Re: [PR] FLINK-13871: Consolidate volatile status fields in StreamTask [flink] via GitHub
  • Re: [PR] FLINK-13871: Consolidate volatile status fields in StreamTask [flink] via GitHub
• Re: [PR] [FLINK-12449][table] Add BIT_AND, BIT_OR functions supported in Table API and SQL [flink] via GitHub
  • Re: [PR] [FLINK-12449][table] Add BIT_AND, BIT_OR functions supported in Table API and SQL [flink] via GitHub
• Re: [PR] [FLINK-31267][table-planner][resource management]Fine-Grained Resource Management supports table and sql levels [flink] via GitHub
  • Re: [PR] [FLINK-31267][table-planner][resource management]Fine-Grained Resource Management supports table and sql levels [flink] via GitHub
• Re: [PR] [FLINK-31282][Client]Fix the SQL Problem to create and close zookeepr connections frequently [flink] via GitHub
  • Re: [PR] [FLINK-31282][Client]Fix the SQL Problem to create and close zookeepr connections frequently [flink] via GitHub
• Re: [PR] [FLINK-30971][table-planner] Modify the default value of parameter 'table.exec.local-hash-agg.adaptive.sampling-threshold' [flink] via GitHub
  • Re: [PR] [FLINK-30971][table-planner] Modify the default value of parameter 'table.exec.local-hash-agg.adaptive.sampling-threshold' [flink] via GitHub
• Re: [PR] [hotfix] [docs] Replace deprecated option in jdbc connector of Chinese document [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Replace deprecated option in jdbc connector of Chinese document [flink] via GitHub
• Re: [PR] [FLINK-30738] Disable verbose mode of CycloneDX plugin [flink] via GitHub
  • Re: [PR] [FLINK-30738] Disable verbose mode of CycloneDX plugin [flink] via GitHub
• Re: [PR] [FLINK-30242][table-planner] Swap local aggregate and union node to a… [flink] via GitHub
  • Re: [PR] [FLINK-30242][table-planner] Swap local aggregate and union node to a… [flink] via GitHub
• Re: [PR] [FLINK-30810] Rework CliClientITCase extends AbstractStatementTestBase [flink] via GitHub
  • Re: [PR] [FLINK-30810] Rework CliClientITCase extends AbstractStatementTestBase [flink] via GitHub
• Re: [PR] [FLINK-25622][Python] Fix recursive extraction in PythonUDF SQL optimization [flink] via GitHub
  • Re: [PR] [FLINK-25622][Python] Fix recursive extraction in PythonUDF SQL optimization [flink] via GitHub
• Re: [PR] [FLINK-31084][connectors/dataGen] Add default value for dataGen seque… [flink] via GitHub
  • Re: [PR] [FLINK-31084][connectors/dataGen] Add default value for dataGen seque… [flink] via GitHub
• Re: [PR] [FLINK-23810][TABLE]Show detail sql when parse failed [flink] via GitHub
  • Re: [PR] [FLINK-23810][TABLE]Show detail sql when parse failed [flink] via GitHub
• Re: [PR] [FLINK-19065] [runtime] Generate unique and consistent UID for internal Map operators used in CoGroupedStreams [flink] via GitHub
  • Re: [PR] [FLINK-19065] [runtime] Generate unique and consistent UID for internal Map operators used in CoGroupedStreams [flink] via GitHub
• Re: [PR] [FLINK-30974][connectors/hbase] Add commons-io to flink-sql-connector-hbase [flink] via GitHub
  • Re: [PR] [FLINK-30974][connectors/hbase] Add commons-io to flink-sql-connector-hbase [flink] via GitHub
• Re: [PR] [FLINK-30792][state/changelog] make state changelog pre-emptively upl… [flink] via GitHub
  • Re: [PR] [FLINK-30792][state/changelog] make state changelog pre-emptively upl… [flink] via GitHub
• Re: [PR] [FLINK-30817] Fix ClassCastException in TestValuesTableFactory [flink] via GitHub
  • Re: [PR] [FLINK-30817] Fix ClassCastException in TestValuesTableFactory [flink] via GitHub
• Re: [PR] [FLINK-29481] Show jobType in webUI [flink] via GitHub
  • Re: [PR] [FLINK-29481] Show jobType in webUI [flink] via GitHub
• Re: [PR] [hotfix] Fix typo DataStream [flink] via GitHub
• Re: [PR] [FLINK-30597] Refactor FlinkProjectJoinTransposeRule and FlinkPruneEm… [flink] via GitHub
  • Re: [PR] [FLINK-30597] Refactor FlinkProjectJoinTransposeRule and FlinkPruneEm… [flink] via GitHub
• Re: [PR] [FLINK-30888][doc] Flink Doc(zh version) has misspelled words [flink] via GitHub
  • Re: [PR] [FLINK-30888][doc] Flink Doc(zh version) has misspelled words [flink] via GitHub
• Re: [PR] [FLINK-30524] Support full screen viewing on the Logs/Stdout/Thread D… [flink] via GitHub
  • Re: [PR] [FLINK-30524] Support full screen viewing on the Logs/Stdout/Thread D… [flink] via GitHub
• Re: [PR] [FLIP-278][connector] Add hybrid source connector for table & sql [flink] via GitHub
• Re: [PR] [FLINK-30721][avro-confluent-registry] Enable 8byte schema id [flink] via GitHub
  • Re: [PR] [FLINK-30721][avro-confluent-registry] Enable 8byte schema id [flink] via GitHub
• Re: [PR] [FLINK-30499][SQL/Table] Fix over window codegen error when member code incorrectly used in method body [flink] via GitHub
  • Re: [PR] [FLINK-30499][SQL/Table] Fix over window codegen error when member code incorrectly used in method body [flink] via GitHub
• Re: [PR] [hotfix] [docs] Fix results of upper() in example [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Fix results of upper() in example [flink] via GitHub
• Re: [PR] [FLINK-30475][runtime][impovement] RocksDBMapState clear with deleteRange [flink] via GitHub
  • Re: [PR] [FLINK-30475][runtime][impovement] RocksDBMapState clear with deleteRange [flink] via GitHub
• Re: [PR] Update intro_to_table_api.md [flink] via GitHub
  • Re: [PR] Update intro_to_table_api.md [flink] via GitHub
  • Re: [PR] Update intro_to_table_api.md [flink] via GitHub
  • Re: [PR] Update intro_to_table_api.md [flink] via GitHub
• Re: [PR] [FLINK-24386] Guard JobMaster against exceptions from starting the Op… [flink] via GitHub
  • Re: [PR] [FLINK-24386] Guard JobMaster against exceptions from starting the Op… [flink] via GitHub
• Re: [PR] [hotfix] [docs] Fix a typo in a query that erroneously tries to perform an aggregation on a string column [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Fix a typo in a query that erroneously tries to perform an aggregation on a string column [flink] via GitHub
• Re: [PR] [FLINK-30743][docs] added RBAC hints to Kubernetes HA documentation [flink] via GitHub
  • Re: [PR] [FLINK-30743][docs] added RBAC hints to Kubernetes HA documentation [flink] via GitHub
• Re: [PR] [FLINK-18397][docs-zh] Translate "Table & SQL Connectors Overview" pa… [flink] via GitHub
  • Re: [PR] [FLINK-18397][docs-zh] Translate "Table & SQL Connectors Overview" pa… [flink] via GitHub
• Re: [PR] The sql in the hive Connectors write document has syntax errors. I fixed it [flink] via GitHub
  • Re: [PR] The sql in the hive Connectors write document has syntax errors. I fixed it [flink] via GitHub
• Re: [PR] Update over-agg.md [flink] via GitHub
  • Re: [PR] Update over-agg.md [flink] via GitHub
  • Re: [PR] Update over-agg.md [flink] via GitHub
  • Re: [PR] Update over-agg.md [flink] via GitHub
  • Re: [PR] Update over-agg.md [flink] via GitHub
  • Re: [PR] Update over-agg.md [flink] via GitHub
  • Re: [PR] Update over-agg.md [flink] via GitHub
  • Re: [PR] Update over-agg.md [flink] via GitHub
• Re: [PR] [FLINK-27482][code] Updated config.sh [flink] via GitHub
  • Re: [PR] [FLINK-27482][code] Updated config.sh [flink] via GitHub
• Re: [PR] [FLINK-30551] Add open/close interface to PartitionCommitPolicy [flink] via GitHub
  • Re: [PR] [FLINK-30551] Add open/close interface to PartitionCommitPolicy [flink] via GitHub
• Re: [PR] [FLINK-28882] Changed the return type of ENCODE from BINARY to VARBINARY [flink] via GitHub
  • Re: [PR] [FLINK-28882] Changed the return type of ENCODE from BINARY to VARBINARY [flink] via GitHub
• Re: [PR] [FLINK-30570] Fix error inferred partition condition [flink] via GitHub
  • Re: [PR] [FLINK-30570] Fix error inferred partition condition [flink] via GitHub
• Re: [PR] [hotfix] Remove the duplicated test case [flink] via GitHub
  • Re: [PR] [hotfix] Remove the duplicated test case [flink] via GitHub
• Re: [PR] [FLINK-29776][flink-statebackend-changelog][JUnit5 Migration]Module: flink-statebackend-changelog. [flink] via GitHub
  • Re: [PR] [FLINK-29776][flink-statebackend-changelog][JUnit5 Migration]Module: flink-statebackend-changelog. [flink] via GitHub
• Re: [PR] [FLINK-30483] [Formats] [Avro] Add avro format support for TIMESTAMP_LTZ [flink] via GitHub
  • Re: [PR] [FLINK-30483] [Formats] [Avro] Add avro format support for TIMESTAMP_LTZ [flink] via GitHub
• Re: [PR] [hotfix][docs] maven project generation command for windows in Fraud Detection with the DataStream API [flink] via GitHub
  • Re: [PR] [hotfix][docs] maven project generation command for windows in Fraud Detection with the DataStream API [flink] via GitHub
• Re: [PR] [FLINK-19889][connectors/hive/filesystem][format/parquet] Supports nested projection pushdown for filesystem connector of columnar format [flink] via GitHub
  • Re: [PR] [FLINK-19889][connectors/hive/filesystem][format/parquet] Supports nested projection pushdown for filesystem connector of columnar format [flink] via GitHub
• Re: [PR] [FLINK-30476][Connector/FileSystem] TrackingFsDataInputStream batch tracking issue [flink] via GitHub
  • Re: [PR] [FLINK-30476][Connector/FileSystem] TrackingFsDataInputStream batch tracking issue [flink] via GitHub
• Re: [PR] [FLINK-30097][docs] Update the example in the docs of DataStream cache [flink] via GitHub
  • Re: [PR] [FLINK-30097][docs] Update the example in the docs of DataStream cache [flink] via GitHub
• Re: [PR] [hotfix][doc] Fix some errors in sql gateway docs [flink] via GitHub
  • Re: [PR] [hotfix][doc] Fix some errors in sql gateway docs [flink] via GitHub
• Re: [PR] [FLINK-30088][runtime] Fix excessive state updates for TtlMapState and TtlListState [flink] via GitHub
  • Re: [PR] [FLINK-30088][runtime] Fix excessive state updates for TtlMapState and TtlListState [flink] via GitHub
• Re: [PR] [FLINK-28741][hive] fix un-expect behavior for cast string to boolean [flink] via GitHub
  • Re: [PR] [FLINK-28741][hive] fix un-expect behavior for cast string to boolean [flink] via GitHub
• Re: [PR] [FLINK-36973]udf dateformat support LocalZonedTimestampData datatype [flink-cdc] via GitHub
• [jira] [Resolved] (FLINK-36516) Migrate deprecated SinkV2 API to new API introduced in FLIP-372 Yanquan Lv (Jira)
• [jira] [Resolved] (FLINK-37529) Add flink-cdc-commom to the package to all the incremental source framework Ruan Hang (Jira)
• Re: [PR] [FLINK-37529][cdc-connector] Add flink-cdc-commo to the package to al… [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-37235) Add e2e test for flink-connector-elasticsearch8 Weijie Guo (Jira)
  • [jira] [Updated] (FLINK-37235) Add e2e test for flink-connector-elasticsearch8 Weijie Guo (Jira)
• [jira] [Closed] (FLINK-37151) Remove redundant testing dependencies of Flink UI Xuannan Su (Jira)

• Earlier messages
• Later messages