[GitHub] [flink] flinkbot edited a comment on pull request #14672: [FLINK-20998][docs] - flink-raw.jar no longer mentioned + prettier maven xml dependencies

flinkbot edited a comment on pull request #14672: URL: https://github.com/apache/flink/pull/14672#issuecomment-761593893 ## CI report: * 50f142696f4553e0bf7742ef4b46be78f57461d6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20919) After the flink batch job is completed, the yarn application cannot be completed.

[ https://issues.apache.org/jira/browse/FLINK-20919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266711#comment-17266711 ] Wu commented on FLINK-20919: Thanks for your response [~trohrmann], [~twalthr]. I have anoth

[GitHub] [flink] flinkbot edited a comment on pull request #14672: [FLINK-20998][docs] - flink-raw.jar no longer mentioned + prettier maven xml dependencies

flinkbot edited a comment on pull request #14672: URL: https://github.com/apache/flink/pull/14672#issuecomment-761593893 ## CI report: * c1ae8b92b6a0bec992e149b45b3ae6a58ffa92fe Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * 4a0e89bfae261aa2fbbb3aa37bc6980093a16259 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Created] (FLINK-21001) Flink job is blocked while using tableEnvironment with tableFunction and join

Wu created FLINK-21001: -- Summary: Flink job is blocked while using tableEnvironment with tableFunction and join Key: FLINK-21001 URL: https://issues.apache.org/jira/browse/FLINK-21001 Project: Flink Is

[GitHub] [flink] yuruguo commented on pull request #14603: [FLINK-20914][core] Format the description of 'security.ssl.internal.session-cache-size' option

yuruguo commented on pull request #14603: URL: https://github.com/apache/flink/pull/14603#issuecomment-761744908 Hi @rmetzger, please review the code, thx! This is an automated message from the Apache Git Service. To respond

[jira] [Comment Edited] (FLINK-20947) Unable to trigger Hive partition commit when use table sql to write data from Kafka into a Hive table

[ https://issues.apache.org/jira/browse/FLINK-20947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266708#comment-17266708 ] Shengkai Fang edited comment on FLINK-20947 at 1/17/21, 6:50 AM: -

[jira] [Commented] (FLINK-20947) Unable to trigger Hive partition commit when use table sql to write data from Kafka into a Hive table

[ https://issues.apache.org/jira/browse/FLINK-20947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266708#comment-17266708 ] Shengkai Fang commented on FLINK-20947: --- Sorry for the late response. I think the

[jira] [Commented] (FLINK-20952) Changelog json formats should support inherit options from JSON format

[ https://issues.apache.org/jira/browse/FLINK-20952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266707#comment-17266707 ] Shengkai Fang commented on FLINK-20952: --- Big +1. I think it also will help avro, c

[GitHub] [flink] flinkbot edited a comment on pull request #14673: [FLINK-20963][python] Update example with the latest recommended API

flinkbot edited a comment on pull request #14673: URL: https://github.com/apache/flink/pull/14673#issuecomment-761728608 ## CI report: * 22f12c8736744595dadf746d76f1089c31d96acb Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14673: [FLINK-20963][python] Update example with the latest recommended API

flinkbot commented on pull request #14673: URL: https://github.com/apache/flink/pull/14673#issuecomment-761728608 ## CI report: * 22f12c8736744595dadf746d76f1089c31d96acb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-20963) Rewrite the example under 'flink-python/pyflink/table/examples'

[ https://issues.apache.org/jira/browse/FLINK-20963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20963: --- Labels: pull-request-available (was: ) > Rewrite the example under 'flink-python/pyflink/ta

[GitHub] [flink] flinkbot commented on pull request #14673: [FLINK-20963][python] Update example with the latest recommended API

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

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * dd0c5787dff7ece30e49399adaef5114f60311a3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-20962) Rewrite the example in 'flink-python/pyflink/shell.py'

[ https://issues.apache.org/jira/browse/FLINK-20962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20962: --- Labels: pull-request-available (was: ) > Rewrite the example in 'flink-python/pyflink/shell

[GitHub] [flink] lometheus opened a new pull request #14673: [FLINK-20962][python] Update example with the latest recommended API

lometheus opened a new pull request #14673: URL: https://github.com/apache/flink/pull/14673 ## What is the purpose of the change *This pull request update 'flink-python/pyflink/table/examples' with the latest recommended API.* ## Brief change log - *Use recommend

[GitHub] [flink] lingya commented on a change in pull request #14271: [FLINK-12130][clients] Apply command line options to configuration be…

lingya commented on a change in pull request #14271: URL: https://github.com/apache/flink/pull/14271#discussion_r559072598 ## File path: flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java ## @@ -630,66 +715,75 @@ public CommandLine getCommandLine(final Op

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * dd0c5787dff7ece30e49399adaef5114f60311a3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * dd0c5787dff7ece30e49399adaef5114f60311a3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-9925) ClientTest.testSimpleRequests fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266695#comment-17266695 ] Huang Xingbo commented on FLINK-9925: - Failed instance in release-1.11 [https://dev.

[GitHub] [flink] liuyufei9527 commented on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

liuyufei9527 commented on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-761723357 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [flink] liuyufei9527 removed a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

liuyufei9527 removed a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-761608713 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the mes

[jira] [Commented] (FLINK-20659) YARNSessionCapacitySchedulerITCase.perJobYarnClusterOffHeap test failed with NPE

[ https://issues.apache.org/jira/browse/FLINK-20659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266694#comment-17266694 ] Huang Xingbo commented on FLINK-20659: -- [https://dev.azure.com/apache-flink/apache-

[jira] [Commented] (FLINK-21000) set MetricGroup in SourceCoordinatorContext

[ https://issues.apache.org/jira/browse/FLINK-21000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266679#comment-17266679 ] Steven Zhen Wu commented on FLINK-21000: I tried to trace the code up the chain:

[jira] [Created] (FLINK-21000) set MetricGroup in SourceCoordinatorContext

Steven Zhen Wu created FLINK-21000: -- Summary: set MetricGroup in SourceCoordinatorContext Key: FLINK-21000 URL: https://issues.apache.org/jira/browse/FLINK-21000 Project: Flink Issue Type: B

[GitHub] [flink] flinkbot edited a comment on pull request #14621: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

flinkbot edited a comment on pull request #14621: URL: https://github.com/apache/flink/pull/14621#issuecomment-75873 ## CI report: * 1100d0e39c512c5a301cf979f38902e9f0a99659 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266654#comment-17266654 ] Arvid Heise commented on FLINK-20309: - The latest issues were test only issues. Merg

[jira] [Resolved] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20309. - Resolution: Fixed > UnalignedCheckpointTestBase.execute is failed >

[jira] [Updated] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20309: Priority: Major (was: Blocker) > UnalignedCheckpointTestBase.execute is failed >

[jira] [Resolved] (FLINK-20462) MailboxOperatorTest.testAvoidTaskStarvation

[ https://issues.apache.org/jira/browse/FLINK-20462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20462. - Fix Version/s: 1.12.2 1.13.0 Resolution: Fixed > MailboxOperatorTest.t

[jira] [Commented] (FLINK-20462) MailboxOperatorTest.testAvoidTaskStarvation

[ https://issues.apache.org/jira/browse/FLINK-20462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266653#comment-17266653 ] Arvid Heise commented on FLINK-20462: - Merged into master as cc44a5533d2bf984e601a26

[GitHub] [flink] AHeise merged pull request #14667: [FLINK-20309][tests] Make source split assignment in UnalignedCheckpointITCase stable. [1.12]

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

[GitHub] [flink] AHeise commented on pull request #14667: [FLINK-20309][tests] Make source split assignment in UnalignedCheckpointITCase stable. [1.12]

AHeise commented on pull request #14667: URL: https://github.com/apache/flink/pull/14667#issuecomment-761642275 No changes and green AZP -> merging. This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] AHeise merged pull request #14668: [FLINK-20462][runtime] Port MailboxOperatorTest to StreamTaskMailboxTestHarness. [1.12]

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

[GitHub] [flink] AHeise commented on pull request #14668: [FLINK-20462][runtime] Port MailboxOperatorTest to StreamTaskMailboxTestHarness. [1.12]

AHeise commented on pull request #14668: URL: https://github.com/apache/flink/pull/14668#issuecomment-761642030 No changes and green AZP -> merging. This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * dd0c5787dff7ece30e49399adaef5114f60311a3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * Unknown: [CANCELED](TBD) * dd0c5787dff7ece30e49399adaef5114f60311a3 Azure: [PENDING]

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * Unknown: [CANCELED](TBD) * dd0c5787dff7ece30e49399adaef5114f60311a3 UNKNOWN

[GitHub] [flink] liuyufei9527 commented on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

liuyufei9527 commented on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-761608713 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [flink] flinkbot edited a comment on pull request #14621: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

flinkbot edited a comment on pull request #14621: URL: https://github.com/apache/flink/pull/14621#issuecomment-75873 ## CI report: * 1a07f8eafb9f951a217ec7622525958a4eeaf333 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14621: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

flinkbot edited a comment on pull request #14621: URL: https://github.com/apache/flink/pull/14621#issuecomment-75873 ## CI report: * 1a07f8eafb9f951a217ec7622525958a4eeaf333 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14672: [FLINK-20998][docs] - flink-raw.jar no longer mentioned + prettier maven xml dependencies

flinkbot edited a comment on pull request #14672: URL: https://github.com/apache/flink/pull/14672#issuecomment-761593893 ## CI report: * c1ae8b92b6a0bec992e149b45b3ae6a58ffa92fe Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14672: [FLINK-20998][docs] - flink-raw.jar no longer mentioned + prettier maven xml dependencies

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

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * 79c45e016fd20a854ab1d6a9ed6613dd691e562a Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] Myasuka commented on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

Myasuka commented on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-761592380 Your CI was broken due to the bad format, please resubmit your PR with correct format with maven spotless plugin. Since you actually split two commits in one PR, please us

[jira] [Commented] (FLINK-20999) Confluent Avro Format should document how to serialize kafka keys

[ https://issues.apache.org/jira/browse/FLINK-20999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266624#comment-17266624 ] Svend Vanderveken commented on FLINK-20999: --- Thanks for the nice feed-back Jar

[GitHub] [flink] flinkbot commented on pull request #14672: [FLINK-20998][docs] - flink-raw.jar no longer mentioned + prettier maven xml dependencies

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

[GitHub] [flink] sv3ndk opened a new pull request #14672: [FLINK-20998][docs] - flink-raw.jar no longer mentioned + prettier maven xml dependencies

sv3ndk opened a new pull request #14672: URL: https://github.com/apache/flink/pull/14672 ## What is the purpose of the change *fix documentation mistake: the raw format is a built-in format distributed with blink-table-planner but was documented as a separate jar.*

[jira] [Updated] (FLINK-20998) flink-raw-1.12.jar does not exist

[ https://issues.apache.org/jira/browse/FLINK-20998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20998: --- Labels: pull-request-available (was: ) > flink-raw-1.12.jar does not exist > --

[jira] [Comment Edited] (FLINK-20597) Update flink training exercises to 1.12

[ https://issues.apache.org/jira/browse/FLINK-20597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266619#comment-17266619 ] David Anderson edited comment on FLINK-20597 at 1/16/21, 4:10 PM:

[jira] [Commented] (FLINK-20597) Update flink training exercises to 1.12

[ https://issues.apache.org/jira/browse/FLINK-20597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266619#comment-17266619 ] David Anderson commented on FLINK-20597: closed with d3914a27b04274d17fe1abb7703

[jira] [Resolved] (FLINK-20597) Update flink training exercises to 1.12

[ https://issues.apache.org/jira/browse/FLINK-20597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson resolved FLINK-20597. Resolution: Done > Update flink training exercises to 1.12 > -

[GitHub] [flink-training] alpinegizmo commented on pull request #15: add support for Flink 1.12

alpinegizmo commented on pull request #15: URL: https://github.com/apache/flink-training/pull/15#issuecomment-761587212 @sv3ndk Thanks! This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] flinkbot edited a comment on pull request #14670: [FLINK-20918][FileSystem] Avoid excessive flush of Hadoop output stream

flinkbot edited a comment on pull request #14670: URL: https://github.com/apache/flink/pull/14670#issuecomment-761544566 ## CI report: * 4d2ecb25c3544e84f89a35498efa1c92186ef6ae Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-training] alpinegizmo merged pull request #15: add support for Flink 1.12

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

[GitHub] [flink] flinkbot edited a comment on pull request #14669: [FLINK-20997][tests] Generate yarn classpath before test phase

flinkbot edited a comment on pull request #14669: URL: https://github.com/apache/flink/pull/14669#issuecomment-761544534 ## CI report: * da7f00f824be3c9d8ae9a543c01dbeefc852a09c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * 6aca99bf5bcb80b77c9f2703f8505b591e80f1d8 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] hwanju commented on pull request #14499: [FLINK-15156] Warn user if System.exit() is called in user code

hwanju commented on pull request #14499: URL: https://github.com/apache/flink/pull/14499#issuecomment-761572560 > I believe sources are relatively important, in particular because some users have their own implementations there. > @hwanju do you want to address this in this PR, or in a f

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * 9cc5abebea8b35545b206504e5590e395452ef5e Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-20995) Calling execute() on org.apache.flink.table.api.Table Throws Exception

[ https://issues.apache.org/jira/browse/FLINK-20995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20995: Fix Version/s: 1.13.0 > Calling execute() on org.apache.flink.table.api.Table Throws Exception > -

[jira] [Commented] (FLINK-20995) Calling execute() on org.apache.flink.table.api.Table Throws Exception

[ https://issues.apache.org/jira/browse/FLINK-20995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266604#comment-17266604 ] Jark Wu commented on FLINK-20995: - [~TsReaper], could you help to check this? > Calling

[GitHub] [flink-training] sv3ndk commented on pull request #15: add support for Flink 1.12

sv3ndk commented on pull request #15: URL: https://github.com/apache/flink-training/pull/15#issuecomment-761569254 Ah yes, indeed. There you go This is an automated message from the Apache Git Service. To respond to the m

[jira] [Updated] (FLINK-20998) flink-raw-1.12.jar does not exist

[ https://issues.apache.org/jira/browse/FLINK-20998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20998: Fix Version/s: 1.12.2 > flink-raw-1.12.jar does not exist > - > >

[jira] [Updated] (FLINK-20998) flink-raw-1.12.jar does not exist

[ https://issues.apache.org/jira/browse/FLINK-20998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20998: Component/s: Table SQL / Ecosystem > flink-raw-1.12.jar does not exist > -

[jira] [Comment Edited] (FLINK-20998) flink-raw-1.12.jar does not exist

[ https://issues.apache.org/jira/browse/FLINK-20998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266603#comment-17266603 ] Jark Wu edited comment on FLINK-20998 at 1/16/21, 2:07 PM: --- Ye

[jira] [Updated] (FLINK-20998) flink-raw-1.12.jar does not exist

[ https://issues.apache.org/jira/browse/FLINK-20998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20998: Fix Version/s: 1.13.0 > flink-raw-1.12.jar does not exist > - > >

[jira] [Assigned] (FLINK-20998) flink-raw-1.12.jar does not exist

[ https://issues.apache.org/jira/browse/FLINK-20998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20998: --- Assignee: Svend Vanderveken > flink-raw-1.12.jar does not exist > -

[jira] [Commented] (FLINK-20998) flink-raw-1.12.jar does not exist

[ https://issues.apache.org/jira/browse/FLINK-20998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266603#comment-17266603 ] Jark Wu commented on FLINK-20998: - Yes. This is a documentation mistake. The raw format

[jira] [Assigned] (FLINK-20999) Confluent Avro Format should document how to serialize kafka keys

[ https://issues.apache.org/jira/browse/FLINK-20999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20999: --- Assignee: Svend Vanderveken > Confluent Avro Format should document how to serialize kafka keys > -

[jira] [Commented] (FLINK-20999) Confluent Avro Format should document how to serialize kafka keys

[ https://issues.apache.org/jira/browse/FLINK-20999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266602#comment-17266602 ] Jark Wu commented on FLINK-20999: - Sounds great to me. I have assigned this issue to you

[jira] [Updated] (FLINK-20999) Confluent Avro Format should document how to serialize kafka keys

[ https://issues.apache.org/jira/browse/FLINK-20999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20999: Fix Version/s: 1.13.0 > Confluent Avro Format should document how to serialize kafka keys > --

[jira] [Updated] (FLINK-20999) Confluent Avro Format should document how to serialize kafka keys

[ https://issues.apache.org/jira/browse/FLINK-20999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20999: Component/s: Table SQL / Ecosystem > Confluent Avro Format should document how to serialize kafka keys > -

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * 9cc5abebea8b35545b206504e5590e395452ef5e Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] liuyufei9527 commented on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

liuyufei9527 commented on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-761567758 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [flink] liuyufei9527 removed a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

liuyufei9527 removed a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-761554975 @Myasuka Should I fix the conflicts since code format have changed? This is an automated message f

[jira] [Updated] (FLINK-20999) Confluent Avro Format should document how to serialize kafka keys

[ https://issues.apache.org/jira/browse/FLINK-20999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Svend Vanderveken updated FLINK-20999: -- Description: The [Confluent Avro Format|https://ci.apache.org/projects/flink/flink-do

[jira] [Created] (FLINK-20999) Confluent Avro Format should document how to serialize kafka keys

Svend Vanderveken created FLINK-20999: - Summary: Confluent Avro Format should document how to serialize kafka keys Key: FLINK-20999 URL: https://issues.apache.org/jira/browse/FLINK-20999 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #14671: [hotfix][docs] Fix typo in 'docs/dev/table/functions/udfs.md & udfs.zh.md'.

flinkbot edited a comment on pull request #14671: URL: https://github.com/apache/flink/pull/14671#issuecomment-761562774 ## CI report: * c394bd3fa216cb3ba3c9451a003d79b2dadae860 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14671: [hotfix][docs] Fix typo in 'docs/dev/table/functions/udfs.md & udfs.zh.md'.

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

[GitHub] [flink] flinkbot commented on pull request #14671: [hotfix][docs] Fix typo in 'docs/dev/table/functions/udfs.md & udfs.zh.md'.

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

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * 9cc5abebea8b35545b206504e5590e395452ef5e Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] RocMarshal opened a new pull request #14671: [hotfix][docs] Fix typo in 'docs/dev/table/functions/udfs.md & udfs.zh.md'.

RocMarshal opened a new pull request #14671: URL: https://github.com/apache/flink/pull/14671 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * 9cc5abebea8b35545b206504e5590e395452ef5e Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] liuyufei9527 commented on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

liuyufei9527 commented on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-761554975 @Myasuka Should I fix the conflicts since code format have changed? This is an automated message from the

[jira] [Closed] (FLINK-20909) MiniBatch Interval derivation does not work well when enable miniBatch optimization in a job which contains deduplicate on row and unbounded aggregate.

[ https://issues.apache.org/jira/browse/FLINK-20909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20909. --- Resolution: Fixed Fixed in master: d1d78e72220e2938bf5af77420af16c477c96e29 > MiniBatch Interval derivation

[GitHub] [flink] wuchong merged pull request #14610: [FLINK-20909][table-planner-blink] Fix deduplicate mini-batch interval infer

wuchong merged pull request #14610: URL: https://github.com/apache/flink/pull/14610 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] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266581#comment-17266581 ] Huang Xingbo commented on FLINK-18634: -- [https://dev.azure.com/apache-flink/apache-

[GitHub] [flink] flinkbot edited a comment on pull request #14670: [FLINK-20918][FileSystem] Avoid excessive flush of Hadoop output stream

flinkbot edited a comment on pull request #14670: URL: https://github.com/apache/flink/pull/14670#issuecomment-761544566 ## CI report: * 4d2ecb25c3544e84f89a35498efa1c92186ef6ae Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14669: [FLINK-20997][tests] Generate yarn classpath before test phase

flinkbot edited a comment on pull request #14669: URL: https://github.com/apache/flink/pull/14669#issuecomment-761544534 ## CI report: * da7f00f824be3c9d8ae9a543c01dbeefc852a09c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14610: [FLINK-20909][table-planner-blink] Fix deduplicate mini-batch interval infer

flinkbot edited a comment on pull request #14610: URL: https://github.com/apache/flink/pull/14610#issuecomment-758033846 ## CI report: * 0482293fe8ca9fdd51defaa6db8e86b35dac1c5f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-20799) Restructure TOC of the "Working with state" documentation page

[ https://issues.apache.org/jira/browse/FLINK-20799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Svend Vanderveken closed FLINK-20799. - Resolution: Abandoned No feed-back received after 2 weeks, I guess this one is not relev

[GitHub] [flink] flinkbot commented on pull request #14670: [FLINK-20918][FileSystem] Avoid excessive flush of Hadoop output stream

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

[jira] [Created] (FLINK-20998) flink-raw-1.12.jar does not exist

Svend Vanderveken created FLINK-20998: - Summary: flink-raw-1.12.jar does not exist Key: FLINK-20998 URL: https://issues.apache.org/jira/browse/FLINK-20998 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #14669: [FLINK-20997][tests] Generate yarn classpath before test phase

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

[GitHub] [flink-training] alpinegizmo commented on pull request #15: add support for Flink 1.12

alpinegizmo commented on pull request #15: URL: https://github.com/apache/flink-training/pull/15#issuecomment-761542509 @sv3ndk Thank you for this; it looks good. If you would also remove the `TimeCharacteristic` from the Java versions of the exercises and solutions, then I think this will

[GitHub] [flink] flinkbot commented on pull request #14670: [FLINK-20918][FileSystem] Avoid excessive flush of Hadoop output stream

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

[jira] [Updated] (FLINK-20918) Avoid excessive flush of Hadoop output stream

[ https://issues.apache.org/jira/browse/FLINK-20918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20918: --- Labels: pull-request-available (was: ) > Avoid excessive flush of Hadoop output stream > --

[GitHub] [flink] link3280 opened a new pull request #14670: [FLINK-20918][FileSystem] Avoid excessive flush of Hadoop output stream

link3280 opened a new pull request #14670: URL: https://github.com/apache/flink/pull/14670 ## What is the purpose of the change HadoopRecoverableFsDataOutputStream#sync calls both `hflush` and `hsync`, whereas `hsync` is an enhanced version of `hflush`. We should remove the `hflush`

[GitHub] [flink] flinkbot commented on pull request #14669: [FLINK-20997][tests] Generate yarn classpath before test phase

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

[jira] [Updated] (FLINK-20997) YarnTestBaseTest fails due to NPE

[ https://issues.apache.org/jira/browse/FLINK-20997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20997: --- Labels: pull-request-available (was: ) > YarnTestBaseTest fails due to NPE > --

  1   2   >