[jira] [Commented] (FLINK-20926) Allow to read metadata for maxwell-json format

2021-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263880#comment-17263880 ] Jark Wu commented on FLINK-20926: - Which maxwell field maps the {{primary-key-columns}} metadata?

[GitHub] [flink] lmagic233 commented on pull request #14604: [FLINK-20861][format/json] Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

2021-01-12 Thread GitBox
lmagic233 commented on pull request #14604: URL: https://github.com/apache/flink/pull/14604#issuecomment-759194539 Copy that @wuchong , I have rebased the branch. Also I have rewrote the test case, plase verify. This is an

[jira] [Updated] (FLINK-20942) Digest of FLOAT literals throws UnsupportedOperationException

2021-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20942: Fix Version/s: 1.12.2 > Digest of FLOAT literals throws UnsupportedOperationException >

[jira] [Updated] (FLINK-20942) Digest of FLOAT literals throws UnsupportedOperationException

2021-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20942: Fix Version/s: 1.13.0 > Digest of FLOAT literals throws UnsupportedOperationException >

[GitHub] [flink] leonardBang commented on a change in pull request #14620: [FLINK-20940][table-planner] Use session time zone in LOCALTIME/LOCALTIMSTAMP functions

2021-01-12 Thread GitBox
leonardBang commented on a change in pull request #14620: URL: https://github.com/apache/flink/pull/14620#discussion_r556252112 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/expressions/TemporalTypesTest.scala ## @@ -674,6

[GitHub] [flink] wuchong commented on pull request #14616: [FLINK-20879][table-api] Use MemorySize type instead of String type for memory ConfigOption in ExecutionConfigOptions

2021-01-12 Thread GitBox
wuchong commented on pull request #14616: URL: https://github.com/apache/flink/pull/14616#issuecomment-759192837 Thanks @xiaoHoly , I will help to review this. This is an automated message from the Apache Git Service. To

[GitHub] [flink] wuchong commented on pull request #14604: [FLINK-20861][format/json] Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

2021-01-12 Thread GitBox
wuchong commented on pull request #14604: URL: https://github.com/apache/flink/pull/14604#issuecomment-759192699 Hi @lmagic233 , please use `git rebase` instead of `git merge` or `git pull`. You are pulling other commits into this PR.

[jira] [Commented] (FLINK-20913) Improve new HiveConf(jobConf, HiveConf.class)

2021-01-12 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263878#comment-17263878 ] Rui Li commented on FLINK-20913: [~dixingx...@yeah.net] Thanks for the explanations. According to hive

[GitHub] [flink] flinkbot commented on pull request #14624: [FLINK-20750][python][table-planner-blink] Port stream python group aggregate nodes to Java

2021-01-12 Thread GitBox
flinkbot commented on pull request #14624: URL: https://github.com/apache/flink/pull/14624#issuecomment-759191873 ## CI report: * 062f813ecf60bcc973829ab9e2ace0bdf1afa969 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14606: [Flink-20876][table-planner-blink] Separate the implementation of StreamExecTemporalJoin

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14606: URL: https://github.com/apache/flink/pull/14606#issuecomment-757754275 ## CI report: * 34b5cc968f647c2a7c2e9fdd24c36de5f86f2624 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disab

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-752828536 ## CI report: * 33da876b229f8c2ff4f32b0903cf48c76e1b8c16 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14530: [FLINK-20348][kafka] Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14530: URL: https://github.com/apache/flink/pull/14530#issuecomment-752828495 ## CI report: * 35003647ea219b5b67317e240a0dcd85860dbe51 Azure:

[jira] [Updated] (FLINK-20832) Deliver bootstrap resouces ourselves for website and documentation

