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

2020-12-22 Thread GitBox
HuangZhenQiu commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r547770638 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java ## @@ -0,0 +1,89 @@ +/* + * Licensed

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

2020-12-22 Thread GitBox
HuangZhenQiu commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r547770563 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java ## @@ -0,0 +1,89 @@ +/* + * Licensed

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

2020-12-22 Thread GitBox
HuangZhenQiu commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r547770123 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java ## @@ -0,0 +1,89 @@ +/* + * Licensed

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

2020-12-22 Thread GitBox
HuangZhenQiu commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r547769893 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java ## @@ -0,0 +1,89 @@ +/* + * Licensed

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

2020-12-22 Thread GitBox
HuangZhenQiu commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r547769505 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/NoFailureRater.java ## @@ -0,0 +1,48 @@ +/* + * Licensed to the Apache

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

2020-12-22 Thread GitBox
HuangZhenQiu commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r547768470 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/FailureRaterUtil.java ## @@ -0,0 +1,40 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot commented on pull request #14471: [FLINK-20654][tests] Ignore UnalignedCheckpointITCase until resolved

2020-12-22 Thread GitBox
flinkbot commented on pull request #14471: URL: https://github.com/apache/flink/pull/14471#issuecomment-749990505 ## CI report: * bc4804950ff69e439e436f313a396be4e5a1688d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-20722) Fail to insert into hive table due to ClassCastException

2020-12-22 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253940#comment-17253940 ] Rui Li commented on FLINK-20722: Thanks [~godfreyhe] for your suggestions. I'll open a PR accordingly.

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

2020-12-22 Thread GitBox
HuangZhenQiu commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r547752610 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/FailureRater.java ## @@ -0,0 +1,49 @@ +/* + * Licensed to the Apache

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

2020-12-22 Thread GitBox
HuangZhenQiu commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r547752610 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/FailureRater.java ## @@ -0,0 +1,49 @@ +/* + * Licensed to the Apache

[jira] [Updated] (FLINK-20735) Support configurable log level

2020-12-22 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-20735: - Component/s: Runtime / Coordination > Support configurable log level > -- >

[jira] [Closed] (FLINK-20715) pyflink DataStream filter error.

2020-12-22 Thread Enter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Enter closed FLINK-20715. - Resolution: Not A Bug > pyflink DataStream filter error. > > >

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

2020-12-22 Thread GitBox
HuangZhenQiu commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r547752610 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/FailureRater.java ## @@ -0,0 +1,49 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-20725) TableFunction#getTypeInference is not work well for JdbcRowDataLookupFunction, it's always throws Exception

2020-12-22 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253932#comment-17253932 ] Jark Wu commented on FLINK-20725: - It sounds like relate to FLINK-18890, could you help to have a look

[jira] [Updated] (FLINK-20744) org.apache.flink.test.checkpointing.UnalignedCheckpointITCase fails due to java.lang.ArrayIndexOutOfBoundsException

2020-12-22 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-20744: - Description:

[jira] [Closed] (FLINK-20621) Refactor the TypeInformation implementation in Python DataStream API

2020-12-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20621. --- Resolution: Fixed Merged to master via dca092f301a0894bceaf591512b0e03c9fa8d220 > Refactor the

[GitHub] [flink] flinkbot edited a comment on pull request #14468: [FLINK-20552][connectors/jdbc] JdbcDynamicTableSink doesn't sink buff…

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14468: URL: https://github.com/apache/flink/pull/14468#issuecomment-749674915 ## CI report: * Unknown: [CANCELED](TBD) * d2b4d901d51c87824302397aa6059fc255ce57f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14457: [FLINK-20707][table-planner-blink] Separate the implementation of BatchExecExpand and StreamExecExpand

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14457: URL: https://github.com/apache/flink/pull/14457#issuecomment-749464644 ## CI report: * 77c31b7c883b6e158ab3d609125d734bdc9dbe59 Azure:

[GitHub] [flink] dianfu closed pull request #14401: [FLINK-20621][python] Refactor the TypeInformation implementation in Python DataStream API.

