[jira] [Commented] (FLINK-19133) User provided kafka partitioners are not initialized correctly

2020-09-03 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190573#comment-17190573 ] Danny Chen commented on FLINK-19133: Hi, [~dwysakowicz], may i take this issue ~ > User provided

[GitHub] [flink] klion26 commented on a change in pull request #13279: [FLINK-19090][docs-zh] Translate "Local Cluster" of "Clusters & Depolyment" page into Chinese

2020-09-03 Thread GitBox
klion26 commented on a change in pull request #13279: URL: https://github.com/apache/flink/pull/13279#discussion_r483402111 ## File path: docs/ops/deployment/local.zh.md ## @@ -122,38 +121,38 @@ INFO ... - Recovering all persisted jobs. INFO ... - Registering TaskManager ...

[jira] [Closed] (FLINK-19108) Stop expanding the identifiers with scope aliased by the system with 'EXPR$' prefix

2020-09-03 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19108. Fix Version/s: (was: 1.12.0) Assignee: Danny Chen Resolution: Fixed master: 

[GitHub] [flink] JingsongLi merged pull request #13293: [FLINK-19108][table] Stop expanding the identifiers with scope aliase…

2020-09-03 Thread GitBox
JingsongLi merged pull request #13293: URL: https://github.com/apache/flink/pull/13293 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 #13325: [FLINK-15974][python] Support to use the Python UDF directly in the Python Table API

2020-09-03 Thread GitBox
flinkbot commented on pull request #13325: URL: https://github.com/apache/flink/pull/13325#issuecomment-686925091 ## CI report: * 26abf1ecf936d0232c6d49c0bdd4fe3beae6252e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink-statefun] tzulitai commented on pull request #142: [FLINK-19130] [core] Expose metrics for backpressure

2020-09-03 Thread GitBox
tzulitai commented on pull request #142: URL: https://github.com/apache/flink-statefun/pull/142#issuecomment-686920891 Discussion point: Strictly speaking, the per-operator `inflight-async-ops` metric is redundant, since most metric reporter systems commonly used by Flink

[GitHub] [flink-statefun] tzulitai opened a new pull request #142: [FLINK-19130] [core] Expose metrics for backpressure

2020-09-03 Thread GitBox
tzulitai opened a new pull request #142: URL: https://github.com/apache/flink-statefun/pull/142 This PR adds in total 2 new metrics related to backpressure: - Number of blocked addresses (per function type) - Number of inflight async operations (per function type + per operator)

[jira] [Updated] (FLINK-19130) Expose backpressure metrics / logs for function dispatcher operator

2020-09-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19130: --- Labels: pull-request-available (was: ) > Expose backpressure metrics / logs for function

[GitHub] [flink] flinkbot commented on pull request #13325: [FLINK-15974][python] Support to use the Python UDF directly in the Python Table API

2020-09-03 Thread GitBox
flinkbot commented on pull request #13325: URL: https://github.com/apache/flink/pull/13325#issuecomment-686918964 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] dianfu opened a new pull request #13325: [FLINK-15974][python] Support to use the Python UDF directly in the Python Table API

2020-09-03 Thread GitBox
dianfu opened a new pull request #13325: URL: https://github.com/apache/flink/pull/13325 ## What is the purpose of the change *This pull request add support to use the Python UDF directly in the Python Table API. E.g. for Python UDF inc, users could use it directly in the Python

[jira] [Updated] (FLINK-15974) Support to use the Python UDF directly in the Python Table API

2020-09-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15974: --- Labels: pull-request-available (was: ) > Support to use the Python UDF directly in the

[jira] [Assigned] (FLINK-15974) Support to use the Python UDF directly in the Python Table API

2020-09-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-15974: --- Assignee: Dian Fu (was: Shuiqiang Chen) > Support to use the Python UDF directly in the Python

[GitHub] [flink] klion26 commented on a change in pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

