[jira] [Updated] (FLINK-25335) Improvement of task deployment by enable source split Asynchronous enumerate

[ https://issues.apache.org/jira/browse/FLINK-25335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25335: --- Summary: Improvement of task deployment by enable source split Asynchronous enumerate (was:

[jira] [Updated] (FLINK-25335) Improvement of task deployment by enable source split async enumerate

[ https://issues.apache.org/jira/browse/FLINK-25335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25335: --- Summary: Improvement of task deployment by enable source split async enumerate (was: Improvoment

[GitHub] [flink] flinkbot edited a comment on pull request #18114: [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

flinkbot edited a comment on pull request #18114: URL: https://github.com/apache/flink/pull/18114#issuecomment-994556266 ## CI report: * 163245e6c628a06bc5ce593d014e1588262aae60 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * f5d5ba06b2427d6ea53fc92d74db1a2f8c0f3928 Azure:

[jira] [Commented] (FLINK-22485) Support client attach on application mode

[ https://issues.apache.org/jira/browse/FLINK-22485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460386#comment-17460386 ] Junfan Zhang commented on FLINK-22485: -- Rediscuss this ticket.  After reading the code about the

[jira] [Updated] (FLINK-25335) Improvoment of task deployment by enable source split async enumerate

[ https://issues.apache.org/jira/browse/FLINK-25335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25335: --- Description: When submit olap query by flink client to Flink Session Cluster, the JobMaster will

[jira] [Commented] (FLINK-25332) When using Pyflink Table API, 'where' clause seems to work incorrectly

[ https://issues.apache.org/jira/browse/FLINK-25332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460385#comment-17460385 ] Dian Fu commented on FLINK-25332: - Hi [~paranoia], could you post the execution plan? You could get the

[jira] [Created] (FLINK-25336) Kafka connector compatible problem in Flink sql

Yuan Zhu created FLINK-25336: Summary: Kafka connector compatible problem in Flink sql Key: FLINK-25336 URL: https://issues.apache.org/jira/browse/FLINK-25336 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * f5d5ba06b2427d6ea53fc92d74db1a2f8c0f3928 Azure:

[GitHub] [flink] Myasuka commented on a change in pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

Myasuka commented on a change in pull request #17774: URL: https://github.com/apache/flink/pull/17774#discussion_r770194196 ## File path:

[jira] [Updated] (FLINK-25335) Improvoment of task deployment by enable source split async enumerate

[ https://issues.apache.org/jira/browse/FLINK-25335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25335: --- Attachment: image-2021-12-16-11-14-36-030.png > Improvoment of task deployment by enable source

[jira] [Updated] (FLINK-25335) Improvoment of task deployment by enable source split async enumerate

[ https://issues.apache.org/jira/browse/FLINK-25335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25335: --- Description: When submit olap query by flink client to Flink Session Cluster, the JobMaster will

[jira] [Created] (FLINK-25335) Improvoment of task deployment by enable source split async enumerate

KevinyhZou created FLINK-25335: -- Summary: Improvoment of task deployment by enable source split async enumerate Key: FLINK-25335 URL: https://issues.apache.org/jira/browse/FLINK-25335 Project: Flink

[jira] [Updated] (FLINK-22485) Support client attach on application mode

[ https://issues.apache.org/jira/browse/FLINK-22485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22485: - Priority: Major (was: Not a Priority) > Support client attach on application mode >

[GitHub] [flink] JingsongLi commented on a change in pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

JingsongLi commented on a change in pull request #18088: URL: https://github.com/apache/flink/pull/18088#discussion_r770192030 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FactoryUtil.java ## @@ -620,10 +624,16 @@ public static

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

[jira] [Closed] (FLINK-24862) The user-defined hive udaf/udtf cannot be used normally in hive dialect

[ https://issues.apache.org/jira/browse/FLINK-24862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang closed FLINK-24862. -- Resolution: Fixed > The user-defined hive udaf/udtf cannot be used normally in hive dialect >

[jira] [Commented] (FLINK-24947) Support host network for native K8s integration

[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460383#comment-17460383 ] liuzhuo commented on FLINK-24947: - HI [~wangyang0918] This pull request has been submitted, if you have

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * Unknown: [CANCELED](TBD) * d2242677110bbd6b38963379d4f8624f13c7 Azure:

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

[GitHub] [flink] jelly-1203 commented on pull request #18017: [FLINK-25171] Validation of duplicate fields in ddl sql

jelly-1203 commented on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-995395488 Hi, @wenlong88 I have adjusted the position of the verification logic and made the error message return more clear. Could you please help to review it and see what needs to

[jira] [Updated] (FLINK-24862) The user-defined hive udaf/udtf cannot be used normally in hive dialect

[ https://issues.apache.org/jira/browse/FLINK-24862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-24862: --- Affects Version/s: 1.12.0 1.11.0 > The user-defined hive udaf/udtf cannot be

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * Unknown: [CANCELED](TBD) * d2242677110bbd6b38963379d4f8624f13c7 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] spoon-lz commented on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

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

[jira] [Updated] (FLINK-24862) The user-defined hive udaf/udtf cannot be used normally in hive dialect

[ https://issues.apache.org/jira/browse/FLINK-24862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-24862: --- Fix Version/s: 1.15.0 > The user-defined hive udaf/udtf cannot be used normally in hive dialect >

[jira] [Commented] (FLINK-24862) The user-defined hive udaf/udtf cannot be used normally in hive dialect

[ https://issues.apache.org/jira/browse/FLINK-24862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460378#comment-17460378 ] Jing Zhang commented on FLINK-24862: Fixed in master: 95b8309213a5470b2e7e61771d6e90de75c71227 >

[GitHub] [flink] flinkbot edited a comment on pull request #18118: [FLINK-24907] Support side out late data for interval join

flinkbot edited a comment on pull request #18118: URL: https://github.com/apache/flink/pull/18118#issuecomment-994686917 ## CI report: * d8e09a1643cb2fffc9bf3c836dbfb20a9114f26b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18118: [FLINK-24907] Support side out late data for interval join

flinkbot edited a comment on pull request #18118: URL: https://github.com/apache/flink/pull/18118#issuecomment-994686917 ## CI report: * d8e09a1643cb2fffc9bf3c836dbfb20a9114f26b Azure:

[GitHub] [flink] chenyuzhi459 commented on pull request #18118: [FLINK-24907] Support side out late data for interval join

chenyuzhi459 commented on pull request #18118: URL: https://github.com/apache/flink/pull/18118#issuecomment-995390917 @flinkbot -- 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] wenlong88 commented on pull request #17938: [FLINK-25073][streaming] Introduce TreeMode description for vertices

wenlong88 commented on pull request #17938: URL: https://github.com/apache/flink/pull/17938#issuecomment-995390402 @gaoyunhaii Regarding very long description, if tree mode is enabled, UI will not break line automatically(in order to keep the tree presentation), user can scroll the

[GitHub] [flink] beyond1920 merged pull request #17761: [FLINK-24862][Connectors / Hive]Fix user-defined hive udaf/udtf cannot be used normally in hive dialect

beyond1920 merged pull request #17761: URL: https://github.com/apache/flink/pull/17761 -- 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] beyond1920 commented on a change in pull request #17761: [FLINK-24862][Connectors / Hive]Fix user-defined hive udaf/udtf cannot be used normally in hive dialect

beyond1920 commented on a change in pull request #17761: URL: https://github.com/apache/flink/pull/17761#discussion_r770184306 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectITCase.java ## @@ -635,6 +636,35 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17938: [FLINK-25073][streaming] Introduce TreeMode description for vertices

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

[GitHub] [flink] flinkbot edited a comment on pull request #17938: [FLINK-25073][streaming] Introduce TreeMode description for vertices

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

[GitHub] [flink] JingsongLi commented on a change in pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

JingsongLi commented on a change in pull request #18088: URL: https://github.com/apache/flink/pull/18088#discussion_r770182123 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FactoryUtil.java ## @@ -620,10 +624,16 @@ public static

[GitHub] [flink] wenlong88 commented on pull request #17938: [FLINK-25073][streaming] Introduce TreeMode description for vertices

wenlong88 commented on pull request #17938: URL: https://github.com/apache/flink/pull/17938#issuecomment-995385587 hi, @gaoyunhaii , thanks for the detailed review, I have updated the pr based on the comment, please check again, thanks. -- This is an automated message from the Apache

[GitHub] [flink] JingsongLi commented on a change in pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

JingsongLi commented on a change in pull request #18088: URL: https://github.com/apache/flink/pull/18088#discussion_r770178624 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java ## @@ -686,7 +701,14 @@ public void

[jira] [Closed] (FLINK-12022) Enable StreamWriter to update file length on sync flush

[ https://issues.apache.org/jira/browse/FLINK-12022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin closed FLINK-12022. Resolution: Won't Fix > Enable StreamWriter to update file length on sync flush >

[GitHub] [flink] flinkbot commented on pull request #18125: [FLINK-25210][pulsar][e2e][tests] add resource file to test jar

flinkbot commented on pull request #18125: URL: https://github.com/apache/flink/pull/18125#issuecomment-995380198 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 #18125: [FLINK-25210][pulsar][e2e][tests] add resource file to test jar

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

[jira] [Commented] (FLINK-25328) Improvement of share memory manager between jobs if they use the same slot in TaskManager for flink olap queries

[ https://issues.apache.org/jira/browse/FLINK-25328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460368#comment-17460368 ] Shammon commented on FLINK-25328: - [~xtsong] Thanks for you reply. As you mentioned, MemoryManager takes

[GitHub] [flink] flinkbot commented on pull request #18125: [FLINK-25210][pulsar][e2e][tests] add resource file to test jar

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

[jira] [Updated] (FLINK-25210) PulsarSource(Un)OrderedE2ECase is broken

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

[GitHub] [flink] imaffe opened a new pull request #18125: [FLINK-25210][pulsar][e2e][tests] add resource file to test jar

imaffe opened a new pull request #18125: URL: https://github.com/apache/flink/pull/18125 ## What is the purpose of the change Add resource file to the test jar to avoid find not found exception and re-enable pulsar e2e tests due to FLINK-25210 ## Brief change log

[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=17460367#comment-17460367 ] Yang Wang commented on FLINK-25321: --- It would help if you could increase the JVM overhead memory and

[GitHub] [flink] wanglijie95 commented on a change in pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

wanglijie95 commented on a change in pull request #18023: URL: https://github.com/apache/flink/pull/18023#discussion_r770172671 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java ## @@ -307,13 +323,21 @@ public

[GitHub] [flink] wanglijie95 commented on a change in pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

wanglijie95 commented on a change in pull request #18023: URL: https://github.com/apache/flink/pull/18023#discussion_r770172671 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java ## @@ -307,13 +323,21 @@ public

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

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770169936 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvBulkWriter.java ## @@ -0,0 +1,89 @@ +/* + * Licensed to the Apache

[jira] [Created] (FLINK-25334) Manage and share gateways of taskmanagers between jobs in session cluster

Shammon created FLINK-25334: --- Summary: Manage and share gateways of taskmanagers between jobs in session cluster Key: FLINK-25334 URL: https://issues.apache.org/jira/browse/FLINK-25334 Project: Flink

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

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770169936 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvBulkWriter.java ## @@ -0,0 +1,89 @@ +/* + * Licensed to the Apache

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

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770164551 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

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

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770164551 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

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

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770164551 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatITCase.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the

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

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770161770 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvSerDeSchemaFactory.java ## @@ -0,0 +1,192 @@ +/* + * Licensed to

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

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770161770 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvSerDeSchemaFactory.java ## @@ -0,0 +1,192 @@ +/* + * Licensed to

[GitHub] [flink-web] izzyacademy commented on pull request #489: Add 1.11.6/1.12.7/1.13.5/1.14.2 releases

izzyacademy commented on pull request #489: URL: https://github.com/apache/flink-web/pull/489#issuecomment-995359226 Looks great. Thanks for the effort in making this happen on short notice. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] wenlong88 commented on a change in pull request #17938: [FLINK-25073][streaming] Introduce TreeMode description for vertices

wenlong88 commented on a change in pull request #17938: URL: https://github.com/apache/flink/pull/17938#discussion_r770160161 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/overview/detail/job-overview-drawer-detail.component.ts ## @@ -39,6 +40,12 @@ export

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

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770157114 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatFactory.java ## @@ -125,128 +70,88 @@ public String

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

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770157114 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatFactory.java ## @@ -125,128 +70,88 @@ public String

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

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

[jira] [Updated] (FLINK-25222) Remove NetworkFailureProxy used for Kafka connector tests

[ https://issues.apache.org/jira/browse/FLINK-25222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25222: - Fix Version/s: 1.14.3 (was: 1.14.2) > Remove NetworkFailureProxy

[GitHub] [flink] flinkbot edited a comment on pull request #18044: [FLINK-25215][table] ISODOW, ISOYEAR fail and DECADE gives wrong result for timestamps with timezones

flinkbot edited a comment on pull request #18044: URL: https://github.com/apache/flink/pull/18044#issuecomment-987951721 ## CI report: * 5724a6b4e5c9f7706fa0f27ba05fe95aa34df198 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18044: [FLINK-25215][table] ISODOW, ISOYEAR fail and DECADE gives wrong result for timestamps with timezones

flinkbot edited a comment on pull request #18044: URL: https://github.com/apache/flink/pull/18044#issuecomment-987951721 ## CI report: * 5724a6b4e5c9f7706fa0f27ba05fe95aa34df198 Azure:

[GitHub] [flink] snuyanzin commented on pull request #18044: [FLINK-25215][table] ISODOW, ISOYEAR fail and DECADE gives wrong result for timestamps with timezones

snuyanzin commented on pull request #18044: URL: https://github.com/apache/flink/pull/18044#issuecomment-995328340 @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] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770140011 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvToRowDataConverters.java ## @@ -305,7 +311,7 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

flinkbot edited a comment on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-989975508 ## CI report: * 6832524d7d78de814cbeadb44fa8037da5c10ca9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

flinkbot edited a comment on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-989975508 ## CI report: * 6832524d7d78de814cbeadb44fa8037da5c10ca9 Azure:

[GitHub] [flink] gaoyunhaii commented on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

gaoyunhaii commented on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-995317842 @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] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770126659 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormat.java ## @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache

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

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r770126659 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormat.java ## @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #18017: [FLINK-25171] Validation of duplicate fields in ddl sql

flinkbot edited a comment on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-986500405 ## CI report: * 2af8ddbbe3fffee2a9673788783ce8cdbe6b985b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18044: [FLINK-25215][table] ISODOW, ISOYEAR fail and DECADE gives wrong result for timestamps with timezones

flinkbot edited a comment on pull request #18044: URL: https://github.com/apache/flink/pull/18044#issuecomment-987951721 ## CI report: * 5724a6b4e5c9f7706fa0f27ba05fe95aa34df198 Azure:

[jira] [Updated] (FLINK-12312) Temporarily disable CLI command for rescaling

[ https://issues.apache.org/jira/browse/FLINK-12312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12312: - Description: Temporarily remove support to rescale job via CLI. See this thread for

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

viirya edited a comment on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-995275934 I got the following compilation error when running `mvn clean install -DskipTests -Dfast`: ``` [ERROR]

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

viirya commented on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-995275934 I got the following compilation error when running `mvn clean install -DskipTests -Dfast`: ``` [ERROR]

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

flinkbot edited a comment on pull request #18115: URL: https://github.com/apache/flink/pull/18115#issuecomment-994592321 ## CI report: * c4b56ec01dd481f9477bd7cfca90b275a8aaa082 Azure:

[jira] [Updated] (FLINK-11818) Provide pipe transformation function for DataSet API

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

[jira] [Updated] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

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

[jira] [Updated] (FLINK-11968) Fix runtime SingleElementIterator.iterator and remove table.SingleElementIterator

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

[jira] [Updated] (FLINK-11934) Remove the deprecate methods in TableEnvironment

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

[jira] [Updated] (FLINK-11909) Provide default failure/timeout/backoff handling strategy for AsyncIO functions

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

[jira] [Updated] (FLINK-11799) KryoSerializer/OperatorChain ignores copy failure resulting in NullPointerException

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

[jira] [Updated] (FLINK-11848) Delete outdated kafka topics caused UNKNOWN_TOPIC_EXCEPTIION

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

[jira] [Updated] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue.

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

[jira] [Updated] (FLINK-11893) Update ecosystem page and add it to the navigation bar

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

[jira] [Updated] (FLINK-12003) Revert the config option about mapreduce.output.basename in HadoopOutputFormatBase

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

[jira] [Updated] (FLINK-11970) TableEnvironment#registerFunction should overwrite if the same name function existed.

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

[jira] [Updated] (FLINK-18366) Track E2E test durations centrally

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

[jira] [Updated] (FLINK-18610) Clean up Table connector docs grammar

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

[jira] [Updated] (FLINK-7193) Update all OVER window ProcessFunction implementations to use SortedQueueState

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

[jira] [Updated] (FLINK-7167) Job can't set checkpoint meta directory to cover the system setting state.checkpoints.dir

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

[jira] [Updated] (FLINK-18540) Unnecessary retract messages when setIdleStateRetentionTime before converting dynamic table to retract stream

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

[jira] [Updated] (FLINK-7217) Give hints about unsupported SQL / Table API features.

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

[jira] [Updated] (FLINK-18409) The FilterJoinRule.FILTER_ON_JOIN optimizer rule cause 'Join With a Temporal Table' not working properly

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

[jira] [Updated] (FLINK-18308) KafkaProducerTestBase->Kafka011ProducerExactlyOnceITCase. testExactlyOnceCustomOperator hangs in Azure

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

[jira] [Updated] (FLINK-18496) Anchors are not generated based on ZH characters

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

[jira] [Updated] (FLINK-18580) Incomplete conversion for MySQL types

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

[GitHub] [flink] flinkbot edited a comment on pull request #18013: [FLINK-24227][connectors/kinesis] Kinesis DataStreams connector using Kinesis async client

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

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

flinkbot edited a comment on pull request #18115: URL: https://github.com/apache/flink/pull/18115#issuecomment-994592321 ## CI report: * be9c303bfc87bb5522259061b713052a3e26451b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18124: [FLINK-24824][coordination] Use CREATED for WaitingForResources/CreatingEG

flinkbot edited a comment on pull request #18124: URL: https://github.com/apache/flink/pull/18124#issuecomment-994923428 ## CI report: * 6b81fbe1ad2e82b889f232b71d90f86163e85e87 Azure:

<    1   2   3   4   5   6   7   8   9   >