[GitHub] [flink] wuchong commented on pull request #14309: [FLINK-20485][table] Improve performance of data views

2020-12-06 Thread GitBox
wuchong commented on pull request #14309: URL: https://github.com/apache/flink/pull/14309#issuecomment-739735113 cc @JingsongLi , do you want to have a look? This is an automated message from the Apache Git Service. To respon

[jira] [Created] (FLINK-20507) Support Aggregate Operation in Python Table API

2020-12-06 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20507: Summary: Support Aggregate Operation in Python Table API Key: FLINK-20507 URL: https://issues.apache.org/jira/browse/FLINK-20507 Project: Flink Issue Type: S

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

2020-12-06 Thread GitBox
xintongsong edited a comment on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-739733015 Thanks for the PR, @HuangZhenQiu. Before diving into the implementation details, I'd like to have some more high level discussions, concerning the problem we want to

[GitHub] [flink] flinkbot edited a comment on pull request #14317: [FLINK-20482][python] Support General Python UDF for Map Operation in Python Table API

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

[GitHub] [flink] flinkbot edited a comment on pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

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

[GitHub] [flink] flinkbot edited a comment on pull request #14316: [FLINK-20470]MissingNode can't be casted to ObjectNode when deserializing JSON

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

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

2020-12-06 Thread GitBox
xintongsong commented on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-739733015 Thanks for the PR, @HuangZhenQiu. Before dive into the implementation details, I'd like to have some more high level discussions, concerning the problem we want to solve and

[GitHub] [flink] shuiqiangchen commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-06 Thread GitBox
shuiqiangchen commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r537286597 ## File path: docs/deployment/resource-providers/standalone/docker.md ## @@ -352,6 +352,27 @@ as described in [how to run the Flink image](#how-to-

[GitHub] [flink] shuiqiangchen commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-06 Thread GitBox
shuiqiangchen commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r537286597 ## File path: docs/deployment/resource-providers/standalone/docker.md ## @@ -352,6 +352,27 @@ as described in [how to run the Flink image](#how-to-

[jira] [Updated] (FLINK-20506) Support FlatMap Operation in Python Table API