2020-09-03 Thread GitBox
klion26 commented on a change in pull request #13225: URL: https://github.com/apache/flink/pull/13225#discussion_r483392234 ## File path: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/Fetch.java ## @@ -0,0 +1,13 @@ +package

[GitHub] [flink] klion26 commented on a change in pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

2020-09-03 Thread GitBox
klion26 commented on a change in pull request #13225: URL: https://github.com/apache/flink/pull/13225#discussion_r483392129 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/utils/SortOperationFactory.java ## @@ -121,9 +121,9 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13015: [FLINK-18536][kinesis] Adding enhanced fan-out related configurations.

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13015: URL: https://github.com/apache/flink/pull/13015#issuecomment-665526783 ## CI report: * 8aac0b56736097238b12499b837ed010fcbf7d15 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13015: [FLINK-18536][kinesis] Adding enhanced fan-out related configurations.

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13015: URL: https://github.com/apache/flink/pull/13015#issuecomment-665526783 ## CI report: * 820de7186da99bece7f43b5300781d7b3a2dbe41 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17709][kubernetes][docs] Support running PyFlink on Kubernetes.

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * ef15d07af7eff785478fb42a3cfb67a7463aeb06 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13015: [FLINK-18536][kinesis] Adding enhanced fan-out related configurations.

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13015: URL: https://github.com/apache/flink/pull/13015#issuecomment-665526783 ## CI report: * 820de7186da99bece7f43b5300781d7b3a2dbe41 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13324: [hotfix][docs] Fix ExecutionEnvironment.scala doc error

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13324: URL: https://github.com/apache/flink/pull/13324#issuecomment-686875157 ## CI report: * 04c250f4f16667c122c12e4b793204337d204c59 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13323: FLINK-19137: Bump Parquet from 1.10.0 to 1.11.1

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13323: URL: https://github.com/apache/flink/pull/13323#issuecomment-686869045 ## CI report: * 084ec77b7f7b01dc6314797cb3fa0aa2455432f7 Azure:

[GitHub] [flink] flinkbot commented on pull request #13324: [hotfix][docs] Fix ExecutionEnvironment.scala doc error

2020-09-03 Thread GitBox
flinkbot commented on pull request #13324: URL: https://github.com/apache/flink/pull/13324#issuecomment-686875157 ## CI report: * 04c250f4f16667c122c12e4b793204337d204c59 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] JingsongLi commented on a change in pull request #13306: [FLINK-17779][Connectors/ORC]Orc file format support filter push down

2020-09-03 Thread GitBox
JingsongLi commented on a change in pull request #13306: URL: https://github.com/apache/flink/pull/13306#discussion_r483360115 ## File path: flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcFileSystemFormatFactory.java ## @@ -83,14 +96,227 @@ private static

[GitHub] [flink] JingsongLi commented on a change in pull request #13306: [FLINK-17779][Connectors/ORC]Orc file format support filter push down

2020-09-03 Thread GitBox
JingsongLi commented on a change in pull request #13306: URL: https://github.com/apache/flink/pull/13306#discussion_r483358009 ## File path: flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcFileSystemFormatFactory.java ## @@ -83,14 +96,227 @@ private static

[jira] [Closed] (FLINK-14087) throws java.lang.ArrayIndexOutOfBoundsException when emiting the data using RebalancePartitioner.

2020-09-03 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-14087. --- > throws java.lang.ArrayIndexOutOfBoundsException when emiting the data using > RebalancePartitioner. >

[jira] [Commented] (FLINK-14087) throws java.lang.ArrayIndexOutOfBoundsException when emiting the data using RebalancePartitioner.

2020-09-03 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190507#comment-17190507 ] Yun Gao commented on FLINK-14087: - fix in master: d7fe9af0b6caa1c76e811240e53434969be771b1 > throws

[jira] [Resolved] (FLINK-14087) throws java.lang.ArrayIndexOutOfBoundsException when emiting the data using RebalancePartitioner.

