[jira] [Updated] (FLINK-15983) add native reader for Hive parquet files

[ https://issues.apache.org/jira/browse/FLINK-15983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15983: --- Fix Version/s: (was: 1.11.0) > add native reader for Hive parquet files > --

[jira] [Updated] (FLINK-15984) support hive stream table sink

[ https://issues.apache.org/jira/browse/FLINK-15984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15984: --- Fix Version/s: (was: 1.11.0) > support hive stream table sink > -- >

[jira] [Resolved] (FLINK-13890) HiveCatalogUseBlinkITCase failed to get metastore connection

[ https://issues.apache.org/jira/browse/FLINK-13890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-13890. -- Resolution: Duplicate Feel free to re-open if the problem is re-produced. > HiveCatalogUseBli

[GitHub] [flink] hequn8128 commented on a change in pull request #11444: [FLINK-16608][python] Support primitive data types for vectorized Python UDF

hequn8128 commented on a change in pull request #11444: [FLINK-16608][python] Support primitive data types for vectorized Python UDF URL: https://github.com/apache/flink/pull/11444#discussion_r396243233 ## File path: flink-python/src/main/java/org/apache/flink/table/runtime/arrow/w

[GitHub] [flink] hequn8128 commented on a change in pull request #11444: [FLINK-16608][python] Support primitive data types for vectorized Python UDF

hequn8128 commented on a change in pull request #11444: [FLINK-16608][python] Support primitive data types for vectorized Python UDF URL: https://github.com/apache/flink/pull/11444#discussion_r396237402 ## File path: flink-python/src/main/java/org/apache/flink/table/runtime/arrow/w

[GitHub] [flink] hequn8128 commented on a change in pull request #11444: [FLINK-16608][python] Support primitive data types for vectorized Python UDF

hequn8128 commented on a change in pull request #11444: [FLINK-16608][python] Support primitive data types for vectorized Python UDF URL: https://github.com/apache/flink/pull/11444#discussion_r396237588 ## File path: flink-python/src/main/java/org/apache/flink/table/runtime/arrow/w

[jira] [Commented] (FLINK-16708) When a JDBC connection has been closed, the retry policy of the JDBCUpsertOutputFormat cannot take effect and may result in data loss

[ https://issues.apache.org/jira/browse/FLINK-16708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064580#comment-17064580 ] Weike Dong commented on FLINK-16708: Hi [~lzljs3620320] , do you have time to look i

[jira] [Closed] (FLINK-13420) Supported hive versions are hard coded

[ https://issues.apache.org/jira/browse/FLINK-13420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-13420. Resolution: Invalid > Supported hive versions are hard coded > ---

[GitHub] [flink] TisonKun closed pull request #11415: [FLINK-15667][k8s] Support to mount custom Hadoop configurations

TisonKun closed pull request #11415: [FLINK-15667][k8s] Support to mount custom Hadoop configurations URL: https://github.com/apache/flink/pull/11415 This is an automated message from the Apache Git Service. To respond to th

[jira] [Commented] (FLINK-15667) Support to mount Hadoop Configurations

[ https://issues.apache.org/jira/browse/FLINK-15667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064581#comment-17064581 ] Zili Chen commented on FLINK-15667: --- master via f56a075aa029832b9cbacab51649c900498e18

[jira] [Closed] (FLINK-15667) Support to mount Hadoop Configurations

[ https://issues.apache.org/jira/browse/FLINK-15667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-15667. - Resolution: Fixed > Support to mount Hadoop Configurations > -- > >

[GitHub] [flink] flinkbot edited a comment on issue #10973: [FLINK-15647][k8s] Support user-specified annotations for JM/TM Pods

flinkbot edited a comment on issue #10973: [FLINK-15647][k8s] Support user-specified annotations for JM/TM Pods URL: https://github.com/apache/flink/pull/10973#issuecomment-580223229 ## CI report: * 33776e6aa098656ddb2820bbac39b4b08f9fa3f8 Travis: [CANCELED](https://travis-ci.co

[jira] [Updated] (FLINK-15932) Add download url to hive dependencies

[ https://issues.apache.org/jira/browse/FLINK-15932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15932: - Fix Version/s: (was: 1.11.0) > Add download url to hive dependencies > -

[jira] [Updated] (FLINK-16405) Fix hive-metastore dependency description in connecting to hive docs

[ https://issues.apache.org/jira/browse/FLINK-16405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-16405: - Fix Version/s: (was: 1.10.1) (was: 1.11.0) > Fix hive-metastore depen

[jira] [Updated] (FLINK-13278) add Chinese documentation for Hive source/sink

[ https://issues.apache.org/jira/browse/FLINK-13278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13278: - Parent: (was: FLINK-10729) Issue Type: Task (was: Sub-task) > add Chinese documenta

[jira] [Commented] (FLINK-16475) PulsarConsumerSource messageReceiveTimeoutMs parameter should be configurable

[ https://issues.apache.org/jira/browse/FLINK-16475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064583#comment-17064583 ] Robert Metzger commented on FLINK-16475: No worries, and thanks for referring to

[jira] [Created] (FLINK-16713) Flink can not support the type of source table to query data from es

jackray wang created FLINK-16713: Summary: Flink can not support the type of source table to query data from es Key: FLINK-16713 URL: https://issues.apache.org/jira/browse/FLINK-16713 Project: Flink

[jira] [Closed] (FLINK-4407) Add DSL for specifying Window Triggers

[ https://issues.apache.org/jira/browse/FLINK-4407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-4407. - Resolution: Won't Fix > Add DSL for specifying Window Triggers >

[GitHub] [flink] flinkbot edited a comment on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT.

flinkbot edited a comment on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#issuecomment-593407935 ## CI report: * 0be3fd11e11d708b254036e9e91fc71f1fd02181 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/fli

[jira] [Closed] (FLINK-10729) Create a Hive connector for Hive data access in Flink

[ https://issues.apache.org/jira/browse/FLINK-10729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-10729. Resolution: Fixed > Create a Hive connector for Hive data access in Flink > --

[jira] [Assigned] (FLINK-6215) Make the StatefulSequenceSource scalable.

[ https://issues.apache.org/jira/browse/FLINK-6215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-6215: - Assignee: (was: Kostas Kloudas) > Make the StatefulSequenceSource scalable. > --

[jira] [Commented] (FLINK-10729) Create a Hive connector for Hive data access in Flink

[ https://issues.apache.org/jira/browse/FLINK-10729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064584#comment-17064584 ] Jingsong Lee commented on FLINK-10729: -- Close, Thanks for the great work [~xuefuz]

[jira] [Assigned] (FLINK-7771) Make the operator state queryable

[ https://issues.apache.org/jira/browse/FLINK-7771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-7771: - Assignee: (was: Kostas Kloudas) > Make the operator state queryable > --

[GitHub] [flink] flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config

flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config URL: https://github.com/apache/flink/pull/11481#issuecomment-602174011 ## CI report: * cb9eb2458536cf858d110b30c6481b3d6597c9bc Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/f

[GitHub] [flink] flinkbot edited a comment on issue #11471: [FLINK-16692] flink joblistener can register from config

flinkbot edited a comment on issue #11471: [FLINK-16692] flink joblistener can register from config URL: https://github.com/apache/flink/pull/11471#issuecomment-602012274 ## CI report: * ad9049971efa640a2b22ee8f258b0a0d7f64cc47 Travis: [CANCELED](https://travis-ci.com/github/fli

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table.

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: * d595c9fddd3ac09

[jira] [Commented] (FLINK-16692) flink joblistener can register from config

[ https://issues.apache.org/jira/browse/FLINK-16692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064587#comment-17064587 ] Kostas Kloudas commented on FLINK-16692: Hi, I think this is a nice feature to h

[GitHub] [flink] azagrebin commented on issue #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components

azagrebin commented on issue #11445: [FLINK-16615] Introduce data structures and utilities to calculate Job Manager memory components URL: https://github.com/apache/flink/pull/11445#issuecomment-602426159 Thanks for the review @xintongsong I refactored more the class structure. The fina

[jira] [Commented] (FLINK-16708) When a JDBC connection has been closed, the retry policy of the JDBCUpsertOutputFormat cannot take effect and may result in data loss

[ https://issues.apache.org/jira/browse/FLINK-16708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064588#comment-17064588 ] Jingsong Lee commented on FLINK-16708: -- Hi, Thanks for reporting. Can you try FLINK

[jira] [Updated] (FLINK-13483) PrestoS3FileSystemITCase.testDirectoryListing fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-13483: --- Affects Version/s: 1.10.0 > PrestoS3FileSystemITCase.testDirectoryListing fails on Travis >

[jira] [Updated] (FLINK-13483) PrestoS3FileSystemITCase.testDirectoryListing fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-13483: --- Fix Version/s: 1.11.0 > PrestoS3FileSystemITCase.testDirectoryListing fails on Travis >

[jira] [Updated] (FLINK-13483) PrestoS3FileSystemITCase.testDirectoryListing fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-13483: --- Labels: test-stability (was: ) > PrestoS3FileSystemITCase.testDirectoryListing fails on Tra

[jira] [Updated] (FLINK-16713) Support source mode of elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-16713: - Component/s: (was: Table SQL / Client) Connectors / ElasticSearch > Support

[jira] [Updated] (FLINK-16713) Support source mode of elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-16713: - Summary: Support source mode of elasticsearch connector (was: Flink can not support the type of

[jira] [Commented] (FLINK-16713) Support source mode of elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064590#comment-17064590 ] Jingsong Lee commented on FLINK-16713: -- Hi [~jackray], unfortunately, as far as I k

[GitHub] [flink] flinkbot edited a comment on issue #11482: [FLINK-16581][table] Minibatch deduplication lack state TTL bug fix

flinkbot edited a comment on issue #11482: [FLINK-16581][table] Minibatch deduplication lack state TTL bug fix URL: https://github.com/apache/flink/pull/11482#issuecomment-60726 ## CI report: * 95c74ce398cdc779ac895edb7cf3433579f1 Travis: [SUCCESS](https://travis-ci.com/

[GitHub] [flink] TisonKun commented on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

TisonKun commented on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#issuecomment-602429506 @flinkbot run azure -

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table.

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: * d595c9fddd3ac09

[GitHub] [flink] WeiZhong94 commented on a change in pull request #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink

WeiZhong94 commented on a change in pull request #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#discussion_r396254822 ## File path: flink-

[GitHub] [flink] kl0u closed pull request #11472: [FLINK-16547][yarn] Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

kl0u closed pull request #11472: [FLINK-16547][yarn] Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH URL: https://github.com/apache/flink/pull/11472 This is an automated message from the Apache Git Ser

[jira] [Updated] (FLINK-16547) Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16547: --- Labels: pull-request-available (was: ) > Respect the config option of FileJobGraphRetriever

[GitHub] [flink] WeiZhong94 commented on a change in pull request #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink

WeiZhong94 commented on a change in pull request #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#discussion_r396257250 ## File path: flink-

[GitHub] [flink] WeiZhong94 commented on a change in pull request #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink

WeiZhong94 commented on a change in pull request #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#discussion_r396257250 ## File path: flink-

[jira] [Created] (FLINK-16714) Kafka committedOffsets value <0

pingle wang created FLINK-16714: --- Summary: Kafka committedOffsets value <0 Key: FLINK-16714 URL: https://issues.apache.org/jira/browse/FLINK-16714 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-16547) Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16547. -- Resolution: Fixed Merged on master with 6049b8307482a1d2d67d9642675345fc5093c197 > Respect th

[GitHub] [flink] wangyang0918 commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT.

wangyang0918 commented on a change in pull request #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#discussion_r396259803 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java

[GitHub] [flink] zhengcanbin commented on issue #11472: [FLINK-16547][yarn] Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

zhengcanbin commented on issue #11472: [FLINK-16547][yarn] Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH URL: https://github.com/apache/flink/pull/11472#issuecomment-602436628 > Thanks for the work @zhengcanbin and for the review @TisonKun. I will merge this. >

[GitHub] [flink] kl0u commented on issue #11471: [FLINK-16692] flink joblistener can register from config

kl0u commented on issue #11471: [FLINK-16692] flink joblistener can register from config URL: https://github.com/apache/flink/pull/11471#issuecomment-602438160 Hi @liuyongvs . Thanks for the work, I had some comments on the JIRA and I will have a better look at the PR now. In the meantime,

[jira] [Updated] (FLINK-16407) Remove "FAQ" section from Flink website

[ https://issues.apache.org/jira/browse/FLINK-16407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16407: --- Labels: pull-request-available (was: ) > Remove "FAQ" section from Flink website >

[GitHub] [flink] kl0u edited a comment on issue #11471: [FLINK-16692] flink joblistener can register from config

kl0u edited a comment on issue #11471: [FLINK-16692] flink joblistener can register from config URL: https://github.com/apache/flink/pull/11471#issuecomment-602438160 Hi @liuyongvs . Thanks for the work, I had some comments on the JIRA and I will have a better look at the PR now. I

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r396264764 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] flinkbot edited a comment on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT.

flinkbot edited a comment on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#issuecomment-593407935 ## CI report: * ff670f742762f45214ca32df966e02f4dbe6f758 Travis: [PENDING](https://travis-ci.com/github/flink-ci/fli

[jira] [Commented] (FLINK-16421) Changing default catalog to hive without changing default database fails

[ https://issues.apache.org/jira/browse/FLINK-16421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064611#comment-17064611 ] Gyula Fora commented on FLINK-16421: my point is that defualt_database should switch

[jira] [Created] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained

Canbin Zheng created FLINK-16715: Summary: Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained Key: FLINK-16715 URL: https://issues.apache.org/jira/browse/F

[jira] [Updated] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained

[ https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16715: - Description: In the YarnClusterDescriptor#{{startAppMaster()}} we are using some time the {{conf

[jira] [Updated] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained

[ https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16715: - Priority: Trivial (was: Minor) > Always use the configuration argument in YarnClusterDescriptor

[GitHub] [flink] liuzhixing1006 commented on issue #11455: [FLINK-16098] [chinese-translation, Documentation] Translate "Overvie…

liuzhixing1006 commented on issue #11455: [FLINK-16098] [chinese-translation, Documentation] Translate "Overvie… URL: https://github.com/apache/flink/pull/11455#issuecomment-602444612 Hi @JingsongLi @lirui-apache I have finished the modification, Is there anything else I need to do? Thanks

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r396269643 ## File path: flink-runtime/src/main/java/org/apache/fli

[jira] [Commented] (FLINK-16713) Support source mode of elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064613#comment-17064613 ] jackray wang commented on FLINK-16713: -- Hi [~lzljs3620320] ,this feature is essenti

[jira] [Closed] (FLINK-16540) Fully specify bugfix version of Docker containers in Flink Playground docker-compose.yaml files

[ https://issues.apache.org/jira/browse/FLINK-16540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-16540. - Fix Version/s: 1.9.0 1.10.0 1.11.0 Resolution: Fixed

[jira] [Comment Edited] (FLINK-16713) Support source mode of elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064613#comment-17064613 ] jackray wang edited comment on FLINK-16713 at 3/23/20, 8:15 AM: --

[GitHub] [flink] flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config

flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config URL: https://github.com/apache/flink/pull/11481#issuecomment-602174011 ## CI report: * cb9eb2458536cf858d110b30c6481b3d6597c9bc Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/f

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table.

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: * 2821e4a2542bffc

[GitHub] [flink] flinkbot edited a comment on issue #11471: [FLINK-16692] flink joblistener can register from config

flinkbot edited a comment on issue #11471: [FLINK-16692] flink joblistener can register from config URL: https://github.com/apache/flink/pull/11471#issuecomment-602012274 ## CI report: * 7f0c7e868fce22437c1b4b7a02fece52afb70f4a UNKNOWN * 57f1b99ac6db6626e6c78cb7b39e2026b59d128

[jira] [Commented] (FLINK-16156) TableAggregateITCase.testGroupByFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-16156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064619#comment-17064619 ] Kurt Young commented on FLINK-16156: FunctionITCase.testDynamicTableFunction  has b

[jira] [Commented] (FLINK-16156) TableAggregateITCase.testGroupByFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-16156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064620#comment-17064620 ] Kurt Young commented on FLINK-16156: TableAggregateITCase.testGroupByFlatAggregate s

[jira] [Commented] (FLINK-16692) flink joblistener can register from config

[ https://issues.apache.org/jira/browse/FLINK-16692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064621#comment-17064621 ] jackylau commented on FLINK-16692: -- HI [~kkl0u],  1) i will move the arguments to Depl

[jira] [Commented] (FLINK-16175) Add config option to switch case sensitive for column names in SQL

[ https://issues.apache.org/jira/browse/FLINK-16175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064624#comment-17064624 ] Dawid Wysakowicz commented on FLINK-16175: -- I agree with the principle of the t

[GitHub] [flink] TisonKun commented on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils

TisonKun commented on issue #11458: [FLINK-16625][k8s] Extract BootstrapTools#getEnvironmentVariables to a general utility in ConfigurationUtils URL: https://github.com/apache/flink/pull/11458#issuecomment-602454643 @zhengcanbin please rebase on master. I think this PR itself is good to go

[GitHub] [flink-statefun] tzulitai closed pull request #62: [FLINK-16685] Add a k8s example for the Python SDK

tzulitai closed pull request #62: [FLINK-16685] Add a k8s example for the Python SDK URL: https://github.com/apache/flink-statefun/pull/62 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on issue #11471: [FLINK-16692] flink joblistener can register from config

flinkbot edited a comment on issue #11471: [FLINK-16692] flink joblistener can register from config URL: https://github.com/apache/flink/pull/11471#issuecomment-602012274 ## CI report: * 7f0c7e868fce22437c1b4b7a02fece52afb70f4a UNKNOWN * 57f1b99ac6db6626e6c78cb7b39e2026b59d128

[GitHub] [flink] flinkbot edited a comment on issue #11486: [FLINK-16712][task] Refactor StreamTask to construct final fields

flinkbot edited a comment on issue #11486: [FLINK-16712][task] Refactor StreamTask to construct final fields URL: https://github.com/apache/flink/pull/11486#issuecomment-602377929 ## CI report: * 53b97eb753986785848b55a6626e01f20e070626 Travis: [FAILURE](https://travis-ci.com/gi

[jira] [Closed] (FLINK-16685) Add an example of how to deploy a multi-language function to Kubernetes.

[ https://issues.apache.org/jira/browse/FLINK-16685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-16685. --- Fix Version/s: statefun-1.1 Resolution: Fixed Merged to master via b9752c8954

[jira] [Closed] (FLINK-16706) Update Stateful Functions master branch version to 2.0-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-16706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-16706. --- Fix Version/s: statefun-1.1 Resolution: Fixed Merged via 2c9074d443866048c49e

[jira] [Created] (FLINK-16716) Update Roadmap after Flink 1.10 release

Fabian Hueske created FLINK-16716: - Summary: Update Roadmap after Flink 1.10 release Key: FLINK-16716 URL: https://issues.apache.org/jira/browse/FLINK-16716 Project: Flink Issue Type: Bug

[GitHub] [flink] TisonKun commented on issue #11472: [FLINK-16547][yarn] Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

TisonKun commented on issue #11472: [FLINK-16547][yarn] Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH URL: https://github.com/apache/flink/pull/11472#issuecomment-602458510 > Thanks for the work @zhengcanbin and for the review @TisonKun. I will merge this. >

[GitHub] [flink] TisonKun edited a comment on issue #11472: [FLINK-16547][yarn] Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

TisonKun edited a comment on issue #11472: [FLINK-16547][yarn] Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH URL: https://github.com/apache/flink/pull/11472#issuecomment-602458510 > Thanks for the work @zhengcanbin and for the review @TisonKun. I will merge this.

[GitHub] [flink] kl0u commented on a change in pull request #11471: [FLINK-16692] flink joblistener can register from config

kl0u commented on a change in pull request #11471: [FLINK-16692] flink joblistener can register from config URL: https://github.com/apache/flink/pull/11471#discussion_r396289410 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecut

[GitHub] [flink] kl0u commented on a change in pull request #11471: [FLINK-16692] flink joblistener can register from config

kl0u commented on a change in pull request #11471: [FLINK-16692] flink joblistener can register from config URL: https://github.com/apache/flink/pull/11471#discussion_r396281963 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecut

[jira] [Commented] (FLINK-16620) Add attempt information in logging

[ https://issues.apache.org/jira/browse/FLINK-16620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064631#comment-17064631 ] Roman Khachatryan commented on FLINK-16620: --- I think this way we'll have in to

[GitHub] [flink] kl0u commented on a change in pull request #11471: [FLINK-16692] flink joblistener can register from config

kl0u commented on a change in pull request #11471: [FLINK-16692] flink joblistener can register from config URL: https://github.com/apache/flink/pull/11471#discussion_r396291783 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java ##

[GitHub] [flink] kl0u commented on a change in pull request #11471: [FLINK-16692] flink joblistener can register from config

kl0u commented on a change in pull request #11471: [FLINK-16692] flink joblistener can register from config URL: https://github.com/apache/flink/pull/11471#discussion_r396289877 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/environment/StreamExecut

[GitHub] [flink] kl0u commented on a change in pull request #11471: [FLINK-16692] flink joblistener can register from config

kl0u commented on a change in pull request #11471: [FLINK-16692] flink joblistener can register from config URL: https://github.com/apache/flink/pull/11471#discussion_r396281963 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecut

[jira] [Commented] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained

[ https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064634#comment-17064634 ] Xintong Song commented on FLINK-16715: -- I tend to think this differently. Instead o

[jira] [Created] (FLINK-16717) Use headless service for rpc and blob port when flink on K8S

vanderliang created FLINK-16717: --- Summary: Use headless service for rpc and blob port when flink on K8S Key: FLINK-16717 URL: https://issues.apache.org/jira/browse/FLINK-16717 Project: Flink I

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table.

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: * 2821e4a2542bffc

[GitHub] [flink] flinkbot edited a comment on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT.

flinkbot edited a comment on issue #11284: [FLINK-15911][runtime] Make Flink work with NAT. URL: https://github.com/apache/flink/pull/11284#issuecomment-593407935 ## CI report: * ff670f742762f45214ca32df966e02f4dbe6f758 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/fli

[jira] [Created] (FLINK-16718) KvStateServerHandlerTest leaks Netty ByteBufs

Gary Yao created FLINK-16718: Summary: KvStateServerHandlerTest leaks Netty ByteBufs Key: FLINK-16718 URL: https://issues.apache.org/jira/browse/FLINK-16718 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on issue #11486: [FLINK-16712][task] Refactor StreamTask to construct final fields

flinkbot edited a comment on issue #11486: [FLINK-16712][task] Refactor StreamTask to construct final fields URL: https://github.com/apache/flink/pull/11486#issuecomment-602377929 ## CI report: * 9535112ff0782fd584600cc3fdbefe0457b1bcfb Travis: [FAILURE](https://travis-ci.com/gi

[jira] [Updated] (FLINK-16718) KvStateServerHandlerTest leaks Netty ByteBufs

[ https://issues.apache.org/jira/browse/FLINK-16718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-16718: - Description: The {{KvStateServerHandlerTest}} leaks Netty {{ByteBuf}} instances. (was: The {{KvStateSer

[jira] [Commented] (FLINK-16717) Use headless service for rpc and blob port when flink on K8S

[ https://issues.apache.org/jira/browse/FLINK-16717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064649#comment-17064649 ] Canbin Zheng commented on FLINK-16717: -- Is it a duplicate of FLINK-16602? > Use he

[jira] [Commented] (FLINK-16638) Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

[ https://issues.apache.org/jira/browse/FLINK-16638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064651#comment-17064651 ] Roman Khachatryan commented on FLINK-16638: --- Unfortunately, I can't follow the

[GitHub] [flink] liuyongvs commented on issue #11471: [FLINK-16692] flink joblistener can register from config

liuyongvs commented on issue #11471: [FLINK-16692] flink joblistener can register from config URL: https://github.com/apache/flink/pull/11471#issuecomment-602476909 Thanks you so much. Becase my personal PC doen't run fast. so i just not run on my PC and commits directly. i will commit wit

[GitHub] [flink] GJL closed pull request #11453: [FLINK-16718][tests] Fix ByteBuf leak in KvStateServerHandlerTest

GJL closed pull request #11453: [FLINK-16718][tests] Fix ByteBuf leak in KvStateServerHandlerTest URL: https://github.com/apache/flink/pull/11453 This is an automated message from the Apache Git Service. To respond to the me

[jira] [Updated] (FLINK-16718) KvStateServerHandlerTest leaks Netty ByteBufs

[ https://issues.apache.org/jira/browse/FLINK-16718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16718: --- Labels: pull-request-available (was: ) > KvStateServerHandlerTest leaks Netty ByteBufs > --

[jira] [Updated] (FLINK-16718) KvStateServerHandlerTest leaks Netty ByteBufs

[ https://issues.apache.org/jira/browse/FLINK-16718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-16718: - Fix Version/s: 1.10.1 > KvStateServerHandlerTest leaks Netty ByteBufs >

[GitHub] [flink] flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#issuecomment-596323413 ## CI report: * 655adff5f2d9298b34b167b5a355f4b536613246 Travis:

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded

ifndef-SleePy commented on a change in pull request #11347: [FLINK-14971][checkpointing] Make all the non-IO operations in CheckpointCoordinator single-threaded URL: https://github.com/apache/flink/pull/11347#discussion_r396315368 ## File path: flink-runtime/src/main/java/org/apac

[jira] [Commented] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained

[ https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064658#comment-17064658 ] Kostas Kloudas commented on FLINK-16715: [~xintongsong] I see your point. In gen

[jira] [Comment Edited] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained

[ https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064658#comment-17064658 ] Kostas Kloudas edited comment on FLINK-16715 at 3/23/20, 9:33 AM:

  1   2   3   4   5   6   >