[GitHub] [flink] flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-522053886 ## CI report: * 009da497d7c551ba854dc7ed8fa658f2acd6d6ce : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-522053886 ## CI report: * 009da497d7c551ba854dc7ed8fa658f2acd6d6ce : SUCCESS

[jira] [Created] (FLINK-13880) The behavior of JobExecutionResult.getAccumulatorResult does not match its java doc

Caizhi Weng created FLINK-13880: --- Summary: The behavior of JobExecutionResult.getAccumulatorResult does not match its java doc Key: FLINK-13880 URL: https://issues.apache.org/jira/browse/FLINK-13880

[GitHub] [flink] JingsongLi commented on a change in pull request #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

JingsongLi commented on a change in pull request #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#discussion_r318362631 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey

flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey URL: https://github.com/apache/flink/pull/9517#issuecomment-524187390 ## CI report: * cdbd732fd99f2d2b5ad3cac2d119ef201079aafa : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey

flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey URL: https://github.com/apache/flink/pull/9517#issuecomment-524185771 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey

flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey URL: https://github.com/apache/flink/pull/9517#issuecomment-524187390 ## CI report: * cdbd732fd99f2d2b5ad3cac2d119ef201079aafa : CANCELED

[GitHub] [flink] kaibozhou commented on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey

kaibozhou commented on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey URL: https://github.com/apache/flink/pull/9517#issuecomment-525584456 @flinkbot run travis This

[GitHub] [flink] flinkbot edited a comment on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader

flinkbot edited a comment on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader URL: https://github.com/apache/flink/pull/9510#issuecomment-523878082 ## CI report: * 7e7bc9b213b2fadb8759449b65e5be19b11aa829 : SUCCESS

[jira] [Updated] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13740: Fix Version/s: 1.9.1 > TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis >

[jira] [Updated] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13740: Affects Version/s: 1.9.0 > TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis >

[jira] [Updated] (FLINK-13503) Add contract in `LookupableTableSource` to specify the behavior when lookupKeys contains null

[ https://issues.apache.org/jira/browse/FLINK-13503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13503: Fix Version/s: 1.9.1 1.10.0 > Add contract in `LookupableTableSource` to specify the

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523767672 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r318379606 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523767672 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r318379352 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey

flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey URL: https://github.com/apache/flink/pull/9517#issuecomment-524187390 ## CI report: * cdbd732fd99f2d2b5ad3cac2d119ef201079aafa : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader

flinkbot edited a comment on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader URL: https://github.com/apache/flink/pull/9510#issuecomment-523878082 ## CI report: * 7e7bc9b213b2fadb8759449b65e5be19b11aa829 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-522374042 ## CI report: * 1530600eaf36324966f343c277437e48c2416dc2 :

[jira] [Updated] (FLINK-13568) DDL create table doesn't allow STRING data type

[ https://issues.apache.org/jira/browse/FLINK-13568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13568: Fix Version/s: 1.9.1 1.10.0 > DDL create table doesn't allow STRING data type >

[GitHub] [flink] flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-522373234 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] zhijiangW edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

zhijiangW edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-525565847 Thanks for the review @pnowojski ! I have submitted the fixup

[GitHub] [flink] zhijiangW commented on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

zhijiangW commented on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-525565847 Thanks for the review @pnowojski ! I have submitted the fixup commit

[GitHub] [flink] flinkbot edited a comment on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader

flinkbot edited a comment on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader URL: https://github.com/apache/flink/pull/9510#issuecomment-523875969 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-522374042 ## CI report: * 1530600eaf36324966f343c277437e48c2416dc2 :

[GitHub] [flink] TisonKun commented on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader

TisonKun commented on issue #9510: [FLINK-13807][tests] Read file with UTF-8 charset in TestBaseUtils.getResultReader URL: https://github.com/apache/flink/pull/9510#issuecomment-525564884 @flinkbot run travis This is an

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523767672 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-522373234 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r318375048 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-522373234 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523767672 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r318374178 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-522373234 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] flinkbot edited a comment on issue #9518: [FLINK-13823] [Table] Fix incorrect debug log in CompileUtils

flinkbot edited a comment on issue #9518: [FLINK-13823] [Table] Fix incorrect debug log in CompileUtils URL: https://github.com/apache/flink/pull/9518#issuecomment-524212346 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Assigned] (FLINK-13823) Incorrect debug log in CompileUtils