2020-12-22 Thread GitBox
dianfu closed pull request #14401: URL: https://github.com/apache/flink/pull/14401 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] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * 2f104aa43ea5d49cddcca3587a54c87924e8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13800: [FLINK-19650][connectors jdbc]Support the limit push down for the Jdb…

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #13800: URL: https://github.com/apache/flink/pull/13800#issuecomment-717132623 ## CI report: * 71a5140cb517517feb3a0dea17c4e274f3ed7fcb Azure:

[jira] [Created] (FLINK-20744) org.apache.flink.test.checkpointing.UnalignedCheckpointITCase fails due to java.lang.ArrayIndexOutOfBoundsException

2020-12-22 Thread Matthias (Jira)
Matthias created FLINK-20744: Summary: org.apache.flink.test.checkpointing.UnalignedCheckpointITCase fails due to java.lang.ArrayIndexOutOfBoundsException Key: FLINK-20744 URL:

[jira] [Commented] (FLINK-20743) Print ContainerId For RemoteTransportException

2020-12-22 Thread yang gang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253926#comment-17253926 ] yang gang commented on FLINK-20743: --- [~zjwang] Hi. Please see if this proposal is reasonable, thank

[jira] [Commented] (FLINK-20739) Ban `if` from HiveModule

2020-12-22 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253927#comment-17253927 ] Rui Li commented on FLINK-20739: I agree it's a valid issue that the IF function doesn't support short

[jira] [Updated] (FLINK-20742) Skip deployment of StateFun example artifacts

2020-12-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20742: --- Labels: pull-request-available (was: ) > Skip deployment of StateFun example artifacts >

[GitHub] [flink-statefun] tzulitai opened a new pull request #191: [FLINK-20742] Skip deployment of Maven artifacts for examples

2020-12-22 Thread GitBox
tzulitai opened a new pull request #191: URL: https://github.com/apache/flink-statefun/pull/191 This PR makes us no longer deploy / release Maven artifacts for the examples, starting from the next release. We never expect users to try out the examples via Maven artifacts. ##

[jira] [Updated] (FLINK-20743) Print ContainerId For RemoteTransportException

2020-12-22 Thread yang gang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yang gang updated FLINK-20743: -- Description: !image-2020-12-23-15-13-21-226.png|width=970,height=291! RemoteTransportException, this

[jira] [Updated] (FLINK-20743) Print ContainerId For RemoteTransportException

2020-12-22 Thread yang gang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yang gang updated FLINK-20743: -- Attachment: image-2020-12-23-15-13-21-226.png > Print ContainerId For RemoteTransportException >

[GitHub] [flink] flinkbot commented on pull request #14471: [FLINK-20654][tests] Ignore UnalignedCheckpointITCase until resolved

2020-12-22 Thread GitBox
flinkbot commented on pull request #14471: URL: https://github.com/apache/flink/pull/14471#issuecomment-749979972 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] [Updated] (FLINK-20743) Print ContainerId For RemoteTransportException

2020-12-22 Thread yang gang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yang gang updated FLINK-20743: -- Attachment: (was: image-2020-12-23-14-48-13-489.png) > Print ContainerId For

[GitHub] [flink] rkhachatryan opened a new pull request #14471: [FLINK-20654][tests] Ignore UnalignedCheckpointITCase until resolved

2020-12-22 Thread GitBox
rkhachatryan opened a new pull request #14471: URL: https://github.com/apache/flink/pull/14471 (backport to 1.12) Ignore `UnalignedCheckpointITCase` until resolved This is an automated message from the Apache Git Service.

[jira] [Created] (FLINK-20743) Print ContainerId For RemoteTransportException

2020-12-22 Thread yang gang (Jira)
yang gang created FLINK-20743: - Summary: Print ContainerId For RemoteTransportException Key: FLINK-20743 URL: https://issues.apache.org/jira/browse/FLINK-20743 Project: Flink Issue Type:

[jira] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

2020-12-22 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253921#comment-17253921 ] Matthias commented on FLINK-20654: -- [This

[GitHub] [flink] xiaoHoly commented on a change in pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-22 Thread GitBox
xiaoHoly commented on a change in pull request #14387: URL: https://github.com/apache/flink/pull/14387#discussion_r547735809 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTableSourceSinkFactoryTest.java ## @@

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

