[GitHub] [flink] flinkbot edited a comment on pull request #18147: [FLINK-25370][docs] update HBase SQL Connector Options table-name des…

flinkbot edited a comment on pull request #18147: URL: https://github.com/apache/flink/pull/18147#issuecomment-997161014 ## CI report: * b2d09bee2449e854792aecf00cd4229f568c831e Azure:

[GitHub] [flink] flinkbot commented on pull request #18147: [FLINK-25370][docs] update HBase SQL Connector Options table-name des…

flinkbot commented on pull request #18147: URL: https://github.com/apache/flink/pull/18147#issuecomment-997161014 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[jira] [Updated] (FLINK-25370) HBase SQL Connector Options 'table-name' description

[ https://issues.apache.org/jira/browse/FLINK-25370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25370: --- Labels: pull-request-available (was: ) > HBase SQL Connector Options 'table-name'

[GitHub] [flink] lipusheng opened a new pull request #18147: [FLINK-25370][docs] update HBase SQL Connector Options table-name des…

lipusheng opened a new pull request #18147: URL: https://github.com/apache/flink/pull/18147 …cription ## What is the purpose of the change In document the HBase SQL Connector Options "table-name" description is "The name of HBase table to connect.". All demo of HBase

[jira] [Created] (FLINK-25370) HBase SQL Connector Options 'table-name' description

Ibson created FLINK-25370: - Summary: HBase SQL Connector Options 'table-name' description Key: FLINK-25370 URL: https://issues.apache.org/jira/browse/FLINK-25370 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

flinkbot edited a comment on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-997131565 ## CI report: * 40542ee7d47de0055e01435cebeed8424685ad76 Azure:

[jira] [Updated] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-25369: - Description: table list like this: {code:java} //catalog c1, database d1 t1 //current catalog c2,

[jira] [Updated] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-25369: - Description: table list like this: {code:java} //catalog c1, database d1 t1 //current catalog c2,

[jira] [Updated] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-25369: - Description: table list like this: {code:java} //catalog c1, database d1 t1 //current catalog c2,

[jira] [Updated] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-25369: - Description: table list like this: {code:java} //catalog c1, database d1 t1 //current catalog c2,

[jira] [Updated] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-25369: - Description: table list like this: {code:java} //catalog c1, database d1 t1 //current catalog c2,

[jira] [Updated] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-25369: - Description: table list like this: {code:java} //catalog c1, database d1 t1 //current catalog c2,

[jira] [Updated] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-25369: - Description: table list like this: {code:java} //catalog c1, database d1 t1 //current catalog c2,

[jira] [Updated] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-25369: - Description: table list like this: {code:java} //catalog c1, database d1 t1 //current catalog c2,

[jira] [Updated] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-25369: - Description: table list like this: {code:java} //catalog c1, database d1 t1 //current catalog c2,

[jira] [Updated] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-25369: - Description: table list like this: {code:java} //catalog c1, database d1 t1 //current catalog c2,

[GitHub] [flink] flinkbot edited a comment on pull request #18146: [FLINK-25369][table] CatalogManager provide right tables or views in given catalog database name

flinkbot edited a comment on pull request #18146: URL: https://github.com/apache/flink/pull/18146#issuecomment-997153629 ## CI report: * 0128a06a07a132924da89fb0c70f5cd3d2fce648 Azure:

[jira] [Updated] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-25369: - Description: table context like this: {code:java} //catalog c1, database d1 t1 //current catalog c2,

[GitHub] [flink] flinkbot commented on pull request #18146: [FLINK-25369][table] CatalogManager provide right tables or views in given catalog database name

flinkbot commented on pull request #18146: URL: https://github.com/apache/flink/pull/18146#issuecomment-997153629 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[jira] [Updated] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25369: --- Labels: pull-request-available (was: ) > CatalogManager provide wrong tables or views in

[GitHub] [flink] liyubin117 opened a new pull request #18146: [FLINK-25369][table] CatalogManager provide right tables or views in given catalog database name

liyubin117 opened a new pull request #18146: URL: https://github.com/apache/flink/pull/18146 ## What is the purpose of the change CatalogManager provide right tables or views in given catalog database name ## Brief change log * put the given catalog or database name in

[jira] [Created] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name

Yubin Li created FLINK-25369: Summary: CatalogManager provide wrong tables or views in given catalog database name Key: FLINK-25369 URL: https://issues.apache.org/jira/browse/FLINK-25369 Project: Flink

[GitHub] [flink] JingsongLi commented on pull request #18114: [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

JingsongLi commented on pull request #18114: URL: https://github.com/apache/flink/pull/18114#issuecomment-997145695 > @JingsongLi Thanks for the efforts. Shall we add a description section into the relevant documentation page based on `HiveConfOptions.java`? I am currently not ready

[GitHub] [flink] dengziming commented on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

dengziming commented on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-997132164 hello @becketqin @fapaul , PTAL. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] flinkbot edited a comment on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

