[jira] [Created] (FLINK-22254) Only trigger scale up if the resources have stabilized

Till Rohrmann created FLINK-22254: - Summary: Only trigger scale up if the resources have stabilized Key: FLINK-22254 URL: https://issues.apache.org/jira/browse/FLINK-22254 Project: Flink

[jira] [Commented] (FLINK-22134) Test the reactive mode

[ https://issues.apache.org/jira/browse/FLINK-22134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320042#comment-17320042 ] Till Rohrmann commented on FLINK-22134: --- Thanks for testing this feature [~xintongsong]. Your

[GitHub] [flink] flinkbot edited a comment on pull request #15589: [Flink-22248][Flink-22249] Harden JobMasterStopWithSavepointITCase

flinkbot edited a comment on pull request #15589: URL: https://github.com/apache/flink/pull/15589#issuecomment-818562022 ## CI report: * 4d61173cf9c5f289b002e13efb8c1bdd98d249a3 Azure:

[GitHub] [flink] flinkbot commented on pull request #15591: [FLINK-22124][python] Fix the bug that errors are not thrown in custom python function

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

[GitHub] [flink] flinkbot edited a comment on pull request #15578: [FLINK-21431][upsert-kafka] Use testcontainers for KafkaTable ITCase

flinkbot edited a comment on pull request #15578: URL: https://github.com/apache/flink/pull/15578#issuecomment-817840111 ## CI report: * e35e401c6997227d6d491326b31f5109caf93760 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15567: [FLINK-22215][runtime] RECOVERING state is renamed to RESTORING

flinkbot edited a comment on pull request #15567: URL: https://github.com/apache/flink/pull/15567#issuecomment-817660891 ## CI report: * 573fe974264e4f54056f4c794e74ea59f7a95f77 Azure:

[GitHub] [flink] flinkbot commented on pull request #15590: [FLINK-22124][python] Fix the bug that errors are not thrown in custom python function

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

[GitHub] [flink] flinkbot edited a comment on pull request #15559: [FLINK-21627][table-planner-blink] The digest of TableScan & Sink should consider table hints

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

[GitHub] [flink] flinkbot edited a comment on pull request #15581: [Hotfix][python] Fix variable typo.

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

[GitHub] [flink] flinkbot edited a comment on pull request #15543: [FLINK-17803][table] Should throw a readable exception when group by Map type

flinkbot edited a comment on pull request #15543: URL: https://github.com/apache/flink/pull/15543#issuecomment-816526178 ## CI report: * bd8ebbcaf2c9c2d018cdfe63e84687c99f207399 Azure:

[GitHub] [flink] curcur commented on pull request #15584: [FLINK-21743] Document limitation of JdbcXaSinkFunction for MySQL support

curcur commented on pull request #15584: URL: https://github.com/apache/flink/pull/15584#issuecomment-818575236 > Could you please also update docs in `content.zh`? yes, I should! Thanks for reminding. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[jira] [Comment Edited] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist in current row schema

[ https://issues.apache.org/jira/browse/FLINK-22196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320039#comment-17320039 ] Lsw_aka_laplace edited comment on FLINK-22196 at 4/13/21, 9:00 AM: ---

[jira] [Commented] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist in current row schema

[ https://issues.apache.org/jira/browse/FLINK-22196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320039#comment-17320039 ] Lsw_aka_laplace commented on FLINK-22196: - This issue have been fixed by 

[jira] [Resolved] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist in current row schema

[ https://issues.apache.org/jira/browse/FLINK-22196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace resolved FLINK-22196. - Resolution: Fixed > FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the

[jira] [Updated] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist in current row schema

[ https://issues.apache.org/jira/browse/FLINK-22196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-22196: Fix Version/s: 1.13.0 > FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the

[GitHub] [flink] flinkbot edited a comment on pull request #13011: [FLINK-16384][table sql/client] Support SHOW CREATE TABLE statement

flinkbot edited a comment on pull request #13011: URL: https://github.com/apache/flink/pull/13011#issuecomment-665419965 ## CI report: * 89596653e0ca12f6c0272770a2341b63f60af633 Azure:

[jira] [Commented] (FLINK-8531) Support separation of "Exclusive", "Shared" and "Task owned" state

[ https://issues.apache.org/jira/browse/FLINK-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320035#comment-17320035 ] fanrui commented on FLINK-8531: --- [~sewen] For some high-parallel Flink tasks, when hdfs Namenode is under

[GitHub] [flink] flinkbot commented on pull request #15591: [FLINK-22124][python] Fix the bug that errors are not thrown in custom python function

flinkbot commented on pull request #15591: URL: https://github.com/apache/flink/pull/15591#issuecomment-818569506 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-web] tillrohrmann commented on a change in pull request #427: Add reactive mode blog post

tillrohrmann commented on a change in pull request #427: URL: https://github.com/apache/flink-web/pull/427#discussion_r612258141 ## File path: _posts/2021-04-05-reactive-mode.md ## @@ -0,0 +1,149 @@ +--- +layout: post +title: "Scaling Flink automatically with Reactive Mode"

[GitHub] [flink] HuangXingBo opened a new pull request #15591: [FLINK-22124][python] Fix the bug that errors are not thrown in custom python function

HuangXingBo opened a new pull request #15591: URL: https://github.com/apache/flink/pull/15591 ## What is the purpose of the change *This pull request will fix the bug that errors are not thrown in custom python function* ## Brief change log - *Change the

[GitHub] [flink] StephanEwen commented on pull request #15438: [FLINK-22000] Set a default character set in InputStreamReader to sol…

StephanEwen commented on pull request #15438: URL: https://github.com/apache/flink/pull/15438#issuecomment-818566333 Could you update it in the remaining places as well? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] wuchong edited a comment on pull request #15580: [FLINK-22245][sql-client] Reuse PrintUtils.MAX_COLUMN_WIDTH in CliCha…

wuchong edited a comment on pull request #15580: URL: https://github.com/apache/flink/pull/15580#issuecomment-818565807 Could we add a test in `select.q`? I think this is very easy by adding a `timestamp(9)` column and print tableau result in streaming mode. -- This is an automated

[GitHub] [flink] zuston edited a comment on pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston edited a comment on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-818561960 @XComp Thanks for your reply > I'm still not comfortable with this change considering that it's not tested. Have you had the chance to check whether it works? Could

[GitHub] [flink] wuchong commented on pull request #15580: [FLINK-22245][sql-client] Reuse PrintUtils.MAX_COLUMN_WIDTH in CliCha…

wuchong commented on pull request #15580: URL: https://github.com/apache/flink/pull/15580#issuecomment-818565807 Could we add a test in `select.q`? I think this is very easy by adding a `timestamp(9)` type and print tableau result in streaming mode. -- This is an automated message from

[GitHub] [flink] flinkbot commented on pull request #15590: [FLINK-22124][python] Fix the bug that errors are not thrown in custom python function

flinkbot commented on pull request #15590: URL: https://github.com/apache/flink/pull/15590#issuecomment-818564299 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 #15589: [Flink-22248][Flink-22249] Harden JobMasterStopWithSavepointITCase

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

[GitHub] [flink] flinkbot edited a comment on pull request #15586: [FLINK-21992][network] Fix availability notification in UnionInputGate.

flinkbot edited a comment on pull request #15586: URL: https://github.com/apache/flink/pull/15586#issuecomment-818534703 ## CI report: * 20b72d2a0489adc3e70cecd59e5dbf4acc95ab24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15578: [FLINK-21431][upsert-kafka] Use testcontainers for KafkaTable ITCase

flinkbot edited a comment on pull request #15578: URL: https://github.com/apache/flink/pull/15578#issuecomment-817840111 ## CI report: * e35e401c6997227d6d491326b31f5109caf93760 Azure:

[jira] [Updated] (FLINK-22124) The job finished without any exception if error was thrown during state access

[ https://issues.apache.org/jira/browse/FLINK-22124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22124: --- Labels: pull-request-available (was: ) > The job finished without any exception if error

[GitHub] [flink] flinkbot edited a comment on pull request #15587: [FLINK-21992][network] Fix availability notification in UnionInputGate. [1.12]

flinkbot edited a comment on pull request #15587: URL: https://github.com/apache/flink/pull/15587#issuecomment-818534854 ## CI report: * 115396e1e4fdcee63985236765099b138e0903dc Azure:

[GitHub] [flink] zuston commented on pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston commented on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-818561960 @XComp Thanks for your reply > I'm still not comfortable with this change considering that it's not tested. Have you had the chance to check whether it works? Could you

[GitHub] [flink] flinkbot edited a comment on pull request #15588: [FLINK-20613][table] Update TableResult.collect() to the new type system

flinkbot edited a comment on pull request #15588: URL: https://github.com/apache/flink/pull/15588#issuecomment-818534989 ## CI report: * 78fcbcf1e843bafad1355d779afbe34dc3d2ac5d Azure:

[GitHub] [flink] HuangXingBo opened a new pull request #15590: [FLINK-22124][python] Fix the bug that errors are not thrown in custom python function

HuangXingBo opened a new pull request #15590: URL: https://github.com/apache/flink/pull/15590 ## What is the purpose of the change *This pull request will fix the bug that errors are not thrown in custom python function* ## Brief change log - *Change the

[GitHub] [flink] flinkbot edited a comment on pull request #15559: [FLINK-21627][table-planner-blink] The digest of TableScan & Sink should consider table hints

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

[GitHub] [flink] flinkbot edited a comment on pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

flinkbot edited a comment on pull request #15564: URL: https://github.com/apache/flink/pull/15564#issuecomment-817625124 ## CI report: * a55cd0203bfb07c5cbc4f2b06e2704ba9ec31466 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15543: [FLINK-17803][table] Should throw a readable exception when group by Map type

flinkbot edited a comment on pull request #15543: URL: https://github.com/apache/flink/pull/15543#issuecomment-816526178 ## CI report: * bd8ebbcaf2c9c2d018cdfe63e84687c99f207399 Azure:

[jira] [Updated] (FLINK-22253) Update backpressure monitoring documentation

[ https://issues.apache.org/jira/browse/FLINK-22253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22253: - Fix Version/s: 1.13.0 > Update backpressure monitoring documentation >

[jira] [Updated] (FLINK-22253) Update backpressure monitoring documentation

[ https://issues.apache.org/jira/browse/FLINK-22253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22253: - Priority: Critical (was: Major) > Update backpressure monitoring documentation >

[jira] [Updated] (FLINK-20863) Exclude network memory from ResourceProfile

[ https://issues.apache.org/jira/browse/FLINK-20863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20863: -- Component/s: Runtime / Coordination > Exclude network memory from ResourceProfile >

[GitHub] [flink] PxPt commented on pull request #15521: [hotfix] Fix the release version for JdbcXaSinkFunction

PxPt commented on pull request #15521: URL: https://github.com/apache/flink/pull/15521#issuecomment-818551994 Good -- 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. For

[GitHub] [flink] est08zw closed pull request #15399: [hotfix] add coordinatorState into hashCode() to comply with equals().

est08zw closed pull request #15399: URL: https://github.com/apache/flink/pull/15399 -- 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. For queries about this service,

[jira] [Created] (FLINK-22253) Update backpressure monitoring documentation

Dawid Wysakowicz created FLINK-22253: Summary: Update backpressure monitoring documentation Key: FLINK-22253 URL: https://issues.apache.org/jira/browse/FLINK-22253 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13011: [FLINK-16384][table sql/client] Support SHOW CREATE TABLE statement

flinkbot edited a comment on pull request #13011: URL: https://github.com/apache/flink/pull/13011#issuecomment-665419965 ## CI report: * 89596653e0ca12f6c0272770a2341b63f60af633 Azure:

[jira] [Commented] (FLINK-22122) StreamingKafkaITCase Fail due to TestTimedOutException

[ https://issues.apache.org/jira/browse/FLINK-22122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320021#comment-17320021 ] Dawid Wysakowicz commented on FLINK-22122: --

[GitHub] [flink] rkhachatryan commented on pull request #15584: [FLINK-21743] Document limitation of JdbcXaSinkFunction for MySQL support

rkhachatryan commented on pull request #15584: URL: https://github.com/apache/flink/pull/15584#issuecomment-818543731 Could you please also update docs in `content.zh`? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-21556) StreamingKafkaITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-21556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320019#comment-17320019 ] Dawid Wysakowicz commented on FLINK-21556: --

[jira] [Commented] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320017#comment-17320017 ] hayden zhou commented on FLINK-22047: - the amount of jobs a cluster can submit is almost 70, if

[GitHub] [flink] leonardBang commented on pull request #15578: [FLINK-21431][upsert-kafka] Use testcontainers for KafkaTable ITCase

leonardBang commented on pull request #15578: URL: https://github.com/apache/flink/pull/15578#issuecomment-818537080 > Could you also update `KafkaTableITCase`, `KafkaChangelogTableITCase` to use testcontainers? IIUC, they may also have the problem. Although `KafkaTableITCase`,

[GitHub] [flink] hameizi commented on a change in pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

hameizi commented on a change in pull request #15564: URL: https://github.com/apache/flink/pull/15564#discussion_r612180011 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalogTest.java ## @@ -78,4 +80,17 @@ public

[GitHub] [flink] flinkbot commented on pull request #15588: [FLINK-20613][table] Update TableResult.collect() to the new type system

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

[GitHub] [flink] flinkbot commented on pull request #15587: [FLINK-21992][network] Fix availability notification in UnionInputGate. [1.12]

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

[GitHub] [flink] flinkbot edited a comment on pull request #15580: [FLINK-22245][sql-client] Reuse PrintUtils.MAX_COLUMN_WIDTH in CliCha…

flinkbot edited a comment on pull request #15580: URL: https://github.com/apache/flink/pull/15580#issuecomment-818409161 ## CI report: * a5613bd98763175b59d5d2a3ecbf8a1cb047299a Azure:

[GitHub] [flink] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r612220526 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -1079,15 +1091,24 @@ private ApplicationReport

[GitHub] [flink] flinkbot edited a comment on pull request #15585: [FLINK-22065] [sql-client]Beautify the parse error exception

flinkbot edited a comment on pull request #15585: URL: https://github.com/apache/flink/pull/15585#issuecomment-818496243 ## CI report: * 43ba5f79a68e74db6f5eb14733ec99c3329cc439 UNKNOWN * 10c7cb76e1d0541956a669c4a6b7fb75e76e8f36 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15568: [FLINK-17371][table-runtime] Add cases for decimal casting

flinkbot edited a comment on pull request #15568: URL: https://github.com/apache/flink/pull/15568#issuecomment-817675780 ## CI report: * f2eb5ba61975ecaa45a40c8ac18c0537e2cc9912 Azure:

[GitHub] [flink] flinkbot commented on pull request #15586: [FLINK-21992][network] Fix availability notification in UnionInputGate.

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

[jira] [Closed] (FLINK-22082) Nested projection push down doesn't work for data such as row(array(row))

[ https://issues.apache.org/jira/browse/FLINK-22082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22082. -- Resolution: Fixed > Nested projection push down doesn't work for data such as row(array(row)) >

[jira] [Comment Edited] (FLINK-22082) Nested projection push down doesn't work for data such as row(array(row))

[ https://issues.apache.org/jira/browse/FLINK-22082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319842#comment-17319842 ] godfrey he edited comment on FLINK-22082 at 4/13/21, 8:03 AM: -- Fixed in

[GitHub] [flink] godfreyhe closed pull request #15548: [FLINK-22082][planner] Nested projection push down doesn't work for d…

godfreyhe closed pull request #15548: URL: https://github.com/apache/flink/pull/15548 -- 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. For queries about this service,

[jira] [Updated] (FLINK-19988) Make Approximate Local Recovery Compatible With Unaligned Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-19988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-19988: --- Fix Version/s: (was: 1.13.0) > Make Approximate Local Recovery Compatible With

[jira] [Updated] (FLINK-20672) notifyCheckpointAborted RPC failure can fail JM

[ https://issues.apache.org/jira/browse/FLINK-20672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-20672: --- Fix Version/s: (was: 1.13.0) > notifyCheckpointAborted RPC failure can fail JM >

[GitHub] [flink] flinkbot commented on pull request #15589: [Flink-22248][Flink-22249] Harden JobMasterStopWithSavepointITCase

flinkbot commented on pull request #15589: URL: https://github.com/apache/flink/pull/15589#issuecomment-818531509 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] [Commented] (FLINK-21839) SinkFunction snapshotState don't snapshot all data when trigger a stop-with-drain savepoint

[ https://issues.apache.org/jira/browse/FLINK-21839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320007#comment-17320007 ] Yuan Mei commented on FLINK-21839: -- Hey [~lintingbin], that's exactly what I explained above, source

[GitHub] [flink] flinkbot edited a comment on pull request #13011: [FLINK-16384][table sql/client] Support SHOW CREATE TABLE statement

flinkbot edited a comment on pull request #13011: URL: https://github.com/apache/flink/pull/13011#issuecomment-665419965 ## CI report: * 89596653e0ca12f6c0272770a2341b63f60af633 Azure:

[jira] [Updated] (FLINK-21124) notifyCheckpointAborted RPC can be ignored in some cases

[ https://issues.apache.org/jira/browse/FLINK-21124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-21124: --- Fix Version/s: (was: 1.13.0) > notifyCheckpointAborted RPC can be ignored in some cases

[jira] [Updated] (FLINK-21015) Wait for checkpoint cleanup completion during shutdown

[ https://issues.apache.org/jira/browse/FLINK-21015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-21015: --- Fix Version/s: (was: 1.13.0) > Wait for checkpoint cleanup completion during shutdown >

[GitHub] [flink] dawidwys opened a new pull request #15589: [Flink-22248][Flink-22249] Harden JobMasterStopWithSavepointITCase

dawidwys opened a new pull request #15589: URL: https://github.com/apache/flink/pull/15589 ## What is the purpose of the change Harden the JobMasterStopWithSavepointITCase ## Brief change log - Increased timeouts (I run tests 10k times locally and they always pass)

[GitHub] [flink] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r612215610 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -529,6 +530,17 @@ public void killCluster(ApplicationId

[jira] [Updated] (FLINK-21131) Show alignment timeout in checkpoint configuration (web UI)

[ https://issues.apache.org/jira/browse/FLINK-21131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-21131: --- Fix Version/s: (was: 1.13.0) > Show alignment timeout in checkpoint configuration (web

[jira] [Commented] (FLINK-21376) Failed state might not provide failureCause

[ https://issues.apache.org/jira/browse/FLINK-21376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320004#comment-17320004 ] Johannes Moser commented on FLINK-21376: Removed the fix version for now, as this might not go

[GitHub] [flink] flinkbot commented on pull request #15588: [FLINK-20613][table] Update TableResult.collect() to the new type system

flinkbot commented on pull request #15588: URL: https://github.com/apache/flink/pull/15588#issuecomment-818528736 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-21376) Failed state might not provide failureCause

[ https://issues.apache.org/jira/browse/FLINK-21376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-21376: --- Fix Version/s: (was: 1.13.0) > Failed state might not provide failureCause >

[jira] [Updated] (FLINK-20613) Update TableResult.collect()/TableResult.print() to the new type system

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

[jira] [Assigned] (FLINK-22197) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException

[ https://issues.apache.org/jira/browse/FLINK-22197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-22197: - Assignee: Roman Khachatryan >

[jira] [Commented] (FLINK-21839) SinkFunction snapshotState don't snapshot all data when trigger a stop-with-drain savepoint

[ https://issues.apache.org/jira/browse/FLINK-21839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320003#comment-17320003 ] Darcy Lin commented on FLINK-21839: --- Hi [~ym], I think this problem has nothing to do with source. My

[GitHub] [flink] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r612213453 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java ## @@ -197,21 +197,31 @@ private static LocalResource registerLocalResource(

[GitHub] [flink] twalthr opened a new pull request #15588: [FLINK-20613][table] Update TableResult.collect() to the new type system

twalthr opened a new pull request #15588: URL: https://github.com/apache/flink/pull/15588 ## What is the purpose of the change This updates `TableResult.collect()` to the new type system and thus reduces type incompatibilities. It is now possible to fully stream all records either

[GitHub] [flink] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r612211361 ## File path: flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java ## @@ -108,6 +108,19 @@ +

[GitHub] [flink] LadyForest commented on a change in pull request #13011: [FLINK-16384][table sql/client] Support SHOW CREATE TABLE statement

LadyForest commented on a change in pull request #13011: URL: https://github.com/apache/flink/pull/13011#discussion_r611443796 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java ## @@ -1095,6 +1109,75 @@

[GitHub] [flink] godfreyhe commented on pull request #15525: [FLINK-22154][table-planner-blink] Fix bug where PushFilterIntoTableSourceScanRule fails to deal with IN expressions

godfreyhe commented on pull request #15525: URL: https://github.com/apache/flink/pull/15525#issuecomment-818523964 @TsReaper please resolve the conflicts and fix PushFilterInCalcIntoTableSourceRule too -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-21992) Fix availability notification in UnionInputGate

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320001#comment-17320001 ] Dawid Wysakowicz commented on FLINK-21992: -- Do we target that for 1.13? > Fix availability

[GitHub] [flink] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r612209147 ## File path: flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java ## @@ -108,6 +108,19 @@ +

[GitHub] [flink] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r612209147 ## File path: flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java ## @@ -108,6 +108,19 @@ +

[jira] [Updated] (FLINK-21675) predicates can not be pushed into TableScan when there is a WatermarkAssigner between Filter and Scan

[ https://issues.apache.org/jira/browse/FLINK-21675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-21675: --- Summary: predicates can not be pushed into TableScan when there is a WatermarkAssigner between

[jira] [Assigned] (FLINK-21675) Push filter into the scan when watermark assigner is the parent of the table scan

[ https://issues.apache.org/jira/browse/FLINK-21675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21675: -- Assignee: Yuval Itzchakov > Push filter into the scan when watermark assigner is the parent

[jira] [Closed] (FLINK-21675) Push filter into the scan when watermark assigner is the parent of the table scan

[ https://issues.apache.org/jira/browse/FLINK-21675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21675. -- Resolution: Fixed Fixed in 1.13.0: 449048e2d8127380ba1327d05d0832faaf300c52 > Push filter into the

[GitHub] [flink] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r612209147 ## File path: flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java ## @@ -108,6 +108,19 @@ +

[jira] [Assigned] (FLINK-21992) Fix availability notification in UnionInputGate

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21992: --- Assignee: Arvid Heise (was: Piotr Nowojski) > Fix availability notification in

[jira] [Updated] (FLINK-21675) Push filter into the scan when watermark assigner is the parent of the table scan

[ https://issues.apache.org/jira/browse/FLINK-21675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-21675: --- Fix Version/s: 1.13.0 > Push filter into the scan when watermark assigner is the parent of the

[GitHub] [flink] godfreyhe closed pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

godfreyhe closed pull request #15307: URL: https://github.com/apache/flink/pull/15307 -- 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. For queries about this service,

[GitHub] [flink] flinkbot commented on pull request #15587: [FLINK-21992][network] Fix availability notification in UnionInputGate. [1.12]

flinkbot commented on pull request #15587: URL: https://github.com/apache/flink/pull/15587#issuecomment-818521817 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 #15586: [FLINK-21992][network] Fix availability notification in UnionInputGate.

flinkbot commented on pull request #15586: URL: https://github.com/apache/flink/pull/15586#issuecomment-818520462 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] [Commented] (FLINK-22173) UnalignedCheckpointRescaleITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319992#comment-17319992 ] Arvid Heise commented on FLINK-22173: - I'm expecting some connection to FLINK-21992. >

[GitHub] [flink] AHeise opened a new pull request #15587: [FLINK-21992][network] Fix availability notification in UnionInputGate. [1.12]

AHeise opened a new pull request #15587: URL: https://github.com/apache/flink/pull/15587 Unchanged backport of #15586. ## What is the purpose of the change The available notification of UnionInputGate is reset when the last gate with data is read independent of how

[GitHub] [flink] flinkbot edited a comment on pull request #15585: [FLINK-22065] [sql-client]Beautify the parse error exception

flinkbot edited a comment on pull request #15585: URL: https://github.com/apache/flink/pull/15585#issuecomment-818496243 ## CI report: * 43ba5f79a68e74db6f5eb14733ec99c3329cc439 UNKNOWN * 10c7cb76e1d0541956a669c4a6b7fb75e76e8f36 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #15583: [FLINK-21012][format-avro] Replace lambda with anonymous class to prevent serialization issue

flinkbot edited a comment on pull request #15583: URL: https://github.com/apache/flink/pull/15583#issuecomment-818496019 ## CI report: * 4f65676901b2b7cfb2acf95fa8effe4a182748d1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15584: [FLINK-21743] Document limitation of JdbcXaSinkFunction for MySQL support

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

[GitHub] [flink] flinkbot edited a comment on pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

flinkbot edited a comment on pull request #15564: URL: https://github.com/apache/flink/pull/15564#issuecomment-817625124 ## CI report: * 48a157f0bde64007467f0f9b683d75d5eaa71f64 Azure:

<    1   2   3   4   5   6   >