2020-12-22 Thread GitBox
HuangZhenQiu commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r547734776 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ResourceManagerOptions.java ## @@ -67,6 +67,33 @@ "for

[jira] [Created] (FLINK-20742) Skip deployment of StateFun example artifacts

2020-12-22 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-20742: --- Summary: Skip deployment of StateFun example artifacts Key: FLINK-20742 URL: https://issues.apache.org/jira/browse/FLINK-20742 Project: Flink

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

2020-12-22 Thread GitBox
HuangZhenQiu commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r547734287 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ResourceManagerOptions.java ## @@ -67,6 +67,33 @@ "for

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

2020-12-22 Thread GitBox
HuangZhenQiu commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r547734136 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ResourceManagerOptions.java ## @@ -67,6 +67,33 @@ "for

[GitHub] [flink] danny0405 commented on a change in pull request #14451: [FLINK-20704][table-planner] Some rel data type does not implement th…

2020-12-22 Thread GitBox
danny0405 commented on a change in pull request #14451: URL: https://github.com/apache/flink/pull/14451#discussion_r547731023 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/calcite/FlinkTypeFactoryTest.scala ## @@ -0,0 +1,47 @@ +package

[GitHub] [flink] flinkbot edited a comment on pull request #14468: [FLINK-20552][connectors/jdbc] JdbcDynamicTableSink doesn't sink buff…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14459: [FLINK-20709][table-planner-blink] Introduce StreamPhysicalMiniBatchAssigner, and make StreamExecMiniBatchAssigner only extended from

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14459: URL: https://github.com/apache/flink/pull/14459#issuecomment-749464764 ## CI report: * f6343d765a1105227dff8f8f0e82fc0b3b8df7a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * 86d6ceb6111c573bdbceafed8b8f42f81216a542 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13800: [FLINK-19650][connectors jdbc]Support the limit push down for the Jdb…

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #13800: URL: https://github.com/apache/flink/pull/13800#issuecomment-717132623 ## CI report: * 62897544138e2bececa6a3f53c63289150864495 Azure:

[GitHub] [flink] wangxlong commented on a change in pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-22 Thread GitBox
wangxlong commented on a change in pull request #14387: URL: https://github.com/apache/flink/pull/14387#discussion_r547728288 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTableSourceSinkFactoryTest.java ## @@

[GitHub] [flink] meijies commented on pull request #14468: [FLINK-20552][connectors/jdbc] JdbcDynamicTableSink doesn't sink buff…

2020-12-22 Thread GitBox
meijies commented on pull request #14468: URL: https://github.com/apache/flink/pull/14468#issuecomment-749973352 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-20739) Ban `if` from HiveModule

2020-12-22 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253917#comment-17253917 ] jiawen xiao commented on FLINK-20739: - Do other modules have this problem? [~hackergin] > Ban `if`

[GitHub] [flink-docker] xintongsong closed pull request #52: [hotfix] Remove unnecessary logs to pass official image ci tests.

2020-12-22 Thread GitBox
xintongsong closed pull request #52: URL: https://github.com/apache/flink-docker/pull/52 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] [Issue Comment Deleted] (FLINK-20739) Ban `if` from HiveModule

