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

matriv commented on a change in pull request #18058: URL: https://github.com/apache/flink/pull/18058#discussion_r772255153 ## File path:

[jira] [Updated] (FLINK-9740) Support group windows over intervals of months

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

[jira] [Updated] (FLINK-14480) Sort out exception supression during snapshotting for non-running tasks.

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

[jira] [Updated] (FLINK-25383) Skip waiting for the final checkpoint if the task do not contains 2-pc operators

[ https://issues.apache.org/jira/browse/FLINK-25383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25383: Description: Currently all the tasks would wait for final checkpoint before exiting. However, if the

[jira] [Updated] (FLINK-24510) Fix the duplicate log output of libraries/connectors，when logback is used

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

[jira] [Updated] (FLINK-9774) Allow to pass a string-based cluster identifier to command line

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

[jira] [Updated] (FLINK-14986) Support to get detailed Kubernetes cluster description

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

[jira] [Updated] (FLINK-18209) Replace "charged" words in the Flink codebase.

[ https://issues.apache.org/jira/browse/FLINK-18209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18209: --- Labels: pull-request-available stale-minor (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-15219) LocalEnvironment is not initializing plugins

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

[jira] [Updated] (FLINK-15786) Load connector code with separate classloader

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

[jira] [Updated] (FLINK-16224) Refine Hadoop Delegation Token based testing framework

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

[jira] [Updated] (FLINK-14350) Introduce dedicated MetricScope

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

[jira] [Updated] (FLINK-18572) Flink web UI doesn't display tolerable-failed-checkpoints

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

[jira] [Updated] (FLINK-19382) Introducing ReplayableSourceStateBackend

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

[jira] [Updated] (FLINK-14763) flink sql cep parallelism error

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

[jira] [Updated] (FLINK-21186) RecordWriterOutput swallows interrupt state when interrupted.

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

[jira] [Updated] (FLINK-14569) use flink to deal with batch task,when parallelism granter than 1, always 1 or 2 records loss

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

[jira] [Updated] (FLINK-14510) Remove the lazy vertex attaching mechanism from ExecutionGraph

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

[jira] [Updated] (FLINK-15017) add a thrift server for Flink

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

[jira] [Updated] (FLINK-14996) Missing java doc in org.apache.flink.runtime.operators.TempBarrier

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

[jira] [Updated] (FLINK-20128) Data loss for over windows with rows unbounded preceding

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

[jira] [Updated] (FLINK-14361) Decorrelate subQuery fail when multi correlate in project

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

[jira] [Updated] (FLINK-22582) Scrollbar "jumps" when clicking on tabs for Scala and Python

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

[jira] [Updated] (FLINK-22561) Restore checkpoint from another cluster

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

[jira] [Updated] (FLINK-25384) Job can not migrate from flink-1.12 to flink-1.13

[ https://issues.apache.org/jira/browse/FLINK-25384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tanjialiang updated FLINK-25384: Description: The NotNullEnforcer is always add in the Flink-1.12. But in this PR, it make a IF

[jira] [Created] (FLINK-25384) Job can not migrate from flink-1.12 to flink-1.13

tanjialiang created FLINK-25384: --- Summary: Job can not migrate from flink-1.12 to flink-1.13 Key: FLINK-25384 URL: https://issues.apache.org/jira/browse/FLINK-25384 Project: Flink Issue Type:

[jira] [Created] (FLINK-25383) Skip waiting for the final checkpoint if the task do not contains 2-pc operators

Yun Gao created FLINK-25383: --- Summary: Skip waiting for the final checkpoint if the task do not contains 2-pc operators Key: FLINK-25383 URL: https://issues.apache.org/jira/browse/FLINK-25383 Project:

[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: * 43250b5615b79bdd1471410c16505c423d6e6038 Azure:

[jira] [Assigned] (FLINK-24270) Rewrite tests for illegal job modification against VertexFinishedStateChecker

[ https://issues.apache.org/jira/browse/FLINK-24270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-24270: --- Assignee: Yun Gao > Rewrite tests for illegal job modification against VertexFinishedStateChecker

[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_r772252228 ## 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 #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: * 43250b5615b79bdd1471410c16505c423d6e6038 Azure:

[jira] [Closed] (FLINK-25382) Failure in "Upload Logs" task

[ https://issues.apache.org/jira/browse/FLINK-25382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25382. -- Resolution: Duplicate > Failure in "Upload Logs" task > - > >

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

liyubin117 commented on a change in pull request #18146: URL: https://github.com/apache/flink/pull/18146#discussion_r772249719 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/catalog/CatalogITCase.java ## @@ -169,6 +186,51 @@ public

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

liyubin117 commented on a change in pull request #18146: URL: https://github.com/apache/flink/pull/18146#discussion_r772249557 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/catalog/CatalogITCase.java ## @@ -169,6 +186,51 @@ public

[jira] [Updated] (FLINK-22090) Upload logs fails

[ https://issues.apache.org/jira/browse/FLINK-22090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22090: --- Priority: Critical (was: Not a Priority) > Upload logs fails > - > >

[jira] [Commented] (FLINK-22090) Upload logs fails

[ https://issues.apache.org/jira/browse/FLINK-22090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462503#comment-17462503 ] Piotr Nowojski commented on FLINK-22090: Another instances:

[jira] [Created] (FLINK-25382) Failure in "Upload Logs" task

Piotr Nowojski created FLINK-25382: -- Summary: Failure in "Upload Logs" task Key: FLINK-25382 URL: https://issues.apache.org/jira/browse/FLINK-25382 Project: Flink Issue Type: Bug

[GitHub] [flink] baisui1981 commented on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

baisui1981 commented on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-997794130 > @baisui1981 Thanks for the update. Please run `mvn spotless:apply` in the flink root directory for fixing the checkstyle. In my limited read, would you mind introducing

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

baisui1981 removed a comment on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-997793461 > Thanks for the update. thanks for your remind，I will add some test cases for the change. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] baisui1981 commented on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

baisui1981 commented on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-997793461 > Thanks for the update. thanks for your remind，I will add some test cases for the change. -- This is an automated message from the Apache Git Service. To respond to

[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462498#comment-17462498 ] Haohui Mai commented on FLINK-24456: IMO anything on-par with the current table API is sufficient >

[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: * b2fc0dd330c23f07af7a63830c6f601207236654 Azure:

[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: * b2fc0dd330c23f07af7a63830c6f601207236654 Azure:

[jira] [Commented] (FLINK-23959) FLIP-175: Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

[ https://issues.apache.org/jira/browse/FLINK-23959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462492#comment-17462492 ] Yun Gao commented on FLINK-23959: - Merged on master via e9c10b8acd4300a62c2193aef2948f933bc4c67d >

[jira] [Closed] (FLINK-23959) FLIP-175: Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

[ https://issues.apache.org/jira/browse/FLINK-23959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-23959. --- Assignee: Dong Lin Resolution: Fixed > FLIP-175: Compose Estimator/Model/AlgoOperator from DAG of >

[jira] [Updated] (FLINK-23959) FLIP-175: Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

[ https://issues.apache.org/jira/browse/FLINK-23959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23959: Fix Version/s: ml-0.1.0 > FLIP-175: Compose Estimator/Model/AlgoOperator from DAG of >

[jira] [Updated] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25185: --- Summary: StreamFaultToleranceTestBase hangs on AZP (was:

[GitHub] [flink-ml] gaoyunhaii closed pull request #20: [FLINK-23959][FLIP-175] Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

gaoyunhaii closed pull request #20: URL: https://github.com/apache/flink-ml/pull/20 -- 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:

[jira] [Updated] (FLINK-25185) UdfStreamOperatorCheckpointingITCase (StreamFaultToleranceTestBase) hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25185: --- Summary: UdfStreamOperatorCheckpointingITCase (StreamFaultToleranceTestBase) hangs on AZP

[jira] [Resolved] (FLINK-23375) Flink connector jdbc tests jar is almost empty

[ https://issues.apache.org/jira/browse/FLINK-23375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov resolved FLINK-23375. --- Resolution: Fixed > Flink connector jdbc tests jar is almost empty >

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #20: [FLINK-23959][FLIP-175] Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

gaoyunhaii commented on a change in pull request #20: URL: https://github.com/apache/flink-ml/pull/20#discussion_r772228361 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/builder/GraphBuilder.java ## @@ -0,0 +1,431 @@ +/* + * Licensed to the Apache Software

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

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

[jira] [Comment Edited] (FLINK-25337) Check whether the target table is valid when SqlToOperationConverter.convertSqlInsert

[ https://issues.apache.org/jira/browse/FLINK-25337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461167#comment-17461167 ] vim-wang edited comment on FLINK-25337 at 12/20/21, 9:50 AM: - hi,

[GitHub] [flink-ml] lindong28 commented on a change in pull request #20: [FLINK-23959][FLIP-175] Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

lindong28 commented on a change in pull request #20: URL: https://github.com/apache/flink-ml/pull/20#discussion_r772221497 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/builder/GraphExecutionHelper.java ## @@ -0,0 +1,118 @@ +/* + * Licensed to the Apache

[jira] [Comment Edited] (FLINK-25337) Check whether the target table is valid when SqlToOperationConverter.convertSqlInsert

[ https://issues.apache.org/jira/browse/FLINK-25337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461167#comment-17461167 ] vim-wang edited comment on FLINK-25337 at 12/20/21, 9:49 AM: - [~wenlong.lwl] 

[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: * b2fc0dd330c23f07af7a63830c6f601207236654 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-XXXX][connectors/elasticsearch] Add Elasticsearch 7 Source

flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * 31108c79f41b48c4dfe2eca5d65da3986375ebf8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18152: [FLINK-25364][python][table-planner] Remove dependency on planner internal code generation

flinkbot edited a comment on pull request #18152: URL: https://github.com/apache/flink/pull/18152#issuecomment-997674905 ## CI report: * 8fff2e77f98ffc2774a9087a65f749f70b898689 Azure:

[jira] [Commented] (FLINK-25360) Add State Desc to CheckpointMetadata

[ https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462480#comment-17462480 ] 刘方奇 commented on FLINK-25360: - [~yunta] , Actually, we can restore StateMetaInfoSnapshot in the state file,

[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-ml] lindong28 commented on a change in pull request #20: [FLINK-23959][FLIP-175] Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

lindong28 commented on a change in pull request #20: URL: https://github.com/apache/flink-ml/pull/20#discussion_r772214551 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/builder/GraphBuilder.java ## @@ -0,0 +1,431 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] flinkbot commented on pull request #18153: [FLINK-XXXX][connectors/elasticsearch] Add Elasticsearch 7 Source

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

[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] RocMarshal commented on a change in pull request #18146: [FLINK-25369][table] CatalogManager provide right tables or views in given catalog database

RocMarshal commented on a change in pull request #18146: URL: https://github.com/apache/flink/pull/18146#discussion_r772210693 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/catalog/CatalogITCase.java ## @@ -169,6 +186,51 @@ public

[GitHub] [flink] flinkbot commented on pull request #18153: [FLINK-XXXX][connectors/elasticsearch] Add Elasticsearch 7 Source

flinkbot commented on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997755249 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] 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-997753911 @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] 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-997753722 @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] twalthr commented on a change in pull request #18152: [FLINK-25364][python][table-planner] Remove dependency on planner internal code generation

twalthr commented on a change in pull request #18152: URL: https://github.com/apache/flink/pull/18152#discussion_r772170828 ## File path:

[GitHub] [flink] alpreu opened a new pull request #18153: [FLINK-XXXX][connectors/elasticsearch] Add Elasticsearch 7 Source

alpreu opened a new pull request #18153: URL: https://github.com/apache/flink/pull/18153 # Draft PR for the Elasticsearch 7 source - not final yet ## What is the purpose of the change This PR introduces a new Source connector for Elasticsearch 7. ## Brief change log

[GitHub] [flink] flinkbot edited a comment on pull request #17660: [FLINK-24657][runtime] Added metric of the total real size of input/o…

flinkbot edited a comment on pull request #17660: URL: https://github.com/apache/flink/pull/17660#issuecomment-958945516 ## CI report: * 7f6624189d4dc8b287c4a97ac5d29e4e3b946d67 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17660: [FLINK-24657][runtime] Added metric of the total real size of input/o…

flinkbot edited a comment on pull request #17660: URL: https://github.com/apache/flink/pull/17660#issuecomment-958945516 ## CI report: * 7f6624189d4dc8b287c4a97ac5d29e4e3b946d67 Azure:

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

xintongsong commented on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-997747703 @X-czh No worries. There seems to be some infrastructure problems. The community is currently looking into this. We can re-run the CI after the problem being fixed.

[GitHub] [flink] flinkbot edited a comment on pull request #18150: [docs] Fix typo

flinkbot edited a comment on pull request #18150: URL: https://github.com/apache/flink/pull/18150#issuecomment-997636068 ## CI report: * 86df0924fbaa931b4be21ff1ba6b7795acf9a02d Azure:

[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:

[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_r772200630 ## 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 #18150: [docs] Fix typo

flinkbot edited a comment on pull request #18150: URL: https://github.com/apache/flink/pull/18150#issuecomment-997636068 ## CI report: * 86df0924fbaa931b4be21ff1ba6b7795acf9a02d Azure:

[GitHub] [flink-ml] lindong28 commented on a change in pull request #20: [FLINK-23959][FLIP-175] Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

lindong28 commented on a change in pull request #20: URL: https://github.com/apache/flink-ml/pull/20#discussion_r772198890 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/builder/GraphExecutionHelper.java ## @@ -0,0 +1,118 @@ +/* + * Licensed to the Apache

[GitHub] [flink] aihai commented on pull request #18150: [docs] Fix typo

aihai commented on pull request #18150: URL: https://github.com/apache/flink/pull/18150#issuecomment-997740343 @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

[jira] [Updated] (FLINK-25365) Remove remaining references to planner from Python

[ https://issues.apache.org/jira/browse/FLINK-25365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-25365: Description: This issue should conclude the effort of accessing planner classes

[jira] [Commented] (FLINK-24483) Document what is Public API and what compatibility guarantees Flink is providing

[ https://issues.apache.org/jira/browse/FLINK-24483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462474#comment-17462474 ] Till Rohrmann commented on FLINK-24483: --- Hi [~monster#12], have you read through the FLIP and do

[jira] [Commented] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462475#comment-17462475 ] Till Rohrmann commented on FLINK-25185: --- cc [~pnowojski] > StreamFaultToleranceTestBase hangs on

[jira] [Updated] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25185: -- Fix Version/s: 1.15.0 > StreamFaultToleranceTestBase hangs on AZP >

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #20: [FLINK-23959][FLIP-175] Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

gaoyunhaii commented on a change in pull request #20: URL: https://github.com/apache/flink-ml/pull/20#discussion_r772195958 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/builder/GraphExecutionHelper.java ## @@ -0,0 +1,118 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

flinkbot edited a comment on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-986441468 ## CI report: * 163e826eea7eb58d13e9712562a231bdabae9052 Azure:

[GitHub] [flink-ml] lindong28 commented on a change in pull request #20: [FLINK-23959][FLIP-175] Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

lindong28 commented on a change in pull request #20: URL: https://github.com/apache/flink-ml/pull/20#discussion_r772189546 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/builder/GraphBuilder.java ## @@ -0,0 +1,431 @@ +/* + * Licensed to the Apache Software

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

packages between two runs though):  However, I was able to build it locally, how could I debug this problem? The CI log doesn't seem to be helpful to me

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

Airblader commented on a change in pull request #18151: URL: https://github.com/apache/flink/pull/18151#discussion_r772187986 ## 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 #18150: [docs] Fix typo

flinkbot edited a comment on pull request #18150: URL: https://github.com/apache/flink/pull/18150#issuecomment-997636068 ## CI report: * 86df0924fbaa931b4be21ff1ba6b7795acf9a02d Azure:

[GitHub] [flink] liufangqi commented on pull request #18059: [FLINK-25224][filesystem] Bump Hadoop version to 2.8.4

liufangqi commented on pull request #18059: URL: https://github.com/apache/flink/pull/18059#issuecomment-997723167 @dmvk Hi, sorry to bother, what about the opinions of the community about bump the Hadoop version up? Just take your time, hope I did not disturb you. -- This is an

[GitHub] [flink] flinkbot edited a comment on pull request #18150: [docs] Fix typo

flinkbot edited a comment on pull request #18150: URL: https://github.com/apache/flink/pull/18150#issuecomment-997636068 ## CI report: * 86df0924fbaa931b4be21ff1ba6b7795acf9a02d Azure:

[GitHub] [flink-ml] lindong28 commented on a change in pull request #20: [FLINK-23959][FLIP-175] Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

lindong28 commented on a change in pull request #20: URL: https://github.com/apache/flink-ml/pull/20#discussion_r772182495 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/builder/GraphExecutionHelper.java ## @@ -0,0 +1,118 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #20: [FLINK-23959][FLIP-175] Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

lindong28 commented on a change in pull request #20: URL: https://github.com/apache/flink-ml/pull/20#discussion_r772182729 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/builder/GraphExecutionHelper.java ## @@ -0,0 +1,118 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #20: [FLINK-23959][FLIP-175] Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

lindong28 commented on a change in pull request #20: URL: https://github.com/apache/flink-ml/pull/20#discussion_r772181330 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/builder/GraphExecutionHelper.java ## @@ -0,0 +1,118 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #18150: [docs] Fix typo

flinkbot edited a comment on pull request #18150: URL: https://github.com/apache/flink/pull/18150#issuecomment-997636068 ## CI report: * 86df0924fbaa931b4be21ff1ba6b7795acf9a02d Azure:

[GitHub] [flink-ml] lindong28 commented on a change in pull request #20: [FLINK-23959][FLIP-175] Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

lindong28 commented on a change in pull request #20: URL: https://github.com/apache/flink-ml/pull/20#discussion_r772178928 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/builder/Graph.java ## @@ -0,0 +1,151 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

ruanhang1993 commented on a change in pull request #18137: URL: https://github.com/apache/flink/pull/18137#discussion_r772176342 ## File path:

[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:

[jira] [Updated] (FLINK-25375) Update Log4j to 2.17.0

[ https://issues.apache.org/jira/browse/FLINK-25375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-25375: - Affects Version/s: 1.13.5 1.12.7 1.11.6 >

<    1   2   3   4   5   6   >