2020-09-03 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao resolved FLINK-14087. - Resolution: Fixed > throws java.lang.ArrayIndexOutOfBoundsException when emiting the data using >

[GitHub] [flink] flinkbot commented on pull request #13324: [hotfix][docs] Fix ExecutionEnvironment.scala doc error

2020-09-03 Thread GitBox
flinkbot commented on pull request #13324: URL: https://github.com/apache/flink/pull/13324#issuecomment-686872257 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-19127) Provide a replacement of StreamExecutionEnvironment.createRemoteEnvironment for TableEnvironment

2020-09-03 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190505#comment-17190505 ] Danny Chen commented on FLINK-19127: Thanks, indeed, notebook like zeppelin may need this ~ >

[GitHub] [flink] haveanote opened a new pull request #13324: [hotfix][docs] Fix ExecutionEnvironment.scala doc error

2020-09-03 Thread GitBox
haveanote opened a new pull request #13324: URL: https://github.com/apache/flink/pull/13324 ## What is the purpose of the change *There is a doc error in ExecutionEnvironment.readTextFileWithValue . Change utf-0 to utf-8* ## Brief change log - *Change

[jira] [Created] (FLINK-19138) Python UDF supports directly specifying input_types as DataTypes.ROW

2020-09-03 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-19138: Summary: Python UDF supports directly specifying input_types as DataTypes.ROW Key: FLINK-19138 URL: https://issues.apache.org/jira/browse/FLINK-19138 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #13323: FLINK-19137: Bump Parquet from 1.10.0 to 1.11.1

2020-09-03 Thread GitBox
flinkbot commented on pull request #13323: URL: https://github.com/apache/flink/pull/13323#issuecomment-686869045 ## CI report: * 084ec77b7f7b01dc6314797cb3fa0aa2455432f7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13323: FLINK-19137: Bump Parquet from 1.10.0 to 1.11.1

2020-09-03 Thread GitBox
flinkbot commented on pull request #13323: URL: https://github.com/apache/flink/pull/13323#issuecomment-686867076 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-19137) Bump Apache Parquet to 1.11.1

2020-09-03 Thread ABC (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190497#comment-17190497 ] ABC commented on FLINK-19137: - [https://github.com/apache/flink/pull/13323] > Bump Apache Parquet to 1.11.1

[GitHub] [flink] C08061 opened a new pull request #13323: FLINK-19137: Bump Parquet from 1.10.0 to 1.11.1

2020-09-03 Thread GitBox
C08061 opened a new pull request #13323: URL: https://github.com/apache/flink/pull/13323 https://issues.apache.org/jira/browse/FLINK-19137 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-19137) Bump Apache Parquet to 1.11.1

2020-09-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19137: --- Labels: pull-request-available (was: ) > Bump Apache Parquet to 1.11.1 >

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17709][kubernetes][docs] Support running PyFlink on Kubernetes.

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * ef15d07af7eff785478fb42a3cfb67a7463aeb06 Azure:

[jira] [Created] (FLINK-19137) Bump Apache Parquet to 1.11.1

2020-09-03 Thread ABC (Jira)
ABC created FLINK-19137: --- Summary: Bump Apache Parquet to 1.11.1 Key: FLINK-19137 URL: https://issues.apache.org/jira/browse/FLINK-19137 Project: Flink Issue Type: Improvement Components:

[GitHub] [flink-statefun] tzulitai closed pull request #141: [FLINK-19129] [k8s] Update log4j-console in template Helm chart

2020-09-03 Thread GitBox
tzulitai closed pull request #141: URL: https://github.com/apache/flink-statefun/pull/141 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] lirui-apache commented on pull request #13315: [FLINK-19070][hive] Hive connector should throw a meaningful exception if user reads/writes ACID tables

2020-09-03 Thread GitBox
lirui-apache commented on pull request #13315: URL: https://github.com/apache/flink/pull/13315#issuecomment-686860019 @SteNicholas Thanks for working on this. I think the check should be enforced when getting source/sink for a hive table, rather than creating the hive table itself.