[ https://issues.apache.org/jira/browse/FLINK-13823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13823: --- Assignee: wangsan > Incorrect debug log in CompileUtils > --- > >

[jira] [Resolved] (FLINK-13823) Incorrect debug log in CompileUtils

[ https://issues.apache.org/jira/browse/FLINK-13823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13823. - Fix Version/s: 1.10.0 Resolution: Fixed 1.10.0: 9d03fbdf7524af6de0e0e99386fff1c1f135d3bf 1.9.1: 

[GitHub] [flink] asfgit closed pull request #9518: [FLINK-13823] [Table] Fix incorrect debug log in CompileUtils

asfgit closed pull request #9518: [FLINK-13823] [Table] Fix incorrect debug log in CompileUtils URL: https://github.com/apache/flink/pull/9518 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] lirui-apache commented on a change in pull request #9502: [FLINK-13814][hive] HiveTableSink should strip quotes from partition …

lirui-apache commented on a change in pull request #9502: [FLINK-13814][hive] HiveTableSink should strip quotes from partition … URL: https://github.com/apache/flink/pull/9502#discussion_r318368965 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9518: [FLINK-13823] [Table] Fix incorrect debug log in CompileUtils

flinkbot edited a comment on issue #9518: [FLINK-13823] [Table] Fix incorrect debug log in CompileUtils URL: https://github.com/apache/flink/pull/9518#issuecomment-524212346 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot edited a comment on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese

flinkbot edited a comment on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9299#issuecomment-516836559 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey

flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey URL: https://github.com/apache/flink/pull/9517#issuecomment-524187390 ## CI report: * cdbd732fd99f2d2b5ad3cac2d119ef201079aafa : CANCELED

[GitHub] [flink] wuchong commented on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese

wuchong commented on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9299#issuecomment-525554592 @YngwieWang , yes, you can create a hotfix pull request.

[GitHub] [flink] flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey

flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey URL: https://github.com/apache/flink/pull/9517#issuecomment-524187390 ## CI report: * cdbd732fd99f2d2b5ad3cac2d119ef201079aafa : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-522373234 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] zhijiangW commented on a change in pull request #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

zhijiangW commented on a change in pull request #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#discussion_r318363758 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey

flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey URL: https://github.com/apache/flink/pull/9517#issuecomment-524185771 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] YngwieWang edited a comment on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese

YngwieWang edited a comment on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9299#issuecomment-525549502 @wuchong ，谢谢。 我刚才检查，第319行的java没有改成scala，第538行的六没有改成七，请问如何修正? 直接提一个 [hotfix] 的 PR 可以么？

[jira] [Commented] (FLINK-13879) It seems that there might be some problem with the DataStream.keyBy(xx).maxBy(yy)

[ https://issues.apache.org/jira/browse/FLINK-13879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16917345#comment-16917345 ] liusong commented on FLINK-13879: - it is work when i try to use 'TupleTypeInfoBase' instead of

[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-522623760 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot edited a comment on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese

flinkbot edited a comment on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9299#issuecomment-516836559 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] JingsongLi commented on a change in pull request #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

JingsongLi commented on a change in pull request #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#discussion_r318362631 ## File path:

[GitHub] [flink] YngwieWang commented on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese

YngwieWang commented on issue #9299: [FLINK-13405][docs-zh] Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9299#issuecomment-525549502 @wuchong ，谢谢。 我刚才检查，第319行的java没有改成scala，第538行的六没有改成七，请问如何修正?

[GitHub] [flink] flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-522373234 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] zhijiangW commented on a change in pull request #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

zhijiangW commented on a change in pull request #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#discussion_r318360858 ## File path:

[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-522623760 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

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

JingsongLi commented on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-525546756 Hi @twalthr @dawidwys , I will try to do two things as your suggestion: 1.Use `FieldReferenceExpression`

[jira] [Created] (FLINK-13879) It seems that there might be some problem with the DataStream.keyBy(xx).maxBy(yy)

liusong created FLINK-13879: --- Summary: It seems that there might be some problem with the DataStream.keyBy(xx).maxBy(yy) Key: FLINK-13879 URL: https://issues.apache.org/jira/browse/FLINK-13879 Project:

[GitHub] [flink] flinkbot edited a comment on issue #9547: [FLINK-13877][hive] Support Hive version 2.1.0 and 2.1.1

flinkbot edited a comment on issue #9547: [FLINK-13877][hive] Support Hive version 2.1.0 and 2.1.1 URL: https://github.com/apache/flink/pull/9547#issuecomment-525514771 ## CI report: * c4f4353fcb2486fb375427e8f08f0e78b1a8c9a9 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9546: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

flinkbot edited a comment on issue #9546: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9546#issuecomment-525486944 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] tweise merged pull request #9546: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

tweise merged pull request #9546: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9546 This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on issue #9547: [FLINK-13877][hive] Support Hive version 2.1.0 and 2.1.1

flinkbot edited a comment on issue #9547: [FLINK-13877][hive] Support Hive version 2.1.0 and 2.1.1 URL: https://github.com/apache/flink/pull/9547#issuecomment-525514771 ## CI report: * c4f4353fcb2486fb375427e8f08f0e78b1a8c9a9 : PENDING

[GitHub] [flink] flinkbot commented on issue #9547: [FLINK-13877][hive] Support Hive version 2.1.0 and 2.1.1

flinkbot commented on issue #9547: [FLINK-13877][hive] Support Hive version 2.1.0 and 2.1.1 URL: https://github.com/apache/flink/pull/9547#issuecomment-525514771 ## CI report: * c4f4353fcb2486fb375427e8f08f0e78b1a8c9a9 : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9546: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

flinkbot edited a comment on issue #9546: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9546#issuecomment-525489084 ## CI report: * 54ba8b50eb37475f9994a29f8d96250801d72203 : FAILURE

[GitHub] [flink] flinkbot commented on issue #9547: [FLINK-13877][hive] Support Hive version 2.1.0 and 2.1.1

flinkbot commented on issue #9547: [FLINK-13877][hive] Support Hive version 2.1.0 and 2.1.1 URL: https://github.com/apache/flink/pull/9547#issuecomment-525512048 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] xuefuz commented on issue #9547: [FLINK-13877][hive] Support Hive version 2.1.0 and 2.1.1

xuefuz commented on issue #9547: [FLINK-13877][hive] Support Hive version 2.1.0 and 2.1.1 URL: https://github.com/apache/flink/pull/9547#issuecomment-525511334 cc: @bowenli86 @lirui-apache @zjuwangg This is an automated

[jira] [Updated] (FLINK-13877) Support Hive version 2.1.0 and 2.1.1

[ https://issues.apache.org/jira/browse/FLINK-13877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13877: --- Labels: pull-request-available (was: ) > Support Hive version 2.1.0 and 2.1.1 >

[GitHub] [flink] xuefuz opened a new pull request #9547: [FLINK-13877][hive] Support Hive version 2.1.0 and 2.1.1

xuefuz opened a new pull request #9547: [FLINK-13877][hive] Support Hive version 2.1.0 and 2.1.1 URL: https://github.com/apache/flink/pull/9547 ## What is the purpose of the change Support Hive 2.1.x versions (2.1.0 and 2.1.1). ## Brief change log - Added new shims

[GitHub] [flink] flinkbot edited a comment on issue #9546: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

flinkbot edited a comment on issue #9546: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9546#issuecomment-525489084 ## CI report: * 54ba8b50eb37475f9994a29f8d96250801d72203 : PENDING

[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-517608148 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] walterddr commented on a change in pull request #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application

walterddr commented on a change in pull request #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application URL: https://github.com/apache/flink/pull/9336#discussion_r318305310 ## File path:

[GitHub] [flink] flinkbot commented on issue #9546: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

flinkbot commented on issue #9546: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9546#issuecomment-525489084 ## CI report: * 54ba8b50eb37475f9994a29f8d96250801d72203 : UNKNOWN

[GitHub] [flink] flinkbot commented on issue #9546: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

flinkbot commented on issue #9546: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9546#issuecomment-525486944 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help 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-517608148 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] tweise opened a new pull request #9546: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

tweise opened a new pull request #9546: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9546 cherry pick b6bd8f602a4a8c4c5c3bb45c4afe9aec6ad902a3 from master

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

walterddr commented on issue #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application URL: https://github.com/apache/flink/pull/9336#issuecomment-525485982 > Just a comment for a possible test. I think it would be enough to test that we submit an

[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-517608148 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] walterddr commented on a change in pull request #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application

walterddr commented on a change in pull request #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application URL: https://github.com/apache/flink/pull/9336#discussion_r318299776 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

flinkbot edited a comment on issue #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9537#issuecomment-525052373 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] tweise merged pull request #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

tweise merged pull request #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9537 This is an automated message from the Apache Git

[jira] [Updated] (FLINK-13297) Flink SQL should be able to reference functions across catalogs with full path

[ https://issues.apache.org/jira/browse/FLINK-13297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13297: - Description: Flink SQL should be able to precisely reference functions with fully qualified name

[jira] [Updated] (FLINK-13297) Flink SQL should be able to reference functions across catalogs with full path

[ https://issues.apache.org/jira/browse/FLINK-13297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13297: - Fix Version/s: 1.10.0 > Flink SQL should be able to reference functions across catalogs with full path

[GitHub] [flink] flinkbot edited a comment on issue #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

flinkbot edited a comment on issue #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9537#issuecomment-525052373 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] jgrier commented on issue #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout

jgrier commented on issue #9537: [hotfix][kinesis] Update emit record javadoc and don't count max watermark as timeout URL: https://github.com/apache/flink/pull/9537#issuecomment-525454173 @flinkbot approve all This is

[GitHub] [flink] flinkbot edited a comment on issue #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code

flinkbot edited a comment on issue #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code URL: https://github.com/apache/flink/pull/9494#issuecomment-523025067 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] bowenli86 commented on a change in pull request #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code

bowenli86 commented on a change in pull request #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code URL: https://github.com/apache/flink/pull/9494#discussion_r318247144 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code

bowenli86 commented on a change in pull request #9494: [FLINK-12847] [Connectors / Kinesis] update flink-connector-kinesis to use Apache 2.0 licensed code URL: https://github.com/apache/flink/pull/9494#discussion_r318245066 ## File path: NOTICE-binary ## @@ -54,7 +54,6

[jira] [Created] (FLINK-13878) Flink CLI fails (TimeoutException) for unknown reason

Mitch Wasson created FLINK-13878: Summary: Flink CLI fails (TimeoutException) for unknown reason Key: FLINK-13878 URL: https://issues.apache.org/jira/browse/FLINK-13878 Project: Flink Issue

[jira] [Closed] (FLINK-13841) Extend Hive version support to all 1.2 and 2.3 versions

[ https://issues.apache.org/jira/browse/FLINK-13841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13841. Resolution: Fixed merged in master: 0437ad2fce8a064424522b4b01d3dcea55597033 > Extend Hive version

[GitHub] [flink] flinkbot edited a comment on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve…

flinkbot edited a comment on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve… URL: https://github.com/apache/flink/pull/9524#issuecomment-524485727 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Assigned] (FLINK-13841) Extend Hive version support to all 1.2 and 2.3 versions

[ https://issues.apache.org/jira/browse/FLINK-13841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-13841: Assignee: Xuefu Zhang > Extend Hive version support to all 1.2 and 2.3 versions >

[GitHub] [flink] asfgit closed pull request #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve…

asfgit closed pull request #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve… URL: https://github.com/apache/flink/pull/9524 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on issue #9544: [FLINK-13875][docs] Add missing redirects to the documentation

flinkbot edited a comment on issue #9544: [FLINK-13875][docs] Add missing redirects to the documentation URL: https://github.com/apache/flink/pull/9544#issuecomment-525340056 ## CI report: * f1e1c11a3b75aa67ec0b2f7424ce31ec4f07a3bb : FAILURE

[jira] [Commented] (FLINK-13869) Hive functions can not work in blink planner stream mode

[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916974#comment-16916974 ] Bowen Li commented on FLINK-13869: -- [~Terry1897] thanks for reporting the bug. I renamed it to "Hive

[jira] [Updated] (FLINK-13869) Hive functions can not work in blink planner stream mode

[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13869: - Summary: Hive functions can not work in blink planner stream mode (was: Hive built-in function can not

[jira] [Assigned] (FLINK-13869) Hive built-in function can not work in blink planner stream mode

[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-13869: Assignee: Jingsong Lee > Hive built-in function can not work in blink planner stream mode >

[GitHub] [flink] flinkbot edited a comment on issue #9545: [FLINK-13355][docs] Add documentation for Temporal Table Join in blink planner

flinkbot edited a comment on issue #9545: [FLINK-13355][docs] Add documentation for Temporal Table Join in blink planner URL: https://github.com/apache/flink/pull/9545#issuecomment-525381895 ## CI report: * 88e894661cfb3d8bc1b61540bc03dd2315706b63 : SUCCESS

[GitHub] [flink] bowenli86 edited a comment on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve…

bowenli86 edited a comment on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve… URL: https://github.com/apache/flink/pull/9524#issuecomment-525415498 > Let's discuss about this in the JIRA you created. For short comment, I don't think we need to provide a

[GitHub] [flink] flinkbot edited a comment on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve…

flinkbot edited a comment on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve… URL: https://github.com/apache/flink/pull/9524#issuecomment-524485727 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] bowenli86 commented on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve…

bowenli86 commented on issue #9524: [FLINK-13841][hive] Extend Hive version support to all 1.2 and 2.3 ve… URL: https://github.com/apache/flink/pull/9524#issuecomment-525415498 > Let's discuss about this in the JIRA you created. For short comment, I don't think we need to provide a

[jira] [Updated] (FLINK-13866) develop testing plan for many Hive versions that we support

[ https://issues.apache.org/jira/browse/FLINK-13866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13866: - Description: with FLINK-13841, we will start to support quite a few hive versions, let alone other

  1   2   3   4   5   >