2020-12-06 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-20506: - Description: Support Python UDTF for FlatMap Operation in Python Table API The usage: {code:jav

[GitHub] [flink] leonardBang commented on pull request #14267: [FLINK-20429][kafka] Using proper watermark interval in KafkaTableITCase.testKafkaTemporalJoinChangelog test

2020-12-06 Thread GitBox
leonardBang commented on pull request #14267: URL: https://github.com/apache/flink/pull/14267#issuecomment-739730115 Thanks @wuchong for the review, I've rebased This is an automated message from the Apache Git Service. To r

[jira] [Created] (FLINK-20506) Support FlatMap Operation in Python Table API

2020-12-06 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20506: Summary: Support FlatMap Operation in Python Table API Key: FLINK-20506 URL: https://issues.apache.org/jira/browse/FLINK-20506 Project: Flink Issue Type: Sub

[GitHub] [flink] leonardBang commented on pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-06 Thread GitBox
leonardBang commented on pull request #14310: URL: https://github.com/apache/flink/pull/14310#issuecomment-739727317 I've updated and Rebased This is an automated message from the Apache Git Service. To respond to the message

[GitHub] [flink] shuiqiangchen commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-06 Thread GitBox
shuiqiangchen commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r537282915 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,244 @@ specific language governing permissions and limitatio

[GitHub] [flink] flinkbot commented on pull request #14317: [FLINK-20482][python] Support General Python UDF for Map Operation in Python Table API

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

[GitHub] [flink] flinkbot commented on pull request #14316: [FLINK-20470]MissingNode can't be casted to ObjectNode when deserializing JSON

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

[GitHub] [flink] flinkbot edited a comment on pull request #14245: [FLINK-18897][doc] Add document for Maxwell format

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

[GitHub] [flink] leonardBang commented on a change in pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-06 Thread GitBox
leonardBang commented on a change in pull request #14310: URL: https://github.com/apache/flink/pull/14310#discussion_r537276200 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveLookupTableSource.java ## @@ -114,16 +117,16 @

[GitHub] [flink] leonardBang commented on a change in pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-06 Thread GitBox
leonardBang commented on a change in pull request #14310: URL: https://github.com/apache/flink/pull/14310#discussion_r537222451 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveLookupTableSource.java ## @@ -114,16 +117,16 @

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

2020-12-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245011#comment-17245011 ] Xintong Song commented on FLINK-20505: -- [~zoucao], BTW, I've assigned myself to thi

[GitHub] [flink] fsk119 commented on pull request #14245: [FLINK-18897][doc] Add document for Maxwell format

2020-12-06 Thread GitBox
fsk119 commented on pull request #14245: URL: https://github.com/apache/flink/pull/14245#issuecomment-739718086 The new tab page in mawell doc now: ![image](https://user-images.githubusercontent.com/33114724/101319983-dc2eaf00-389d-11eb-806a-42c3e8ed44ef.png) --

[GitHub] [flink] flinkbot commented on pull request #14317: [FLINK-20482][python] Support General Python UDF for Map Operation in Python Table API

2020-12-06 Thread GitBox
flinkbot commented on pull request #14317: URL: https://github.com/apache/flink/pull/14317#issuecomment-739715415 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-20482) Support General Python UDF for Map Operation in Python Table API

2020-12-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20482: --- Labels: pull-request-available (was: ) > Support General Python UDF for Map Operation in Py

[GitHub] [flink] HuangXingBo opened a new pull request #14317: [FLINK-20482][python] Support General Python UDF for Map Operation in Python Table API

2020-12-06 Thread GitBox
HuangXingBo opened a new pull request #14317: URL: https://github.com/apache/flink/pull/14317 ## What is the purpose of the change *This pull request will support General Python UDF for Map Operation in Python Table API* ## Brief change log - *Add rewrite rule `Py

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

2020-12-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244999#comment-17244999 ] Xintong Song commented on FLINK-20505: -- Thanks for the replies, [~ZhenqiuHuang] and

[GitHub] [flink] flinkbot edited a comment on pull request #14245: [FLINK-18897][doc] Add document for Maxwell format

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

[GitHub] [flink] wangyang0918 commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-06 Thread GitBox
wangyang0918 commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r537270214 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,269 @@ specific language governing permissions and limitation

[jira] [Commented] (FLINK-20480) Methods from CheckpointedFunction interface in FlinkKafkaConsumerBase are set to final

2020-12-06 Thread lidesheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244997#comment-17244997 ] lidesheng commented on FLINK-20480: --- I think setting {{CheckpointedFunction}} interfac

[GitHub] [flink] wangyang0918 commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-06 Thread GitBox
wangyang0918 commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r537268317 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,244 @@ specific language governing permissions and limitation

[GitHub] [flink] flinkbot commented on pull request #14316: [FLINK-20470]MissingNode can't be casted to ObjectNode when deserializing JSON

2020-12-06 Thread GitBox
flinkbot commented on pull request #14316: URL: https://github.com/apache/flink/pull/14316#issuecomment-739709029 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] wangyang0918 commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-06 Thread GitBox
wangyang0918 commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r537267418 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,244 @@ specific language governing permissions and limitation

[jira] [Updated] (FLINK-20470) MissingNode can't be casted to ObjectNode when deserializing JSON

2020-12-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20470: --- Labels: pull-request-available (was: ) > MissingNode can't be casted to ObjectNode when des

[GitHub] [flink] zhuxiaoshang opened a new pull request #14316: [FLINK-20470]MissingNode can't be casted to ObjectNode when deserializing JSON

2020-12-06 Thread GitBox
zhuxiaoshang opened a new pull request #14316: URL: https://github.com/apache/flink/pull/14316 ## What is the purpose of the change *add check for MissingNode when deserializing JSON* ## Brief change log - *add check for MissingNode when deserializing JSON*

[GitHub] [flink] V1ncentzzZ commented on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-06 Thread GitBox
V1ncentzzZ commented on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-739702396 @godfreyhe Help to review it. This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [flink] flinkbot edited a comment on pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

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

[GitHub] [flink] flinkbot edited a comment on pull request #14245: [FLINK-18897][doc] Add document for Maxwell format

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

[GitHub] [flink] lirui-apache commented on a change in pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-06 Thread GitBox
lirui-apache commented on a change in pull request #14310: URL: https://github.com/apache/flink/pull/14310#discussion_r537258582 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveLookupTableSource.java ## @@ -114,16 +117,16

[jira] [Commented] (FLINK-20470) MissingNode can't be casted to ObjectNode when deserializing JSON

2020-12-06 Thread zhuxiaoshang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244976#comment-17244976 ] zhuxiaoshang commented on FLINK-20470: -- [~jark],The legacy  JsonRowDeserializationS

[jira] [Closed] (FLINK-20494) SQLClientHBaseITCase Task Timeout

2020-12-06 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo closed FLINK-20494. Resolution: Won't Fix > SQLClientHBaseITCase Task Timeout > - > >

[jira] [Commented] (FLINK-20494) SQLClientHBaseITCase Task Timeout

2020-12-06 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244969#comment-17244969 ] Huang Xingbo commented on FLINK-20494: -- [~Leonard Xu] Thanks a lot for your investi

[GitHub] [flink] wuchong commented on a change in pull request #14245: [FLINK-18897][doc] Add document for Maxwell format

2020-12-06 Thread GitBox
wuchong commented on a change in pull request #14245: URL: https://github.com/apache/flink/pull/14245#discussion_r537226135 ## File path: docs/dev/table/connectors/formats/maxwell.md ## @@ -0,0 +1,212 @@ +--- +title: "Maxwell Format" +nav-title: Maxwell +nav-parent_id: sql-form

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

2020-12-06 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244964#comment-17244964 ] zoucao commented on FLINK-20505: hi xintong, I reported this problem in  user-zh. Thanks

[GitHub] [flink] SteNicholas commented on pull request #14207: [FLINK-20250][table-runtime] NPE when invoking AsyncLookupJoinRunner#close method

2020-12-06 Thread GitBox
SteNicholas commented on pull request #14207: URL: https://github.com/apache/flink/pull/14207#issuecomment-739677745 @leonardBang Any comments? This is an automated message from the Apache Git Service. To respond to the messa

[jira] [Commented] (FLINK-12130) Apply command line options to configuration before installing security modules

2020-12-06 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244953#comment-17244953 ] Victor Wong commented on FLINK-12130: - [~lingyaKK], thanks for your time! [~aljoscha

[GitHub] [flink-web] wuchong commented on a change in pull request #397: Add 1.12 Release announcement.

2020-12-06 Thread GitBox
wuchong commented on a change in pull request #397: URL: https://github.com/apache/flink-web/pull/397#discussion_r537224338 ## File path: _posts/2020-12-04-release-1.12.0.md ## @@ -0,0 +1,332 @@ +--- +layout: post +title: "Apache Flink 1.12.0 Release Announcement" +date: 2020

[GitHub] [flink] leonardBang commented on a change in pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-06 Thread GitBox
leonardBang commented on a change in pull request #14310: URL: https://github.com/apache/flink/pull/14310#discussion_r537222451 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveLookupTableSource.java ## @@ -114,16 +117,16 @

[jira] [Commented] (FLINK-20461) YARNFileReplicationITCase.testPerJobModeWithDefaultFileReplication

2020-12-06 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244951#comment-17244951 ] Zhenqiu Huang commented on FLINK-20461: --- [~hxbks2ks] I checked in master. Both tes

[GitHub] [flink] wuchong commented on a change in pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-06 Thread GitBox
wuchong commented on a change in pull request #14310: URL: https://github.com/apache/flink/pull/14310#discussion_r537220712 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveLookupTableSource.java ## @@ -114,16 +117,16 @@ pr

[GitHub] [flink] wuchong commented on a change in pull request #14267: [FLINK-20429][kafka] Using proper watermark interval in KafkaTableITCase.testKafkaTemporalJoinChangelog test

2020-12-06 Thread GitBox
wuchong commented on a change in pull request #14267: URL: https://github.com/apache/flink/pull/14267#discussion_r537219582 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableITCase.java ## @@ -551,7 +

[jira] [Commented] (FLINK-20494) SQLClientHBaseITCase Task Timeout

2020-12-06 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244948#comment-17244948 ] Leonard Xu commented on FLINK-20494: Thanks for the report [~hxbks2ks] But the erro

[jira] [Closed] (FLINK-19857) FLIP-149: Introduce the upsert-kafka Connector

2020-12-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19857. --- Fix Version/s: 1.12.0 Resolution: Fixed > FLIP-149: Introduce the upsert-kafka Connector > --

[jira] [Commented] (FLINK-19710) Fix performance regression to rebase FRocksDB with higher version RocksDB

2020-12-06 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244945#comment-17244945 ] Yun Tang commented on FLINK-19710: -- Yes, I also heard voice to support ARM platform. As

[GitHub] [flink] flinkbot edited a comment on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-06 Thread GitBox
flinkbot edited a comment on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-732020040 ## CI report: * Unknown: [CANCELED](TBD) * 9a54066e688f3de335b646b40b1888be88b41beb Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

2020-12-06 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244942#comment-17244942 ] Zhenqiu Huang commented on FLINK-20505: --- It should not be a flink bug. It is just

[jira] [Created] (FLINK-20505) Yarn provided lib does not work with http paths.

2020-12-06 Thread Xintong Song (Jira)
Xintong Song created FLINK-20505: Summary: Yarn provided lib does not work with http paths. Key: FLINK-20505 URL: https://issues.apache.org/jira/browse/FLINK-20505 Project: Flink Issue Type:

[GitHub] [flink] Myasuka commented on a change in pull request #14195: [FLINK-20300] Add Flink 1.12 release notes

2020-12-06 Thread GitBox
Myasuka commented on a change in pull request #14195: URL: https://github.com/apache/flink/pull/14195#discussion_r537211445 ## File path: docs/release-notes/flink-1.12.md ## @@ -0,0 +1,173 @@ +--- +title: "Release Notes - Flink 1.12" +--- + + + +These release notes discuss impo

[jira] [Commented] (FLINK-19710) Fix performance regression to rebase FRocksDB with higher version RocksDB

2020-12-06 Thread Brad Davis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244935#comment-17244935 ] Brad Davis commented on FLINK-19710: The reason for my interest is that I'm working

[GitHub] [flink] flinkbot edited a comment on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-06 Thread GitBox
flinkbot edited a comment on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-732020040 ## CI report: * Unknown: [CANCELED](TBD) * 9a54066e688f3de335b646b40b1888be88b41beb UNKNOWN Bot commands The @flinkbot bot supports the fol

[GitHub] [flink] V1ncentzzZ removed a comment on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-06 Thread GitBox
V1ncentzzZ removed a comment on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-738834116 @flinkbot run azure. This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] V1ncentzzZ commented on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-06 Thread GitBox
V1ncentzzZ commented on pull request #14165: URL: https://github.com/apache/flink/pull/14165#issuecomment-739642703 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Commented] (FLINK-20480) Methods from CheckpointedFunction interface in FlinkKafkaConsumerBase are set to final

