[GitHub] [flink] wangxlong commented on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

2020-12-30 Thread GitBox
wangxlong commented on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-752366742 > Could you help rebase this PR? @wangxlong The master branch merged a big format PR which caused the conflict Sure, I will update this tonight. --

[GitHub] [flink] wangyang0918 commented on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2020-12-30 Thread GitBox
wangyang0918 commented on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-752367340 @blublinsky It seems that you have introduced too many unrelated changes in this PR. Could you rebase the latest master branch? I believe the conflicts is caused by huge re

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

2020-12-30 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256371#comment-17256371 ] Nicholas Jiang commented on FLINK-20811: [~xintongsong], if nobody work for this

[GitHub] [flink] wangyang0918 commented on a change in pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2020-12-30 Thread GitBox
wangyang0918 commented on a change in pull request #14512: URL: https://github.com/apache/flink/pull/14512#discussion_r550018222 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesOwnerReference.java ## @@ -0,0 +1,75 @@ +/*

[jira] [Assigned] (FLINK-20348) Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

2020-12-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20348: --- Assignee: zhuxiaoshang > Make "schema-registry.subject" optional for Kafka sink with avro-confluent

[jira] [Commented] (FLINK-20348) Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

2020-12-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256376#comment-17256376 ] Jark Wu commented on FLINK-20348: - Assigned to you [~ZhuShang]. > Make "schema-registry

[jira] [Commented] (FLINK-20813) SQL Client should create modules with user class loader

2020-12-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256377#comment-17256377 ] Jark Wu commented on FLINK-20813: - cc [~fsk119] > SQL Client should create modules with

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

2020-12-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256378#comment-17256378 ] Xintong Song commented on FLINK-20811: -- Thanks for offering the effort, [~nicholasj

[jira] [Commented] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

2020-12-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256381#comment-17256381 ] Jark Wu commented on FLINK-20777: - I'm also fine with enabled by default for unbounded m

[jira] [Assigned] (FLINK-20026) Jdbc connector support regular expression

2020-12-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20026: --- Assignee: jiawen xiao > Jdbc connector support regular expression > ---

[GitHub] [flink] xiaoHoly opened a new pull request #14523: [FLINK-18654][Connector][jdbc] Correct missleading documentation in "Partitioned Scan" section of JDBC connector

2020-12-30 Thread GitBox
xiaoHoly opened a new pull request #14523: URL: https://github.com/apache/flink/pull/14523 Correct missleading documentation in "Partitioned Scan" section of JDBC connector ## What is the purpose of the change Correct missleading documentation in "Partitioned Scan" sec

[jira] [Updated] (FLINK-18654) Correct missleading documentation in "Partitioned Scan" section of JDBC connector

2020-12-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18654: --- Labels: pull-request-available (was: ) > Correct missleading documentation in "Partitioned

[GitHub] [flink] xiaoHoly commented on pull request #14523: [FLINK-18654][Connector][jdbc] Correct missleading documentation in "Partitioned Scan" section of JDBC connector

2020-12-30 Thread GitBox
xiaoHoly commented on pull request #14523: URL: https://github.com/apache/flink/pull/14523#issuecomment-752373856 cc,@wuchong This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot commented on pull request #14523: [FLINK-18654][Connector][jdbc] Correct missleading documentation in "Partitioned Scan" section of JDBC connector

2020-12-30 Thread GitBox
flinkbot commented on pull request #14523: URL: https://github.com/apache/flink/pull/14523#issuecomment-752374212 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] pnowojski merged pull request #14509: [FLINK-20654][checkpointing] Decline checkpoints until restored channel state is consumed

2020-12-30 Thread GitBox
pnowojski merged pull request #14509: URL: https://github.com/apache/flink/pull/14509 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 t

[GitHub] [flink] cshuo commented on a change in pull request #13413: [FLINK-19188][examples-table] Add a new streaming SQL example

2020-12-30 Thread GitBox
cshuo commented on a change in pull request #13413: URL: https://github.com/apache/flink/pull/13413#discussion_r550041737 ## File path: flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/basics/UpdatingTopCityExample.java ## @@ -0,0 +1,193 @