2020-12-22 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiawen xiao updated FLINK-20739: Comment: was deleted (was: in my opinion,[2] stand for size is not less than 3. can you try ? 

[jira] [Commented] (FLINK-20739) Ban `if` from HiveModule

2020-12-22 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253916#comment-17253916 ] jiawen xiao commented on FLINK-20739: - in my opinion,[2] stand for size is not less than 3. can you

[jira] [Comment Edited] (FLINK-20739) Ban `if` from HiveModule

2020-12-22 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253916#comment-17253916 ] jiawen xiao edited comment on FLINK-20739 at 12/23/20, 6:49 AM: in my

[GitHub] [flink-docker] xintongsong commented on pull request #52: [hotfix] Remove unnecessary logs to pass official image ci tests.

2020-12-22 Thread GitBox
xintongsong commented on pull request #52: URL: https://github.com/apache/flink-docker/pull/52#issuecomment-749971661 cc @wangyang0918 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-docker] xintongsong opened a new pull request #52: [hotfix] Remove unnecessary logs to pass official image ci tests.

2020-12-22 Thread GitBox
xintongsong opened a new pull request #52: URL: https://github.com/apache/flink-docker/pull/52 This applies #51 to 1.12.0. This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-docker] xintongsong closed pull request #51: [hotfix] Remove the unnecessary logs so that docker official image CI tests could pass

2020-12-22 Thread GitBox
xintongsong closed pull request #51: URL: https://github.com/apache/flink-docker/pull/51 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-docker] xintongsong commented on pull request #51: [hotfix] Remove the unnecessary logs so that docker official image CI tests could pass

2020-12-22 Thread GitBox
xintongsong commented on pull request #51: URL: https://github.com/apache/flink-docker/pull/51#issuecomment-749969775 Merged via: * dev-master: 906ba7de3a5afa33253f821ff9fa9bd22c042367 * dev-1.12: 847a58397f7abb01c69cff52b61b3c71516e1c72

[GitHub] [flink] flinkbot edited a comment on pull request #14454: [FLINK-20705][table-planner-blink] Separate the implementation of BatchExecValues and StreamExecValues

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14454: URL: https://github.com/apache/flink/pull/14454#issuecomment-749330771 ## CI report: * 4f26226231f0905e6121d5dba2e84820f2a01f20 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * 86d6ceb6111c573bdbceafed8b8f42f81216a542 Azure:

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

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * 40095107c80dfdb13e7024ed2bb9a1760b4e41a4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13800: [FLINK-19650][connectors jdbc]Support the limit push down for the Jdb…

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #13800: URL: https://github.com/apache/flink/pull/13800#issuecomment-717132623 ## CI report: * 62897544138e2bececa6a3f53c63289150864495 Azure:

[GitHub] [flink-docker] wangyang0918 commented on pull request #51: [hotfix] Remove the unnecessary logs so that docker official image CI tests could pass

2020-12-22 Thread GitBox
wangyang0918 commented on pull request #51: URL: https://github.com/apache/flink-docker/pull/51#issuecomment-749967612 cc @xintongsong This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-docker] wangyang0918 opened a new pull request #51: [hotfix] Remove the unnecessary logs so that docker official image CI tests could pass

2020-12-22 Thread GitBox
wangyang0918 opened a new pull request #51: URL: https://github.com/apache/flink-docker/pull/51 The docker official image CI tests are checking the output of `docker-entrypoint.sh`. We need to remove the unnecessary logs.

[jira] [Comment Edited] (FLINK-17493) Possible direct memory leak in cassandra sink

2020-12-22 Thread Antti Kaikkonen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202337#comment-17202337 ] Antti Kaikkonen edited comment on FLINK-17493 at 12/23/20, 6:35 AM:

[jira] [Commented] (FLINK-17493) Possible direct memory leak in cassandra sink

2020-12-22 Thread Antti Kaikkonen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253914#comment-17253914 ] Antti Kaikkonen commented on FLINK-17493: - For me the growing memory issue seem to be finally

[jira] [Updated] (FLINK-20725) TableFunction#getTypeInference is not work well for JdbcRowDataLookupFunction, it's always throws Exception

2020-12-22 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-20725: --- Description: I found that TableFunction#getTypeInference  is not work well for

[jira] [Commented] (FLINK-20700) Default value type does not match the return type of method input()

2020-12-22 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253910#comment-17253910 ] Jark Wu commented on FLINK-20700: - [~wbgentleman], we should figure out whether this is a bug first. Hi

[jira] [Assigned] (FLINK-20004) UpperLimitExceptionParameter description is misleading

2020-12-22 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20004: --- Assignee: robinwang (was: wbgentleman) > UpperLimitExceptionParameter description is misleading >

[jira] [Assigned] (FLINK-20004) UpperLimitExceptionParameter description is misleading

2020-12-22 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20004: --- Assignee: wbgentleman > UpperLimitExceptionParameter description is misleading >

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

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * 40095107c80dfdb13e7024ed2bb9a1760b4e41a4 Azure:

[jira] [Updated] (FLINK-20713) out/err file support rolling

2020-12-22 Thread muzimusi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] muzimusi updated FLINK-20713: - Description: It is meaningful for out / err files to support scrolling. In particular, when you have