2021-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20832: Summary: Deliver bootstrap resouces ourselves for website and documentation (was: flink.apache.org site

[jira] [Updated] (FLINK-20832) Deliver bootstrap resouces ourselves for website and documentation

2021-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20832: Priority: Major (was: Blocker) > Deliver bootstrap resouces ourselves for website and documentation >

[jira] [Comment Edited] (FLINK-20832) flink.apache.org site Typography exception

2021-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17261333#comment-17261333 ] Jark Wu edited comment on FLINK-20832 at 1/13/21, 4:05 AM: --- Fixed in -

[jira] [Closed] (FLINK-20832) flink.apache.org site Typography exception

2021-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20832. --- Fix Version/s: (was: 1.12.0) 1.12.2 1.11.4

[GitHub] [flink] curcur commented on pull request #14567: [FLINK-20453][runtime][checkpoint] Move checkpointing classes to an a…

2021-01-12 Thread GitBox
curcur commented on pull request #14567: URL: https://github.com/apache/flink/pull/14567#issuecomment-759189724 My local azure green https://dev.azure.com/mymeiyuan/Flink/_build/results?buildId=163=results This is an

[GitHub] [flink] wuchong commented on a change in pull request #14620: [FLINK-20940][table-planner] Use session time zone in LOCALTIME/LOCALTIMSTAMP functions

2021-01-12 Thread GitBox
wuchong commented on a change in pull request #14620: URL: https://github.com/apache/flink/pull/14620#discussion_r556248368 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/expressions/TemporalTypesTest.scala ## @@ -674,6

[GitHub] [flink] yuruguo commented on pull request #14477: [FLINK-16005][yarn] Support yarn and hadoop config override

2021-01-12 Thread GitBox
yuruguo commented on pull request #14477: URL: https://github.com/apache/flink/pull/14477#issuecomment-759188494 Hi @tillrohrmann, CI has failed but it seems to be unrelated to this pr, please take a look. This is an

[GitHub] [flink] flinkbot commented on pull request #14624: [FLINK-20750][python][table-planner-blink] Port stream python group aggregate nodes to Java

2021-01-12 Thread GitBox
flinkbot commented on pull request #14624: URL: https://github.com/apache/flink/pull/14624#issuecomment-759186900 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 #14616: [FLINK-20879][table-api] Use MemorySize type instead of String type for memory ConfigOption in ExecutionConfigOptions

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14616: URL: https://github.com/apache/flink/pull/14616#issuecomment-758526377 ## CI report: * 448c026a402e045e050f405daf934a8a7c880c9d UNKNOWN * 088770300dee0faec4b956833dccef115b05bbb7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14612: [FLINK-20864][runtime] Introduce the DEFAULT resource profile for the…

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14612: URL: https://github.com/apache/flink/pull/14612#issuecomment-758375136 ## CI report: * e8f754cc415e4ff814616ed4eb1c7160cb765d7d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14606: [Flink-20876][table-planner-blink] Separate the implementation of StreamExecTemporalJoin

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14606: URL: https://github.com/apache/flink/pull/14606#issuecomment-757754275 ## CI report: * 34b5cc968f647c2a7c2e9fdd24c36de5f86f2624 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disab

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-752828536 ## CI report: * 21c6c5cfdbaa95cb8d99274f69b9190ca8aec0c5 Azure:

[jira] [Updated] (FLINK-20750) Port stream python group aggregate nodes to Java

2021-01-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20750: --- Labels: pull-request-available (was: ) > Port stream python group aggregate nodes to Java

[GitHub] [flink] HuangXingBo opened a new pull request #14624: [FLINK-20750][python][table-planner-blink] Port stream python group aggregate nodes to Java

2021-01-12 Thread GitBox
HuangXingBo opened a new pull request #14624: URL: https://github.com/apache/flink/pull/14624 ## What is the purpose of the change *This pull request will Port stream python group aggregate nodes to Java* ## Brief change log - *Port stream python group aggregate

[jira] [Commented] (FLINK-20935) can't write flink configuration to tmp file and add it to local resource in yarn session mode

2021-01-12 Thread yuemeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263861#comment-17263861 ] yuemeng commented on FLINK-20935: - [~fly_in_gis],yes ,i set fs.default-scheme to hdfs, but create tmp

[GitHub] [flink] flinkbot edited a comment on pull request #14606: [Flink-20876][table-planner-blink] Separate the implementation of StreamExecTemporalJoin

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14606: URL: https://github.com/apache/flink/pull/14606#issuecomment-757754275 ## CI report: * 34b5cc968f647c2a7c2e9fdd24c36de5f86f2624 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disab

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-752828536 ## CI report: * 21c6c5cfdbaa95cb8d99274f69b9190ca8aec0c5 Azure:

[jira] [Comment Edited] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-12 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263858#comment-17263858 ] wangfei edited comment on FLINK-20885 at 1/13/21, 3:16 AM: --- table

[jira] [Comment Edited] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-12 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263858#comment-17263858 ] wangfei edited comment on FLINK-20885 at 1/13/21, 3:14 AM: --- table

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

2021-01-12 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263859#comment-17263859 ] Yang Wang commented on FLINK-20919: --- [~Janze] The submission command is not complete. If you could not

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-12 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263858#comment-17263858 ] wangfei commented on FLINK-20885: - table test_2.userName (int); table test_1.userName (varchar); You

[jira] [Commented] (FLINK-20944) Launching in application mode requesting a ClusterIP rest service type results in an Exception

2021-01-12 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263855#comment-17263855 ] Yang Wang commented on FLINK-20944: --- If the {{kubernetes.rest-service.exposed.type}} is {{ClusterIP}},

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-12 Thread wangfei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263857#comment-17263857 ] wangfei commented on FLINK-20885: - [~nicholasjiang] CREATE TABLE `test_2` ( `id` int(11) NOT NULL,

[GitHub] [flink] flinkbot edited a comment on pull request #14612: [FLINK-20864][runtime] Introduce the DEFAULT resource profile for the…

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14612: URL: https://github.com/apache/flink/pull/14612#issuecomment-758375136 ## CI report: * 6a65d8ad557da469d8b91b3b4c598ae02d5ee0f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14606: [Flink-20876][table-planner-blink] Separate the implementation of StreamExecTemporalJoin

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14606: URL: https://github.com/apache/flink/pull/14606#issuecomment-757754275 ## CI report: * 34b5cc968f647c2a7c2e9fdd24c36de5f86f2624 Azure:

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

2021-01-12 Thread Weijia Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijia Xu updated FLINK-20947: -- Description: I use table sql to create stream with kafka source, and write data from Kafka into a

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

2021-01-12 Thread Weijia Xu (Jira)
Weijia Xu created FLINK-20947: - Summary: Unable to trigger Hive partition commit when use table sql to write data from Kafka into a Hive table Key: FLINK-20947 URL: https://issues.apache.org/jira/browse/FLINK-20947

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

2021-01-12 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263851#comment-17263851 ] Nicholas Jiang commented on FLINK-20885: [~wangfeiair2324], could you please provide me with the

[jira] [Closed] (FLINK-20848) Kafka consumer ID is not specified correctly in new KafkaSource

2021-01-12 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin closed FLINK-20848. Fix Version/s: (was: 1.12.1) 1.12.2 Resolution: Fixed Merged.

[GitHub] [flink] becketqin commented on pull request #14556: [FLINK-20848][connector/kafka] Fix Kafka consumer client ID with subtask ID suffix

2021-01-12 Thread GitBox
becketqin commented on pull request #14556: URL: https://github.com/apache/flink/pull/14556#issuecomment-759169148 Merged. Master: 9313b01a73d5d05fab2fc8be8fac21a3ede039d6 release-1.12: e203e24cf775e4d5cdd0469b9db3cf2894b2f9c5

[GitHub] [flink] flinkbot edited a comment on pull request #14616: [FLINK-20879][table-api] Use MemorySize type instead of String type for memory ConfigOption in ExecutionConfigOptions

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14616: URL: https://github.com/apache/flink/pull/14616#issuecomment-758526377 ## CI report: * 448c026a402e045e050f405daf934a8a7c880c9d UNKNOWN * 7ae8320042ec2e4390961c202f1c126f2ba07384 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14612: [FLINK-20864][runtime] Introduce the DEFAULT resource profile for the…

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14612: URL: https://github.com/apache/flink/pull/14612#issuecomment-758375136 ## CI report: * 6a65d8ad557da469d8b91b3b4c598ae02d5ee0f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14606: [Flink-20876][table-planner-blink] Separate the implementation of StreamExecTemporalJoin

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14606: URL: https://github.com/apache/flink/pull/14606#issuecomment-757754275 ## CI report: * 34b5cc968f647c2a7c2e9fdd24c36de5f86f2624 Azure:

[jira] [Commented] (FLINK-20935) can't write flink configuration to tmp file and add it to local resource in yarn session mode

2021-01-12 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263844#comment-17263844 ] Yang Wang commented on FLINK-20935: --- TBH, I do not completely understand your problem. IIRC, the

[jira] [Created] (FLINK-20946) Optimize Python ValueState Implementation In PyFlink

2021-01-12 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20946: Summary: Optimize Python ValueState Implementation In PyFlink Key: FLINK-20946 URL: https://issues.apache.org/jira/browse/FLINK-20946 Project: Flink Issue

[GitHub] [flink] xiaoHoly commented on pull request #14616: [FLINK-20879][table-api] Use MemorySize type instead of String type for memory ConfigOption in ExecutionConfigOptions

2021-01-12 Thread GitBox
xiaoHoly commented on pull request #14616: URL: https://github.com/apache/flink/pull/14616#issuecomment-759165382 @wuchong ,Jark, I hava resovle the conflicts. This is an automated message from the Apache Git Service. To

[GitHub] [flink] leonardBang commented on a change in pull request #14610: [FLINK-20909][table-planner-blink] Fix deduplicate mini-batch interval infer

2021-01-12 Thread GitBox
leonardBang commented on a change in pull request #14610: URL: https://github.com/apache/flink/pull/14610#discussion_r556225680 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/DeduplicateITCase.scala ## @@

[GitHub] [flink] becketqin merged pull request #14556: [FLINK-20848][connector/kafka] Fix Kafka consumer client ID with subtask ID suffix

2021-01-12 Thread GitBox
becketqin merged pull request #14556: URL: https://github.com/apache/flink/pull/14556 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] becketqin commented on pull request #14556: [FLINK-20848][connector/kafka] Fix Kafka consumer client ID with subtask ID suffix

2021-01-12 Thread GitBox
becketqin commented on pull request #14556: URL: https://github.com/apache/flink/pull/14556#issuecomment-759162202 Thanks for the patch. LGTM. This is an automated message from the Apache Git Service. To respond to the

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

2021-01-12 Thread Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263840#comment-17263840 ] Wu commented on FLINK-20919: [~fly_in_gis] The submission command is as follows.   {code:java} //代码占位符

[jira] [Commented] (FLINK-20913) Improve new HiveConf(jobConf, HiveConf.class)

2021-01-12 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263838#comment-17263838 ] Xingxing Di commented on FLINK-20913: - Hi [~lirui], i looked into the code, i found the

[GitHub] [flink] flinkbot edited a comment on pull request #14490: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14490: URL: https://github.com/apache/flink/pull/14490#issuecomment-751138236 ## CI report: * 754c80e47aa429d7c7533789bcde295bb629e47e Azure:

[GitHub] [flink] beyond1920 commented on a change in pull request #14610: [FLINK-20909][table-planner-blink] Fix deduplicate mini-batch interval infer

2021-01-12 Thread GitBox
beyond1920 commented on a change in pull request #14610: URL: https://github.com/apache/flink/pull/14610#discussion_r556214065 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/DeduplicateITCase.scala ## @@

[GitHub] [flink] xiaoHoly commented on a change in pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and

2021-01-12 Thread GitBox
xiaoHoly commented on a change in pull request #14531: URL: https://github.com/apache/flink/pull/14531#discussion_r556211376 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java ## @@ -458,6 +458,29

[jira] [Created] (FLINK-20945) flink hive insert heap out of memory

2021-01-12 Thread Bruce GAO (Jira)
Bruce GAO created FLINK-20945: - Summary: flink hive insert heap out of memory Key: FLINK-20945 URL: https://issues.apache.org/jira/browse/FLINK-20945 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use maximum-failed-containers as limit of resource acquirement

2021-01-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-10868. Fix Version/s: 1.13.0 Resolution: Fixed Fixed via * master (1.13):

[GitHub] [flink] xintongsong closed pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

2021-01-12 Thread GitBox
xintongsong closed pull request #8952: URL: https://github.com/apache/flink/pull/8952 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] [Closed] (FLINK-20905) Format the description of 'kubernetes.container.image' option

2021-01-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20905. Resolution: Fixed Fixed via * master (1.13): a1d62e45f72e8cddd009bc907860a3937adb728c > Format

[GitHub] [flink] xintongsong closed pull request #14597: [FLINK-20905][k8s] Format the description of 'kubernetes.container.image' option

2021-01-12 Thread GitBox
xintongsong closed pull request #14597: URL: https://github.com/apache/flink/pull/14597 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 #14622: [FLINK-20727][connector] pulsar SourceFunction

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14622: URL: https://github.com/apache/flink/pull/14622#issuecomment-758893663 ## CI report: * 10dbc3e59fb47de1cb88dc65b40fb4c208e832ef Azure:

[GitHub] [flink] zentol commented on a change in pull request #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

2021-01-12 Thread GitBox
zentol commented on a change in pull request #14510: URL: https://github.com/apache/flink/pull/14510#discussion_r556161762 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java ## @@ -137,11 +156,18 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #14490: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14490: URL: https://github.com/apache/flink/pull/14490#issuecomment-751138236 ## CI report: * 540f96673010cbae00f1a7258627c32221b98988 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14490: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14490: URL: https://github.com/apache/flink/pull/14490#issuecomment-751138236 ## CI report: * 540f96673010cbae00f1a7258627c32221b98988 Azure:

[GitHub] [flink] HuangZhenQiu commented on pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

2021-01-12 Thread GitBox
HuangZhenQiu commented on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-759073868 @xintongsong Thanks for polishing the variable and function naming and comments. I am happy that the change is more readable now.

[jira] [Created] (FLINK-20944) Launching in application mode requesting a ClusterIP rest service type results in an Exception

2021-01-12 Thread Jason Brome (Jira)
Jason Brome created FLINK-20944: --- Summary: Launching in application mode requesting a ClusterIP rest service type results in an Exception Key: FLINK-20944 URL: https://issues.apache.org/jira/browse/FLINK-20944

[GitHub] [flink] flinkbot edited a comment on pull request #14623: [FLINK-20728][connector] Pulsar SinkFunction

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14623: URL: https://github.com/apache/flink/pull/14623#issuecomment-758904858 ## CI report: * f28be8f0598d98586165e832081f030e185d5b6a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14623: [FLINK-20728][connector] Pulsar SinkFunction

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14623: URL: https://github.com/apache/flink/pull/14623#issuecomment-758904858 ## CI report: * f28be8f0598d98586165e832081f030e185d5b6a Azure:

[GitHub] [flink] flinkbot commented on pull request #14623: [FLINK-20728][connector] Pulsar SinkFunction

2021-01-12 Thread GitBox
flinkbot commented on pull request #14623: URL: https://github.com/apache/flink/pull/14623#issuecomment-758904858 ## CI report: * f28be8f0598d98586165e832081f030e185d5b6a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14622: [FLINK-20727][connector] pulsar SourceFunction

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14622: URL: https://github.com/apache/flink/pull/14622#issuecomment-758893663 ## CI report: * 10dbc3e59fb47de1cb88dc65b40fb4c208e832ef Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14620: [FLINK-20940][table-planner] Use session time zone in LOCALTIME/LOCALTIMSTAMP functions

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14620: URL: https://github.com/apache/flink/pull/14620#issuecomment-758696085 ## CI report: * 9476884989f58f1f3ecc2bf33e9d225524d3d0b1 Azure:

[jira] [Closed] (FLINK-14712) Improve back-pressure reporting mechanism

2021-01-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-14712. -- Resolution: Fixed > Improve back-pressure reporting mechanism >

[jira] [Updated] (FLINK-20724) Create a http handler for aggregating metrics from whole job

2021-01-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20724: --- Description: This is an optimisation idea. Create a similar http handler to

[jira] [Updated] (FLINK-20724) Create a http handler for aggregating metrics from whole job

2021-01-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20724: --- Description: Create a similar http handler to {{AggregatingSubtasksMetricsHandler}}, but

[jira] [Updated] (FLINK-20724) Create a http handler for aggregating metrics from whole job

2021-01-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20724: --- Parent: (was: FLINK-14712) Issue Type: Improvement (was: Sub-task) > Create a

[jira] [Closed] (FLINK-14127) Better BackPressure Detection in WebUI

2021-01-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-14127. -- Fix Version/s: (was: 1.13.0) Resolution: Won't Fix For the time being this won't

[jira] [Closed] (FLINK-20852) Enrich back pressure stats per subtask in the WebUI

2021-01-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-20852. -- Resolution: Fixed Merged to master as 56314b72123..f43fc042909. In the end I decided to not

[GitHub] [flink] flinkbot commented on pull request #14622: [FLINK-20727][connector] pulsar SourceFunction

2021-01-12 Thread GitBox
flinkbot commented on pull request #14622: URL: https://github.com/apache/flink/pull/14622#issuecomment-758893663 ## CI report: * 10dbc3e59fb47de1cb88dc65b40fb4c208e832ef UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14623: [FLINK-20728][connector] Pulsar SinkFunction

2021-01-12 Thread GitBox
flinkbot commented on pull request #14623: URL: https://github.com/apache/flink/pull/14623#issuecomment-758892207 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] jianyun8023 commented on pull request #14623: [FLINK-20728][connector] Pulsar SinkFunction

2021-01-12 Thread GitBox
jianyun8023 commented on pull request #14623: URL: https://github.com/apache/flink/pull/14623#issuecomment-758891364 The pr depends on #14622 This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-20728) Pulsar SinkFunction

2021-01-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20728: --- Labels: pull-request-available (was: ) > Pulsar SinkFunction > --- > >

[jira] [Updated] (FLINK-20852) Enrich back pressure stats per subtask in the WebUI

2021-01-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20852: --- Description: We can enrich the back pressure tab in the WebUI with a couple of more metrics

[GitHub] [flink] jianyun8023 opened a new pull request #14623: [FLINK-20728][connector] Pulsar SinkFunction

2021-01-12 Thread GitBox
jianyun8023 opened a new pull request #14623: URL: https://github.com/apache/flink/pull/14623 ## What is the purpose of the change Add the `SinkFunction` implementation of Pulsar to the connector. ## Brief change log - Add Pulsar `SinkFunction` implementation -

[jira] [Updated] (FLINK-20852) Enrich back pressure stats per subtask in the WebUI

2021-01-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20852: --- Description: We can enrich the back pressure tab in the WebUI with a couple of more metrics

[GitHub] [flink] pnowojski merged pull request #14618: [FLINK-20852][metrics][webui] Provide more detailed per subtask backpressure stats

2021-01-12 Thread GitBox
pnowojski merged pull request #14618: URL: https://github.com/apache/flink/pull/14618 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] pnowojski commented on pull request #14618: [FLINK-20852][metrics][webui] Provide more detailed per subtask backpressure stats

2021-01-12 Thread GitBox
pnowojski commented on pull request #14618: URL: https://github.com/apache/flink/pull/14618#issuecomment-758889979 Thanks for the review @zentol. Azure is green, so merging. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on pull request #14622: [FLINK-20727][connector] pulsar SourceFunction

2021-01-12 Thread GitBox
flinkbot commented on pull request #14622: URL: https://github.com/apache/flink/pull/14622#issuecomment-758886440 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-20932) sql client.blink streaming to make it checkpoint enabled [HOw |supported now?]

2021-01-12 Thread Norman He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263640#comment-17263640 ] Norman He commented on FLINK-20932: --- turn out it is this    {{execution.checkpointing.interval:

[jira] [Updated] (FLINK-20727) Pulsar SourceFunction

2021-01-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20727: --- Labels: pull-request-available (was: ) > Pulsar SourceFunction > - > >

[GitHub] [flink] jianyun8023 opened a new pull request #14622: [FLINK-20727][connector] pulsar SourceFunction

2021-01-12 Thread GitBox
jianyun8023 opened a new pull request #14622: URL: https://github.com/apache/flink/pull/14622 ## What is the purpose of the change Add the `SourceFunction` implementation of Pulsar to the connector. ## Brief change log - Add Pulsar SourceFunction implementation -

[jira] [Closed] (FLINK-20890) flink-state-processor-api: differents serializers being taken by Flink & State processor api

2021-01-12 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-20890. Resolution: Workaround > flink-state-processor-api: differents serializers being taken by Flink &

[jira] [Commented] (FLINK-20890) flink-state-processor-api: differents serializers being taken by Flink & State processor api

2021-01-12 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263628#comment-17263628 ] Seth Wiesman commented on FLINK-20890: -- Let's go ahead and close it. A mid-term goal is to port the

[GitHub] [flink] stevenzwu commented on pull request #14595: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

2021-01-12 Thread GitBox
stevenzwu commented on pull request #14595: URL: https://github.com/apache/flink/pull/14595#issuecomment-758870877 @sjwiesman thx. I should have looked into the iterator code first. This is an automated message from the

[GitHub] [flink-web] asfgit closed pull request #411: [FLINK-20900][docs] Added guidelines for documenting commands.

2021-01-12 Thread GitBox
asfgit closed pull request #411: URL: https://github.com/apache/flink-web/pull/411 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink-web] rmetzger commented on pull request #411: [FLINK-20900][docs] Added guidelines for documenting commands.

2021-01-12 Thread GitBox
rmetzger commented on pull request #411: URL: https://github.com/apache/flink-web/pull/411#issuecomment-758867903 Thx for taking another look. Merging it now This is an automated message from the Apache Git Service. To

[GitHub] [flink-web] asfgit closed pull request #409: [FLINK-20832] Deliver bootstrap css and js ourselves

2021-01-12 Thread GitBox
asfgit closed pull request #409: URL: https://github.com/apache/flink-web/pull/409 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink-web] asfgit closed pull request #410: Add fine-grained batch fault tolerance blog post

2021-01-12 Thread GitBox
asfgit closed pull request #410: URL: https://github.com/apache/flink-web/pull/410 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink-web] rmetzger commented on pull request #410: Add fine-grained batch fault tolerance blog post

2021-01-12 Thread GitBox
rmetzger commented on pull request #410: URL: https://github.com/apache/flink-web/pull/410#issuecomment-758858275 Thx. Merging now This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #14618: [FLINK-20852][metrics][webui] Provide more detailed per subtask backpressure stats

2021-01-12 Thread GitBox
flinkbot edited a comment on pull request #14618: URL: https://github.com/apache/flink/pull/14618#issuecomment-758605763 ## CI report: * 80aefc49c25a16273dc01a5441c23b664228d2c5 Azure:

<    1   2   3   4   5   >