[GitHub] [flink] cshuo commented on a change in pull request #13413: [FLINK-19188][examples-table] Add a new streaming SQL example

2020-12-30 Thread GitBox
cshuo commented on a change in pull request #13413: URL: https://github.com/apache/flink/pull/13413#discussion_r550041860 ## File path: flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/basics/UpdatingTopCityExample.java ## @@ -0,0 +1,193 @

[GitHub] [flink] HuangXingBo opened a new pull request #14524: [FLINK-20769][python] Support minibatch to optimize Python UDAF

2020-12-30 Thread GitBox
HuangXingBo opened a new pull request #14524: URL: https://github.com/apache/flink/pull/14524 ## What is the purpose of the change *This pull request will Support minibatch to optimize Python UDAF* ## Brief change log - *Support minibatch to optimize Python UDAF*

[jira] [Updated] (FLINK-20769) Support minibatch to optimize Python UDAF

2020-12-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20769: --- Labels: pull-request-available (was: ) > Support minibatch to optimize Python UDAF > --

[GitHub] [flink] flinkbot commented on pull request #14524: [FLINK-20769][python] Support minibatch to optimize Python UDAF

2020-12-30 Thread GitBox
flinkbot commented on pull request #14524: URL: https://github.com/apache/flink/pull/14524#issuecomment-752378157 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] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

2020-12-30 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256386#comment-17256386 ] Piotr Nowojski commented on FLINK-20654: A couple of fixes for the corrupted rec

[GitHub] [flink] flinkbot edited a comment on pull request #14464: [FLINK-20385][canal][json] Allow to read metadata for canal-json format

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461 ## CI report: * e81abd70d44d6ce7221d4cd2f44d31deab78ea9a UNKNOWN * 554e0a2c2ada42836d65397b163bad657806e8c2 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14477: [FLINK-16005][flink-yarn] Support yarn and hadoop config override

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14477: URL: https://github.com/apache/flink/pull/14477#issuecomment-750231028 ## CI report: * 472c9d41864d5c6834f0932a4a1cefca9a5e262d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14523: [FLINK-18654][Connector][jdbc] Correct missleading documentation in "Partitioned Scan" section of JDBC connector

2020-12-30 Thread GitBox
flinkbot commented on pull request #14523: URL: https://github.com/apache/flink/pull/14523#issuecomment-752378982 ## CI report: * 92a553aed336c8fd2578bb99d69cb263dfa1d22e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14477: [FLINK-16005][flink-yarn] Support yarn and hadoop config override

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14477: URL: https://github.com/apache/flink/pull/14477#issuecomment-750231028 ## CI report: * 90ad920f7f511a6f66ffbc50f371343dad4f55b1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14523: [FLINK-18654][Connector][jdbc] Correct missleading documentation in "Partitioned Scan" section of JDBC connector

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14523: URL: https://github.com/apache/flink/pull/14523#issuecomment-752378982 ## CI report: * 92a553aed336c8fd2578bb99d69cb263dfa1d22e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14524: [FLINK-20769][python] Support minibatch to optimize Python UDAF

2020-12-30 Thread GitBox
flinkbot commented on pull request #14524: URL: https://github.com/apache/flink/pull/14524#issuecomment-752383882 ## CI report: * 87f9a7aac8cbd730781b7cdcbacaa30b76f506fe UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] rkhachatryan opened a new pull request #14525: (backport to 1.12) [FLINK-20654][checkpointing] Decline checkpoints until restored channel state is consumed

2020-12-30 Thread GitBox
rkhachatryan opened a new pull request #14525: URL: https://github.com/apache/flink/pull/14525 This is a backport of #14509 to 1.12 fixing several issues with Unaligned Checkpoints. This is an automated message from the Apac

[GitHub] [flink] flinkbot commented on pull request #14525: (backport to 1.12) [FLINK-20654][checkpointing] Decline checkpoints until restored channel state is consumed

2020-12-30 Thread GitBox
flinkbot commented on pull request #14525: URL: https://github.com/apache/flink/pull/14525#issuecomment-752386296 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] wuchong merged pull request #14392: [FLINK-20606][connectors/hive, table sql] sql cli with hive catalog c…