[GitHub] [flink] flinkbot commented on pull request #13322: [FLINK-17709][kubernetes][docs] Support running PyFlink on Kubernetes.

2020-09-03 Thread GitBox
flinkbot commented on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * ef15d07af7eff785478fb42a3cfb67a7463aeb06 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] tzulitai commented on a change in pull request #13015: [FLINK-18536][kinesis] Adding enhanced fan-out related configurations.

2020-09-03 Thread GitBox
tzulitai commented on a change in pull request #13015: URL: https://github.com/apache/flink/pull/13015#discussion_r483345056 ## File path:

[GitHub] [flink] flinkbot commented on pull request #13322: [FLINK-17709][kubernetes][docs] Support running PyFlink on Kubernetes.

2020-09-03 Thread GitBox
flinkbot commented on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686856023 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-17709) Active Kubernetes integration phase 3 - Advanced Features

2020-09-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17709: --- Labels: pull-request-available (was: ) > Active Kubernetes integration phase 3 - Advanced

[GitHub] [flink] shuiqiangchen opened a new pull request #13322: [FLINK-17709][kubernetes][docs] Support running PyFlink on Kubernetes.

2020-09-03 Thread GitBox
shuiqiangchen opened a new pull request #13322: URL: https://github.com/apache/flink/pull/13322 ## 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] [Commented] (FLINK-18858) Kinesis Flink SQL Connector

2020-09-03 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190475#comment-17190475 ] Tzu-Li (Gordon) Tai commented on FLINK-18858: - [~danny.cranmer]I think a FLIP is not needed

[jira] [Created] (FLINK-19136) MetricsAvailabilityITCase.testReporter failed with "Could not satisfy the predicate within the allowed time"

2020-09-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-19136: --- Summary: MetricsAvailabilityITCase.testReporter failed with "Could not satisfy the predicate within the allowed time" Key: FLINK-19136 URL:

[jira] [Updated] (FLINK-19136) MetricsAvailabilityITCase.testReporter failed with "Could not satisfy the predicate within the allowed time"

2020-09-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19136: Labels: test-stability (was: ) > MetricsAvailabilityITCase.testReporter failed with "Could not satisfy

[jira] [Commented] (FLINK-18815) AbstractCloseableRegistryTest.testClose unstable

2020-09-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190472#comment-17190472 ] Dian Fu commented on FLINK-18815: - Another instance: 

[GitHub] [flink] flinkbot edited a comment on pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13309: URL: https://github.com/apache/flink/pull/13309#issuecomment-685901869 ## CI report: * 1d254fbbfe4ee9aa6c05bf9fcb44af3317c9274b UNKNOWN * 0ac70b7637256b8b4320e509c0649075c7c0aabf Azure:

[jira] [Closed] (FLINK-19118) Support Expression in the operations of the Python Table API

2020-09-03 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-19118. --- Resolution: Fixed Fixed in Master: a8cc62a901dabe6c4d877b97db6024715b68174a > Support Expression

[GitHub] [flink] sunjincheng121 merged pull request #13304: [FLINK-19118][python] Support Expression in the operations of Python Table API

2020-09-03 Thread GitBox
sunjincheng121 merged pull request #13304: URL: https://github.com/apache/flink/pull/13304 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

[GitHub] [flink] sunjincheng121 commented on pull request #13304: [FLINK-19118][python] Support Expression in the operations of Python Table API

2020-09-03 Thread GitBox
sunjincheng121 commented on pull request #13304: URL: https://github.com/apache/flink/pull/13304#issuecomment-686839232 @flinkbot approve all This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-19069) finalizeOnMaster takes too much time and client timeouts

2020-09-03 Thread Kenneth William Krugler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190447#comment-17190447 ] Kenneth William Krugler commented on FLINK-19069: - See also 

