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

[ https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190592#comment-17190592 ] Dawid Wysakowicz commented on FLINK-14087: -- Fixed in: * master ** d7fe9af0b6caa

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

[ https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14087: - Fix Version/s: 1.10.3 1.11.2 1.12.0 > throws java.

[GitHub] [flink] dianfu commented on a change in pull request #13295: [FLINK-18598][python][docs] Add instructions for asynchronous execute in PyFlink doc.

dianfu commented on a change in pull request #13295: URL: https://github.com/apache/flink/pull/13295#discussion_r483425236 ## File path: docs/dev/python/faq.md ## @@ -52,6 +52,20 @@ $ source venv/bin/activate $ python xxx.py {% endhighlight %} +**Note:** When running jobs i

[jira] [Closed] (FLINK-18536) [Kinesis][EFO] Configuration deserialisation and validation

[ https://issues.apache.org/jira/browse/FLINK-18536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-18536. --- Resolution: Fixed Fixed in master via e472abb39681adb3d0e0de02254fd92b04b451f3 Than

[GitHub] [flink] asfgit closed pull request #13015: [FLINK-18536][kinesis] Adding enhanced fan-out related configurations.

asfgit closed pull request #13015: URL: https://github.com/apache/flink/pull/13015 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[GitHub] [flink] flinkbot edited a comment on pull request #13326: [FLINK-19133] Open custom partitioners in KafkaSerializationSchemaWrapper

flinkbot edited a comment on pull request #13326: URL: https://github.com/apache/flink/pull/13326#issuecomment-686943261 ## CI report: * e8a32ce376b09df4766fd6ddd439d8f634210ad7 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

dianfu commented on pull request #13325: URL: https://github.com/apache/flink/pull/13325#issuecomment-686950814 @WeiZhong94 Thanks for the review. Updated the PR. This is an automated message from the Apache Git Service. To r

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

flinkbot edited a comment on pull request #13225: URL: https://github.com/apache/flink/pull/13225#issuecomment-678953566 ## CI report: * 9d5f591223a0e46a22e24bbeb084a6b59c48a445 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] dianfu commented on a change in pull request #13314: [FLINK-18913][docs][python] Add a "TableEnvironment" document under the "Python API" -> "Table API User's Guide" section

dianfu commented on a change in pull request #13314: URL: https://github.com/apache/flink/pull/13314#discussion_r483404672 ## File path: docs/dev/python/table-api-users-guide/table_environment.md ## @@ -0,0 +1,833 @@ +--- +title: "TableEnvironment" +nav-parent_id: python_tablea

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

WeiZhong94 commented on a change in pull request #13325: URL: https://github.com/apache/flink/pull/13325#discussion_r483411913 ## File path: flink-python/pyflink/table/expressions.py ## @@ -538,9 +538,44 @@ def call(f: Union[str, UserDefinedFunctionWrapper], *args) -> Expressi

[GitHub] [flink] zhuxiaoshang 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

zhuxiaoshang commented on a change in pull request #13225: URL: https://github.com/apache/flink/pull/13225#discussion_r483414657 ## File path: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/Fetch.java ## @@ -0,0 +1,13 @@ +package org.apache.flink.tab

[GitHub] [flink] flinkbot commented on pull request #13326: [FLINK-19133] Open custom partitioners in KafkaSerializationSchemaWrapper

flinkbot commented on pull request #13326: URL: https://github.com/apache/flink/pull/13326#issuecomment-686943261 ## CI report: * e8a32ce376b09df4766fd6ddd439d8f634210ad7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

flinkbot edited a comment on pull request #13325: URL: https://github.com/apache/flink/pull/13325#issuecomment-686925091 ## CI report: * 26abf1ecf936d0232c6d49c0bdd4fe3beae6252e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #13326: [FLINK-19133] Open custom partitioners in KafkaSerializationSchemaWrapper

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

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

[ https://issues.apache.org/jira/browse/FLINK-19133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190574#comment-17190574 ] Dawid Wysakowicz commented on FLINK-19133: -- I have the PR prepared already, was

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

[ https://issues.apache.org/jira/browse/FLINK-19133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19133: --- Labels: pull-request-available (was: ) > User provided kafka partitioners are not initializ

[GitHub] [flink] dawidwys opened a new pull request #13326: [FLINK-19133] Open custom partitioners in KafkaSerializationSchemaWrapper

dawidwys opened a new pull request #13326: URL: https://github.com/apache/flink/pull/13326 ## What is the purpose of the change Fix the issue that custom partitioners were not opened. ## Brief change log - Moved openning of the partitioner from initProducer to open

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

[ https://issues.apache.org/jira/browse/FLINK-19133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190573#comment-17190573 ] Danny Chen commented on FLINK-19133: Hi, [~dwysakowicz], may i take this issue ~ >

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

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 ... a

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

[ 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: fb

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

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

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 r

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

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 (Prometheu

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

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

[ 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 di

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

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 pro

[GitHub] [flink] dianfu opened a new pull request #13325: [FLINK-15974][python] Support to use the Python UDF directly in the Python Table API

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

[ 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 Pyth

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

[ 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 Tab

[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

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 org.apache.flink.table.ap

[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

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 @@ pri

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

flinkbot edited a comment on pull request #13015: URL: https://github.com/apache/flink/pull/13015#issuecomment-665526783 ## CI report: * 8aac0b56736097238b12499b837ed010fcbf7d15 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13015: URL: https://github.com/apache/flink/pull/13015#issuecomment-665526783 ## CI report: * 820de7186da99bece7f43b5300781d7b3a2dbe41 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * ef15d07af7eff785478fb42a3cfb67a7463aeb06 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13015: URL: https://github.com/apache/flink/pull/13015#issuecomment-665526783 ## CI report: * 820de7186da99bece7f43b5300781d7b3a2dbe41 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13324: URL: https://github.com/apache/flink/pull/13324#issuecomment-686875157 ## CI report: * 04c250f4f16667c122c12e4b793204337d204c59 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13323: URL: https://github.com/apache/flink/pull/13323#issuecomment-686869045 ## CI report: * 084ec77b7f7b01dc6314797cb3fa0aa2455432f7 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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 r

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

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 Proper

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

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 Proper

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

[ 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.

[ https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190507#comment-17190507 ] Yun Gao commented on FLINK-14087: - fix in master: d7fe9af0b6caa1c76e811240e53434969be771

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

[ 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 > Reba

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

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 pro

[jira] [Commented] (FLINK-19127) Provide a replacement of StreamExecutionEnvironment.createRemoteEnvironment for TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-19127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190505#comment-17190505 ] Danny Chen commented on FLINK-19127: Thanks, indeed, notebook like zeppelin may need

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

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 utf-

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

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

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 r

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

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 pro

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

[ https://issues.apache.org/jira/browse/FLINK-19137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190497#comment-17190497 ] ABC commented on FLINK-19137: - [https://github.com/apache/flink/pull/13323] > Bump Apache P

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

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, p

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

[ 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.

flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * ef15d07af7eff785478fb42a3cfb67a7463aeb06 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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: For

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

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

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.

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 r

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

tzulitai commented on a change in pull request #13015: URL: https://github.com/apache/flink/pull/13015#discussion_r483345056 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/publisher/fanout/FanOutRecordPublis

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

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 pro

[jira] [Updated] (FLINK-17709) Active Kubernetes integration phase 3 - Advanced Features

[ 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 F

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

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 t

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

[ https://issues.apache.org/jira/browse/FLINK-18858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190475#comment-17190475 ] Tzu-Li (Gordon) Tai commented on FLINK-18858: - [~danny.cranmer]I think a FLI

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

Dian Fu created FLINK-19136: --- Summary: MetricsAvailabilityITCase.testReporter failed with "Could not satisfy the predicate within the allowed time" Key: FLINK-19136 URL: https://issues.apache.org/jira/browse/FLINK-19136

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

[ 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 th

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

[ https://issues.apache.org/jira/browse/FLINK-18815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190472#comment-17190472 ] Dian Fu commented on FLINK-18815: - Another instance:  [https://dev.azure.com/apache-flin

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

flinkbot edited a comment on pull request #13309: URL: https://github.com/apache/flink/pull/13309#issuecomment-685901869 ## CI report: * 1d254fbbfe4ee9aa6c05bf9fcb44af3317c9274b UNKNOWN * 0ac70b7637256b8b4320e509c0649075c7c0aabf Azure: [SUCCESS](https://dev.azure.com/apache-fl

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

[ 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 in

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

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 to

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

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 message

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

[ https://issues.apache.org/jira/browse/FLINK-19069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190447#comment-17190447 ] Kenneth William Krugler commented on FLINK-19069: - See also [https://kb.

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

flinkbot edited a comment on pull request #13309: URL: https://github.com/apache/flink/pull/13309#issuecomment-685901869 ## CI report: * 7f8d6066b5e021ff8a343e2c43bd40d256d1a2c9 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

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. [SavepointWriterITCase.patch.txt](https://github.com/apache/flink/files/5171892/SavepointWriterITCase.

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

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

flinkbot edited a comment on pull request #13309: URL: https://github.com/apache/flink/pull/13309#issuecomment-685901869 ## CI report: * fd94dc00ac4095094d0a3c84bd066b44ddd346a7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13309: URL: https://github.com/apache/flink/pull/13309#issuecomment-685901869 ## CI report: * fd94dc00ac4095094d0a3c84bd066b44ddd346a7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13309: URL: https://github.com/apache/flink/pull/13309#issuecomment-685901869 ## CI report: * fd94dc00ac4095094d0a3c84bd066b44ddd346a7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13181: URL: https://github.com/apache/flink/pull/13181#issuecomment-675091412 ## CI report: * e7553689356882de1ffe606400d1255d1d757bc4 UNKNOWN * a96b2db52a0db507e0077266c8e9cb947413e1ba Azure: [SUCCESS](https://dev.azure.com/apache-fl

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

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

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 @@ publi

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

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 @@ publi

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

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

flinkbot edited a comment on pull request #13284: URL: https://github.com/apache/flink/pull/13284#issuecomment-683683000 ## CI report: * 71281ac4921c174c214f2393e169e7140698af2d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13309: URL: https://github.com/apache/flink/pull/13309#issuecomment-685901869 ## CI report: * fd94dc00ac4095094d0a3c84bd066b44ddd346a7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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 +1,100

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

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

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 +1,100

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

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 @@ publi

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

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

flinkbot edited a comment on pull request #13321: URL: https://github.com/apache/flink/pull/13321#issuecomment-686567896 ## CI report: * d79f152fa91b8bc555af6fb2a00a8d62b184be5a UNKNOWN * 7039064922aaec22752ac84e4e9d41d663e68a14 Azure: [FAILURE](https://dev.azure.com/apache-fl

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

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 Serv

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

[ https://issues.apache.org/jira/browse/FLINK-18858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190366#comment-17190366 ] Danny Cranmer commented on FLINK-18858: --- Thanks [~tzulitai]. Hello [~whummer], I a

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

[ https://issues.apache.org/jira/browse/FLINK-19133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190358#comment-17190358 ] Kenneth William Krugler commented on FLINK-19133: - Yes, we ran into this

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

flinkbot edited a comment on pull request #13319: URL: https://github.com/apache/flink/pull/13319#issuecomment-686508323 ## CI report: * 9fab4d5bbccc29d78dee92726cce852421e40541 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #13320: URL: https://github.com/apache/flink/pull/13320#issuecomment-686520258 ## CI report: * a424075cc80ced3f5620b580134393213cc378a5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

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

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 +1,

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

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 +1,

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

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 +1,

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

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

  1   2   3   4   >