flinkbot edited a comment on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-997131565 ## CI report: * 40542ee7d47de0055e01435cebeed8424685ad76 Azure:

[GitHub] [flink] flinkbot commented on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

flinkbot commented on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-997131669 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

flinkbot commented on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-997131565 ## CI report: * 40542ee7d47de0055e01435cebeed8424685ad76 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-25368) Use AdminClient to get offsets rather than KafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-25368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25368: --- Labels: pull-request-available (was: ) > Use AdminClient to get offsets rather than

[GitHub] [flink] dengziming opened a new pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets

dengziming opened a new pull request #18145: URL: https://github.com/apache/flink/pull/18145 ## What is the purpose of the change `AdminClient.listOffsets` is provided in Kafka 2.7, In the future more `OffsetSpce` types will be added to it, for example, OffsetSpec.MaxTimestampSpec

[jira] [Created] (FLINK-25368) Use AdminClient to get offsets rather than KafkaConsumer

dengziming created FLINK-25368: -- Summary: Use AdminClient to get offsets rather than KafkaConsumer Key: FLINK-25368 URL: https://issues.apache.org/jira/browse/FLINK-25368 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * b8f5219af5fd7fb7994d5ffa20eb8d23fa81693d Azure:

[jira] [Updated] (FLINK-6873) Limit the number of open writers in file system connector