2020-12-06 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244929#comment-17244929 ] Yun Tang commented on FLINK-20480: -- I think setting {{CheckpointedFunction}} interfaces

[jira] [Created] (FLINK-20504) NPE when writing to hive and fail over happened

2020-12-06 Thread zhuxiaoshang (Jira)
zhuxiaoshang created FLINK-20504: Summary: NPE when writing to hive and fail over happened Key: FLINK-20504 URL: https://issues.apache.org/jira/browse/FLINK-20504 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-20494) SQLClientHBaseITCase Task Timeout

2020-12-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244927#comment-17244927 ] Jark Wu commented on FLINK-20494: - cc [~Leonard Xu] > SQLClientHBaseITCase Task Timeou

[jira] [Commented] (FLINK-20503) Internal cpu configuration option is leaked in logs

2020-12-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244926#comment-17244926 ] Xintong Song commented on FLINK-20503: -- cc: [~karmagyz], [~azagrebin], [~mapohl] >

[GitHub] [flink] V1ncentzzZ edited a comment on pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

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

[jira] [Assigned] (FLINK-20503) Internal cpu configuration option is leaked in logs

2020-12-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20503: Assignee: Xintong Song > Internal cpu configuration option is leaked in logs > --

[jira] [Created] (FLINK-20503) Internal cpu configuration option is leaked in logs