[GitHub] [flink] flinkbot edited a comment on pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13309: URL: https://github.com/apache/flink/pull/13309#issuecomment-685901869 ## CI report: * 7f8d6066b5e021ff8a343e2c43bd40d256d1a2c9 Azure:

[GitHub] [flink] sjwiesman commented on pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
sjwiesman commented on pull request #13309: URL: https://github.com/apache/flink/pull/13309#issuecomment-686819620 You can apply this patch to SavepointWriterITCase to see the failure.

[GitHub] [flink] sjwiesman commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
sjwiesman commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r483299944 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/functions/FileCopyMapFunction.java ## @@ -0,0 +1,54

[GitHub] [flink] flinkbot edited a comment on pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13309: URL: https://github.com/apache/flink/pull/13309#issuecomment-685901869 ## CI report: * fd94dc00ac4095094d0a3c84bd066b44ddd346a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13309: URL: https://github.com/apache/flink/pull/13309#issuecomment-685901869 ## CI report: * fd94dc00ac4095094d0a3c84bd066b44ddd346a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13309: URL: https://github.com/apache/flink/pull/13309#issuecomment-685901869 ## CI report: * fd94dc00ac4095094d0a3c84bd066b44ddd346a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13181: URL: https://github.com/apache/flink/pull/13181#issuecomment-675091412 ## CI report: * e7553689356882de1ffe606400d1255d1d757bc4 UNKNOWN * a96b2db52a0db507e0077266c8e9cb947413e1ba Azure:

[GitHub] [flink] qinjunjerry commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
qinjunjerry commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r483220192 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/functions/FileCopyRichMapFunction.java ## @@ -0,0

[GitHub] [flink] qinjunjerry commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
qinjunjerry commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r483216756 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/WritableSavepoint.java ## @@ -90,38 +93,37 @@

[GitHub] [flink] qinjunjerry commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
qinjunjerry commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r483214542 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/WritableSavepoint.java ## @@ -90,38 +93,37 @@

[GitHub] [flink] qinjunjerry commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
qinjunjerry commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r483212926 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/functions/FileCopyRichMapFunction.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #13284: [FLINK-17016][runtime] Enable pipelined region scheduling

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13284: URL: https://github.com/apache/flink/pull/13284#issuecomment-683683000 ## CI report: * 71281ac4921c174c214f2393e169e7140698af2d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13309: URL: https://github.com/apache/flink/pull/13309#issuecomment-685901869 ## CI report: * fd94dc00ac4095094d0a3c84bd066b44ddd346a7 Azure:

[GitHub] [flink] qinjunjerry commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
qinjunjerry commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r483212773 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/functions/StatePathExtractor.java ## @@ -0,0

[GitHub] [flink] qinjunjerry commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
qinjunjerry commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r483211627 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/functions/FileCopyRichMapFunction.java ## @@ -0,0

[GitHub] [flink] qinjunjerry commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
qinjunjerry commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r483211813 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/functions/StatePathExtractor.java ## @@ -0,0

[GitHub] [flink] qinjunjerry commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
qinjunjerry commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r48328 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/WritableSavepoint.java ## @@ -90,38 +93,37 @@

[GitHub] [flink] qinjunjerry commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
qinjunjerry commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r483211312 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/functions/FileCopyRichMapFunction.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #13321: [FLINK-14870] Remove nullable assumption of task slot sharing group

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13321: URL: https://github.com/apache/flink/pull/13321#issuecomment-686567896 ## CI report: * d79f152fa91b8bc555af6fb2a00a8d62b184be5a UNKNOWN * 7039064922aaec22752ac84e4e9d41d663e68a14 Azure:

[GitHub] [flink] sjwiesman commented on pull request #13179: [FLINK-18978][state-backends] Support full table scan of key and namespace from statebackend

2020-09-03 Thread GitBox
sjwiesman commented on pull request #13179: URL: https://github.com/apache/flink/pull/13179#issuecomment-686698188 @myasuka please take another look when you have the time This is an automated message from the Apache Git

