[GitHub] [flink] tianon commented on pull request #14630: [FLINK-20915][docker] Move docker entrypoint to distribution

2021-01-15 Thread GitBox
tianon commented on pull request #14630: URL: https://github.com/apache/flink/pull/14630#issuecomment-761165429 I agree that the Docker image being a complete black box is a bad thing, which is exactly why I'm confused by this PR. Let me try to rephrase what I'm suggesting: Take a

[GitHub] [flink] flinkbot edited a comment on pull request #14594: [FLINK-20551][docs] Make SQL documentation Blink only

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14594: URL: https://github.com/apache/flink/pull/14594#issuecomment-756890853 ## CI report: * 2062801ba381ee60fedb9c8ce07b6000dd485ab7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14619: [FLINK-20862][table] Support creating DataType from TypeInformation

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14619: URL: https://github.com/apache/flink/pull/14619#issuecomment-758635914 ## CI report: * 421fbf52f2ec18801b430ddeec0be5332a56788f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14594: [FLINK-20551][docs] Make SQL documentation Blink only

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14594: URL: https://github.com/apache/flink/pull/14594#issuecomment-756890853 ## CI report: * bdfba9d2127fd0f843c3d57a953decec82eb15ff Azure:

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

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14610: URL: https://github.com/apache/flink/pull/14610#issuecomment-758033846 ## CI report: * 384aa1d095bc02c376ec2a0af43501a19e2a81ef Azure:

[jira] [Created] (FLINK-20996) Using a cryptographically weak Pseudo Random Number Generator (PRNG)

2021-01-15 Thread Ya Xiao (Jira)
Ya Xiao created FLINK-20996: --- Summary: Using a cryptographically weak Pseudo Random Number Generator (PRNG) Key: FLINK-20996 URL: https://issues.apache.org/jira/browse/FLINK-20996 Project: Flink

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

2021-01-15 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17266490#comment-17266490 ] Huang Xingbo commented on FLINK-20329: --

[GitHub] [flink] flinkbot edited a comment on pull request #14666: [FLINK-17085][kubernetes] Remove FlinkKubeClient.handleException

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14666: URL: https://github.com/apache/flink/pull/14666#issuecomment-760926129 ## CI report: * 8dc1342fec505ced26932fae17a394b456b2dac2 Azure:

[jira] [Commented] (FLINK-19519) Add support for port range in taskmanager.data.port

