[GitHub] [flink] tillrohrmann commented on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging

tillrohrmann commented on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456#issuecomment-522444040 Hi @Johnlon, the Flink community does not merge feature branches with the master but rebases onto the

[GitHub] [flink] pnowojski commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

pnowojski commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r315066822 ## File path:

[GitHub] [flink] wzhero1 commented on issue #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application

wzhero1 commented on issue #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application URL: https://github.com/apache/flink/pull/9336#issuecomment-522445398 @walterddr Thanks for the test about ApplicationReport~ I have updated the doc and added a test in

[GitHub] [flink] luoguohao opened a new pull request #9481: [FLINK-13758] [flink-clients] failed to submit JobGraph when registered hdfs file in DistributedCache.

luoguohao opened a new pull request #9481: [FLINK-13758] [flink-clients] failed to submit JobGraph when registered hdfs file in DistributedCache. URL: https://github.com/apache/flink/pull/9481 ## What is the purpose of the change *make jobGraph submission success when using

[GitHub] [flink] flinkbot commented on issue #9481: [FLINK-13758] [flink-clients] failed to submit JobGraph when registered hdfs file in DistributedCache.

flinkbot commented on issue #9481: [FLINK-13758] [flink-clients] failed to submit JobGraph when registered hdfs file in DistributedCache. URL: https://github.com/apache/flink/pull/9481#issuecomment-522446929 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] flinkbot edited a comment on issue #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application

flinkbot edited a comment on issue #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application URL: https://github.com/apache/flink/pull/9336#issuecomment-517610510 ## CI report: * 4fe9e1ba5707fb4d208290116bc172142e6be08a : FAILURE

[GitHub] [flink] AHeise commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

AHeise commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r315070914 ## File path:

[GitHub] [flink] flinkbot commented on issue #9481: [FLINK-13758] [flink-clients] failed to submit JobGraph when registered hdfs file in DistributedCache.

flinkbot commented on issue #9481: [FLINK-13758] [flink-clients] failed to submit JobGraph when registered hdfs file in DistributedCache. URL: https://github.com/apache/flink/pull/9481#issuecomment-522450188 ## CI report: * 127ee0f0c7e02cc145976e8eccab83f2bbaf37f5 : PENDING

[GitHub] [flink] pnowojski commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

pnowojski commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r315072874 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #9387: [FLINK-13231] [pubsub] Replace Max outstanding acknowledgement ids li…

becketqin commented on a change in pull request #9387: [FLINK-13231] [pubsub] Replace Max outstanding acknowledgement ids li… URL: https://github.com/apache/flink/pull/9387#discussion_r315072045 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9479: [FLINK-13768] [Documentation] Add documentation regarding path style access for s3

flinkbot edited a comment on issue #9479: [FLINK-13768] [Documentation] Add documentation regarding path style access for s3 URL: https://github.com/apache/flink/pull/9479#issuecomment-522435214 ## CI report: * f4b4a9e1343252b7783d8fd39d8ab25e39b400d7 : SUCCESS

[GitHub] [flink] tillrohrmann commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

tillrohrmann commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r315075935 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

tillrohrmann commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r315074979 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

tillrohrmann commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r315075717 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

tillrohrmann commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r315074592 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

tillrohrmann commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r315075331 ## File path:

[GitHub] [flink] achyuthsamudrala opened a new pull request #9479: [FLINK-13768] [Documentation] Add documentation regarding path style access for s3

achyuthsamudrala opened a new pull request #9479: [FLINK-13768] [Documentation] Add documentation regarding path style access for s3 URL: https://github.com/apache/flink/pull/9479 ## What is the purpose of the change When interacting with s3 compatible file systems such as

[GitHub] [flink] flinkbot commented on issue #9479: [FLINK-13768] [Documentation] Add documentation regarding path style access for s3

flinkbot commented on issue #9479: [FLINK-13768] [Documentation] Add documentation regarding path style access for s3 URL: https://github.com/apache/flink/pull/9479#issuecomment-522434059 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot commented on issue #9479: [FLINK-13768] [Documentation] Add documentation regarding path style access for s3