[jira] [Commented] (FLINK-18858) Kinesis Flink SQL Connector

2020-09-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190366#comment-17190366 ] Danny Cranmer commented on FLINK-18858: --- Thanks [~tzulitai]. Hello [~whummer], I am a member of

[jira] [Commented] (FLINK-19133) User provided kafka partitioners are not initialized correctly

2020-09-03 Thread Kenneth William Krugler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190358#comment-17190358 ] Kenneth William Krugler commented on FLINK-19133: - Yes, we ran into this exact issue

[GitHub] [flink] flinkbot edited a comment on pull request #13319: [FLINK-19022][runtime]Register the TerminationFuture of ResourceManager and Dispatcher with DispatcherResourceManagerComponent

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13319: URL: https://github.com/apache/flink/pull/13319#issuecomment-686508323 ## CI report: * 9fab4d5bbccc29d78dee92726cce852421e40541 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13320: [FLINK-19035] Remove fold from DataStream API

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13320: URL: https://github.com/apache/flink/pull/13320#issuecomment-686520258 ## CI report: * a424075cc80ced3f5620b580134393213cc378a5 Azure:

[GitHub] [flink] sjwiesman commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
sjwiesman commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r483158834 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/functions/StatePathExtractor.java ## @@ -0,0 +1,100

[GitHub] [flink] sjwiesman commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
sjwiesman commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r483158317 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/functions/StatePathExtractor.java ## @@ -0,0 +1,100

[GitHub] [flink] sjwiesman commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
sjwiesman commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r483157850 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/functions/FileCopyRichMapFunction.java ## @@ -0,0

[GitHub] [flink] sjwiesman commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
sjwiesman commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r483157398 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/functions/FileCopyRichMapFunction.java ## @@ -0,0

[GitHub] [flink] sjwiesman commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
sjwiesman commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r483156521 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/functions/FileCopyRichMapFunction.java ## @@ -0,0

[GitHub] [flink] sjwiesman commented on a change in pull request #13309: [Flink-14942][state-processor-api] savepoint deep copy

2020-09-03 Thread GitBox
sjwiesman commented on a change in pull request #13309: URL: https://github.com/apache/flink/pull/13309#discussion_r483156392 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/WritableSavepoint.java ## @@ -90,38 +93,37 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #13305: [FLINK-19109][task] Ignore isLoopRunning in MailboxExecutor.isIdle

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13305: URL: https://github.com/apache/flink/pull/13305#issuecomment-685657746 ## CI report: * 380b8d7be6ae142a27061c6d529c2ca059a51aa5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13316: [FLINK-14422][runtime] Expose network memory usage to TaskManagerDetailsHandler's endpoint

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13316: URL: https://github.com/apache/flink/pull/13316#issuecomment-686398901 ## CI report: * e37cb771c66ed8cab48e0b7abd53132fb15dfca3 UNKNOWN * 5ccdc55dc70a57332c50bd59c0a8e6e59a29bffd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13128: [FLINK-18795][hbase] Support for HBase 2

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13128: URL: https://github.com/apache/flink/pull/13128#issuecomment-672766836 ## CI report: * 313b80f4474455d7013b0852929b5a8458f391a1 UNKNOWN * ece578a9fdbaee4d815de501187d92a729790c9b Azure:

[GitHub] [flink] rkhachatryan commented on pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

2020-09-03 Thread GitBox
rkhachatryan commented on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-686639977 Thanks for updating your PR @echauchot There is no cyclic dependency now and `CompletedCheckpointStore`s are not affected! I'm not sure I understood you about

[jira] [Updated] (FLINK-19135) (Stream)ExecutionEnvironment.execute() should not throw ExecutionException

2020-09-03 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19135: - Issue Type: Bug (was: Improvement) > (Stream)ExecutionEnvironment.execute() should not

