[jira] [Updated] (FLINK-10077) Web UI should respond when there is no elected Dispatcher

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

[jira] [Updated] (FLINK-10015) Use Elasticsearch's ESIntegTestCase to rework 5.x and 6.x's ITCases

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

[jira] [Updated] (FLINK-13944) Table.toAppendStream: InvalidProgramException: Table program cannot be compiled.

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

[jira] [Updated] (FLINK-10167) SessionWindows not compatible with typed DataStreams in scala

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

[jira] [Updated] (FLINK-10106) Include test name in temp directory of e2e test

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

[GitHub] [flink] wuchong commented on pull request #17826: [FLINK-24953][Connectors / Hive]Optime hive parallelism inference

wuchong commented on pull request #17826: URL: https://github.com/apache/flink/pull/17826#issuecomment-976109317 cc @luoyuxia, could you help to review this when you are free? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] leonardBang commented on a change in pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speif

leonardBang commented on a change in pull request #17749: URL: https://github.com/apache/flink/pull/17749#discussion_r754766805 ## File path: docs/content/docs/connectors/table/filesystem.md ## @@ -320,23 +320,32 @@ Time extractors define extracting time from partition

[jira] [Assigned] (FLINK-24953) Optime hive parallelism inference

[ https://issues.apache.org/jira/browse/FLINK-24953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24953: --- Assignee: xiangqiao > Optime hive parallelism inference > - > >

[GitHub] [flink] flinkbot commented on pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

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

[GitHub] [flink] flinkbot edited a comment on pull request #17805: [FLINK-24708][planner] Fix wrong results of the IN operator

flinkbot edited a comment on pull request #17805: URL: https://github.com/apache/flink/pull/17805#issuecomment-969943622 ## CI report: * c84c8b1c74e02daeb82fc1c35c68576a5fc3c770 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17823: [FLINK-24937][e2e] Return correct exit code in build_image

flinkbot edited a comment on pull request #17823: URL: https://github.com/apache/flink/pull/17823#issuecomment-972474977 ## CI report: * fc2c92648891940ca961617c5a7715d3e8137689 Azure:

[jira] [Commented] (FLINK-24997) count(null) not supported in flink sql query

[ https://issues.apache.org/jira/browse/FLINK-24997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447762#comment-17447762 ] Jark Wu commented on FLINK-24997: - I agree with [~icshuo]. But the exception can be improved. >

[GitHub] [flink] wangyang0918 opened a new pull request #17876: [FLINK-24937][e2e] Return correct exit code in build_image

wangyang0918 opened a new pull request #17876: URL: https://github.com/apache/flink/pull/17876 Backport #17823 to 1.14. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[jira] [Commented] (FLINK-24975) Add hooks and extension points to FlinkSQL

[ https://issues.apache.org/jira/browse/FLINK-24975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447778#comment-17447778 ] junbiao chen commented on FLINK-24975: -- I will start a discussion about this issue later > Add

[GitHub] [flink] leonardBang commented on pull request #17653: FLINK SQL checkpoint不生效

leonardBang commented on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-976103527 @fanghj I closed this PR as its invalid, you need open a [JIRA issue](https://issues.apache.org/jira/projects/FLINK/issues/FLINK-24998?filter=allopenissues) firstly and

[GitHub] [flink] leonardBang commented on a change in pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speif

leonardBang commented on a change in pull request #17749: URL: https://github.com/apache/flink/pull/17749#discussion_r754767968 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/FsStreamingSinkITCaseBase.scala ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

flinkbot edited a comment on pull request #17874: URL: https://github.com/apache/flink/pull/17874#issuecomment-976109395 ## CI report: * 95f6020ca7df973e5a50a0eab36fa2bd1a33878c Azure:

[jira] [Commented] (FLINK-24939) Support 'SHOW CREATE CATALOG' syntax

[ https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447735#comment-17447735 ] Yubin Li commented on FLINK-24939: -- hi, [~shenzhu0127] SHOW CATALOGS only show existing catalogs name,

[jira] [Commented] (FLINK-25008) Improve behaviour of NotNullEnforcer when dropping records

[ https://issues.apache.org/jira/browse/FLINK-25008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447748#comment-17447748 ] Jark Wu commented on FLINK-25008: - Sounds good to me. > Improve behaviour of NotNullEnforcer when

[jira] [Commented] (FLINK-24002) Support count window with the window TVF

[ https://issues.apache.org/jira/browse/FLINK-24002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447749#comment-17447749 ] Jark Wu commented on FLINK-24002: - Thanks [~jingzhang] for hte summary. Your proposed syntax looks good

[jira] [Updated] (FLINK-24966) Fix spelling errors in the project

[ https://issues.apache.org/jira/browse/FLINK-24966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24966: Summary: Fix spelling errors in the project (was: Typo fix) > Fix spelling errors in the project >

[jira] [Commented] (FLINK-24997) count(null) not supported in flink sql query

[ https://issues.apache.org/jira/browse/FLINK-24997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447767#comment-17447767 ] zouyunhe commented on FLINK-24997: -- OK [~icshuo]  > count(null) not supported in flink sql query >

[GitHub] [flink] flinkbot edited a comment on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify DateTi

flinkbot edited a comment on pull request #17749: URL: https://github.com/apache/flink/pull/17749#issuecomment-965029957 ## CI report: * b87090dace76f1298934c25b6fdb892853376bb1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17670: [FLINK-24760][docs] Update user document for batch window tvf

flinkbot edited a comment on pull request #17670: URL: https://github.com/apache/flink/pull/17670#issuecomment-960539433 ## CI report: * 9f14fb2c282614088363960f23af3d6c5770ff15 Azure:

[jira] [Updated] (FLINK-14039) Flink Kinesis consumer: configurable per-shard consumption rate when running in adaptive mode

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

[jira] [Updated] (FLINK-10165) JarRunHandler/JarRunRequestBody should allow to pass program arguments as escaped json list

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

[jira] [Updated] (FLINK-10173) Elasticsearch 6 connector does not package Elasticsearch

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

[jira] [Updated] (FLINK-10212) REST API for listing all the available save points

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

[jira] [Updated] (FLINK-10155) JobExecutionException when using evictor followed with map

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

[jira] [Updated] (FLINK-10196) API to test streaming pipelines with windows

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

[jira] [Updated] (FLINK-14002) FlinkKafkaProducer constructor that takes KafkaSerializationSchema shouldnt take default topic

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

[jira] [Updated] (FLINK-10199) StandaloneSessionClusterEntrypoint does not respect host/ui-port given from jobmanager.sh

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

[jira] [Updated] (FLINK-10039) FlinkKafkaProducer - Serializer Error

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

[jira] [Updated] (FLINK-13899) Add SQL DDL for Elasticsearch 5.X version

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

[jira] [Updated] (FLINK-13881) CEP within method should applied in every independent pattern

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

[jira] [Updated] (FLINK-14030) IS_NULL is optimized to incorrect results

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

[jira] [Updated] (FLINK-13951) Unable to call limit without sort for batch mode

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

[jira] [Updated] (FLINK-14136) Operator Topology and Metrics Inside Vertex

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

[jira] [Updated] (FLINK-14057) Add Remove Other Timers to TimerService

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

[jira] [Updated] (FLINK-13909) LinkElement does not support different anchors required for localization

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

[GitHub] [flink] shenzhu commented on a change in pull request #17831: [FLINK-15825][Table SQL/API] Add renameDatabase() to Catalog

shenzhu commented on a change in pull request #17831: URL: https://github.com/apache/flink/pull/17831#discussion_r754697190 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/Catalog.java ## @@ -206,6 +206,22 @@ void dropDatabase(String

[GitHub] [flink] shenzhu commented on a change in pull request #17831: [FLINK-15825][Table SQL/API] Add renameDatabase() to Catalog

shenzhu commented on a change in pull request #17831: URL: https://github.com/apache/flink/pull/17831#discussion_r754702274 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java ## @@ -398,6 +398,34 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #17805: [FLINK-24708][planner] Fix wrong results of the IN operator

flinkbot edited a comment on pull request #17805: URL: https://github.com/apache/flink/pull/17805#issuecomment-969943622 ## CI report: * c84c8b1c74e02daeb82fc1c35c68576a5fc3c770 Azure:

[GitHub] [flink] fsk119 commented on pull request #17805: [FLINK-24708][planner] Fix wrong results of the IN operator

fsk119 commented on pull request #17805: URL: https://github.com/apache/flink/pull/17805#issuecomment-976093591 @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] leonardBang commented on a change in pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speif

leonardBang commented on a change in pull request #17749: URL: https://github.com/apache/flink/pull/17749#discussion_r754767394 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/FileSystemConnectorOptions.java ## @@ -156,6 +156,22

[GitHub] [flink] flinkbot commented on pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

flinkbot commented on pull request #17874: URL: https://github.com/apache/flink/pull/17874#issuecomment-976109692 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] leonardBang commented on a change in pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speif

leonardBang commented on a change in pull request #17749: URL: https://github.com/apache/flink/pull/17749#discussion_r754767470 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/FsStreamingSinkITCaseBase.scala ## @@

[jira] [Commented] (FLINK-24915) StreamElementSerializer#deserialize(StreamElement reuse, DataInputView source) forgets to handle tag == TAG_STREAM_STATUS

[ https://issues.apache.org/jira/browse/FLINK-24915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447734#comment-17447734 ] Jark Wu commented on FLINK-24915: - [~bx123] it would be better to reach consensus about how to address

[jira] [Commented] (FLINK-24997) count(null) not supported in flink sql query

[ https://issues.apache.org/jira/browse/FLINK-24997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447765#comment-17447765 ] zouyunhe commented on FLINK-24997: -- [~jark] [~icshuo] the calcite can not deduce the type, but the

[GitHub] [flink] godfreyhe commented on a change in pull request #17670: [FLINK-24760][docs] Update user document for batch window tvf

godfreyhe commented on a change in pull request #17670: URL: https://github.com/apache/flink/pull/17670#discussion_r754793897 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-agg.md ## @@ -40,7 +40,9 @@ Unlike other aggregations on continuous tables, window

[jira] [Closed] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

[ https://issues.apache.org/jira/browse/FLINK-24708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-24708. -- Resolution: Fixed Fixed in: 1.15.0: 90e850301e672fc0da293abc55eb446f7ec68ffa 1.14.1:

[GitHub] [flink] godfreyhe commented on pull request #17805: [FLINK-24708][planner] Fix wrong results of the IN operator

godfreyhe commented on pull request #17805: URL: https://github.com/apache/flink/pull/17805#issuecomment-976162994 merged -- 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.

[GitHub] [flink] hililiwei commented on a change in pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify

hililiwei commented on a change in pull request #17749: URL: https://github.com/apache/flink/pull/17749#discussion_r754819067 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/FileSystemConnectorOptions.java ## @@ -156,6 +156,22 @@

[jira] [Commented] (FLINK-12941) Translate "Amazon AWS Kinesis Streams Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447787#comment-17447787 ] ZhuoYu Chen commented on FLINK-12941: - Hi [~jark] I am very interested in this，and I want do some

[GitHub] [flink-ml] lindong28 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

lindong28 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r754820934 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasEpsilon.java ## @@ -0,0 +1,43 @@ +/* + * Licensed to the Apache Software

[jira] [Closed] (FLINK-24964) Upgrade frontend-maven-plugin to 1.11.0

[ https://issues.apache.org/jira/browse/FLINK-24964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24964. Fix Version/s: 1.15.0 Assignee: Maciej Bryński Resolution: Fixed master:

[GitHub] [flink] flinkbot edited a comment on pull request #17806: [FLINK-24708][planner] Fix wrong results of the IN operator

flinkbot edited a comment on pull request #17806: URL: https://github.com/apache/flink/pull/17806#issuecomment-969962850 ## CI report: * c3f5f0fcebad85e7cae6694d5282da369ce69509 Azure:

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

tsreaper commented on pull request #17845: URL: https://github.com/apache/flink/pull/17845#issuecomment-976095323 cc. @godfreyhe do you have any other thoughts about this solution? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #17805: [FLINK-24708][planner] Fix wrong results of the IN operator

flinkbot edited a comment on pull request #17805: URL: https://github.com/apache/flink/pull/17805#issuecomment-969943622 ## CI report: * c84c8b1c74e02daeb82fc1c35c68576a5fc3c770 Azure:

[GitHub] [flink] leonardBang commented on a change in pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speif

leonardBang commented on a change in pull request #17749: URL: https://github.com/apache/flink/pull/17749#discussion_r754140539 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/FsStreamingSinkITCaseBase.scala ## @@

[GitHub] [flink] leonardBang commented on a change in pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speif

leonardBang commented on a change in pull request #17749: URL: https://github.com/apache/flink/pull/17749#discussion_r754130028 ## File path: docs/content/docs/connectors/table/filesystem.md ## @@ -328,15 +328,30 @@ Time extractors define extracting time from partition

[GitHub] [flink] leonardBang commented on a change in pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speif

leonardBang commented on a change in pull request #17749: URL: https://github.com/apache/flink/pull/17749#discussion_r754766540 ## File path: docs/content/docs/connectors/table/filesystem.md ## @@ -320,23 +320,32 @@ Time extractors define extracting time from partition

[GitHub] [flink] RocMarshal removed a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

RocMarshal removed a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-962460877 @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

[GitHub] [flink] flinkbot commented on pull request #17875: [BP-1.14][FLINK-24937][e2e] Return correct exit code in build_image

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

[GitHub] [flink] flinkbot commented on pull request #17875: [BP-1.14][FLINK-24937][e2e] Return correct exit code in build_image

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

[GitHub] [flink] godfreyhe commented on a change in pull request #17666: [FLINK-21327][table-planner-blink] Support window TVF in batch mode

godfreyhe commented on a change in pull request #17666: URL: https://github.com/apache/flink/pull/17666#discussion_r754795448 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/WindowTableFunctionTest.scala ## @@ -0,0

[jira] [Updated] (FLINK-25010) Speed up hive's createMRSplits by multi thread

[ https://issues.apache.org/jira/browse/FLINK-25010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-25010: Component/s: Connectors / Hive > Speed up hive's createMRSplits by multi thread >

[jira] [Created] (FLINK-25010) Speed up hive's createMRSplits by multi thread

Liu created FLINK-25010: --- Summary: Speed up hive's createMRSplits by multi thread Key: FLINK-25010 URL: https://issues.apache.org/jira/browse/FLINK-25010 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

flinkbot edited a comment on pull request #17822: URL: https://github.com/apache/flink/pull/17822#issuecomment-971696959 ## CI report: * 3719c0402ec979c619371fcde9f2e7d2c46d69ed Azure:

[GitHub] [flink] hililiwei commented on a change in pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify

hililiwei commented on a change in pull request #17749: URL: https://github.com/apache/flink/pull/17749#discussion_r754743342 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/FsStreamingSinkITCaseBase.scala ## @@

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

tsreaper commented on a change in pull request #17845: URL: https://github.com/apache/flink/pull/17845#discussion_r754754304 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/join/LookupJoinTest.scala ## @@ -525,7

[GitHub] [flink] flinkbot edited a comment on pull request #17806: [FLINK-24708][planner] Fix wrong results of the IN operator

flinkbot edited a comment on pull request #17806: URL: https://github.com/apache/flink/pull/17806#issuecomment-969962850 ## CI report: * c3f5f0fcebad85e7cae6694d5282da369ce69509 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17792: [FLINK-24763][fs-connector] LimitableReader should swallow exception when reached limit

flinkbot edited a comment on pull request #17792: URL: https://github.com/apache/flink/pull/17792#issuecomment-968524862 ## CI report: * 87ccd1f5232d04d53409eb233bc54722d83f7613 Azure:

[GitHub] [flink] leonardBang edited a comment on pull request #17653: FLINK SQL checkpoint不生效

leonardBang edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-976103527 @fanghj Please close this PR as it's invalid, you need open a [JIRA issue](https://issues.apache.org/jira/projects/FLINK/issues/FLINK-24998?filter=allopenissues)

[jira] [Closed] (FLINK-24976) sink utils not check the schema info between query and sink table

[ https://issues.apache.org/jira/browse/FLINK-24976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24976. --- Resolution: Not A Problem This is a SQL standard that not valid field names when INSERT INTO. If you want

[GitHub] [flink] wuchong commented on a change in pull request #17842: [FLINK-24966] [docs] Fix spelling errors in the project

wuchong commented on a change in pull request #17842: URL: https://github.com/apache/flink/pull/17842#discussion_r754787598 ## File path: flink-end-to-end-tests/flink-tpcds-test/tpcds-tool/query/query44.sql ## @@ -1,5 +1,5 @@ -- start query 1 in stream 0 using template

[GitHub] [flink] flinkbot commented on pull request #17876: [FLINK-24937][e2e] Return correct exit code in build_image

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

[GitHub] [flink] flinkbot edited a comment on pull request #17875: [BP-1.14][FLINK-24937][e2e] Return correct exit code in build_image

flinkbot edited a comment on pull request #17875: URL: https://github.com/apache/flink/pull/17875#issuecomment-976151167 ## CI report: * 3c8b9142f5707820507d61fc71784f7ed4bc07f1 Azure:

[GitHub] [flink] flinkbot commented on pull request #17876: [FLINK-24937][e2e] Return correct exit code in build_image

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

[GitHub] [flink] godfreyhe closed pull request #17805: [FLINK-24708][planner] Fix wrong results of the IN operator

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

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

YuvalItzchakov commented on a change in pull request #17845: URL: https://github.com/apache/flink/pull/17845#discussion_r754823553 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/join/LookupJoinTest.scala ## @@

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

YuvalItzchakov commented on a change in pull request #17845: URL: https://github.com/apache/flink/pull/17845#discussion_r754823553 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/join/LookupJoinTest.scala ## @@

[GitHub] [flink-ml] lindong28 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

lindong28 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r754825324 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasEpsilon.java ## @@ -0,0 +1,43 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-24915) StreamElementSerializer#deserialize(StreamElement reuse, DataInputView source) forgets to handle tag == TAG_STREAM_STATUS

[ https://issues.apache.org/jira/browse/FLINK-24915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447797#comment-17447797 ] bx123 commented on FLINK-24915: --- [~arvid]  [#FLINK-5017] introduced StreamStatus support for this

[jira] [Closed] (FLINK-21510) ExecutionGraph metrics collide on restart

[ https://issues.apache.org/jira/browse/FLINK-21510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21510. Fix Version/s: 1.15.0 Resolution: Fixed > ExecutionGraph metrics collide on

[GitHub] [flink] flinkbot edited a comment on pull request #17813: [FLINK-24802][Table SQL/Planner] Improve cast ROW to STRING

flinkbot edited a comment on pull request #17813: URL: https://github.com/apache/flink/pull/17813#issuecomment-970956527 ## CI report: * c7e634de45cb1f4c024e196c1b4c0d1c37ee9021 Azure:

[GitHub] [flink] fsk119 commented on pull request #17806: [FLINK-24708][planner] Fix wrong results of the IN operator

fsk119 commented on pull request #17806: URL: https://github.com/apache/flink/pull/17806#issuecomment-976093033 The failed test is because FLINK-24789. @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-24997) count(null) not supported in flink sql query

[ https://issues.apache.org/jira/browse/FLINK-24997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zouyunhe updated FLINK-24997: - Description: I use sql client to submit a sql query to flink session cluster,  the sql is  {code:java}

[jira] [Commented] (FLINK-24948) Special character in column names breaks JDBC statement parsing

[ https://issues.apache.org/jira/browse/FLINK-24948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447728#comment-17447728 ] Jark Wu commented on FLINK-24948: - [~Paul Lin], could you give an example for the failed case? Is it

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447729#comment-17447729 ] lincoln lee commented on FLINK-20370: - [~wenlong.lwl]  Good question!  I think it‘s safe adding

[jira] [Updated] (FLINK-24939) Support 'SHOW CREATE CATALOG' syntax

[ https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24939: Component/s: Table SQL / API > Support 'SHOW CREATE CATALOG' syntax >

[jira] [Commented] (FLINK-24975) Add hooks and extension points to FlinkSQL

[ https://issues.apache.org/jira/browse/FLINK-24975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447753#comment-17447753 ] Jark Wu commented on FLINK-24975: - Yes, this one deserves a FLIP. Btw, this may also relate to

[jira] [Commented] (FLINK-21583) Allow comments in CSV format without having to ignore parse errors

[ https://issues.apache.org/jira/browse/FLINK-21583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447755#comment-17447755 ] Jark Wu commented on FLINK-21583: - [~nkruber], could you help to check that? It seems we don't need to

[GitHub] [flink] flinkbot edited a comment on pull request #17823: [FLINK-24937][e2e] Return correct exit code in build_image

flinkbot edited a comment on pull request #17823: URL: https://github.com/apache/flink/pull/17823#issuecomment-972474977 ## CI report: * fc2c92648891940ca961617c5a7715d3e8137689 Azure:

[GitHub] [flink] wangyang0918 opened a new pull request #17875: [BP-1.14][FLINK-24937][e2e] Return correct exit code in build_image

wangyang0918 opened a new pull request #17875: URL: https://github.com/apache/flink/pull/17875 Backport #17823 to 1.14. -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

flinkbot edited a comment on pull request #17822: URL: https://github.com/apache/flink/pull/17822#issuecomment-971696959 ## CI report: * 3719c0402ec979c619371fcde9f2e7d2c46d69ed Azure:

[jira] [Commented] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447786#comment-17447786 ] ZhuoYu Chen commented on FLINK-24696: - Hi [~pnowojski]  , I am very interested in this，and I want do

[GitHub] [flink] flinkbot edited a comment on pull request #17838: [FLINK-24915] [DataStream] fix StreamElementSerializer#deserialize(reuse, source) forgets to handle tag == TAG_STREAM_STATUS.

flinkbot edited a comment on pull request #17838: URL: https://github.com/apache/flink/pull/17838#issuecomment-974023420 ## CI report: * c8204684d4268cad534759a6c7bb487e17fdbb05 Azure:

[GitHub] [flink] zentol merged pull request #17766: [FLINK-24876][docs] Remove metrics limitation of Adaptive Scheduler

zentol merged pull request #17766: URL: https://github.com/apache/flink/pull/17766 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #17813: [FLINK-24802][Table SQL/Planner] Improve cast ROW to STRING

flinkbot edited a comment on pull request #17813: URL: https://github.com/apache/flink/pull/17813#issuecomment-970956527 ## CI report: * c7e634de45cb1f4c024e196c1b4c0d1c37ee9021 Azure:

  1   2   3   4   5   6   7   8   >