2020-12-30 Thread GitBox
wuchong merged pull request #14392: URL: https://github.com/apache/flink/pull/14392 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] [Closed] (FLINK-20606) sql cli with hive catalog cannot create function using user classes from jar which specified by -j option

2020-12-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20606. --- Resolution: Fixed Fixed in master: f17562e78526eb27398ab9699e8e4fb60501cc99 > sql cli with hive catalog ca

[jira] [Commented] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

2020-12-30 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256395#comment-17256395 ] jiawen xiao commented on FLINK-20777: - ok, i will create a pr for it > Default valu

[jira] [Created] (FLINK-20817) kafka source have 200 field,Causes the class to be generated failed

2020-12-30 Thread WeiNan Zhao (Jira)
WeiNan Zhao created FLINK-20817: --- Summary: kafka source have 200 field,Causes the class to be generated failed Key: FLINK-20817 URL: https://issues.apache.org/jira/browse/FLINK-20817 Project: Flink

[jira] [Updated] (FLINK-20817) kafka source have 200 field,Causes the class to be generated failed

2020-12-30 Thread WeiNan Zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] WeiNan Zhao updated FLINK-20817: Attachment: WechatIMG46.jpeg WechatIMG45.jpeg WechatIMG44.jpeg > k

[jira] [Commented] (FLINK-20798) Using PVC as high-availability.storageDir could not work

2020-12-30 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256396#comment-17256396 ] Yang Wang commented on FLINK-20798: --- After offline discussion with [~hayden zhou], we

[GitHub] [flink] V1ncentzzZ commented on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-30 Thread GitBox
V1ncentzzZ commented on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-752392394 @wuchong Okay, Do i need to execute `git rebase` now? This is an automated message from the Apache Git Servic

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

2020-12-30 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256398#comment-17256398 ] Yang Wang commented on FLINK-20811: --- Maybe we could also support HDFS and other hadoop

[GitHub] [flink] BrantZheng commented on pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

2020-12-30 Thread GitBox
BrantZheng commented on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-752393395 I found this class JdbcXaSinkFunction extends AbstractRichFunction implements CheckpointedFunction, CheckpointListener why don't extends TwoPhaseCommitSinkFunction direct

[GitHub] [flink] flinkbot edited a comment on pull request #14524: [FLINK-20769][python] Support minibatch to optimize Python UDAF

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14524: URL: https://github.com/apache/flink/pull/14524#issuecomment-752383882 ## CI report: * 87f9a7aac8cbd730781b7cdcbacaa30b76f506fe Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-16998) Add a changeflag to Row type

2020-12-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256401#comment-17256401 ] Till Rohrmann commented on FLINK-16998: --- Quick question [~twalthr]: Did this chang

[GitHub] [flink] flinkbot commented on pull request #14525: (backport to 1.12) [FLINK-20654][checkpointing] Decline checkpoints until restored channel state is consumed

2020-12-30 Thread GitBox
flinkbot commented on pull request #14525: URL: https://github.com/apache/flink/pull/14525#issuecomment-752393928 ## CI report: * bcea55b7456268ec59c829c2d8c1be41cf57bfcf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Comment Edited] (FLINK-16998) Add a changeflag to Row type

2020-12-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256401#comment-17256401 ] Till Rohrmann edited comment on FLINK-16998 at 12/30/20, 9:48 AM:

[jira] [Updated] (FLINK-20817) kafka source have 798 field,Causes the class to be generated failed