[jira] [Updated] (FLINK-20713) out/err file support rolling

2020-12-22 Thread muzimusi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] muzimusi updated FLINK-20713: - Description: It is meaningful for out / err files to support scrolling. In particular, when you have

[GitHub] [flink] xixingya commented on pull request #14470: [DOC]fix the wrong word

2020-12-22 Thread GitBox
xixingya commented on pull request #14470: URL: https://github.com/apache/flink/pull/14470#issuecomment-749960603 @kl0u hello, can you help me to review this pr? This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-20734) SQL client error when running joining query

2020-12-22 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20734: Description: Run into the following errors when performing join query in SQL client. {code} 01:52:46.189

[GitHub] [flink] xiaoHoly commented on a change in pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-22 Thread GitBox
xiaoHoly commented on a change in pull request #14387: URL: https://github.com/apache/flink/pull/14387#discussion_r547695728 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/table/descriptors/JdbcValidator.java ## @@ -42,6 +42,7 @@

[GitHub] [flink] xiaoHoly commented on a change in pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-22 Thread GitBox
xiaoHoly commented on a change in pull request #14387: URL: https://github.com/apache/flink/pull/14387#discussion_r547690670 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTableSourceSinkFactoryTest.java ## @@ -75,6

[jira] [Commented] (FLINK-20739) Ban `if` from HiveModule

2020-12-22 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253895#comment-17253895 ] Jark Wu commented on FLINK-20739: - What do you think about this? [~lirui] > Ban `if` from HiveModule

[jira] [Closed] (FLINK-20741) StateFun's DataStream interop SDK module is missing a valid NOTICE file

2020-12-22 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-20741. --- Resolution: Fixed statefun/master: 265a8a8593f6082a9ac49afec9e100ec4080c23f

[GitHub] [flink] flinkbot edited a comment on pull request #14470: fix the wrong word

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14470: URL: https://github.com/apache/flink/pull/14470#issuecomment-749912261 ## CI report: * ebb35f0f6768974840e99a02887114a4f89e053e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14419: [FLINK-20650][k8s] Remove "native-k8s" command and add bash wrapper for JobManager and TaskManager container args

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14419: URL: https://github.com/apache/flink/pull/14419#issuecomment-747932005 ## CI report: * 3906f10b3bb3896e8370f5e9a8d8014c96be9076 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * 86d6ceb6111c573bdbceafed8b8f42f81216a542 Azure:

[GitHub] [flink-docker] xintongsong closed pull request #50: Update Dockerfiles for 1.12.0 release

2020-12-22 Thread GitBox
xintongsong closed pull request #50: URL: https://github.com/apache/flink-docker/pull/50 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-20740) Use managed memory to avoid direct memory OOM error for sort-merge shuffle

2020-12-22 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-20740: Parent: FLINK-19614 Issue Type: Sub-task (was: Bug) > Use managed memory to avoid direct

[GitHub] [flink-docker] xintongsong commented on pull request #50: Update Dockerfiles for 1.12.0 release

2020-12-22 Thread GitBox
xintongsong commented on pull request #50: URL: https://github.com/apache/flink-docker/pull/50#issuecomment-749936751 Changes verified with Travis CI. https://travis-ci.com/github/xintongsong/flink-docker/builds/210354192

[jira] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

2020-12-22 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253893#comment-17253893 ] Huang Xingbo commented on FLINK-20654: --

[jira] [Created] (FLINK-20741) StateFun's DataStream interop SDK module is missing a valid NOTICE file

2020-12-22 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-20741: --- Summary: StateFun's DataStream interop SDK module is missing a valid NOTICE file Key: FLINK-20741 URL: https://issues.apache.org/jira/browse/FLINK-20741

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * bca5bd315af411fad878e197c2020a43e3ae9f40 Azure:

[GitHub] [flink] wangxlong commented on a change in pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-22 Thread GitBox
wangxlong commented on a change in pull request #14387: URL: https://github.com/apache/flink/pull/14387#discussion_r547636537 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/table/descriptors/JdbcValidator.java ## @@ -42,6 +42,7 @@

[GitHub] [flink-docker] xintongsong opened a new pull request #50: Update Dockerfiles for 1.12.0 release

