[GitHub] [flink] pnowojski commented on a change in pull request #13091: [FLINK-18856][checkpointing] Don't ignore minPauseBetweenCheckpoints

pnowojski commented on a change in pull request #13091: URL: https://github.com/apache/flink/pull/13091#discussion_r467832735 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java ## @@ -55,20 +55,23 @@

[jira] [Created] (FLINK-18872) Aggregate with mini-batch does not respect state retention

Benchao Li created FLINK-18872: -- Summary: Aggregate with mini-batch does not respect state retention Key: FLINK-18872 URL: https://issues.apache.org/jira/browse/FLINK-18872 Project: Flink Issue

[GitHub] [flink] gyfora commented on pull request #13103: [FLINK-18752][yarn] Allow shipping single files for yarn execution

gyfora commented on pull request #13103: URL: https://github.com/apache/flink/pull/13103#issuecomment-671313516 > Thanks for creating this PR @gyfora. The changes look good. The thing which I think should also be addressed is updating the descriptions of the configuration options and the

[GitHub] [flink] flinkbot edited a comment on pull request #13106: [FLINK-18809][table] Update all built-in aggregate functions to the new type system

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

[GitHub] [flink] flinkbot edited a comment on pull request #13099: [FLINK-18848][python] Fix to_pandas to handle retraction data properly

flinkbot edited a comment on pull request #13099: URL: https://github.com/apache/flink/pull/13099#issuecomment-671214264 ## CI report: * fb7db0d2124b3c76ce8f00ca27f734cb879c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13097: [FLINK-18864][python] Support key_by() operation for Python DataStrea…

flinkbot edited a comment on pull request #13097: URL: https://github.com/apache/flink/pull/13097#issuecomment-671146880 ## CI report: * 70d1588a2ca469ef4dd78f41760a7b1be3a91488 Azure:

[jira] [Updated] (FLINK-18849) Improve the code tabs of the Flink documents