[jira] [Created] (FLINK-19135) (Stream)ExecutionEnvironment.execute() should not throw ExecutionException

2020-09-03 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-19135: Summary: (Stream)ExecutionEnvironment.execute() should not throw ExecutionException Key: FLINK-19135 URL: https://issues.apache.org/jira/browse/FLINK-19135

[jira] [Assigned] (FLINK-19135) (Stream)ExecutionEnvironment.execute() should not throw ExecutionException

2020-09-03 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19135: Assignee: Aljoscha Krettek > (Stream)ExecutionEnvironment.execute() should not

[GitHub] [flink] flinkbot edited a comment on pull request #13305: [FLINK-19109][task] Ignore isLoopRunning in MailboxExecutor.isIdle

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13305: URL: https://github.com/apache/flink/pull/13305#issuecomment-685657746 ## CI report: * b37d13c99ca3f68f80b26a4f97371d309b124810 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13316: [FLINK-14422][runtime] Expose network memory usage to TaskManagerDetailsHandler's endpoint

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13316: URL: https://github.com/apache/flink/pull/13316#issuecomment-686398901 ## CI report: * e37cb771c66ed8cab48e0b7abd53132fb15dfca3 UNKNOWN * a7f19f060e5ec83090a5265e9be287bd8dbe464e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13217: [FLINK-16866] Make job submission non-blocking

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13217: URL: https://github.com/apache/flink/pull/13217#issuecomment-678285884 ## CI report: * 3655fcea1966bfbcb85c86d6a159c354f20d6cc7 UNKNOWN * 8036016c752bce433dc65d1c08695377c917836f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13227: [FLINK-18959][Runtime] Try to revert MiniDispatcher for archiveExecutionGraph

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13227: URL: https://github.com/apache/flink/pull/13227#issuecomment-679046587 ## CI report: * a439269835304a2a64316bcc6779c8997ba4716d Azure:

[jira] [Commented] (FLINK-18815) AbstractCloseableRegistryTest.testClose unstable

2020-09-03 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190276#comment-17190276 ] Kezhu Wang commented on FLINK-18815: Seems that recently two cases are leaking while previous cases

[GitHub] [flink] flinkbot edited a comment on pull request #13321: [FLINK-14870] Remove nullable assumption of task slot sharing group

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13321: URL: https://github.com/apache/flink/pull/13321#issuecomment-686567896 ## CI report: * d79f152fa91b8bc555af6fb2a00a8d62b184be5a UNKNOWN * 7039064922aaec22752ac84e4e9d41d663e68a14 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13284: [FLINK-17016][runtime] Enable pipelined region scheduling

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13284: URL: https://github.com/apache/flink/pull/13284#issuecomment-683683000 ## CI report: * a541f5410ff96d39708288ae7aa672ed2ebb05a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13318: [BP-1.11][FLINK-18959][Runtime] Try to revert MiniDispatcher for archiveExecutionGraph and shutdown cluster upon cancel.

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13318: URL: https://github.com/apache/flink/pull/13318#issuecomment-686450863 ## CI report: * 6c93ba2f6b0915301a85b181b895a4021eab897b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13181: [FLINK-18957] Implement logical request bulk tracking in SlotSharingExecutionSlotAllocator

2020-09-03 Thread GitBox
flinkbot edited a comment on pull request #13181: URL: https://github.com/apache/flink/pull/13181#issuecomment-675091412 ## CI report: * e7553689356882de1ffe606400d1255d1d757bc4 UNKNOWN * 18f88af3b438b13e9a240efd2b4979f841d2b978 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #13319: [FLINK-19022][runtime]Register the TerminationFuture of ResourceManager and Dispatcher with DispatcherResourceManagerCompone

2020-09-03 Thread GitBox
tillrohrmann commented on a change in pull request #13319: URL: https://github.com/apache/flink/pull/13319#discussion_r483078088 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@ -194,8 +194,9 @@ public Dispatcher(

  1   2   3   4   >