2020-12-22 Thread GitBox
xintongsong opened a new pull request #50: URL: https://github.com/apache/flink-docker/pull/50 Deprecate command `native-k8` and add preparation for pass-through mode. This is to address the comments in the following docker-library/official-images PR.

[GitHub] [flink] wangyang0918 commented on pull request #14447: [FLINK-20664][k8s] Support setting service account for TaskManager pod.

2020-12-22 Thread GitBox
wangyang0918 commented on pull request #14447: URL: https://github.com/apache/flink/pull/14447#issuecomment-749928782 @blublinsky I think what till means is to introduce a common config option for service account. It could be `kubernetes.service-account`. It should only take effect when

[GitHub] [flink] flinkbot edited a comment on pull request #14451: [FLINK-20704][table-planner] Some rel data type does not implement th…

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14451: URL: https://github.com/apache/flink/pull/14451#issuecomment-749321360 ## CI report: * 21d75d6c3ae56a159b454726232fa4fb85e43364 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * bca5bd315af411fad878e197c2020a43e3ae9f40 Azure:

[jira] [Updated] (FLINK-20740) Use managed memory to avoid direct memory OOM error for sort-merge shuffle

2020-12-22 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-20740: Summary: Use managed memory to avoid direct memory OOM error for sort-merge shuffle (was: Use

[jira] [Created] (FLINK-20740) Use managed memory to avoid direct memory OOM error

2020-12-22 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-20740: --- Summary: Use managed memory to avoid direct memory OOM error Key: FLINK-20740 URL: https://issues.apache.org/jira/browse/FLINK-20740 Project: Flink Issue

[jira] [Updated] (FLINK-20739) Ban `if` from HiveModule

2020-12-22 Thread jinfeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jinfeng updated FLINK-20739: Description: When using hiveModule, the if function is treated as a normal function. If I have a SQL

[jira] [Created] (FLINK-20739) Ban `if` from HiveModule

2020-12-22 Thread jinfeng (Jira)
jinfeng created FLINK-20739: --- Summary: Ban `if` from HiveModule Key: FLINK-20739 URL: https://issues.apache.org/jira/browse/FLINK-20739 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #14451: [FLINK-20704][table-planner] Some rel data type does not implement th…

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14451: URL: https://github.com/apache/flink/pull/14451#issuecomment-749321360 ## CI report: * d4e0d0bf7183c4a4392efe08ad1adcebd36103cc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14470: fix the wrong word

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14470: URL: https://github.com/apache/flink/pull/14470#issuecomment-749912261 ## CI report: * ebb35f0f6768974840e99a02887114a4f89e053e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14419: [FLINK-20650][k8s] Remove "native-k8s" command and add bash wrapper for JobManager and TaskManager container args

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14419: URL: https://github.com/apache/flink/pull/14419#issuecomment-747932005 ## CI report: * 3906f10b3bb3896e8370f5e9a8d8014c96be9076 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14401: [FLINK-20621][python] Refactor the TypeInformation implementation in Python DataStream API.

2020-12-22 Thread GitBox
flinkbot edited a comment on pull request #14401: URL: https://github.com/apache/flink/pull/14401#issuecomment-745968134 ## CI report: * 2ea69af31eaafde2be7241f658399052c9e7af16 Azure:

[jira] [Updated] (FLINK-20612) Add benchmarks for scheduler

2020-12-22 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-20612: - Description: With Flink 1.12, we failed to run large-scale jobs on our cluster. When we were

[GitHub] [flink] xintongsong commented on pull request #14419: [FLINK-20650][k8s] Remove "native-k8s" command and add bash wrapper for JobManager and TaskManager container args

2020-12-22 Thread GitBox
xintongsong commented on pull request #14419: URL: https://github.com/apache/flink/pull/14419#issuecomment-749916040 LGTM. I'll merge this after AZP gives green light. This is an automated message from the Apache Git

[jira] [Commented] (FLINK-19013) Log start/end of state restoration

2020-12-22 Thread weiyunqing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253871#comment-17253871 ] weiyunqing commented on FLINK-19013: [~wangm92] On this issue, we have made some internal researches

  1   2   3   4   5   >