flinkbot commented on issue #9479: [FLINK-13768] [Documentation] Add documentation regarding path style access for s3 URL: https://github.com/apache/flink/pull/9479#issuecomment-522435214 ## CI report: * f4b4a9e1343252b7783d8fd39d8ab25e39b400d7 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE

[GitHub] [flink] gaoyunhaii opened a new pull request #9480: [Flink-13752] Only references necessary variables when bookkeeping result partitions on TM

gaoyunhaii opened a new pull request #9480: [Flink-13752] Only references necessary variables when bookkeeping result partitions on TM URL: https://github.com/apache/flink/pull/9480 ## What is the purpose of the change This pull request fixes the problem that the

[GitHub] [flink] flinkbot commented on issue #9480: [Flink-13752] Only references necessary variables when bookkeeping result partitions on TM

flinkbot commented on issue #9480: [Flink-13752] Only references necessary variables when bookkeeping result partitions on TM URL: https://github.com/apache/flink/pull/9480#issuecomment-522437510 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot commented on issue #9480: [Flink-13752] Only references necessary variables when bookkeeping result partitions on TM

flinkbot commented on issue #9480: [Flink-13752] Only references necessary variables when bookkeeping result partitions on TM URL: https://github.com/apache/flink/pull/9480#issuecomment-522439114 ## CI report: * a95596e548b62cfc71177f8c2da0be540566f976 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9002: [FLINK-13105][table][doc] Add documentation for blink planner's built-in functions

flinkbot edited a comment on issue #9002: [FLINK-13105][table][doc] Add documentation for blink planner's built-in functions URL: https://github.com/apache/flink/pull/9002#issuecomment-513721231 ## CI report: * 40477a632625f9cb7ebce8ed4488a99b7b4f5093 : FAILURE

[GitHub] [flink] zhijiangW commented on a change in pull request #9471: [FLINK-13754][task] Decouple OperatorChain from StreamStatusMaintainer

zhijiangW commented on a change in pull request #9471: [FLINK-13754][task] Decouple OperatorChain from StreamStatusMaintainer URL: https://github.com/apache/flink/pull/9471#discussion_r315258732 ## File path:

[GitHub] [flink] flinkbot commented on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

flinkbot commented on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-522623760 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink-playgrounds] fhueske commented on issue #2: Add config and code to build Docker image for operations playground

fhueske commented on issue #2: Add config and code to build Docker image for operations playground URL: https://github.com/apache/flink-playgrounds/pull/2#issuecomment-522639023 Thanks for the review @rmetzger! I'll merge the playground for Flink 1.8 and will update it to Flink 1.9 once

[jira] [Commented] (FLINK-4256) Fine-grained recovery

