[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #18033: [FLINK-25141][connector/elasticsearch] add sink parallelism option

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

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[jira] [Commented] (FLINK-25398) Show complete stacktrace when requesting thread dump

[ https://issues.apache.org/jira/browse/FLINK-25398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463053#comment-17463053 ] Xintong Song commented on FLINK-25398: -- Hi [~zuston], Thanks for bringing this up.

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[jira] [Updated] (FLINK-25239) Delete useless variables

[ https://issues.apache.org/jira/browse/FLINK-25239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25239: - Component/s: Table SQL / Ecosystem > Delete useless variables > > >

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] godfreyhe commented on a change in pull request #17845: [FLINK-24352] [flink-table-planner] Add null check for temporal table check on SqlSnapshot

godfreyhe commented on a change in pull request #17845: URL: https://github.com/apache/flink/pull/17845#discussion_r772888377 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/validate/SqlValidatorImpl.java ## @@ -4711,6 +4711,11 @@ private voi

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

flinkbot edited a comment on pull request #17988: URL: https://github.com/apache/flink/pull/17988#issuecomment-984363654 ## CI report: * e7be85162e0b431d518ab1ffe8b59283338d00b7 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] ZhangChaoming commented on a change in pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

ZhangChaoming commented on a change in pull request #18151: URL: https://github.com/apache/flink/pull/18151#discussion_r772879377 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/table/DataGeneratorConnectorITCase.java #

[GitHub] [flink] ZhangChaoming commented on a change in pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

ZhangChaoming commented on a change in pull request #18151: URL: https://github.com/apache/flink/pull/18151#discussion_r772878789 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/table/DataGeneratorConnectorITCase.java #

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #18112: [FLINK-25305][checkpoint] Always wait for input channel state and result partition state get completed in AsyncRunnable

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

[GitHub] [flink] flinkbot edited a comment on pull request #18112: [FLINK-25305][checkpoint] Always wait for input channel state and result partition state get completed in AsyncRunnable

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

[GitHub] [flink] gaoyunhaii commented on pull request #18112: [FLINK-25305][checkpoint] Always wait for input channel state and result partition state get completed in AsyncRunnable

gaoyunhaii commented on pull request #18112: URL: https://github.com/apache/flink/pull/18112#issuecomment-998522990 Very thanks @pnowojski for the review! I updated the PR and the commit message~ -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] flinkbot edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

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

[GitHub] [flink] wuchong commented on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

wuchong commented on pull request #17988: URL: https://github.com/apache/flink/pull/17988#issuecomment-998522664 @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 #17734: [FLINK-23305][table]Support semi/anti interval joins

flinkbot edited a comment on pull request #17734: URL: https://github.com/apache/flink/pull/17734#issuecomment-964006875 ## CI report: * 6e2c662fc3a4e8d63bbf1ffe2b910571b11fc3fe Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-ml] lindong28 commented on a change in pull request #41: [hotfix][FLIP-176] Updates onEpochWatermarkIncremented() and onIterationTerminated() to throw Exception

lindong28 commented on a change in pull request #41: URL: https://github.com/apache/flink-ml/pull/41#discussion_r772871230 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LogisticRegression.java ## @@ -362,7 +362,6 @@ private void

[GitHub] [flink-ml] lindong28 commented on a change in pull request #41: [hotfix][FLIP-176] Updates onEpochWatermarkIncremented() and onIterationTerminated() to throw Exception

lindong28 commented on a change in pull request #41: URL: https://github.com/apache/flink-ml/pull/41#discussion_r772870368 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LogisticRegression.java ## @@ -362,7 +362,6 @@ private void

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463024#comment-17463024 ] Wenhao Ji commented on FLINK-16478: --- Thanks, [~trohrmann] ! > add restApi to modify l

[GitHub] [flink-ml] lindong28 commented on a change in pull request #41: [hotfix][FLIP-176] Updates onEpochWatermarkIncremented() and onIterationTerminated() to throw Exception

lindong28 commented on a change in pull request #41: URL: https://github.com/apache/flink-ml/pull/41#discussion_r772870609 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/Iterations.java ## @@ -117,19 +117,16 @@ */ public static DataStreamL

[GitHub] [flink-ml] lindong28 commented on a change in pull request #41: [hotfix][FLIP-176] Updates onEpochWatermarkIncremented() and onIterationTerminated() to throw Exception

lindong28 commented on a change in pull request #41: URL: https://github.com/apache/flink-ml/pull/41#discussion_r772870536 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/Iterations.java ## @@ -261,10 +256,6 @@ private static DataStreamList createIter

[GitHub] [flink-ml] lindong28 commented on pull request #41: [hotfix][FLIP-176] Updates onEpochWatermarkIncremented() and onIterationTerminated() to throw Exception

lindong28 commented on pull request #41: URL: https://github.com/apache/flink-ml/pull/41#issuecomment-998518178 @gaoyunhaii Could you help review this PR? -- 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

[GitHub] [flink] YuvalItzchakov commented on pull request #17845: [FLINK-24352] [flink-table-planner] Add null check for temporal table check on SqlSnapshot

YuvalItzchakov commented on pull request #17845: URL: https://github.com/apache/flink/pull/17845#issuecomment-998515048 @tsreaper @godfreyhe @MartijnVisser Guys this has been waiting for a month now although the PR is ready. This fix is affecting the ability of my consumers to use F

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

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

lipusheng commented on pull request #18147: URL: https://github.com/apache/flink/pull/18147#issuecomment-998504439 @AHeise Could you help merge it -- 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

[jira] [Commented] (FLINK-25398) Show complete stacktrace when requesting thread dump

[ https://issues.apache.org/jira/browse/FLINK-25398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463009#comment-17463009 ] Junfan Zhang commented on FLINK-25398: -- Could you help check this ticket? [~guoyang

[jira] [Updated] (FLINK-25398) Show complete stacktrace when requesting thread dump

[ https://issues.apache.org/jira/browse/FLINK-25398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-25398: - Attachment: stacktrace.png > Show complete stacktrace when requesting thread dump >

[GitHub] [flink] flinkbot commented on pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

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

[GitHub] [flink] flinkbot edited a comment on pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

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

[GitHub] [flink] flinkbot commented on pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

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

[jira] [Updated] (FLINK-25398) Show complete stacktrace when requesting thread dump

[ https://issues.apache.org/jira/browse/FLINK-25398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25398: --- Labels: pull-request-available (was: ) > Show complete stacktrace when requesting thread du

[GitHub] [flink] zuston opened a new pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

zuston opened a new pull request #18158: URL: https://github.com/apache/flink/pull/18158 ## What is the purpose of the change Now the stacktrace is not complete when clicking the task executor's threaddump in runtime webui. Hence it's hard to the initial calling according t

[jira] [Updated] (FLINK-25398) Show complete stacktrace when requesting thread dump

[ https://issues.apache.org/jira/browse/FLINK-25398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-25398: - Description: h2. Why Now the stacktrace is not complete when clicking the task executor's threa

[jira] [Created] (FLINK-25398) Show complete stacktrace when requesting thread dump

Junfan Zhang created FLINK-25398: Summary: Show complete stacktrace when requesting thread dump Key: FLINK-25398 URL: https://issues.apache.org/jira/browse/FLINK-25398 Project: Flink Issue Ty

[jira] [Closed] (FLINK-25378) kubernetes's request/limit resource can been seperated?

[ https://issues.apache.org/jira/browse/FLINK-25378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-25378. - Resolution: Duplicate > kubernetes's request/limit resource can been seperated? > --

[jira] [Closed] (FLINK-25321) standalone deploy on k8s,pod always OOM killed,actual heap memory usage is normal, gc is normal

[ https://issues.apache.org/jira/browse/FLINK-25321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-25321. - Resolution: Information Provided > standalone deploy on k8s,pod always OOM killed,actual heap memory usa

[GitHub] [flink] wangyang0918 commented on a change in pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

wangyang0918 commented on a change in pull request #18119: URL: https://github.com/apache/flink/pull/18119#discussion_r772792426 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/entrypoint/KubernetesSessionClusterEntrypoint.java ## @@ -36,13 +42,48 @@ p

[jira] [Commented] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ

[ https://issues.apache.org/jira/browse/FLINK-25380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462992#comment-17462992 ] RocMarshal commented on FLINK-25380: [~nicholasjiang] Thanks for the reminding. In

[jira] [Commented] (FLINK-23403) Decrease default values for heartbeat timeout and interval

[ https://issues.apache.org/jira/browse/FLINK-23403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462989#comment-17462989 ] Fei Feng commented on FLINK-23403: -- There is a risk if we decrease heartbeat's timeout

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

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

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

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

leonardBang commented on a change in pull request #18058: URL: https://github.com/apache/flink/pull/18058#discussion_r772819208 ## 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 #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

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

[GitHub] [flink] flinkbot edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

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

[jira] [Updated] (FLINK-25397) support grouped_execution

[ https://issues.apache.org/jira/browse/FLINK-25397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-25397: Description: Performing data bucketing execution: two tables (orders, orders_item), divided into

[jira] [Updated] (FLINK-25397) support grouped_execution

[ https://issues.apache.org/jira/browse/FLINK-25397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-25397: Summary: support grouped_execution (was: grouped_execution) > support grouped_execution > ---

[jira] [Updated] (FLINK-25397) support grouped_execution

[ https://issues.apache.org/jira/browse/FLINK-25397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-25397: Description: Performing data bucketing execution: two tables (orders, orders_item), divided into

[jira] [Created] (FLINK-25397) grouped_execution

ZhuoYu Chen created FLINK-25397: --- Summary: grouped_execution Key: FLINK-25397 URL: https://issues.apache.org/jira/browse/FLINK-25397 Project: Flink Issue Type: Improvement Components:

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[GitHub] [flink] zuston commented on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

zuston commented on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-998442727 @Myasuka @KarmaGYZ Could you help give me some advice to solve this problem. We also meet it in our production practise. -- This is an automated message from the Ap

[jira] [Commented] (FLINK-25321) standalone deploy on k8s,pod always OOM killed,actual heap memory usage is normal, gc is normal

[ https://issues.apache.org/jira/browse/FLINK-25321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462965#comment-17462965 ] Gao Fei commented on FLINK-25321: - [~wangyang0918] OK，thanks > standalone deploy on k8s

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

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

liyubin117 commented on pull request #18146: URL: https://github.com/apache/flink/pull/18146#issuecomment-998440668 @RocMarshal CI result has been success now. Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[jira] [Commented] (FLINK-23687) Add Sql query hint to enable LookupJoin shuffle by join key of left input

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462963#comment-17462963 ] HunterHunter commented on FLINK-23687: -- Well, looking forward to your contribution,

[GitHub] [flink-ml] yunfengzhou-hub commented on pull request #42: [FLINK-25394] Upgrade log4j to 2.17.0 to address CVE-2021-45105

yunfengzhou-hub commented on pull request #42: URL: https://github.com/apache/flink-ml/pull/42#issuecomment-998439869 Hi @Abdelrahman-IK , Thanks for the PR. It looks good to me. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[jira] [Closed] (FLINK-25262) Support to send data to lookup table for KeyGroupStreamPartitioner way for SQL

[ https://issues.apache.org/jira/browse/FLINK-25262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang closed FLINK-25262. -- Resolution: Duplicate > Support to send data to lookup table for KeyGroupStreamPartitioner way for >

[jira] [Commented] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ

[ https://issues.apache.org/jira/browse/FLINK-25380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462959#comment-17462959 ] Nicholas Jiang commented on FLINK-25380: [~RocMarshal], IMO, the RabbitMQ sql co

[jira] [Commented] (FLINK-23687) Add Sql query hint to enable LookupJoin shuffle by join key of left input

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462958#comment-17462958 ] Jing Zhang commented on FLINK-23687: Also invite [~ykt836][~twalthr][~jark][~godfrey

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[jira] [Comment Edited] (FLINK-23687) Add Sql query hint to enable LookupJoin shuffle by join key of left input

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462956#comment-17462956 ] Jing Zhang edited comment on FLINK-23687 at 12/21/21, 3:16 AM: ---

[GitHub] [flink] flinkbot commented on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

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

[GitHub] [flink] flinkbot commented on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[jira] [Commented] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462957#comment-17462957 ] Junfan Zhang commented on FLINK-17808: -- Could i take over this ticket? [~yunta] [~g

[jira] [Updated] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17808: --- Labels: auto-deprioritized-major pull-request-available (was: auto-deprioritized-major) >

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

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

[GitHub] [flink] zuston opened a new pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

zuston opened a new pull request #18157: URL: https://github.com/apache/flink/pull/18157 … completed writing ## What is the purpose of the change In order to solve the situation where the checkpoint metadata file is suspended from being written under certain abnormal condition

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

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

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

wuchong commented on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-998433028 @leonardBang , do you want to review and merge this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Comment Edited] (FLINK-23687) Add Sql query hint to enable LookupJoin shuffle by join key of left input

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462956#comment-17462956 ] Jing Zhang edited comment on FLINK-23687 at 12/21/21, 3:08 AM: ---

  1   2   3   4   5   6   >