[ https://issues.apache.org/jira/browse/FLINK-6873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6873: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-11198) Access to MetricGroup in an AggregateFunction(Non Rich)

[ https://issues.apache.org/jira/browse/FLINK-11198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11198: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-11157) Web UI should show timestamps relative to server time zone

[ https://issues.apache.org/jira/browse/FLINK-11157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11157: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-11102) Enable check for previous data in SpanningRecordSerializer

[ https://issues.apache.org/jira/browse/FLINK-11102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11102: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-11141) Key generation for RocksDBMapState can theoretically be ambiguous

[ https://issues.apache.org/jira/browse/FLINK-11141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11141: --- Labels: auto-deprioritized-critical auto-deprioritized-major stale-minor (was:

[jira] [Updated] (FLINK-11184) Rework TableSource and TableSink interfaces

[ https://issues.apache.org/jira/browse/FLINK-11184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11184: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-11172) Remove the max retention time in StreamQueryConfig

[ https://issues.apache.org/jira/browse/FLINK-11172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11172: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-11150) Check exception messages in ValidationTest of flink-table

[ https://issues.apache.org/jira/browse/FLINK-11150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11150: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-11276) Sliding Window Optimization

[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11276: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-11209) Provide more complete guidance for the log usage documentation

[ https://issues.apache.org/jira/browse/FLINK-11209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11209: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-11258) Add badge to the README

[ https://issues.apache.org/jira/browse/FLINK-11258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11258: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-6866) ClosureCleaner.clean fails for scala's JavaConverters wrapper classes

[ https://issues.apache.org/jira/browse/FLINK-6866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6866: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-11221) Support delimited identifiers in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-11221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11221: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-6849) Refactor operator state backend and internal operator state hierarchy

[ https://issues.apache.org/jira/browse/FLINK-6849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6849: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-6814) Store information about whether or not a registered state is queryable in checkpoints

[ https://issues.apache.org/jira/browse/FLINK-6814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6814: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-6770) Add excludeSerializersInCheckpoints to ExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-6770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6770: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-6790) Flink Kafka Consumer Cannot Round Robin Fetch Records

[ https://issues.apache.org/jira/browse/FLINK-6790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6790: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-6897) Re-add support for Java 8 lambdas in CEP library

[ https://issues.apache.org/jira/browse/FLINK-6897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6897: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-16032) Depends on core classifier hive-exec in hive connector

[ https://issues.apache.org/jira/browse/FLINK-16032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16032: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[jira] [Updated] (FLINK-16305) FlinkYarnSessionClI ignores target executor and uses yarn-session if YARN properties file is present

[ https://issues.apache.org/jira/browse/FLINK-16305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16305: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[jira] [Updated] (FLINK-16193) Improve error messaging when a key is assigned to the wrong key group range

[ https://issues.apache.org/jira/browse/FLINK-16193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16193: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 5d8ba55eda44a0b99288189476b3b8b3655f5f59 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * b8f5219af5fd7fb7994d5ffa20eb8d23fa81693d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * b8f5219af5fd7fb7994d5ffa20eb8d23fa81693d Azure:

[GitHub] [flink] JingGe commented on pull request #17501: [FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

JingGe commented on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-997062683 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] flinkbot edited a comment on pull request #18144: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

flinkbot edited a comment on pull request #18144: URL: https://github.com/apache/flink/pull/18144#issuecomment-996927781 ## CI report: * acb7da45bd3c00778c82e3a9ad5a6cb8a3e0020a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18144: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

flinkbot edited a comment on pull request #18144: URL: https://github.com/apache/flink/pull/18144#issuecomment-996927781 ## CI report: * acb7da45bd3c00778c82e3a9ad5a6cb8a3e0020a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18144: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

flinkbot edited a comment on pull request #18144: URL: https://github.com/apache/flink/pull/18144#issuecomment-996927781 ## CI report: * acb7da45bd3c00778c82e3a9ad5a6cb8a3e0020a Azure:

[GitHub] [flink] mbalassi commented on pull request #18144: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

mbalassi commented on pull request #18144: URL: https://github.com/apache/flink/pull/18144#issuecomment-997022713 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Comment Edited] (FLINK-25330) Flink SQL doesn't retract all versions of Hbase data

[ https://issues.apache.org/jira/browse/FLINK-25330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461651#comment-17461651 ] Jing Ge edited comment on FLINK-25330 at 12/17/21, 8:36 PM: Hi Bruce, multi

[GitHub] [flink] flinkbot edited a comment on pull request #18144: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

flinkbot edited a comment on pull request #18144: URL: https://github.com/apache/flink/pull/18144#issuecomment-996927781 ## CI report: * acb7da45bd3c00778c82e3a9ad5a6cb8a3e0020a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * b8f5219af5fd7fb7994d5ffa20eb8d23fa81693d Azure:

[jira] [Commented] (FLINK-25330) Flink SQL doesn't retract all versions of Hbase data

[ https://issues.apache.org/jira/browse/FLINK-25330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461651#comment-17461651 ] Jing Ge commented on FLINK-25330: - Hi Bruce, multi versions support is one of core design feature of

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] hackergin commented on a change in pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

hackergin commented on a change in pull request #18058: URL: https://github.com/apache/flink/pull/18058#discussion_r771649822 ## File path: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorFactory.java

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Support generating dynamic index based on proctime

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 8e55049e343701112a3b46470119cabe384faf74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17994: [FLINK-24456][Connectors / Kafka,Table SQL / Ecosystem] Support bound…

flinkbot edited a comment on pull request #17994: URL: https://github.com/apache/flink/pull/17994#issuecomment-984598261 ## CI report: * 2202e376c37c483532e650b9a45e433257e3cca1 UNKNOWN * 714ecb4ee385d101b34678a4d1f580052ba814a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 949b964bcb65db05a9c903a28f59f933300a7935 Azure:

[GitHub] [flink] JingGe commented on a change in pull request #17501: [FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

JingGe commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r771626315 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/reader/StreamFormat.java ## @@ -157,6 +166,88 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * 0507c16fcb133b7efb3ad5ac20ee163bd8cb46d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * 0507c16fcb133b7efb3ad5ac20ee163bd8cb46d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * 0507c16fcb133b7efb3ad5ac20ee163bd8cb46d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18144: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

flinkbot edited a comment on pull request #18144: URL: https://github.com/apache/flink/pull/18144#issuecomment-996927781 ## CI report: * acb7da45bd3c00778c82e3a9ad5a6cb8a3e0020a Azure:

[GitHub] [flink] flinkbot commented on pull request #18144: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

flinkbot commented on pull request #18144: URL: https://github.com/apache/flink/pull/18144#issuecomment-996928742 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #18144: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

flinkbot commented on pull request #18144: URL: https://github.com/apache/flink/pull/18144#issuecomment-996927781 ## CI report: * acb7da45bd3c00778c82e3a9ad5a6cb8a3e0020a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] mbalassi opened a new pull request #18144: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

mbalassi opened a new pull request #18144: URL: https://github.com/apache/flink/pull/18144 This is a rebased version of #17582 to the latest master branch to trigger CI runs, as the CI seems to be consistently producing seemingly unrelated

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * bea711eea2b6af329e8b49c3fdd08ee74f90813f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18140: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers backport to release 1.13

flinkbot edited a comment on pull request #18140: URL: https://github.com/apache/flink/pull/18140#issuecomment-996675433 ## CI report: * 5b15a6a3848cd4d4335d0062c0ae6dd758d861ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18138: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers backport to release 1.14

flinkbot edited a comment on pull request #18138: URL: https://github.com/apache/flink/pull/18138#issuecomment-996627205 ## CI report: * 48104df0bf7c34a1fde5b8000fad959ad450885e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18140: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers backport to release 1.13

flinkbot edited a comment on pull request #18140: URL: https://github.com/apache/flink/pull/18140#issuecomment-996675433 ## CI report: * 5b15a6a3848cd4d4335d0062c0ae6dd758d861ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18138: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers backport to release 1.14

flinkbot edited a comment on pull request #18138: URL: https://github.com/apache/flink/pull/18138#issuecomment-996627205 ## CI report: * 48104df0bf7c34a1fde5b8000fad959ad450885e Azure:

[GitHub] [flink] echauchot commented on pull request #18140: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers backport to release 1.13

echauchot commented on pull request #18140: URL: https://github.com/apache/flink/pull/18140#issuecomment-996905879 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] flinkbot edited a comment on pull request #18143: [FLINK-23976][metrics] Add additional job status metrics

flinkbot edited a comment on pull request #18143: URL: https://github.com/apache/flink/pull/18143#issuecomment-996816105 ## CI report: * cb62e67a4c9248e275845e4c555ae4e45ef21fa9 Azure:

[GitHub] [flink] echauchot commented on pull request #18138: [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers backport to release 1.14

echauchot commented on pull request #18138: URL: https://github.com/apache/flink/pull/18138#issuecomment-996905510 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] flinkbot edited a comment on pull request #17907: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #17907: URL: https://github.com/apache/flink/pull/17907#issuecomment-979080179 ## CI report: * c566930ce179517f8cef3cf2a1db070a3ec5df6b Azure:

  1   2   3   4   5   >