[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: * 43250b5615b79bdd1471410c16505c423d6e6038 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * d7b9d71baabfbaa8e2037680221d004d52f297af Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-25374) Azure pipeline get stalled on scanning project

[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25374: Description: {code:java} 2021-12-18T02:01:01.8980373Z Dec 18 02:01:01 RUNNING 'run_mvn -Dflink.forkCount=

[jira] [Comment Edited] (FLINK-25374) Azure pipeline get stalled on scanning project

[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462075#comment-17462075 ] Yun Gao edited comment on FLINK-25374 at 12/19/21, 5:30 AM:

[jira] [Commented] (FLINK-25374) Azure pipeline get stalled on scanning project

[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462075#comment-17462075 ] Yun Gao commented on FLINK-25374: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Updated] (FLINK-25374) Azure pipeline get stalled on scanning project

[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25374: Priority: Blocker (was: Major) > Azure pipeline get stalled on scanning project > ---

[jira] [Created] (FLINK-25374) Azure pipeline get stalled on scanning project

Yun Gao created FLINK-25374: --- Summary: Azure pipeline get stalled on scanning project Key: FLINK-25374 URL: https://issues.apache.org/jira/browse/FLINK-25374 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager

flinkbot edited a comment on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-997327937 ## CI report: * a6f86ee8f82a0fb7ffa0350606de6dfcd39a7a93 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-25372) Add thread dump feature for jobmanager

[ https://issues.apache.org/jira/browse/FLINK-25372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462069#comment-17462069 ] Zhanghao Chen commented on FLINK-25372: --- [~xtsong] [~zjureel] Looking forward to h

[GitHub] [flink] flinkbot commented on pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager

flinkbot commented on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-997328033 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 pro

[jira] [Updated] (FLINK-25372) Add thread dump feature for jobmanager

[ https://issues.apache.org/jira/browse/FLINK-25372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-25372: -- Description: Add thread dump feature for jobmanager in addition to the previous work on TM sid

[GitHub] [flink] flinkbot commented on pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager

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

[jira] [Updated] (FLINK-25372) Add thread dump feature for jobmanager

[ https://issues.apache.org/jira/browse/FLINK-25372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25372: --- Labels: pull-request-available (was: ) > Add thread dump feature for jobmanager > -

[GitHub] [flink] X-czh opened a new pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager

X-czh opened a new pull request #18148: URL: https://github.com/apache/flink/pull/18148 ## What is the purpose of the change Add thread dump feature for jobmanager, so use can get jobmanager thread information easily, which is useful for debugging job submission and schedulin

[jira] [Updated] (FLINK-25373) task manager can not free memory when jobs are finished

[ https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spongebob updated FLINK-25373: -- Description: I submit my Flinksql jobs to the Flink standalone cluster and what  out of my expectatio

[jira] [Created] (FLINK-25373) task manager can not free memory when jobs are finished

Spongebob created FLINK-25373: - Summary: task manager can not free memory when jobs are finished Key: FLINK-25373 URL: https://issues.apache.org/jira/browse/FLINK-25373 Project: Flink Issue Type:

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

liyubin117 commented on a change in pull request #18146: URL: https://github.com/apache/flink/pull/18146#discussion_r771884679 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java ## @@ -538,16 +538,16 @@ public Catalo

[jira] [Updated] (FLINK-6503) Refactor KinesisDataFetcher to separate concerns for shard discovery

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

[jira] [Updated] (FLINK-10568) Show correct time attributes when calling Table.getSchema()

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

[jira] [Updated] (FLINK-10448) VALUES clause is translated into a separate operator per value

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

[jira] [Updated] (FLINK-10294) Split MiniClusterResource to be usable in runtime/streaming-java/clients

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

[jira] [Updated] (FLINK-10273) Access composite type fields after a function

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

[jira] [Updated] (FLINK-10266) Web UI has outdated entry about externalized checkpoints

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

[jira] [Updated] (FLINK-10274) The stop-cluster.sh cannot stop cluster properly when there are multiple clusters running

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

[jira] [Updated] (FLINK-10518) Inefficient design in ContinuousFileMonitoringFunction

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

[jira] [Updated] (FLINK-10306) Support the display of log file from any position on webUI

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

[jira] [Updated] (FLINK-6485) Use buffering to avoid frequent memtable flushes for short intervals in RockdDB incremental checkpoints

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

[jira] [Updated] (FLINK-10476) Change related ProcessFunction to KeyedProcessFunction in Sql/Table-api

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

[jira] [Updated] (FLINK-10515) Improve tokenisation of program args passed as string

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

[jira] [Updated] (FLINK-10489) Inconsistent window information for streams with EventTime characteristic

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

[jira] [Updated] (FLINK-6607) Confusing statement in docs that Kafka 010 consumer does not require timestamp extractors

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

[jira] [Updated] (FLINK-6500) RowSerialization problem

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

[jira] [Updated] (FLINK-6626) Unifying lifecycle management of SubmittedJobGraph- and CompletedCheckpointStore

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

[jira] [Updated] (FLINK-6765) PojoSerializer returns wrong ConvertDeserializer when migration is required

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

[jira] [Updated] (FLINK-6484) Send only the registry keys for already registered files in incremental checkpointing

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

[jira] [Updated] (FLINK-6556) Include and expose Flink version in the savepoint data

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

[jira] [Updated] (FLINK-6735) Add a checkbox to hide the plan visualizer

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

[jira] [Updated] (FLINK-15350) develop JDBC catalogs to connect to relational databases

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

[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&focusedCommentId=17461651#comment-17461651 ] Jing Ge edited comment on FLINK-25330 at 12/18/21, 10:21 PM: -

[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-997242294 Hi @viirya, This CI run seems much more reasonable. 😊 It fails on the e2e k8s ha test, that is a bit more tricky to work with locally, I am looking into this topic anywa

[GitHub] [flink-docker] mbalassi opened a new pull request #96: [readme] Explicitly call out copying the flink distro in Readme

mbalassi opened a new pull request #96: URL: https://github.com/apache/flink-docker/pull/96 Minor Readme improvements. -- 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 u

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

Airblader commented on a change in pull request #18146: URL: https://github.com/apache/flink/pull/18146#discussion_r771847905 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java ## @@ -538,16 +538,16 @@ public Catalog

[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 * 19f311f2459395ae19a546ded975745b39c0603b Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-25372) Add thread dump feature for jobmanager

[ https://issues.apache.org/jira/browse/FLINK-25372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-25372: -- Description: Add thread dump feature for jobmanager in addition to the previous work on TM sid

[jira] [Updated] (FLINK-25372) Add thread dump feature for jobmanager

[ https://issues.apache.org/jira/browse/FLINK-25372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-25372: -- Description: Add thread dump feature for jobmanager in addition to the previous work on TM sid

[jira] [Created] (FLINK-25372) Add thread dump feature for jobmanager

Zhanghao Chen created FLINK-25372: - Summary: Add thread dump feature for jobmanager Key: FLINK-25372 URL: https://issues.apache.org/jira/browse/FLINK-25372 Project: Flink Issue Type: Sub-task

[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: [CANCELED](https://dev.azure.com/apache-f

[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: [CANCELED](https://dev.azure.com/apache-f

[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: [CANCELED](https://dev.azure.com/apache-f

[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: [CANCELED](https://dev.azure.com/apache-f

[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: [CANCELED](https://dev.azure.com/apache-f

[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: [CANCELED](https://dev.azure.com/apache-f

[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: [CANCELED](https://dev.azure.com/apache-f

[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: [PENDING](https://dev.azure.com/apache-fl

[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: [PENDING](https://dev.azure.com/apache-fl

[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: [PENDING](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-10882) Misleading job/task state for scheduled jobs

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

[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: [PENDING](https://dev.azure.com/apache-fl

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

hackergin opened a new pull request #18058: URL: https://github.com/apache/flink/pull/18058 ## What is the purpose of the change *Currently, dynamic index generation can only be based on the time attribute field in the table, I suppose to support generating dynamic index ba

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

hackergin closed pull request #18058: URL: https://github.com/apache/flink/pull/18058 -- 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 unsubscribe, e-mail: issues-unsub

[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: [PENDING](https://dev.azure.com/apache-fl

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

hackergin commented on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-997183674 @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 specifi

[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_r771811071 ## File path: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorFactory.java #

[jira] [Updated] (FLINK-10667) Clean up Scala 2.10 remnants

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

[jira] [Updated] (FLINK-10684) Improve the CSV reading process

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

[jira] [Updated] (FLINK-10576) Introduce Machine/Node/TM health management

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

[jira] [Updated] (FLINK-15498) Using HiveCatalog in TPC-DS e2e

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

[jira] [Updated] (FLINK-10855) CheckpointCoordinator does not delete checkpoint directory of late/failed checkpoints

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

[jira] [Updated] (FLINK-10688) Remove flink-table dependencies from flink-connectors

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

[jira] [Updated] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

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

[jira] [Updated] (FLINK-10873) Remove tableEnv in DataSetConversions#toTable and DataStreamConversions#toTable

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

[jira] [Updated] (FLINK-11070) Add stream-stream non-window cross join

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

[jira] [Updated] (FLINK-12005) [State TTL] Event time support

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

[jira] [Updated] (FLINK-15595) Entirely implement resolution order as FLIP-68 concept

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

[jira] [Updated] (FLINK-15514) Bump Elasticsearch version from 6.3.1 to 6.8.6 for es6 connector

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

[jira] [Updated] (FLINK-15635) Allow passing a ClassLoader to EnvironmentSettings

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

[jira] [Updated] (FLINK-15787) Upgrade REST API response to remove '-' from key names.

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

[jira] [Updated] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

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

[jira] [Updated] (FLINK-15873) Matched result may not be output if existing earlier partial matches

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

[jira] [Updated] (FLINK-15719) Exceptions when using scala types directly with the State Process API

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

[jira] [Updated] (FLINK-15600) Further relax the UDF constraints for Java classes

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

[jira] [Updated] (FLINK-15734) Support spill in batch hash window aggregation

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

[jira] [Updated] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source)

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

  1   2   >