2020-12-30 Thread WeiNan Zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] WeiNan Zhao updated FLINK-20817: Summary: kafka source have 798 field,Causes the class to be generated failed (was: kafka source h

[jira] [Comment Edited] (FLINK-16998) Add a changeflag to Row type

2020-12-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256401#comment-17256401 ] Till Rohrmann edited comment on FLINK-16998 at 12/30/20, 9:49 AM:

[GitHub] [flink] wuchong commented on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-30 Thread GitBox
wuchong commented on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-752396868 As we still haven't started the review, I think it would be great if you can rebase and squash commits. This i

[jira] [Commented] (FLINK-20798) Using PVC as high-availability.storageDir could not work

2020-12-30 Thread hayden zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256416#comment-17256416 ] hayden zhou commented on FLINK-20798: - great thanks to [~fly_in_gis], so patiently t

[GitHub] [flink] flinkbot edited a comment on pull request #14525: (backport to 1.12) [FLINK-20654][checkpointing] Decline checkpoints until restored channel state is consumed

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14525: URL: https://github.com/apache/flink/pull/14525#issuecomment-752393928 ## CI report: * bcea55b7456268ec59c829c2d8c1be41cf57bfcf Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * f03a31c7c7f46424db160faaf4daf5e9fb1b672e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2020-12-30 Thread GitBox
HuangZhenQiu edited a comment on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-752331980 @xintongsong As we discussed offline, the TimestampBasedFailureRater is renamed to ThresholdMeter and moved to the metrics-core module. Please take a more round of

[GitHub] [flink] flinkbot edited a comment on pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324 ## CI report: * d083b630115604e34b0a74498890aedbff61b2a7 UNKNOWN * 70b43a088878601fa074245f88800b163641d6f0 Azure: [FAILURE](https://dev.azure.com/apache-flin

[GitHub] [flink] flinkbot edited a comment on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * f03a31c7c7f46424db160faaf4daf5e9fb1b672e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-20818) End to end test produce excessive amount of logs

2020-12-30 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20818: - Summary: End to end test produce excessive amount of logs Key: FLINK-20818 URL: https://issues.apache.org/jira/browse/FLINK-20818 Project: Flink Issue Type

[GitHub] [flink] flinkbot edited a comment on pull request #14523: [FLINK-18654][Connector][jdbc] Correct missleading documentation in "Partitioned Scan" section of JDBC connector

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14523: URL: https://github.com/apache/flink/pull/14523#issuecomment-752378982 ## CI report: * 92a553aed336c8fd2578bb99d69cb263dfa1d22e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20818) End to end test produce excessive amount of logs

2020-12-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256428#comment-17256428 ] Till Rohrmann commented on FLINK-20818: --- The problem seems to be that we are outpu

[jira] [Updated] (FLINK-20615) Local recovery and sticky scheduling end-to-end test timeout with "IOException: Stream Closed"

2020-12-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20615: -- Fix Version/s: 1.12.2 1.13.0 > Local recovery and sticky scheduling end-to-

[jira] [Commented] (FLINK-20801) Using asynchronous methods in operators causes serialization problems

2020-12-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256431#comment-17256431 ] Chesnay Schepler commented on FLINK-20801: -- No, async operations are relegated

[jira] [Updated] (FLINK-20615) Local recovery and sticky scheduling end-to-end test timeout with "IOException: Stream Closed"

2020-12-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20615: -- Priority: Critical (was: Major) > Local recovery and sticky scheduling end-to-end test timeou

[jira] [Commented] (FLINK-20615) Local recovery and sticky scheduling end-to-end test timeout with "IOException: Stream Closed"

2020-12-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256432#comment-17256432 ] Till Rohrmann commented on FLINK-20615: --- Another instance: https://dev.azure.com/

[GitHub] [flink] zentol merged pull request #14522: [FLINK-20807][build] Remove/narrow various checkstyle suppressions

2020-12-30 Thread GitBox
zentol merged pull request #14522: URL: https://github.com/apache/flink/pull/14522 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

[jira] [Closed] (FLINK-20807) Cleanup checkstyle suppressions files

2020-12-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-20807. Resolution: Fixed master: c04bc9e80fe0a03e422c0769a65f83e02c603e37 > Cleanup checkstyle s

[jira] [Commented] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

2020-12-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256437#comment-17256437 ] Jark Wu commented on FLINK-20777: - [~renqs], what's the behavior of current Kafka connec

[jira] [Commented] (FLINK-20817) kafka source have 798 field,Causes the class to be generated failed

2020-12-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256439#comment-17256439 ] Jark Wu commented on FLINK-20817: - A workaround would be upgrade to 1.11 where shouldn't

[GitHub] [flink] wuchong merged pull request #14523: [FLINK-18654][Connector][jdbc] Correct missleading documentation in "Partitioned Scan" section of JDBC connector

2020-12-30 Thread GitBox
wuchong merged pull request #14523: URL: https://github.com/apache/flink/pull/14523 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] [Closed] (FLINK-18654) Correct missleading documentation in "Partitioned Scan" section of JDBC connector