2021-01-15 Thread Truong Duc Kien (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17266472#comment-17266472 ] Truong Duc Kien commented on FLINK-19519: - Sure. I'll do it. > Add support for port range in

[jira] [Updated] (FLINK-20996) Using a cryptographically weak Pseudo Random Number Generator (PRNG)

2021-01-15 Thread Ya Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ya Xiao updated FLINK-20996: Description: We are a security research team at Virginia Tech. We are doing an empirical study about the

[jira] [Commented] (FLINK-20990) Service account property ignored for Kubernetes Standalone deployment

2021-01-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17266513#comment-17266513 ] Yang Wang commented on FLINK-20990: --- Thanks for sharing the result. I believe it could also help

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

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14610: URL: https://github.com/apache/flink/pull/14610#issuecomment-758033846 ## CI report: * 384aa1d095bc02c376ec2a0af43501a19e2a81ef Azure:

[jira] [Commented] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-15 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265793#comment-17265793 ] Yun Gao commented on FLINK-20972: - The core issue seems to me is that since TwoPhaseOutputCommit is a

[GitHub] [flink] twalthr opened a new pull request #14660: [FLINK-20883][table-api-java] Support calling SQL expressions in Table API

2021-01-15 Thread GitBox
twalthr opened a new pull request #14660: URL: https://github.com/apache/flink/pull/14660 ## What is the purpose of the change This supports calling SQL expressions in Table API. It introduces `callSql` which can be used as a regular scalar expression. ## Brief change log

[GitHub] [flink] rmetzger merged pull request #14450: [FLINK-19971][hbase] Fix HBase connector dependencies

2021-01-15 Thread GitBox
rmetzger merged pull request #14450: URL: https://github.com/apache/flink/pull/14450 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] [Assigned] (FLINK-19971) flink-connector-hbase-base depends on hbase-server, instead of hbase-client

2021-01-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-19971: -- Assignee: Miklos Gergely > flink-connector-hbase-base depends on hbase-server,

[jira] [Commented] (FLINK-20833) Expose pluggable interface for exception analysis and metrics reporting in Execution Graph

2021-01-15 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265795#comment-17265795 ] Zhenqiu Huang commented on FLINK-20833: --- [~rmetzger] Thanks for these suggestions. 1) I think the

[jira] [Updated] (FLINK-19971) flink-connector-hbase-base depends on hbase-server, instead of hbase-client

2021-01-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19971: --- Fix Version/s: 1.13.0 > flink-connector-hbase-base depends on hbase-server, instead of

[jira] [Closed] (FLINK-19971) flink-connector-hbase-base depends on hbase-server, instead of hbase-client

2021-01-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-19971. -- Resolution: Fixed Merged to master in

[GitHub] [flink] flinkbot commented on pull request #14660: [FLINK-20883][table-api-java] Support calling SQL expressions in Table API

2021-01-15 Thread GitBox
flinkbot commented on pull request #14660: URL: https://github.com/apache/flink/pull/14660#issuecomment-760725035 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 #14621: [FLINK-20933][python] Config Python Operator Use Managed Memory In Python DataStream

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14621: URL: https://github.com/apache/flink/pull/14621#issuecomment-75873 ## CI report: * dab22fa1d5e18201415322cbd928767223258e16 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14645: [FLINK-20967][docs] HBase properties 'properties.*' function Description

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14645: URL: https://github.com/apache/flink/pull/14645#issuecomment-760128893 ## CI report: * 130e09ba6abaec1b647f89fed3aee7bb364977da Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14640: [FLINK-20937][Table API/SQL]Drop table can fails, when i create a tab…

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14640: URL: https://github.com/apache/flink/pull/14640#issuecomment-760055828 ## CI report: * 17ac8f48c293e42e7c5e63c1724112048fc57827 Azure:

[jira] [Reopened] (FLINK-20906) Update copyright year to 2021 for NOTICE files

2021-01-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-20906: -- Reopen for 1.10 branch. > Update copyright year to 2021 for NOTICE files >

[jira] [Updated] (FLINK-20906) Update copyright year to 2021 for NOTICE files

2021-01-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20906: - Fix Version/s: 1.11.3 > Update copyright year to 2021 for NOTICE files >

[jira] [Commented] (FLINK-6042) Display last n exceptions/causes for job restarts in Web UI

2021-01-15 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265799#comment-17265799 ] Matthias commented on FLINK-6042: - {quote}Thanks for the proposal [~mapohl]. I have a few comments 1)

[jira] [Comment Edited] (FLINK-20833) Expose pluggable interface for exception analysis and metrics reporting in Execution Graph

2021-01-15 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265795#comment-17265795 ] Zhenqiu Huang edited comment on FLINK-20833 at 1/15/21, 8:07 AM: -

[GitHub] [flink] xintongsong opened a new pull request #14661: [FLINK-20906][legal] Update copyright year to 2021 for NOTICE files.

2021-01-15 Thread GitBox
xintongsong opened a new pull request #14661: URL: https://github.com/apache/flink/pull/14661 ## 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

[jira] [Comment Edited] (FLINK-6042) Display last n exceptions/causes for job restarts in Web UI

2021-01-15 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265799#comment-17265799 ] Matthias edited comment on FLINK-6042 at 1/15/21, 8:08 AM: --- {quote}Thanks for

[jira] [Comment Edited] (FLINK-6042) Display last n exceptions/causes for job restarts in Web UI

2021-01-15 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265799#comment-17265799 ] Matthias edited comment on FLINK-6042 at 1/15/21, 8:09 AM: --- {quote}Thanks for

[jira] [Comment Edited] (FLINK-6042) Display last n exceptions/causes for job restarts in Web UI

2021-01-15 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265799#comment-17265799 ] Matthias edited comment on FLINK-6042 at 1/15/21, 8:09 AM: --- {quote}Thanks for

[GitHub] [flink] flinkbot commented on pull request #14661: [FLINK-20906][legal] Update copyright year to 2021 for NOTICE files.

2021-01-15 Thread GitBox
flinkbot commented on pull request #14661: URL: https://github.com/apache/flink/pull/14661#issuecomment-760732637 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-18280) Kotlin adapters for Flink types?

2021-01-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265803#comment-17265803 ] Robert Metzger commented on FLINK-18280: Cool! Thanks for sharing. I would recommend you to

[jira] [Commented] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-15 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265802#comment-17265802 ] Yun Gao commented on FLINK-20972: - And one more point, might be unrelated to this issue, is that to

[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-15 Thread GitBox
xiaoHoly commented on a change in pull request #14531: URL: https://github.com/apache/flink/pull/14531#discussion_r558004634 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java ## @@ -108,6 +108,15 @@

[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-15 Thread GitBox
xiaoHoly commented on a change in pull request #14531: URL: https://github.com/apache/flink/pull/14531#discussion_r558006111 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceITCase.java ## @@ -82,6 +82,57 @@

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

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14621: URL: https://github.com/apache/flink/pull/14621#issuecomment-75873 ## CI report: * dab22fa1d5e18201415322cbd928767223258e16 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14640: [FLINK-20937][Table API/SQL]Drop table can fails, when i create a tab…

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14640: URL: https://github.com/apache/flink/pull/14640#issuecomment-760055828 ## CI report: * 17ac8f48c293e42e7c5e63c1724112048fc57827 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14652: [FLINK-20953][canal][json] Option 'canal-json.database.include' and 'canal-json.table.include' support regular expression

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14652: URL: https://github.com/apache/flink/pull/14652#issuecomment-760296852 ## CI report: * 72601d907bc02eb3b74499a36f15f713406d911c Azure:

[GitHub] [flink] flinkbot commented on pull request #14660: [FLINK-20883][table-api-java] Support calling SQL expressions in Table API

2021-01-15 Thread GitBox
flinkbot commented on pull request #14660: URL: https://github.com/apache/flink/pull/14660#issuecomment-760748649 ## CI report: * 08a9fff38a4698b216fbc9cd5c25c7875db0e827 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14661: [FLINK-20906][legal] Update copyright year to 2021 for NOTICE files.

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

[GitHub] [flink] wuchong merged pull request #14645: [FLINK-20967][docs] HBase properties 'properties.*' function Description

2021-01-15 Thread GitBox
wuchong merged pull request #14645: URL: https://github.com/apache/flink/pull/14645 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] twalthr commented on a change in pull request #14594: [FLINK-20551][docs] Make SQL documentation Blink only

2021-01-15 Thread GitBox
twalthr commented on a change in pull request #14594: URL: https://github.com/apache/flink/pull/14594#discussion_r558006245 ## File path: docs/dev/table/common.md ## @@ -116,173 +106,119 @@ table_result... -**Note:** Table API and SQL queries can be easily integrated

[GitHub] [flink] dixingxing0 commented on pull request #14634: [FLINK-20913][hive]Improve HiveConf creation

2021-01-15 Thread GitBox
dixingxing0 commented on pull request #14634: URL: https://github.com/apache/flink/pull/14634#issuecomment-760749497 > Thanks @dixingxing0 for working on this. I've left some comments. Thanks for the comments, I will address them.

[jira] [Commented] (FLINK-20833) Expose pluggable interface for exception analysis and metrics reporting in Execution Graph

2021-01-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265814#comment-17265814 ] Robert Metzger commented on FLINK-20833: Thanks a lot for providing a PoC! This makes the

[GitHub] [flink] dixingxing0 edited a comment on pull request #14634: [FLINK-20913][hive]Improve HiveConf creation

2021-01-15 Thread GitBox
dixingxing0 edited a comment on pull request #14634: URL: https://github.com/apache/flink/pull/14634#issuecomment-760749497 > Thanks @dixingxing0 for working on this. I've left some comments. Thanks for the comments, I'am addressing them.

[GitHub] [flink] dixingxing0 edited a comment on pull request #14634: [FLINK-20913][hive]Improve HiveConf creation

2021-01-15 Thread GitBox
dixingxing0 edited a comment on pull request #14634: URL: https://github.com/apache/flink/pull/14634#issuecomment-760749497 > Thanks @dixingxing0 for working on this. I've left some comments. Thanks for the comments, I'am addressing them.

[jira] [Closed] (FLINK-20967) Add documentation for the new introduced 'properties.*' option in HBase connector

2021-01-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20967. --- Resolution: Fixed Fixed in master: ee1453cd96cfc0b9633677ff2f514bd7b9feffdb > Add documentation for the

[jira] [Updated] (FLINK-20886) Add the option to get a threaddump on checkpoint timeouts

2021-01-15 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-20886: Labels: usability (was: ) > Add the option to get a threaddump on checkpoint timeouts >

[jira] [Commented] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-15 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265817#comment-17265817 ] huajiewang commented on FLINK-20972: [~gaoyunhaii] What you said is reasonable, but in my opinion,

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

2021-01-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-20728: - Assignee: Jianyun Zhao > Pulsar SinkFunction > --- > >

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

2021-01-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20728: -- Fix Version/s: 1.13.0 > Pulsar SinkFunction > --- > > Key:

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

2021-01-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-20727: - Assignee: Jianyun Zhao > Pulsar SourceFunction > - > >

[jira] [Updated] (FLINK-20726) Introduce Pulsar connector

2021-01-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20726: -- Fix Version/s: 1.13.0 > Introduce Pulsar connector > -- > >

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

2021-01-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20727: -- Fix Version/s: 1.13.0 > Pulsar SourceFunction > - > >

[jira] [Assigned] (FLINK-20726) Introduce Pulsar connector

2021-01-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-20726: - Assignee: Jianyun Zhao > Introduce Pulsar connector > -- > >

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-15 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265817#comment-17265817 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 8:39 AM: --

[GitHub] [flink] xintongsong closed pull request #14661: [FLINK-20906][legal] Update copyright year to 2021 for NOTICE files.

2021-01-15 Thread GitBox
xintongsong closed pull request #14661: URL: https://github.com/apache/flink/pull/14661 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] xintongsong commented on pull request #14661: [FLINK-20906][legal] Update copyright year to 2021 for NOTICE files.

2021-01-15 Thread GitBox
xintongsong commented on pull request #14661: URL: https://github.com/apache/flink/pull/14661#issuecomment-760755365 Closed via 6e38231d62d3d623c59b1cbac1135cf3b03d4031 This is an automated message from the Apache Git

[jira] [Commented] (FLINK-20726) Introduce Pulsar connector

2021-01-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265821#comment-17265821 ] Till Rohrmann commented on FLINK-20726: --- Hi [~Jianyun Zhao], I've given you access rights to edit

[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-15 Thread GitBox
xiaoHoly commented on pull request #14616: URL: https://github.com/apache/flink/pull/14616#issuecomment-760755775 It looks like the build was successful This is an automated message from the Apache Git Service. To respond

[jira] [Closed] (FLINK-20906) Update copyright year to 2021 for NOTICE files

2021-01-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20906. Resolution: Fixed Merged via * master (1.13): 67d167ccd45046fc5ed222ac1f1e3ba5e6ec434b *

[jira] [Updated] (FLINK-20906) Update copyright year to 2021 for NOTICE files

2021-01-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20906: - Fix Version/s: (was: 1.11.3) 1.10.3 > Update copyright year to 2021 for

[GitHub] [flink] Myasuka opened a new pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

2021-01-15 Thread GitBox
Myasuka opened a new pull request #14662: URL: https://github.com/apache/flink/pull/14662 ## What is the purpose of the change Compared with https://github.com/apache/flink/pull/14656, this PR add another commit to refactor interfaces to decline checkpoint with

[jira] [Updated] (FLINK-20986) GenericTypeInfo equality issue

2021-01-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20986: --- Component/s: (was: Runtime / REST) > GenericTypeInfo equality issue >

[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-15 Thread GitBox
flinkbot edited a comment on pull request #14616: URL: https://github.com/apache/flink/pull/14616#issuecomment-758526377 ## CI report: * 448c026a402e045e050f405daf934a8a7c880c9d UNKNOWN * 043d57501a1c07d476e7b9490faa066eb947a98f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14627: [FLINK-20946][python] Optimize Python ValueState Implementation In PyFlink

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14627: URL: https://github.com/apache/flink/pull/14627#issuecomment-759272918 ## CI report: * 293b8ca01400d911925460a29cc8d2bfb41a8522 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14637: [FLINK-20949][table-planner-blink] Separate the implementation of sink nodes

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14637: URL: https://github.com/apache/flink/pull/14637#issuecomment-759980085 ## CI report: * 640270670c3ce146147fa7f0fd0f7305d8aa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14656: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14656: URL: https://github.com/apache/flink/pull/14656#issuecomment-760627740 ## CI report: * 6cb6c9f2ed48920003bc7c51a785b154eed31ff7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14652: [FLINK-20953][canal][json] Option 'canal-json.database.include' and 'canal-json.table.include' support regular expression

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14652: URL: https://github.com/apache/flink/pull/14652#issuecomment-760296852 ## CI report: * 72601d907bc02eb3b74499a36f15f713406d911c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14660: [FLINK-20883][table-api-java] Support calling SQL expressions in Table API

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14660: URL: https://github.com/apache/flink/pull/14660#issuecomment-760748649 ## CI report: * 08a9fff38a4698b216fbc9cd5c25c7875db0e827 Azure:

[GitHub] [flink] flinkbot commented on pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

2021-01-15 Thread GitBox
flinkbot commented on pull request #14662: URL: https://github.com/apache/flink/pull/14662#issuecomment-760759671 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-20959) How to close Apache Flink REST API

2021-01-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265826#comment-17265826 ] Robert Metzger commented on FLINK-20959: I believe Chesnay posted the wrong Jira ID. I guess he

[jira] [Updated] (FLINK-16478) add restApi to modify loglevel

2021-01-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-16478: -- Priority: Major (was: Minor) > add restApi to modify loglevel >

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

2021-01-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265831#comment-17265831 ] Robert Metzger commented on FLINK-20944: [~fly_in_gis] are you taking care of this issue? >

[GitHub] [flink] wenlong88 opened a new pull request #14663: [FLINK-20925][table-planner-blink] Separate implemention of StreamExecLookupJoin and BatchExecLookupJoin

2021-01-15 Thread GitBox
wenlong88 opened a new pull request #14663: URL: https://github.com/apache/flink/pull/14663 ## What is the purpose of the change Separate the implementation of StreamExecLookupJoin and BatchExecLookupJoin. ## Brief change log Introduce StreamPhysicalLookupJoin and

[jira] [Updated] (FLINK-20925) Separate the implementation of StreamExecLookup and BatchExecLookup

2021-01-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20925: --- Labels: pull-request-available (was: ) > Separate the implementation of StreamExecLookup

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

2021-01-15 Thread GitBox
wuchong merged pull request #14616: URL: https://github.com/apache/flink/pull/14616 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-20879) Use MemorySize type instead of String type for memory ConfigOption in ExecutionConfigOptions

2021-01-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20879. --- Resolution: Fixed Fixed in master: bfb8d6866f5a19a12a1a7e46ff0fe615110a7fd6 > Use MemorySize type instead

[GitHub] [flink] flinkbot commented on pull request #14663: [FLINK-20925][table-planner-blink] Separate implemention of StreamExecLookupJoin and BatchExecLookupJoin

2021-01-15 Thread GitBox
flinkbot commented on pull request #14663: URL: https://github.com/apache/flink/pull/14663#issuecomment-760764364 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] lingya commented on a change in pull request #14271: [FLINK-12130][clients] Apply command line options to configuration be…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14652: [FLINK-20953][canal][json] Option 'canal-json.database.include' and 'canal-json.table.include' support regular expression

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14652: URL: https://github.com/apache/flink/pull/14652#issuecomment-760296852 ## CI report: * 72601d907bc02eb3b74499a36f15f713406d911c Azure:

[GitHub] [flink] flinkbot commented on pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

2021-01-15 Thread GitBox
flinkbot commented on pull request #14662: URL: https://github.com/apache/flink/pull/14662#issuecomment-760769285 ## CI report: * 83d11e2d31f495d56a0566c95f5d1045ae5ef0c3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] godfreyhe opened a new pull request #14664: [FLINK-20989][table-planner-blink] Functions in ExplodeFunctionUtil should handle null data to avoid NPE

2021-01-15 Thread GitBox
godfreyhe opened a new pull request #14664: URL: https://github.com/apache/flink/pull/14664 ## What is the purpose of the change *The following test case will encounter NPE: val t = tEnv.fromValues( DataTypes.ROW( DataTypes.FIELD("a",

[GitHub] [flink] flinkbot commented on pull request #14663: [FLINK-20925][table-planner-blink] Separate implemention of StreamExecLookupJoin and BatchExecLookupJoin

2021-01-15 Thread GitBox
flinkbot commented on pull request #14663: URL: https://github.com/apache/flink/pull/14663#issuecomment-760769392 ## CI report: * 1bac0fae97e00f2c2f5b2d9b0ad7f1ae97845804 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-20989) Functions in ExplodeFunctionUtil should handle null data to avoid NPE

2021-01-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20989: --- Labels: pull-request-available (was: ) > Functions in ExplodeFunctionUtil should handle

[jira] [Updated] (FLINK-20989) Functions in ExplodeFunctionUtil should handle null data to avoid NPE

2021-01-15 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-20989: --- Description: The following test case will encounter NPE: {code:scala} val t = tEnv.fromValues(

[GitHub] [flink] rmetzger merged pull request #14650: [FLINK-20927][yarn] Update configuration option in YarnConfigOptions class

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

[GitHub] [flink] flinkbot commented on pull request #14664: [FLINK-20989][table-planner-blink] Functions in ExplodeFunctionUtil should handle null data to avoid NPE

2021-01-15 Thread GitBox
flinkbot commented on pull request #14664: URL: https://github.com/apache/flink/pull/14664#issuecomment-760770600 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-20927) Update configuration option in YarnConfigOptions class

2021-01-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265847#comment-17265847 ] Robert Metzger commented on FLINK-20927: Merged to master in

[jira] [Updated] (FLINK-20989) Functions in ExplodeFunctionUtil should handle null data to avoid NPE

2021-01-15 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-20989: --- Description: The following test case will encounter NPE: {code:scala} val t = tEnv.fromValues(

[jira] [Closed] (FLINK-20927) Update configuration option in YarnConfigOptions class

2021-01-15 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-20927. -- Resolution: Fixed > Update configuration option in YarnConfigOptions class >

[GitHub] [flink] godfreyhe commented on pull request #14664: [FLINK-20989][table-planner-blink] Functions in ExplodeFunctionUtil should handle null data to avoid NPE

2021-01-15 Thread GitBox
godfreyhe commented on pull request #14664: URL: https://github.com/apache/flink/pull/14664#issuecomment-760770939 cc @wuchong This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Commented] (FLINK-6042) Display last n exceptions/causes for job restarts in Web UI

2021-01-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265851#comment-17265851 ] Till Rohrmann commented on FLINK-6042: -- Any signature change to {{AccessExecutionGraph}} needed to

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

2021-01-15 Thread GitBox
xiaoHoly commented on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-760774148 Hi,@becketqin .I have completed the addition of the unit test ,please take a look when you hava spare cycle

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

2021-01-15 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-20659: Assignee: Matthias > YARNSessionCapacitySchedulerITCase.perJobYarnClusterOffHeap test failed

[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-15 Thread GitBox
flinkbot edited a comment on pull request #14530: URL: https://github.com/apache/flink/pull/14530#issuecomment-752828495 ## CI report: * eaa0445691254f544c231ec0d2d55519af277b33 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-15 Thread GitBox
flinkbot edited a comment on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-752828536 ## CI report: * 638cd231fef2a3a5b866cf1d9e07884ead445c07 Azure:

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

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14621: URL: https://github.com/apache/flink/pull/14621#issuecomment-75873 ## CI report: * e0aa9de7e35bc1ac79a3d938454a9b5368445c69 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14662: [FLINK-20675][checkpointing] Ensure asynchronous checkpoint failure could fail the job by default

2021-01-15 Thread GitBox
flinkbot edited a comment on pull request #14662: URL: https://github.com/apache/flink/pull/14662#issuecomment-760769285 ## CI report: * 83d11e2d31f495d56a0566c95f5d1045ae5ef0c3 Azure:

  1   2   3   4   >