[ https://issues.apache.org/jira/browse/FLINK-4256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910534#comment-16910534 ] Stephan Ewen commented on FLINK-4256: - @Thomas - I think the approach to manually split jobs with a

[jira] [Commented] (FLINK-13788) Document state migration constraints on keys

[ https://issues.apache.org/jira/browse/FLINK-13788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910535#comment-16910535 ] Tzu-Li (Gordon) Tai commented on FLINK-13788: - Looks good to me. I've assigned you to the

[jira] [Assigned] (FLINK-13788) Document state migration constraints on keys

[ https://issues.apache.org/jira/browse/FLINK-13788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-13788: --- Assignee: Seth Wiesman > Document state migration constraints on keys >

[GitHub] [flink] Johnlon commented on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging

Johnlon commented on issue #9456: FLINK-13588 flink-streaming-java don't throw away exception info in logging URL: https://github.com/apache/flink/pull/9456#issuecomment-522651520 @tillrohrmann Hi problem seems fixed on my end. Not sure what you mean in your comment re commit history

[GitHub] [flink] sjwiesman commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

sjwiesman commented on a change in pull request #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#discussion_r315312470 ## File path: docs/getting-started/walkthroughs/datastream_api.md ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on issue #9485: [FLINK-13775][table-planner-blink] Refactor ExpressionConverter(RexNodeConverter) in blink

flinkbot edited a comment on issue #9485: [FLINK-13775][table-planner-blink] Refactor ExpressionConverter(RexNodeConverter) in blink URL: https://github.com/apache/flink/pull/9485#issuecomment-522655319 ## CI report: * 64391df18f5c2e3c25268ad52c724abcaa4211b5 : SUCCESS

[jira] [Commented] (FLINK-13717) allow to set taskmanager.host and taskmanager.bind-host separately

[ https://issues.apache.org/jira/browse/FLINK-13717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910637#comment-16910637 ] Michal Brunát commented on FLINK-13717: --- I think this default would fit. And if not it is just

[jira] [Updated] (FLINK-13643) Document the workaround for users with a different minor Hive version

[ https://issues.apache.org/jira/browse/FLINK-13643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13643: - Fix Version/s: (was: 1.9.0) 1.9.1 1.10.0 > Document the

[GitHub] [flink] asfgit closed pull request #9447: [FLINK-13643][docs]Document the workaround for users with a different minor Hive version

asfgit closed pull request #9447: [FLINK-13643][docs]Document the workaround for users with a different minor Hive version URL: https://github.com/apache/flink/pull/9447 This is an automated message from the Apache Git

[jira] [Commented] (FLINK-7151) Add a function SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910674#comment-16910674 ] Bowen Li commented on FLINK-7151: - Hi [~suez1224] , are you still interested in moving this forward?

[GitHub] [flink] flinkbot edited a comment on issue #9457: [FLINK-13741][table] "SHOW FUNCTIONS" should include Flink built-in functions' names

flinkbot edited a comment on issue #9457: [FLINK-13741][table] "SHOW FUNCTIONS" should include Flink built-in functions' names URL: https://github.com/apache/flink/pull/9457#issuecomment-521829752 ## CI report: * 55c0e5843e029f022ff59fe14a9e6c1d2c5ac69e : FAILURE

[GitHub] [flink] flinkbot commented on issue #9486: [FLINK-13789] move prefix out of the format string

flinkbot commented on issue #9486: [FLINK-13789] move prefix out of the format string URL: https://github.com/apache/flink/pull/9486#issuecomment-522729564 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] flinkbot commented on issue #9486: [FLINK-13789] move prefix out of the format string

flinkbot commented on issue #9486: [FLINK-13789] move prefix out of the format string URL: https://github.com/apache/flink/pull/9486#issuecomment-522731408 ## CI report: * 6b1de55f21733476acacf0de3df5c859e6d49a48 : PENDING

[jira] [Updated] (FLINK-12814) Support a traditional and scrolling view of result (non-interactive)

[ https://issues.apache.org/jira/browse/FLINK-12814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12814: - Fix Version/s: 1.10.0 > Support a traditional and scrolling view of result (non-interactive) >

[GitHub] [flink] sjwiesman edited a comment on issue #9444: [FLINK-13726][docs] build docs with jekyll 4.0.0.pre.beta1

sjwiesman edited a comment on issue #9444: [FLINK-13726][docs] build docs with jekyll 4.0.0.pre.beta1 URL: https://github.com/apache/flink/pull/9444#issuecomment-522735908 Please add the new jekyll cache (`docs/.jekyll-cache/`) to flinks `.gitignore`.

[GitHub] [flink] sjwiesman commented on issue #9444: [FLINK-13726][docs] build docs with jekyll 4.0.0.pre.beta1

sjwiesman commented on issue #9444: [FLINK-13726][docs] build docs with jekyll 4.0.0.pre.beta1 URL: https://github.com/apache/flink/pull/9444#issuecomment-522735908 Please add `docs/.jekyll-cache/*` to flinks `.gitignore`.

[GitHub] [flink] flinkbot edited a comment on issue #9486: [FLINK-13789] move prefix out of the format string

flinkbot edited a comment on issue #9486: [FLINK-13789] move prefix out of the format string URL: https://github.com/apache/flink/pull/9486#issuecomment-522731408 ## CI report: * 6b1de55f21733476acacf0de3df5c859e6d49a48 : CANCELED

[GitHub] [flink] flinkbot commented on issue #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

flinkbot commented on issue #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#issuecomment-522740816 ## CI report: * f4a31e789e78ba3d5ab18ce50c9e8e697d3141d1 : PENDING

[jira] [Closed] (FLINK-13643) Document the workaround for users with a different minor Hive version

[ https://issues.apache.org/jira/browse/FLINK-13643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13643. Resolution: Fixed merged in master: eb0436b4971a0a939395f570b4abbaa9ee508903  1.9.1: 

[jira] [Commented] (FLINK-10231) Add a view SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-10231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910677#comment-16910677 ] Bowen Li commented on FLINK-10231: -- Hi [~winipanda] , are you still interested in moving this forward?

[jira] [Updated] (FLINK-13755) support Hive built-in functions in Flink

[ https://issues.apache.org/jira/browse/FLINK-13755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13755: - Description: Unlike UDFs that are persisted in Hive Metastore, Hive builtin functions are registered

[jira] [Updated] (FLINK-12845) Execute multiple statements in command line or sql script file

[ https://issues.apache.org/jira/browse/FLINK-12845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12845: - Fix Version/s: 1.10.0 > Execute multiple statements in command line or sql script file >

[jira] [Updated] (FLINK-12828) Support -f option with a sql script file as input

[ https://issues.apache.org/jira/browse/FLINK-12828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12828: - Fix Version/s: 1.10.0 > Support -f option with a sql script file as input >

[jira] [Assigned] (FLINK-12845) Execute multiple statements in command line or sql script file

[ https://issues.apache.org/jira/browse/FLINK-12845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-12845: Assignee: Zhenghua Gao > Execute multiple statements in command line or sql script file >

[GitHub] [flink] bowenli86 edited a comment on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line…

bowenli86 edited a comment on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line… URL: https://github.com/apache/flink/pull/8738#issuecomment-522740294 @docete can you rebase this PR? This should be aimed for 1.10

[GitHub] [flink] bowenli86 commented on issue #8727: [FLINK-12828][sql-client] Support -f option with a sql script file as…

bowenli86 commented on issue #8727: [FLINK-12828][sql-client] Support -f option with a sql script file as… URL: https://github.com/apache/flink/pull/8727#issuecomment-522740406 @docete can you rebase this PR? This should be aimed for 1.10

[GitHub] [flink] bowenli86 commented on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line…

bowenli86 commented on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line… URL: https://github.com/apache/flink/pull/8738#issuecomment-522740294 @docete can you rebase this PR? This is an

[jira] [Commented] (FLINK-13790) Support -e option with a sql script file as input

[ https://issues.apache.org/jira/browse/FLINK-13790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910734#comment-16910734 ] Bowen Li commented on FLINK-13790: -- Hi [~docete] , I assigned this Jira to you since it's very similar

[GitHub] [flink] flinkbot edited a comment on issue #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

flinkbot edited a comment on issue #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#issuecomment-514437706 ## CI report: * 5eb979da047c442c0205464c92b5bd9ee3a740dc : FAILURE

[jira] [Closed] (FLINK-12854) evaluate and support for primitive array in Hive functions

[ https://issues.apache.org/jira/browse/FLINK-12854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-12854. Resolution: Fixed Closing this as I don't think we are gonna support or consider it in near future >

[jira] [Closed] (FLINK-12656) Integrate Flink with Hive user defined functions

[ https://issues.apache.org/jira/browse/FLINK-12656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-12656. Resolution: Fixed > Integrate Flink with Hive user defined functions >

[jira] [Updated] (FLINK-12656) Integrate Flink with Hive user defined functions

[ https://issues.apache.org/jira/browse/FLINK-12656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12656: - Fix Version/s: 1.9.0 > Integrate Flink with Hive user defined functions >

[GitHub] [flink] NicoK commented on issue #8887: [FLINK-12982][metrics] improve DescriptiveStatisticsHistogramStatistics performance

NicoK commented on issue #8887: [FLINK-12982][metrics] improve DescriptiveStatisticsHistogramStatistics performance URL: https://github.com/apache/flink/pull/8887#issuecomment-522722305 FYI: I updated the code according to your comments and my findings

[jira] [Created] (FLINK-13789) Transactional Id Generation fails due to user code impacting formatting string

Hao Dang created FLINK-13789: Summary: Transactional Id Generation fails due to user code impacting formatting string Key: FLINK-13789 URL: https://issues.apache.org/jira/browse/FLINK-13789 Project:

[jira] [Commented] (FLINK-12814) Support a traditional and scrolling view of result (non-interactive)

[ https://issues.apache.org/jira/browse/FLINK-12814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910723#comment-16910723 ] Bowen Li commented on FLINK-12814: -- +1. We'd better aim this for release 1.10. > Support a traditional

[GitHub] [flink] bowenli86 commented on issue #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

bowenli86 commented on issue #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#issuecomment-522736547 @docete can you please rebase this PR? This is

[GitHub] [flink] sjwiesman removed a comment on issue #9444: [FLINK-13726][docs] build docs with jekyll 4.0.0.pre.beta1

sjwiesman removed a comment on issue #9444: [FLINK-13726][docs] build docs with jekyll 4.0.0.pre.beta1 URL: https://github.com/apache/flink/pull/9444#issuecomment-522735908 Please add the new jekyll cache (`docs/.jekyll-cache/`) to flinks `.gitignore`.

[GitHub] [flink] flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-519130955 ## CI report: * 5d8448c4813f5b362f98f898998f1278f062d807 : FAILURE

[jira] [Comment Edited] (FLINK-13717) allow to set taskmanager.host and taskmanager.bind-host separately

[ https://issues.apache.org/jira/browse/FLINK-13717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910637#comment-16910637 ] Michal Brunát edited comment on FLINK-13717 at 8/19/19 6:30 PM: I think

[jira] [Commented] (FLINK-12847) Update Kinesis Connectors to latest Apache licensed libraries

[ https://issues.apache.org/jira/browse/FLINK-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910667#comment-16910667 ] Thomas Weise commented on FLINK-12847: -- I prefer we do the 1.x update to get the license change.

[GitHub] [flink] bowenli86 commented on a change in pull request #9447: [FLINK-13643][docs]Document the workaround for users with a different minor Hive version

bowenli86 commented on a change in pull request #9447: [FLINK-13643][docs]Document the workaround for users with a different minor Hive version URL: https://github.com/apache/flink/pull/9447#discussion_r315367004 ## File path: docs/dev/table/hive/index.zh.md ## @@ -40,7

[jira] [Updated] (FLINK-10231) Add a view SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-10231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10231: - Fix Version/s: 1.10.0 > Add a view SQL DDL > -- > > Key: FLINK-10231 >

[jira] [Updated] (FLINK-13789) Transactional Id Generation fails due to user code impacting formatting string

[ https://issues.apache.org/jira/browse/FLINK-13789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hao Dang updated FLINK-13789: - Fix Version/s: 1.8.0 1.8.1 > Transactional Id Generation fails due to user code

[jira] [Updated] (FLINK-13789) Transactional Id Generation fails due to user code impacting formatting string

[ https://issues.apache.org/jira/browse/FLINK-13789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hao Dang updated FLINK-13789: - Description: In [TransactionalIdsGenerator.java|#L94]], prefix contains taskName of the particular

[jira] [Updated] (FLINK-13789) Transactional Id Generation fails due to user code impacting formatting string

[ https://issues.apache.org/jira/browse/FLINK-13789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13789: --- Labels: pull-request-available (was: ) > Transactional Id Generation fails due to user

[GitHub] [flink] haodang opened a new pull request #9486: [FLINK-13789] move prefix out of the format string

haodang opened a new pull request #9486: [FLINK-13789] move prefix out of the format string URL: https://github.com/apache/flink/pull/9486 ## What is the purpose of the change Fixing https://issues.apache.org/jira/browse/FLINK-13789 by moving `prefix` out of the format

[jira] [Updated] (FLINK-13197) support querying Hive's view in Flink

[ https://issues.apache.org/jira/browse/FLINK-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13197: - Description: One goal of HiveCatalog and hive integration is to enable Flink-Hive interoperability,

[jira] [Updated] (FLINK-13197) support querying Hive's view in Flink

[ https://issues.apache.org/jira/browse/FLINK-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13197: - Fix Version/s: 1.10.0 > support querying Hive's view in Flink > - >

[jira] [Updated] (FLINK-13755) support Hive built-in functions in Flink

[ https://issues.apache.org/jira/browse/FLINK-13755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13755: - Description: Unlike UDFs that are persisted in Hive Metastore, Hive builtin functions are registered

[jira] [Updated] (FLINK-13755) support Hive built-in functions in Flink

[ https://issues.apache.org/jira/browse/FLINK-13755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13755: - Description: Unlike UDFs that are persisted in Hive Metastore, Hive builtin functions are registered

[GitHub] [flink] flinkbot commented on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line…

flinkbot commented on issue #8738: [FLINK-12845][sql-client] Execute multiple statements in command line… URL: https://github.com/apache/flink/pull/8738#issuecomment-522743542 ## CI report: * ca6e0d310325ecda459b5c29144161b35ee73278 : PENDING

[GitHub] [flink] flinkbot commented on issue #8727: [FLINK-12828][sql-client] Support -f option with a sql script file as…

flinkbot commented on issue #8727: [FLINK-12828][sql-client] Support -f option with a sql script file as… URL: https://github.com/apache/flink/pull/8727#issuecomment-522743669 ## CI report: * a653c7903cb78b98aa6ddaca6001a587aa8fb7ce : FAILURE

[jira] [Updated] (FLINK-12905) Convert CatalogView to org.apache.calcite.schema.Table so that planner can use unified catalog APIs

[ https://issues.apache.org/jira/browse/FLINK-12905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12905: - Fix Version/s: 1.10.0 > Convert CatalogView to org.apache.calcite.schema.Table so that planner can >

[GitHub] [flink] flinkbot edited a comment on issue #9470: [FLINK-13380][k8s] Improve the usability of Flink session cluster on Kubernetes

flinkbot edited a comment on issue #9470: [FLINK-13380][k8s] Improve the usability of Flink session cluster on Kubernetes URL: https://github.com/apache/flink/pull/9470#issuecomment-522260447 ## CI report: * 3db70d3f656ed9739d1a8f0b913e33732df36150 : SUCCESS

[GitHub] [flink] NicoK commented on a change in pull request #8888: [FLINK-12983][metrics] replace descriptive histogram's storage back-end

NicoK commented on a change in pull request #: [FLINK-12983][metrics] replace descriptive histogram's storage back-end URL: https://github.com/apache/flink/pull/#discussion_r315374624 ## File path:

[GitHub] [flink] NicoK commented on a change in pull request #8888: [FLINK-12983][metrics] replace descriptive histogram's storage back-end

NicoK commented on a change in pull request #: [FLINK-12983][metrics] replace descriptive histogram's storage back-end URL: https://github.com/apache/flink/pull/#discussion_r315374624 ## File path:

[jira] [Updated] (FLINK-13789) Transactional Id Generation fails due to user code impacting formatting string

[ https://issues.apache.org/jira/browse/FLINK-13789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hao Dang updated FLINK-13789: - Fix Version/s: 1.7.2 > Transactional Id Generation fails due to user code impacting formatting string >

[jira] [Created] (FLINK-13790) Support -e option with a sql script file as input

Bowen Li created FLINK-13790: Summary: Support -e option with a sql script file as input Key: FLINK-13790 URL: https://issues.apache.org/jira/browse/FLINK-13790 Project: Flink Issue Type:

[GitHub] [flink] sjwiesman commented on issue #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

sjwiesman commented on issue #9210: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9210#issuecomment-522741985 @NicoK Thank you for taking a look. I believe I have addressed all your comments, please take another look when

[GitHub] [flink] flinkbot edited a comment on issue #9482: [FLINK-13758] [flink-clients] failed to submit JobGraph when registered hdfs file in DistributedCache.

flinkbot edited a comment on issue #9482: [FLINK-13758] [flink-clients] failed to submit JobGraph when registered hdfs file in DistributedCache. URL: https://github.com/apache/flink/pull/9482#issuecomment-522564432 ## CI report: * 78d5077eca1d8a05cbea426d24ac8b476c29828e : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9423: [FLINK-13699][table-api] Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types

flinkbot edited a comment on issue #9423: [FLINK-13699][table-api] Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types URL: https://github.com/apache/flink/pull/9423#issuecomment-520678993 ## CI report: * 0c023712b638e15c14210e41d6a1119e3e508942 :

[GitHub] [flink] flinkbot edited a comment on issue #7751: [FLINK-11608] [docs] Translate the "Local Setup Tutorial" page into Chinese

flinkbot edited a comment on issue #7751: [FLINK-11608] [docs] Translate the "Local Setup Tutorial" page into Chinese URL: https://github.com/apache/flink/pull/7751#issuecomment-517135258 ## CI report: * 82afc481b4eb377bbcec2b9bac53d013a1ba1666 : SUCCESS

[jira] [Created] (FLINK-13780) Introduce ExpressionConverter to legacy planner

Jingsong Lee created FLINK-13780: Summary: Introduce ExpressionConverter to legacy planner Key: FLINK-13780 URL: https://issues.apache.org/jira/browse/FLINK-13780 Project: Flink Issue Type:

[jira] [Created] (FLINK-13781) Use new Expression in RexNodeToExpressionConverter

Jingsong Lee created FLINK-13781: Summary: Use new Expression in RexNodeToExpressionConverter Key: FLINK-13781 URL: https://issues.apache.org/jira/browse/FLINK-13781 Project: Flink Issue

[jira] [Updated] (FLINK-13774) Expression DSL use should resolve Expressions in blink

[ https://issues.apache.org/jira/browse/FLINK-13774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13774: --- Labels: pull-request-available (was: ) > Expression DSL use should resolve Expressions in

[GitHub] [flink] flinkbot commented on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

flinkbot commented on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-522628616 ## CI report: * 9559898f9d03c5aad327febdcd6fcd6a2d3e99f2 : PENDING

[jira] [Updated] (FLINK-13787) PrometheusPushGatewayReporter does not cleanup TM metrics when run on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-13787: --- Description: I have run a flink job on kubernetes and use PrometheusPushGatewayReporter, I can see

[GitHub] [flink] sjwiesman commented on issue #9444: [FLINK-13726][docs] build docs with jekyll 4.0.0.pre.beta1

sjwiesman commented on issue #9444: [FLINK-13726][docs] build docs with jekyll 4.0.0.pre.beta1 URL: https://github.com/apache/flink/pull/9444#issuecomment-522634341 When I previously profiled the docs build 99% of the time is spent rendering `_includes/sidenav.html`. This is because of

[jira] [Comment Edited] (FLINK-10382) Writer has already been opened while using AvroKeyValueSinkWriter and BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-10382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910497#comment-16910497 ] John Lonergan edited comment on FLINK-10382 at 8/19/19 3:48 PM: Just

[GitHub] [flink] flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-522628616 ## CI report: * 9559898f9d03c5aad327febdcd6fcd6a2d3e99f2 : CANCELED

[jira] [Commented] (FLINK-12749) Getting Started - Docker Playgrounds - Flink Cluster Playground

[ https://issues.apache.org/jira/browse/FLINK-12749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910513#comment-16910513 ] Fabian Hueske commented on FLINK-12749: --- After some discussions on the dev mailing list

[GitHub] [flink] xintongsong commented on a change in pull request #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese

xintongsong commented on a change in pull request #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese URL: https://github.com/apache/flink/pull/9454#discussion_r315283603 ## File path: docs/ops/state/state_backends.zh.md ## @@ -22,114 +22,111 @@

[GitHub] [flink] xintongsong commented on a change in pull request #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese

xintongsong commented on a change in pull request #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese URL: https://github.com/apache/flink/pull/9454#discussion_r315285683 ## File path: docs/ops/state/state_backends.zh.md ## @@ -22,114 +22,111 @@

  1   2   3   4   >