2020-12-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18654. --- Resolution: Fixed Fixed in master: 596bba9a7cda02ffae1606579ee016a58cf46a1d > Correct missleading documenta

[jira] [Updated] (FLINK-18654) Correct missleading documentation in "Partitioned Scan" section of JDBC connector

2020-12-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18654: Fix Version/s: (was: 1.11.4) > Correct missleading documentation in "Partitioned Scan" section of JDBC

[GitHub] [flink] flinkbot edited a comment on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * 671c2ee902f84118152ce4d038e548a23885e208 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20615) Local recovery and sticky scheduling end-to-end test timeout with "IOException: Stream Closed"

2020-12-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256444#comment-17256444 ] Till Rohrmann commented on FLINK-20615: --- Looking at the log output {code} [] - S

[GitHub] [flink] zentol commented on a change in pull request #14399: [FLINK-17827] [scala-shell] scala-shell.sh should fail early if no mo…

2020-12-30 Thread GitBox
zentol commented on a change in pull request #14399: URL: https://github.com/apache/flink/pull/14399#discussion_r550135003 ## File path: flink-scala-shell/start-script/start-scala-shell.sh ## @@ -86,11 +86,15 @@ if [[ ($MODE = "local") || ($MODE = "remote") ]] then LOG4J_

[GitHub] [flink-web] NitronR opened a new pull request #406: Minor grammar fixes

2020-12-30 Thread GitBox
NitronR opened a new pull request #406: URL: https://github.com/apache/flink-web/pull/406 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

[jira] [Updated] (FLINK-20615) Local recovery and sticky scheduling end-to-end test timeout with "IOException: Stream Closed"

2020-12-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20615: -- Component/s: Runtime / Task > Local recovery and sticky scheduling end-to-end test timeout wit

[jira] [Commented] (FLINK-20817) kafka source have 798 field,Causes the class to be generated failed

2020-12-30 Thread WeiNan Zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256448#comment-17256448 ] WeiNan Zhao commented on FLINK-20817: - Thanks for your reply > kafka source have 79

[GitHub] [flink] flinkbot edited a comment on pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324 ## CI report: * d083b630115604e34b0a74498890aedbff61b2a7 UNKNOWN * 70b43a088878601fa074245f88800b163641d6f0 Azure: [FAILURE](https://dev.azure.com/apache-flin

[GitHub] [flink] V1ncentzzZ edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-30 Thread GitBox
V1ncentzzZ edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751745476 @flinkbot run azure. This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN * f5f905df114b972534bcd8f701da5f73d067

[GitHub] [flink] SteNicholas commented on pull request #14464: [FLINK-20385][canal][json] Allow to read metadata for canal-json format

2020-12-30 Thread GitBox
SteNicholas commented on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-752421401 @wuchong Thanks for helping to beautify the format. I have set the time zone for the Canal JSON format metadata `ingestion-timestamp` to solve the Azure failure. Please help

[GitHub] [flink] flinkbot edited a comment on pull request #14464: [FLINK-20385][canal][json] Allow to read metadata for canal-json format

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461 ## CI report: * e81abd70d44d6ce7221d4cd2f44d31deab78ea9a UNKNOWN * 554e0a2c2ada42836d65397b163bad657806e8c2 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN * f5f905df114b972534bcd8f701da5f73d067

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

2020-12-30 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256466#comment-17256466 ] zoucao commented on FLINK-20811: hi [~xintongsong], I am OK, if [~nicholasjiang] would l

[jira] [Created] (FLINK-20819) flink : Connectors : JDBC test failing on Red Hat 8.x PowerPC Linux

2020-12-30 Thread Priya (Jira)
Priya created FLINK-20819: - Summary: flink : Connectors : JDBC test failing on Red Hat 8.x PowerPC Linux Key: FLINK-20819 URL: https://issues.apache.org/jira/browse/FLINK-20819 Project: Flink Issue

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

2020-12-30 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256472#comment-17256472 ] Nicholas Jiang commented on FLINK-20811: [~xintongsong][~fly_in_gis][~zoucao], I