[ https://issues.apache.org/jira/browse/FLINK-18849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18849: -- Description: Currently there are some minor problems on the code tabs of the Flink documents: #

[jira] [Updated] (FLINK-17329) Quickstarts Scala nightly e2e test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-17329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17329: Fix Version/s: (was: 1.10.2) 1.10.3 1.11.2 > Quickstarts Scala

[jira] [Commented] (FLINK-17310) Test blink planner failed to generate JobGraph when the checkpoint mode enable

[ https://issues.apache.org/jira/browse/FLINK-17310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174295#comment-17174295 ] Zhu Zhu commented on FLINK-17310: - [~zhanglibing1...@126.com] [~ykt836] is this task still valid? >

[GitHub] [flink] wuchong merged pull request #13100: [hotfix][table-planner-blink] FlinkStreamProgram should not use FlinkBatchRuleSets

wuchong merged pull request #13100: URL: https://github.com/apache/flink/pull/13100 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Updated] (FLINK-17310) Test blink planner failed to generate JobGraph when the checkpoint mode enable

[ https://issues.apache.org/jira/browse/FLINK-17310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17310: Fix Version/s: (was: 1.10.2) > Test blink planner failed to generate JobGraph when the checkpoint

[jira] [Assigned] (FLINK-18795) Support for HBase 2

[ https://issues.apache.org/jira/browse/FLINK-18795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-18795: -- Assignee: Miklos Gergely > Support for HBase 2 > --- > >

[GitHub] [flink] RocMarshal commented on pull request #13088: [FLINK-18814][docs-zh] Translate the 'Side Outputs' page of 'DataStream API' into Chinese

RocMarshal commented on pull request #13088: URL: https://github.com/apache/flink/pull/13088#issuecomment-671338165 LGTM. @klion26 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #13104: [FLINK-18862][table-planner-blink] Fix LISTAGG throws BinaryRawValueData cannot be cast to StringData exception during runtime

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

[GitHub] [flink] flinkbot edited a comment on pull request #13103: [FLINK-18752][yarn] Allow shipping single files for yarn execution

flinkbot edited a comment on pull request #13103: URL: https://github.com/apache/flink/pull/13103#issuecomment-671246733 ## CI report: * 52cd40313ebc6b09f144cd0d93ac07ada370bcc3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13085: [FLINK-18849][docs] Improve the code tabs of the Flink documents.

flinkbot edited a comment on pull request #13085: URL: https://github.com/apache/flink/pull/13085#issuecomment-670497782 ## CI report: * cec71d84d3cfb2a69cbae2ed74fd1612ff95f747 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13101: [FLINK-18867][hive] Generic table stored in Hive catalog is incompati…

flinkbot edited a comment on pull request #13101: URL: https://github.com/apache/flink/pull/13101#issuecomment-671238135 ## CI report: * 0adea4c664e242f5689ee2ec2d16e699a427c83e Azure:

[GitHub] [flink] RocMarshal edited a comment on pull request #13059: [hotfix][docs] Update the links' tags in the 'Debugging Windows & Event Time' page of 'Debugging & Monitoring'

RocMarshal edited a comment on pull request #13059: URL: https://github.com/apache/flink/pull/13059#issuecomment-669234800 Hi, @wuchong . I made a `hotfix`. LGTM. Please take a look. Thank you. This is an

[GitHub] [flink] flinkbot edited a comment on pull request #13097: [FLINK-18864][python] Support key_by() operation for Python DataStrea…

flinkbot edited a comment on pull request #13097: URL: https://github.com/apache/flink/pull/13097#issuecomment-671146880 ## CI report: * 03a8bdd5a1f59e18ea58fafefacddd76c50a09be Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13098: [FLINK-18866][python] Support filter() operation for Python DataStrea…

flinkbot edited a comment on pull request #13098: URL: https://github.com/apache/flink/pull/13098#issuecomment-671163278 ## CI report: * f3d582238a0afb694a4712c247a66cd31fac072b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13085: [FLINK-18849][docs] Improve the code tabs of the Flink documents.

flinkbot edited a comment on pull request #13085: URL: https://github.com/apache/flink/pull/13085#issuecomment-670497782 ## CI report: * c766d6f7449b734976f85691c9bdd9f3f72bf641 UNKNOWN * 2e32aa5a9180f9acabe54baa1be77a0c032f61d0 Azure:

[jira] [Created] (FLINK-18877) Faulty BinarySection.equals()

Timo Walther created FLINK-18877: Summary: Faulty BinarySection.equals() Key: FLINK-18877 URL: https://issues.apache.org/jira/browse/FLINK-18877 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-18644) Remove obsolete doc for hive connector

[ https://issues.apache.org/jira/browse/FLINK-18644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18644: Issue Type: Improvement (was: Task) > Remove obsolete doc for hive connector >

[GitHub] [flink] zentol opened a new pull request #13108: [FLINK-18876][coordination] Move file after stream was closed

zentol opened a new pull request #13108: URL: https://github.com/apache/flink/pull/13108 Small adjustment to the `BlobServer` to not move a file while it has an open `FileInputStream`, so that tests like the `BlobServerPutTest` can succeed on Windows.

[GitHub] [flink] rmetzger commented on pull request #13076: [hotfix] Skip some e2e tests on aarch64

rmetzger commented on pull request #13076: URL: https://github.com/apache/flink/pull/13076#issuecomment-671356801 Yes, I'm merging it now ... This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

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

[GitHub] [flink] liming30 opened a new pull request #13109: [FLINK-18808][runtime/metircs]]Task level numRecordsOut metric increases the output of non-end operators

liming30 opened a new pull request #13109: URL: https://github.com/apache/flink/pull/13109 ## What is the purpose of the change *If an operator has nonChainedOutputs, then its corresponding output should be counted in the task-level numRecordsOut metric.* ## Brief change log

[GitHub] [flink] flinkbot edited a comment on pull request #13101: [FLINK-18867][hive] Generic table stored in Hive catalog is incompati…

flinkbot edited a comment on pull request #13101: URL: https://github.com/apache/flink/pull/13101#issuecomment-671238135 ## CI report: * 0adea4c664e242f5689ee2ec2d16e699a427c83e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13098: [FLINK-18866][python] Support filter() operation for Python DataStrea…

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

[GitHub] [flink] flinkbot edited a comment on pull request #13097: [FLINK-18864][python] Support key_by() operation for Python DataStrea…

flinkbot edited a comment on pull request #13097: URL: https://github.com/apache/flink/pull/13097#issuecomment-671146880 ## CI report: * 70d1588a2ca469ef4dd78f41760a7b1be3a91488 Azure:

[GitHub] [flink] flinkbot commented on pull request #13106: [FLINK-18809][table] Update all built-in aggregate functions to the new type system

flinkbot commented on pull request #13106: URL: https://github.com/apache/flink/pull/13106#issuecomment-671305697 ## CI report: * 7f5f0f8f17767258c2ea4d9897cdb26c4f8b9aaf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13095: [FLINK-18861][python] Support add_source() to get a DataStream for Py…

flinkbot edited a comment on pull request #13095: URL: https://github.com/apache/flink/pull/13095#issuecomment-671073920 ## CI report: * f76786840b2ef177ff8eea018e075370e0505891 Azure:

[jira] [Updated] (FLINK-16246) Exclude "SdkMBeanRegistrySupport" from dynamically loaded AWS connectors

[ https://issues.apache.org/jira/browse/FLINK-16246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16246: Affects Version/s: 1.10.0 > Exclude "SdkMBeanRegistrySupport" from dynamically loaded AWS connectors >

[jira] [Updated] (FLINK-16324) Checkpoint tasks progress would display 100% in web UI even not all tasks finished

[ https://issues.apache.org/jira/browse/FLINK-16324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16324: Fix Version/s: (was: 1.10.2) 1.10.3 1.11.2 > Checkpoint tasks

[jira] [Updated] (FLINK-16612) Submit job through the rest api, job name will be lost

[ https://issues.apache.org/jira/browse/FLINK-16612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16612: Fix Version/s: (was: 1.10.2) 1.10.3 1.11.2 > Submit job through

[GitHub] [flink] flinkbot commented on pull request #13107: [FLINK-18874][python] Support conversion between Table and DataStream.

flinkbot commented on pull request #13107: URL: https://github.com/apache/flink/pull/13107#issuecomment-671335967 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 #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

flinkbot edited a comment on pull request #13089: URL: https://github.com/apache/flink/pull/13089#issuecomment-670624464 ## CI report: * 726ffd0069727a6d8ad080e7eb43ac60702eb462 UNKNOWN * c039163dfbedaacb62cb7957c229f41fb4838d02 Azure:

[GitHub] [flink] zhuzhurk commented on pull request #13105: [FLINK-18859][tests] Increase timeout of ExecutionGraphNotEnoughResourceTest#testRestartWithSlotSharingAndNotEnoughResources to make it more

zhuzhurk commented on pull request #13105: URL: https://github.com/apache/flink/pull/13105#issuecomment-671393594 Thanks for the reviewing @tillrohrmann . Merging. This is an automated message from the Apache Git Service.

[GitHub] [flink] zhuzhurk merged pull request #13105: [FLINK-18859][tests] Increase timeout of ExecutionGraphNotEnoughResourceTest#testRestartWithSlotSharingAndNotEnoughResources to make it more stabl

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

[GitHub] [flink] flinkbot edited a comment on pull request #13109: [FLINK-18808][runtime/metircs]]Task level numRecordsOut metric increases the output of non-end operators

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

[GitHub] [flink] flinkbot edited a comment on pull request #13110: [FLINK-18821][network] Fix indefinite wait in PartitionRequestClientFactory.createPartitionRequestClient - 1.11

flinkbot edited a comment on pull request #13110: URL: https://github.com/apache/flink/pull/13110#issuecomment-671381880 ## CI report: * afc114a64db9d1e5a99e7277fc032109673c6613 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13097: [FLINK-18864][python] Support key_by() operation for Python DataStrea…

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

[GitHub] [flink] flinkbot edited a comment on pull request #13104: [FLINK-18862][table-planner-blink] Fix LISTAGG throws BinaryRawValueData cannot be cast to StringData exception during runtime

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

[GitHub] [flink] flinkbot edited a comment on pull request #13101: [FLINK-18867][hive] Generic table stored in Hive catalog is incompati…

flinkbot edited a comment on pull request #13101: URL: https://github.com/apache/flink/pull/13101#issuecomment-671238135 ## CI report: * 0adea4c664e242f5689ee2ec2d16e699a427c83e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

flinkbot edited a comment on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-666225612 ## CI report: * 30c7fa20d57633b62a3e28ddf4256193e6439ec2 Azure:

[GitHub] [flink] rkhachatryan opened a new pull request #13110: [FLINK-18821][network] Fix indefinite wait in PartitionRequestClientFactory.createPartitionRequestClient - 1.11

rkhachatryan opened a new pull request #13110: URL: https://github.com/apache/flink/pull/13110 ## What is the purpose of the change Fix of FLINK-18821 for FLINK-1.11 release (similar to #13067 for 1.12). Currently, an exception in `PartitionRequestClientFactory` is propagated

[jira] [Updated] (FLINK-18877) Faulty BinarySection.equals()

[ https://issues.apache.org/jira/browse/FLINK-18877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-18877: - Affects Version/s: 1.11.1 > Faulty BinarySection.equals() > - > >

[jira] [Commented] (FLINK-18862) Fix LISTAGG throws BinaryRawValueData cannot be cast to StringData exception in runtime

[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174213#comment-17174213 ] Timo Walther commented on FLINK-18862: -- Yes, this could be a fix for the 1.11 branch. > Fix

[jira] [Commented] (FLINK-15170) WebFrontendITCase.testCancelYarn fails on travis

[ https://issues.apache.org/jira/browse/FLINK-15170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174264#comment-17174264 ] lining commented on FLINK-15170: According to the current message, it can be determined that this is due

[GitHub] [flink] tillrohrmann commented on a change in pull request #13103: [FLINK-18752][yarn] Allow shipping single files for yarn execution

tillrohrmann commented on a change in pull request #13103: URL: https://github.com/apache/flink/pull/13103#discussion_r467794116 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ## @@ -282,11 +282,11 @@ private void

[jira] [Created] (FLINK-18875) DESCRIBE table can return the table properties

Kaibo Zhou created FLINK-18875: -- Summary: DESCRIBE table can return the table properties Key: FLINK-18875 URL: https://issues.apache.org/jira/browse/FLINK-18875 Project: Flink Issue Type:

[jira] [Updated] (FLINK-17742) Blob file not removed after task was cancelled in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-17742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17742: Fix Version/s: (was: 1.10.2) 1.10.3 1.11.2 > Blob file not

[jira] [Commented] (FLINK-18199) Translate "Filesystem SQL Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174312#comment-17174312 ] michaelli commented on FLINK-18199: --- Hi Jark,   Sorry I have some personal issues and is not

[jira] [Updated] (FLINK-18828) Terminate jobmanager process with zero exit code to avoid unexpected restarting by K8s

[ https://issues.apache.org/jira/browse/FLINK-18828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18828: Fix Version/s: (was: 1.10.2) 1.10.3 > Terminate jobmanager process with zero exit

[jira] [Created] (FLINK-18876) BlobServer moves file with an open FileInputStream

Chesnay Schepler created FLINK-18876: Summary: BlobServer moves file with an open FileInputStream Key: FLINK-18876 URL: https://issues.apache.org/jira/browse/FLINK-18876 Project: Flink

[jira] [Updated] (FLINK-18287) Correct the documentation of Python Table API in SQL pages

[ https://issues.apache.org/jira/browse/FLINK-18287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18287: Fix Version/s: (was: 1.10.2) 1.10.3 1.11.2 > Correct the

[GitHub] [flink] twalthr commented on a change in pull request #13104: [FLINK-18862][table-planner-blink] Fix LISTAGG throws BinaryRawValueData cannot be cast to StringData exception during runtime

twalthr commented on a change in pull request #13104: URL: https://github.com/apache/flink/pull/13104#discussion_r467921615 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/AggregateITCase.scala ## @@ -547,6

[GitHub] [flink] RocMarshal edited a comment on pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

RocMarshal edited a comment on pull request #13089: URL: https://github.com/apache/flink/pull/13089#issuecomment-671369763 > @RocMarshal thanks for the contribution, left some comments, please take a look. @klion26 Thank you so much for your review. And I made some changes

[GitHub] [flink] flinkbot edited a comment on pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

flinkbot edited a comment on pull request #13089: URL: https://github.com/apache/flink/pull/13089#issuecomment-670624464 ## CI report: * 5875f7f608fb37a9e6365bbe969c743a5e64bdc8 Azure:

[GitHub] [flink] RocMarshal commented on pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

RocMarshal commented on pull request #13089: URL: https://github.com/apache/flink/pull/13089#issuecomment-671369763 > @RocMarshal thanks for the contribution, left some comments, please take a look. Thank you so much for your review. And I made some changes according to your

[GitHub] [flink] flinkbot edited a comment on pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

flinkbot edited a comment on pull request #13089: URL: https://github.com/apache/flink/pull/13089#issuecomment-670624464 ## CI report: * 5875f7f608fb37a9e6365bbe969c743a5e64bdc8 Azure:

[jira] [Closed] (FLINK-18766) Support add_sink() for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18766. --- Resolution: Resolved > Support add_sink() for Python DataStream API >

[GitHub] [flink] rkhachatryan commented on a change in pull request #13091: [FLINK-18856][checkpointing] Don't ignore minPauseBetweenCheckpoints

rkhachatryan commented on a change in pull request #13091: URL: https://github.com/apache/flink/pull/13091#discussion_r467853626 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java ## @@ -55,20 +55,23 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13085: [FLINK-18849][docs] Improve the code tabs of the Flink documents.

flinkbot edited a comment on pull request #13085: URL: https://github.com/apache/flink/pull/13085#issuecomment-670497782 ## CI report: * cec71d84d3cfb2a69cbae2ed74fd1612ff95f747 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13099: [FLINK-18848][python] Fix to_pandas to handle retraction data properly

flinkbot edited a comment on pull request #13099: URL: https://github.com/apache/flink/pull/13099#issuecomment-671214264 ## CI report: * fb7db0d2124b3c76ce8f00ca27f734cb879c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13098: [FLINK-18866][python] Support filter() operation for Python DataStrea…

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

[jira] [Updated] (FLINK-16218) Chinese character is garbled when reading from MySQL using JDBC source

[ https://issues.apache.org/jira/browse/FLINK-16218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16218: Fix Version/s: (was: 1.10.2) 1.10.3 1.11.2

[jira] [Updated] (FLINK-15801) Timestamp extractor created from properties does not work for some physical fields

[ https://issues.apache.org/jira/browse/FLINK-15801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15801: Fix Version/s: (was: 1.9.4) (was: 1.10.2) 1.10.3

[jira] [Updated] (FLINK-16218) Chinese character is garbled when reading from MySQL using JDBC source

[ https://issues.apache.org/jira/browse/FLINK-16218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16218: Affects Version/s: 1.10.0 > Chinese character is garbled when reading from MySQL using JDBC source >

[jira] [Updated] (FLINK-16246) Exclude "SdkMBeanRegistrySupport" from dynamically loaded AWS connectors

[ https://issues.apache.org/jira/browse/FLINK-16246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16246: Fix Version/s: (was: 1.10.2) 1.10.3 1.11.2 > Exclude

[jira] [Commented] (FLINK-16612) Submit job through the rest api, job name will be lost

[ https://issues.apache.org/jira/browse/FLINK-16612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174307#comment-17174307 ] Zhu Zhu commented on FLINK-16612: - `OptimizerPlanEnvironment` is not used for jobGraph generation

[jira] [Commented] (FLINK-18875) DESCRIBE table can return the table properties

[ https://issues.apache.org/jira/browse/FLINK-18875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174308#comment-17174308 ] Jark Wu commented on FLINK-18875: - We have an issue (FLINK-16384) to support SHOW CREATE TABLE that

[GitHub] [flink] flinkbot commented on pull request #13107: [FLINK-18874][python] Support conversion between Table and DataStream.

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

[GitHub] [flink] flinkbot edited a comment on pull request #13104: [FLINK-18862][table-planner-blink] Fix LISTAGG throws BinaryRawValueData cannot be cast to StringData exception during runtime

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

[GitHub] [flink] flinkbot edited a comment on pull request #13097: [FLINK-18864][python] Support key_by() operation for Python DataStrea…

flinkbot edited a comment on pull request #13097: URL: https://github.com/apache/flink/pull/13097#issuecomment-671146880 ## CI report: * 03a8bdd5a1f59e18ea58fafefacddd76c50a09be Azure:

[GitHub] [flink] flinkbot commented on pull request #13108: [FLINK-18876][coordination] Move file after stream was closed

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

[jira] [Commented] (FLINK-18451) Flink HA on yarn may appear TaskManager double running when HA is restored

[ https://issues.apache.org/jira/browse/FLINK-18451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174355#comment-17174355 ] ming li commented on FLINK-18451: - In this case, we have to wait for a maximum timeout after the

[GitHub] [flink] twalthr opened a new pull request #13106: [FLINK-18809][table] Update all built-in aggregate functions to the new type system

twalthr opened a new pull request #13106: URL: https://github.com/apache/flink/pull/13106 ## What is the purpose of the change Updates all built-in aggregate functions to the new type system. The functions extend from `InternalAggregateFunction` for easier translation but can also

[jira] [Updated] (FLINK-18809) Update internal aggregate functions to new type system

[ https://issues.apache.org/jira/browse/FLINK-18809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18809: --- Labels: pull-request-available (was: ) > Update internal aggregate functions to new type

[jira] [Created] (FLINK-18873) Make the WatermarkStrategy API more scala friendly

Dawid Wysakowicz created FLINK-18873: Summary: Make the WatermarkStrategy API more scala friendly Key: FLINK-18873 URL: https://issues.apache.org/jira/browse/FLINK-18873 Project: Flink

[jira] [Updated] (FLINK-16622) Type ARRAY of table field 'id' does not match with the physical type LEGACY('ARRAY', 'ANY<[Ljava.lang.String;, rO0ABXNyAD......>') of the 'id' field of the Table

[ https://issues.apache.org/jira/browse/FLINK-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16622: Fix Version/s: (was: 1.10.2) 1.10.3 1.12.0 > Type ARRAY of

[jira] [Updated] (FLINK-17310) Test blink planner failed to generate JobGraph when the checkpoint mode enable

[ https://issues.apache.org/jira/browse/FLINK-17310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17310: Fix Version/s: 1.10.3 > Test blink planner failed to generate JobGraph when the checkpoint mode enable >

[jira] [Updated] (FLINK-16585) Table program cannot be compiled.Cannot determine simple type name "com"

[ https://issues.apache.org/jira/browse/FLINK-16585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16585: Fix Version/s: (was: 1.10.2) 1.10.3 1.11.2

[jira] [Updated] (FLINK-17405) add test cases for cancel job in SQL client

[ https://issues.apache.org/jira/browse/FLINK-17405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17405: Fix Version/s: (was: 1.10.2) 1.10.3 1.11.2 > add test cases for

[GitHub] [flink] lirui-apache commented on pull request #13101: [FLINK-18867][hive] Generic table stored in Hive catalog is incompati…

lirui-apache commented on pull request #13101: URL: https://github.com/apache/flink/pull/13101#issuecomment-671340176 @JingsongLi Please take a look. This is an automated message from the Apache Git Service. To respond to

[jira] [Updated] (FLINK-17677) FLINK_LOG_PREFIX recommended in docs is not always available

[ https://issues.apache.org/jira/browse/FLINK-17677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17677: Fix Version/s: (was: 1.9.4) (was: 1.10.2) 1.10.3

[GitHub] [flink] RocMarshal edited a comment on pull request #13059: [hotfix][docs] Update the links' tags in the 'Debugging Windows & Event Time' page of 'Debugging & Monitoring'

RocMarshal edited a comment on pull request #13059: URL: https://github.com/apache/flink/pull/13059#issuecomment-669234800 Hi, @wuchong . I made a `hotfix`. Please take a look. Thank you. This is an automated message

[GitHub] [flink] flinkbot commented on pull request #13110: [FLINK-18821][network] Fix indefinite wait in PartitionRequestClientFactory.createPartitionRequestClient - 1.11

flinkbot commented on pull request #13110: URL: https://github.com/apache/flink/pull/13110#issuecomment-671368082 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 #13109: [FLINK-18808][runtime/metircs]]Task level numRecordsOut metric increases the output of non-end operators

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

[jira] [Updated] (FLINK-15849) Update SQL-CLIENT document from type to data-type

[ https://issues.apache.org/jira/browse/FLINK-15849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15849: Issue Type: Bug (was: Task) > Update SQL-CLIENT document from type to data-type >

[jira] [Updated] (FLINK-18766) Support add_sink() for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18766: Fix Version/s: 1.12.0 > Support add_sink() for Python DataStream API >

[GitHub] [flink] hequn8128 merged pull request #13094: [FLINK-18766][python] Support add_sink() for Python DataStream API.

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

[jira] [Commented] (FLINK-18766) Support add_sink() for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174240#comment-17174240 ] Hequn Cheng commented on FLINK-18766: - Resolved in 1.12.0 via 

[GitHub] [flink] flinkbot edited a comment on pull request #13097: [FLINK-18864][python] Support key_by() operation for Python DataStrea…

flinkbot edited a comment on pull request #13097: URL: https://github.com/apache/flink/pull/13097#issuecomment-671146880 ## CI report: * 70d1588a2ca469ef4dd78f41760a7b1be3a91488 Azure:

[GitHub] [flink] flinkbot commented on pull request #13106: [FLINK-18809][table] Update all built-in aggregate functions to the new type system

flinkbot commented on pull request #13106: URL: https://github.com/apache/flink/pull/13106#issuecomment-671297439 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 #13095: [FLINK-18861][python] Support add_source() to get a DataStream for Py…

flinkbot edited a comment on pull request #13095: URL: https://github.com/apache/flink/pull/13095#issuecomment-671073920 ## CI report: * f76786840b2ef177ff8eea018e075370e0505891 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13085: [FLINK-18849][docs] Improve the code tabs of the Flink documents.

flinkbot edited a comment on pull request #13085: URL: https://github.com/apache/flink/pull/13085#issuecomment-670497782 ## CI report: * cec71d84d3cfb2a69cbae2ed74fd1612ff95f747 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

flinkbot edited a comment on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-666225612 ## CI report: * 30c7fa20d57633b62a3e28ddf4256193e6439ec2 Azure:

[jira] [Created] (FLINK-18874) Support conversion between Table and DataStream

Shuiqiang Chen created FLINK-18874: -- Summary: Support conversion between Table and DataStream Key: FLINK-18874 URL: https://issues.apache.org/jira/browse/FLINK-18874 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #13098: [FLINK-18866][python] Support filter() operation for Python DataStrea…

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

  1   2   3   4   5   >