2020-12-06 Thread Xintong Song (Jira)
Xintong Song created FLINK-20503: Summary: Internal cpu configuration option is leaked in logs Key: FLINK-20503 URL: https://issues.apache.org/jira/browse/FLINK-20503 Project: Flink Issue Typ

[jira] [Updated] (FLINK-20502) Reduce the uploading time of hadoop jars in hbase e2e test

2020-12-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20502: Component/s: Table SQL / Ecosystem > Reduce the uploading time of hadoop jars in hbase e2e test > --

[GitHub] [flink] V1ncentzzZ commented on a change in pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-06 Thread GitBox
V1ncentzzZ commented on a change in pull request #14165: URL: https://github.com/apache/flink/pull/14165#discussion_r537203038 ## File path: flink-table/flink-table-planner/src/test/scala/resources/testStatementSetExecutionExplain1.out ## @@ -0,0 +1,121 @@ +== Abstract Syntax

[jira] [Updated] (FLINK-19435) jdbc JDBCOutputFormat open function invoke Class.forName(drivername)

2020-12-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19435: Fix Version/s: (was: 1.10.3) 1.12.1 1.13.0 > jdbc JDBCOutputForm

[jira] [Commented] (FLINK-19710) Fix performance regression to rebase FRocksDB with higher version RocksDB