[jira] [Comment Edited] (FLINK-20811) Support HTTP paths for yarn ship files/archives

2020-12-30 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256472#comment-17256472 ] Nicholas Jiang edited comment on FLINK-20811 at 12/30/20, 11:32 AM: --

[jira] [Comment Edited] (FLINK-20811) Support HTTP paths for yarn ship files/archives

2020-12-30 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256472#comment-17256472 ] Nicholas Jiang edited comment on FLINK-20811 at 12/30/20, 11:39 AM: --

[GitHub] [flink] V1ncentzzZ commented on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-30 Thread GitBox
V1ncentzzZ commented on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-752454853 @wuchong Finished. Thanks your for your reply. This is an automated message from the Apache Git Service. To r

[GitHub] [flink] flinkbot edited a comment on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * 671c2ee902f84118152ce4d038e548a23885e208 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14464: [FLINK-20385][canal][json] Allow to read metadata for canal-json format

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461 ## CI report: * e81abd70d44d6ce7221d4cd2f44d31deab78ea9a UNKNOWN * 3f3b88d98c525b635179b6a9098a2634a1ffb42c Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN * f5f905df114b972534bcd8f701da5f73d067

[jira] [Closed] (FLINK-20817) kafka source have 798 field,Causes the class to be generated failed

2020-12-30 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20817. --- Resolution: Won't Fix > kafka source have 798 field,Causes the class to be generated failed > --

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

2020-12-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256483#comment-17256483 ] Xintong Song commented on FLINK-20811: -- [~ZhenqiuHuang] and I had a offline discuss

[jira] [Comment Edited] (FLINK-20811) Support HTTP paths for yarn ship files/archives

2020-12-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256483#comment-17256483 ] Xintong Song edited comment on FLINK-20811 at 12/30/20, 11:57 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * 671c2ee902f84118152ce4d038e548a23885e208 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14464: [FLINK-20385][canal][json] Allow to read metadata for canal-json format

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461 ## CI report: * e81abd70d44d6ce7221d4cd2f44d31deab78ea9a UNKNOWN * 3f3b88d98c525b635179b6a9098a2634a1ffb42c Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-30 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN * f5f905df114b972534bcd8f701da5f73d067

[GitHub] [flink] zentol merged pull request #14519: [FLINK-20790][build][avro] Move generated files to target/generated[-test]-sources

2020-12-30 Thread GitBox
zentol merged pull request #14519: URL: https://github.com/apache/flink/pull/14519 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

[jira] [Closed] (FLINK-20790) Generated classes should not be put under src/ directory

2020-12-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-20790. Resolution: Fixed master: 824a3f3cd3bcbc717c73afc82c01826993e55323 > Generated classes sh

[jira] [Updated] (FLINK-20790) Generated classes should not be put under src/ directory

2020-12-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-20790: - Fix Version/s: 1.13.0 > Generated classes should not be put under src/ directory > -

[jira] [Updated] (FLINK-20790) Generated classes should not be put under src/ directory

2020-12-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-20790: - Issue Type: Improvement (was: Bug) > Generated classes should not be put under src/ dir

[jira] [Updated] (FLINK-20798) Using PVC as high-availability.storageDir could not work

2020-12-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20798: -- Description: 我这边 部署 flink 到 k8s 使用 PVC 作为 high avalibility storagedir , 我看jobmanager 的日志,选举成功

[jira] [Commented] (FLINK-20798) Using PVC as high-availability.storageDir could not work

2020-12-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256494#comment-17256494 ] Till Rohrmann commented on FLINK-20798: --- Does the wrongly configured {{kubernetes.

[jira] [Commented] (FLINK-20808) Remove redundant checkstyle rules

2020-12-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256495#comment-17256495 ] Chesnay Schepler commented on FLINK-20808: -- >From what I could tell so far, we

[GitHub] [flink] tillrohrmann commented on a change in pull request #14520: [FLINK-20805][table][build] Remove spotless exclusion for "generated" files

2020-12-30 Thread GitBox
tillrohrmann commented on a change in pull request #14520: URL: https://github.com/apache/flink/pull/14520#discussion_r550178388 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/generated/AggsHandleFunction.java ## @@ -30,9 +30,1

  1   2   3   >