2020-12-06 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244922#comment-17244922 ] Yun Tang commented on FLINK-19710: -- [~jherico] Thanks for your care and sorry for not u

[jira] [Commented] (FLINK-19435) jdbc JDBCOutputFormat open function invoke Class.forName(drivername)

2020-12-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244920#comment-17244920 ] Jark Wu commented on FLINK-19435: - Thanks [~kezhuw] for the detailed anaylisis. I reprod

[GitHub] [flink] lirui-apache commented on a change in pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-06 Thread GitBox
lirui-apache commented on a change in pull request #14310: URL: https://github.com/apache/flink/pull/14310#discussion_r537199758 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveLookupTableSource.java ## @@ -114,16 +117,16

[GitHub] [flink] Myasuka commented on pull request #14307: [FLINK-20209][web] Add missing checkpoint configuration to Flink UI

2020-12-06 Thread GitBox
Myasuka commented on pull request #14307: URL: https://github.com/apache/flink/pull/14307#issuecomment-739634281 @coolderli Have you ever checked the failure test `RestAPIStabilityTest.testDispatcherRestAPIStability` in last [CI](https://dev.azure.com/apache-flink/apache-flink/_build/resul

[jira] [Commented] (FLINK-20433) UnalignedCheckpointTestBase.execute failed with "TestTimedOutException: test timed out after 300 seconds"

2020-12-06 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244915#comment-17244915 ] Huang Xingbo commented on FLINK-20433: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-20502) Reduce the uploading time of hadoop jars in hbase e2e test

2020-12-06 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20502: --- Attachment: flink-vsts-standalonesession-0-fv-az655-588.log > Reduce the uploading time of hadoop ja

[jira] [Created] (FLINK-20502) Reduce the uploading time of hadoop jars in hbase e2e test

2020-12-06 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-20502: -- Summary: Reduce the uploading time of hadoop jars in hbase e2e test Key: FLINK-20502 URL: https://issues.apache.org/jira/browse/FLINK-20502 Project: Flink Iss

[jira] [Created] (FLINK-20501) FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice failed with "Delete test topic : flink-kafka-producer-fail-and-recover-same-checkpoint-twice"

2020-12-06 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20501: Summary: FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice failed with "Delete test topic : flink-kafka-producer-fail-and-recover-same-checkpoint-twice" Key: FLINK-20501

[GitHub] [flink] flinkbot edited a comment on pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

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

[jira] [Updated] (FLINK-19435) jdbc JDBCOutputFormat open function invoke Class.forName(drivername)

2020-12-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19435: Description: when we sink data to multi jdbc outputformat ,  {code} protected void establishConnection()

[jira] [Commented] (FLINK-20493) SQLClientSchemaRegistryITCase failed with "Could not build the flink-dist image"

2020-12-06 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244912#comment-17244912 ] Huang Xingbo commented on FLINK-20493: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] zhisheng17 commented on a change in pull request #14195: [FLINK-20300] Add Flink 1.12 release notes

2020-12-06 Thread GitBox
zhisheng17 commented on a change in pull request #14195: URL: https://github.com/apache/flink/pull/14195#discussion_r537000266 ## File path: docs/release-notes/flink-1.12.md ## @@ -0,0 +1,173 @@ +--- +title: "Release Notes - Flink 1.12" +--- + + + +These release notes discuss i

[jira] [Commented] (FLINK-20500) UpsertKafkaTableITCase.testTemporalJoin test failed

2020-12-06 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244911#comment-17244911 ] Huang Xingbo commented on FLINK-20500: -- cc [~fsk119] Could you help take a look. Th

[jira] [Created] (FLINK-20500) UpsertKafkaTableITCase.testTemporalJoin test failed

2020-12-06 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20500: Summary: UpsertKafkaTableITCase.testTemporalJoin test failed Key: FLINK-20500 URL: https://issues.apache.org/jira/browse/FLINK-20500 Project: Flink Issue Typ

[GitHub] [flink] flinkbot edited a comment on pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

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

[jira] [Commented] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

2020-12-06 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244907#comment-17244907 ] Huang Xingbo commented on FLINK-20431: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-20493) SQLClientSchemaRegistryITCase failed with "Could not build the flink-dist image"

2020-12-06 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244903#comment-17244903 ] Huang Xingbo commented on FLINK-20493: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] liuyongvs commented on pull request #14308: [FLINK-20474][core] fix cep docs bug of pattern contiguity.

2020-12-06 Thread GitBox
liuyongvs commented on pull request #14308: URL: https://github.com/apache/flink/pull/14308#issuecomment-739618003 hi @dawidwys , could you have a look this? This is an automated message from the Apache Git Service. To respon

[GitHub] [flink] flinkbot edited a comment on pull request #14258: [FLINK-20356][docs] Updated Mesos documentation.

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

[GitHub] [flink] flinkbot edited a comment on pull request #14258: [FLINK-20356][docs] Updated Mesos documentation.

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

[GitHub] [flink] flinkbot edited a comment on pull request #14258: [FLINK-20356][docs] Updated Mesos documentation.

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

[GitHub] [flink] StephanEwen commented on pull request #14314: [FLINK-20492][runtime] Add implementations of cancelTask() and finish…

2020-12-06 Thread GitBox
StephanEwen commented on pull request #14314: URL: https://github.com/apache/flink/pull/14314#issuecomment-739566306 Looks good, +1 to merge. A quick thought on the testing code: In my experience, the pattern where the verification is built into the mocks (especially shared mocks) te

[GitHub] [flink] flinkbot edited a comment on pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

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

[GitHub] [flink] flinkbot edited a comment on pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

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

[GitHub] [flink] flinkbot edited a comment on pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

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

[jira] [Updated] (FLINK-20081) ExecutorNotifier should run handler in the main thread when receive an exception from the callable.

2020-12-06 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20081: - Fix Version/s: 1.11.3 > ExecutorNotifier should run handler in the main thread when receive an

[jira] [Updated] (FLINK-19448) CoordinatedSourceITCase.testEnumeratorReaderCommunication hangs

2020-12-06 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-19448: - Fix Version/s: 1.11.3 > CoordinatedSourceITCase.testEnumeratorReaderCommunication hangs > --

[GitHub] [flink] flinkbot edited a comment on pull request #14303: [FLINK-20379][Connector/Kafka] Improve the KafkaRecordDesrializer interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #14314: [FLINK-20492][runtime] Add implementations of cancelTask() and finish…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14303: [FLINK-20379][Connector/Kafka] Improve the KafkaRecordDesrializer interface

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

  1   2   >