[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297509524 ## File path: flink-runtime/src/test/java/or

[GitHub] [flink] aljoscha commented on issue #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord

aljoscha commented on issue #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord URL: https://github.com/apache/flink/pull/8535#issuecomment-505746482 @becketqin Do we want to do that in this PR or as an addition? --

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297508630 ## File path: flink-runtime/src/test/java/or

[GitHub] [flink] dawidwys commented on a change in pull request #8852: [FLINK-12798][table-api][table-planner] Add a proper discover mechanism that will enable switching between Flink & Blink Planner/

dawidwys commented on a change in pull request #8852: [FLINK-12798][table-api][table-planner] Add a proper discover mechanism that will enable switching between Flink & Blink Planner/Executor URL: https://github.com/apache/flink/pull/8852#discussion_r297506834 ## File path: flin

[GitHub] [flink] twalthr commented on a change in pull request #8865: [FLINK-12924][table] Introduce basic type inference interfaces

twalthr commented on a change in pull request #8865: [FLINK-12924][table] Introduce basic type inference interfaces URL: https://github.com/apache/flink/pull/8865#discussion_r297503796 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inferenc

[jira] [Created] (FLINK-12992) All host(s) tried for query failed (tried com.datastax.driver.core.exceptions.TransportException: Error writing...)

yanxiaobin created FLINK-12992: -- Summary: All host(s) tried for query failed (tried com.datastax.driver.core.exceptions.TransportException: Error writing...) Key: FLINK-12992 URL: https://issues.apache.org/jira/brows

[GitHub] [flink] lirui-apache commented on a change in pull request #8890: [FLINK-12989][hive]: Generate HiveTableSink from from a Hive table

lirui-apache commented on a change in pull request #8890: [FLINK-12989][hive]: Generate HiveTableSink from from a Hive table URL: https://github.com/apache/flink/pull/8890#discussion_r297494123 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch

[GitHub] [flink] lirui-apache commented on a change in pull request #8890: [FLINK-12989][hive]: Generate HiveTableSink from from a Hive table

lirui-apache commented on a change in pull request #8890: [FLINK-12989][hive]: Generate HiveTableSink from from a Hive table URL: https://github.com/apache/flink/pull/8890#discussion_r297499365 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/cata

[GitHub] [flink] lirui-apache commented on a change in pull request #8890: [FLINK-12989][hive]: Generate HiveTableSink from from a Hive table

lirui-apache commented on a change in pull request #8890: [FLINK-12989][hive]: Generate HiveTableSink from from a Hive table URL: https://github.com/apache/flink/pull/8890#discussion_r297497943 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalo

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297497629 ## File path: flink-runtime/src/test/java/or

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297497664 ## File path: flink-runtime/src/test/java/or

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297497609 ## File path: flink-runtime/src/test/java/or

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297497075 ## File path: flink-runtime/src/test/java/or

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297496069 ## File path: flink-runtime/src/test/java/or

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297496295 ## File path: flink-runtime/src/test/java/or

[jira] [Updated] (FLINK-12991) Correct the implementation of Catalog.get_table_factory

[ https://issues.apache.org/jira/browse/FLINK-12991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12991: Description: The following method is added in catalog.py in FLINK-11480: {code} def get_table_factory(self

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297496220 ## File path: flink-runtime/src/test/java/or

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297496069 ## File path: flink-runtime/src/test/java/or

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297495056 ## File path: flink-runtime/src/main/java/or

[jira] [Updated] (FLINK-12991) Correct the implementation of Catalog.get_table_factory

[ https://issues.apache.org/jira/browse/FLINK-12991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12991: Description: The following method is added in catalog.py in FLINK-11480: {code:java} def get_table_factory

[jira] [Created] (FLINK-12991) Correct the implementation of Catalog.get_table_factory

Dian Fu created FLINK-12991: --- Summary: Correct the implementation of Catalog.get_table_factory Key: FLINK-12991 URL: https://issues.apache.org/jira/browse/FLINK-12991 Project: Flink Issue Type: Bug

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297494125 ## File path: flink-runtime/src/main/java/or

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297493392 ## File path: flink-runtime/src/main/java/or

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297491959 ## File path: flink-runtime/src/main/java/or

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297465153 ## File path: flink-tests/src/test/java/org/apache/flink/test/runtime/RegionF

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297491370 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/

[GitHub] [flink] Aitozi commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

Aitozi commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297491110 ## File path: docs/_includes/generated/blob_serv

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297491040 ## File path: flink-runtime/src/main/java/or

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297491040 ## File path: flink-runtime/src/main/java/or

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297490492 ## File path: docs/_includes/generated/netty

[GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

zhijiangW commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r297490427 ## File path: docs/_includes/generated/blob_s

[jira] [Comment Edited] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872933#comment-16872933 ] zhijiang edited comment on FLINK-12889 at 6/26/19 5:33 AM: --- My

[jira] [Comment Edited] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872933#comment-16872933 ] zhijiang edited comment on FLINK-12889 at 6/26/19 5:32 AM: --- My

[jira] [Updated] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12889: - Priority: Minor (was: Blocker) > Job keeps in FAILING state > -- > >

[GitHub] [flink] dianfu commented on issue #8847: [FLINK-12609][python] Align the Python data types with Java

dianfu commented on issue #8847: [FLINK-12609][python] Align the Python data types with Java URL: https://github.com/apache/flink/pull/8847#issuecomment-505724940 Hi @sunjincheng121, makes sense to me. I have created #8892 and #8893 for the hotfix changes.

[jira] [Updated] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12889: - Affects Version/s: (was: 1.7.2) > Job keeps in FAILING state > -- > >

[jira] [Updated] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12889: - Component/s: (was: API / DataStream) Runtime / Coordination > Job keeps in FAILING

[jira] [Commented] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872933#comment-16872933 ] zhijiang commented on FLINK-12889: -- My previous analysis in ML was as follows:   Actual

[GitHub] [flink] lirui-apache commented on issue #8875: [FLINK-12970][hive] Support writing Hive complex types

lirui-apache commented on issue #8875: [FLINK-12970][hive] Support writing Hive complex types URL: https://github.com/apache/flink/pull/8875#issuecomment-505721128 Thanks @bowenli86 for the review. Please take another look. T

[GitHub] [flink] xuefuz commented on a change in pull request #8882: [FLINK-12965][table][hive] unify catalog view implementations

xuefuz commented on a change in pull request #8882: [FLINK-12965][table][hive] unify catalog view implementations URL: https://github.com/apache/flink/pull/8882#discussion_r297481016 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/QueryOp

[GitHub] [flink] flinkbot commented on issue #8893: [hotfix][python] Align the signature of type utility methods with Java

flinkbot commented on issue #8893: [hotfix][python] Align the signature of type utility methods with Java URL: https://github.com/apache/flink/pull/8893#issuecomment-505713502 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[GitHub] [flink] dianfu opened a new pull request #8893: [hotfix][python] Align the signature of type utility methods with Java

dianfu opened a new pull request #8893: [hotfix][python] Align the signature of type utility methods with Java URL: https://github.com/apache/flink/pull/8893 ## What is the purpose of the change *Currently, the python method `DataTypes.VARCHAR(length)` assumes default value `1` for

[GitHub] [flink] flinkbot commented on issue #8892: [FLINK-FLINK-12990][python] Date type doesn't consider the local TimeZone

flinkbot commented on issue #8892: [FLINK-FLINK-12990][python] Date type doesn't consider the local TimeZone URL: https://github.com/apache/flink/pull/8892#issuecomment-505711190 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to r

[jira] [Updated] (FLINK-12990) Date type doesn't consider the local TimeZone

[ https://issues.apache.org/jira/browse/FLINK-12990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12990: --- Labels: pull-request-available (was: ) > Date type doesn't consider the local TimeZone > --

[GitHub] [flink] dianfu opened a new pull request #8892: [FLINK-FLINK-12990][python] Date type doesn't consider the local TimeZone

dianfu opened a new pull request #8892: [FLINK-FLINK-12990][python] Date type doesn't consider the local TimeZone URL: https://github.com/apache/flink/pull/8892 ## What is the purpose of the change *Currently, the python DateType is converted by an `int` which indicates the days pas

[GitHub] [flink] flinkbot commented on issue #8891: [hotfix][util] Use OneTimeLeaderListenerFuture in LeaderRetrievalUtils

flinkbot commented on issue #8891: [hotfix][util] Use OneTimeLeaderListenerFuture in LeaderRetrievalUtils URL: https://github.com/apache/flink/pull/8891#issuecomment-505709075 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to rev

[GitHub] [flink] TisonKun opened a new pull request #8891: [hotfix][util] Use OneTimeLeaderListenerFuture in LeaderRetrievalUtils

TisonKun opened a new pull request #8891: [hotfix][util] Use OneTimeLeaderListenerFuture in LeaderRetrievalUtils URL: https://github.com/apache/flink/pull/8891 ## What is the purpose of the change Refactor LeaderRetrievalUtils by removing redundant codes. ## Brief change log

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297475345 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiong

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297476171 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiong

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297475345 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiong

[jira] [Comment Edited] (FLINK-12976) Bump Kafka client version to 2.3.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-12976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872883#comment-16872883 ] vinoyang edited comment on FLINK-12976 at 6/26/19 3:53 AM: --- I

[GitHub] [flink] xintongsong commented on a change in pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool

xintongsong commented on a change in pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool URL: https://github.com/apache/flink/pull/8841#discussion_r297465087 ## File path: flink-core/src/main/java/org/apache/flink/api/co

[GitHub] [flink] xintongsong commented on a change in pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool

xintongsong commented on a change in pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool URL: https://github.com/apache/flink/pull/8841#discussion_r297465713 ## File path: flink-core/src/main/java/org/apache/flink/api/co

[jira] [Created] (FLINK-12990) Date type doesn't consider the local TimeZone

Dian Fu created FLINK-12990: --- Summary: Date type doesn't consider the local TimeZone Key: FLINK-12990 URL: https://issues.apache.org/jira/browse/FLINK-12990 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-12957) Fix thrift and protobuf dependency examples in documentation

[ https://issues.apache.org/jira/browse/FLINK-12957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-12957. - Resolution: Fixed Fix Version/s: 1.9.0 Merged for 1.9.0: 46f94c1194567681

[GitHub] [flink] xintongsong commented on a change in pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool

xintongsong commented on a change in pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool URL: https://github.com/apache/flink/pull/8841#discussion_r297472482 ## File path: flink-runtime/src/main/java/org/apache/flink/run

[GitHub] [flink] xintongsong commented on a change in pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool

xintongsong commented on a change in pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool URL: https://github.com/apache/flink/pull/8841#discussion_r297471061 ## File path: flink-runtime/src/main/java/org/apache/flink/run

[GitHub] [flink] xintongsong commented on a change in pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool

xintongsong commented on a change in pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool URL: https://github.com/apache/flink/pull/8841#discussion_r297470517 ## File path: flink-runtime/src/main/java/org/apache/flink/run

[jira] [Resolved] (FLINK-12732) Add savepoint reader for consuming partitioned operator state

[ https://issues.apache.org/jira/browse/FLINK-12732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-12732. - Resolution: Fixed Fix Version/s: 1.9.0 Thanks for the contribution Seth!

[jira] [Resolved] (FLINK-12729) Add savepoint reader for consuming non-partitioned operator state

[ https://issues.apache.org/jira/browse/FLINK-12729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-12729. - Resolution: Fixed Fix Version/s: 1.9.0 Merged for 1.9.0: 88d2e3cc5c31a770

[GitHub] [flink] asfgit closed pull request #8709: [hotfix][docs]Fix the typos in process_function.md and process_function.zh.md.

asfgit closed pull request #8709: [hotfix][docs]Fix the typos in process_function.md and process_function.zh.md. URL: https://github.com/apache/flink/pull/8709 This is an automated message from the Apache Git Service. To res

[GitHub] [flink] asfgit closed pull request #8849: [hotfix][connectors] fix shadowed NPE in elasticsearch sink connector

asfgit closed pull request #8849: [hotfix][connectors] fix shadowed NPE in elasticsearch sink connector URL: https://github.com/apache/flink/pull/8849 This is an automated message from the Apache Git Service. To respond to t

[GitHub] [flink] asfgit closed pull request #8797: [Docks] Checkpoints: fix typo

asfgit closed pull request #8797: [Docks] Checkpoints: fix typo URL: https://github.com/apache/flink/pull/8797 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[GitHub] [flink] asfgit closed pull request #8640: [FLINK-12741][docs] Update Kafka producer fault tolerance guarantees

asfgit closed pull request #8640: [FLINK-12741][docs] Update Kafka producer fault tolerance guarantees URL: https://github.com/apache/flink/pull/8640 This is an automated message from the Apache Git Service. To respond to th

[GitHub] [flink] asfgit closed pull request #8806: [FLINK-12870][doc] Add missing warnings to schema evolution documentation

asfgit closed pull request #8806: [FLINK-12870][doc] Add missing warnings to schema evolution documentation URL: https://github.com/apache/flink/pull/8806 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] asfgit closed pull request #8848: [FLINK-12957][docs] fix thrift and protobuf dependency examples

asfgit closed pull request #8848: [FLINK-12957][docs] fix thrift and protobuf dependency examples URL: https://github.com/apache/flink/pull/8848 This is an automated message from the Apache Git Service. To respond to the mes

[jira] [Resolved] (FLINK-12870) Improve documentation of keys schema evolution

[ https://issues.apache.org/jira/browse/FLINK-12870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-12870. - Resolution: Fixed Fix Version/s: 1.9.0 Merged for 1.9.0: 641cbed1da37357b

[GitHub] [flink] asfgit closed pull request #8615: [FLINK-12729][state-processor-api] Add state reader for consuming non-partitioned operator state

asfgit closed pull request #8615: [FLINK-12729][state-processor-api] Add state reader for consuming non-partitioned operator state URL: https://github.com/apache/flink/pull/8615 This is an automated message from the Apache

[GitHub] [flink] asfgit closed pull request #8618: [FLINK-12732][state-processor-api] Add savepoint reader for consuming partitioned operator state

asfgit closed pull request #8618: [FLINK-12732][state-processor-api] Add savepoint reader for consuming partitioned operator state URL: https://github.com/apache/flink/pull/8618 This is an automated message from the Apache

[GitHub] [flink] asfgit closed pull request #8174: [FLINK-12190] Fix IllegalArgumentException thrown by FlinkKinesisConsumerMigrationTest#writeSnapshot

asfgit closed pull request #8174: [FLINK-12190] Fix IllegalArgumentException thrown by FlinkKinesisConsumerMigrationTest#writeSnapshot URL: https://github.com/apache/flink/pull/8174 This is an automated message from the Apac

[GitHub] [flink] xintongsong commented on a change in pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool

xintongsong commented on a change in pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool URL: https://github.com/apache/flink/pull/8841#discussion_r297467266 ## File path: flink-runtime/src/main/java/org/apache/flink/run

[GitHub] [flink] xintongsong commented on a change in pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool

xintongsong commented on a change in pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool URL: https://github.com/apache/flink/pull/8841#discussion_r297472941 ## File path: flink-runtime/src/main/java/org/apache/flink/run

[jira] [Resolved] (FLINK-12190) Fix IllegalArgumentException thrown by FlinkKinesisConsumerMigrationTest#writeSnapshot

[ https://issues.apache.org/jira/browse/FLINK-12190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-12190. - Resolution: Fixed Fix Version/s: 1.9.0 Merged for 1.9.0: f9681c0d1d12b912

[jira] [Resolved] (FLINK-12741) Update docs about Kafka producer fault tolerance guarantees

[ https://issues.apache.org/jira/browse/FLINK-12741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-12741. - Resolution: Fixed Fix Version/s: 1.9.0 Merged for 1.9.0: bbe47ade83cefefd

[jira] [Updated] (FLINK-12729) Add savepoint reader for consuming non-partitioned operator state

[ https://issues.apache.org/jira/browse/FLINK-12729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12729: --- Labels: pull-request-available (was: ) > Add savepoint reader for consuming non-partitioned

[jira] [Comment Edited] (FLINK-12976) Bump Kafka client version to 2.3.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-12976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872883#comment-16872883 ] vinoyang edited comment on FLINK-12976 at 6/26/19 3:32 AM: --- I

[GitHub] [flink] tzulitai commented on issue #8174: [FLINK-12190] Fix IllegalArgumentException thrown by FlinkKinesisConsumerMigrationTest#writeSnapshot

tzulitai commented on issue #8174: [FLINK-12190] Fix IllegalArgumentException thrown by FlinkKinesisConsumerMigrationTest#writeSnapshot URL: https://github.com/apache/flink/pull/8174#issuecomment-505703526 Merging ... This is

[jira] [Commented] (FLINK-12976) Bump Kafka client version to 2.3.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-12976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872883#comment-16872883 ] vinoyang commented on FLINK-12976: -- I can make sure that there are compatibility issues

[GitHub] [flink] zjuwangg commented on issue #8890: Xuefu1

zjuwangg commented on issue #8890: Xuefu1 URL: https://github.com/apache/flink/pull/8890#issuecomment-505702146 better to rename the pr title This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297466824 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiong

[GitHub] [flink] tzulitai commented on issue #8640: [FLINK-12741][docs] Update Kafka producer fault tolerance guarantees

tzulitai commented on issue #8640: [FLINK-12741][docs] Update Kafka producer fault tolerance guarantees URL: https://github.com/apache/flink/pull/8640#issuecomment-505701524 Thanks for the fix and reviews. Merging .. This

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297470182 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiong

[GitHub] [flink] tzulitai commented on issue #8709: [hotfix][docs]Fix the typos in process_function.md and process_function.zh.md.

tzulitai commented on issue #8709: [hotfix][docs]Fix the typos in process_function.md and process_function.zh.md. URL: https://github.com/apache/flink/pull/8709#issuecomment-505701130 Merging ... This is an automated message

[GitHub] [flink] tzulitai commented on issue #8797: [Docks] Checkpoints: fix typo

tzulitai commented on issue #8797: [Docks] Checkpoints: fix typo URL: https://github.com/apache/flink/pull/8797#issuecomment-505700499 Thanks for the fix and reviews, merging .. This is an automated message from the Apache Git

[GitHub] [flink] tzulitai commented on issue #8806: [FLINK-12870][doc] Add missing warnings to schema evolution documentation

tzulitai commented on issue #8806: [FLINK-12870][doc] Add missing warnings to schema evolution documentation URL: https://github.com/apache/flink/pull/8806#issuecomment-505700140 I think the extra warnings is already an improvement to the current state of this page. +1, will merge this

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297465424 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiong

[GitHub] [flink] sunjincheng121 commented on issue #8847: [FLINK-12609][python] Align the Python data types with Java

sunjincheng121 commented on issue #8847: [FLINK-12609][python] Align the Python data types with Java URL: https://github.com/apache/flink/pull/8847#issuecomment-505700051 Thanks for the PR @dianfu ! I appreciate if you can open the independent PR for the hotfix change，What do you think?

[jira] [Issue Comment Deleted] (FLINK-12976) Bump Kafka client version to 2.3.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-12976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-12976: - Comment: was deleted (was: It seems the public maven repository has not updated for the newest dependen

[GitHub] [flink] tzulitai commented on issue #8848: [FLINK-12957][docs] fix thrift and protobuf dependency examples

tzulitai commented on issue #8848: [FLINK-12957][docs] fix thrift and protobuf dependency examples URL: https://github.com/apache/flink/pull/8848#issuecomment-505699571 Thanks for the contribution @NicoK! The changes look good, will merge this ..

[GitHub] [flink] xuefuz edited a comment on issue #8890: Xuefu1

xuefuz edited a comment on issue #8890: Xuefu1 URL: https://github.com/apache/flink/pull/8890#issuecomment-505680111 Please note that this PR included the changes in PR #8883. cc: @bowenli86 @lirui-apache This is an automate

[GitHub] [flink] flinkbot edited a comment on issue #8849: [hotfix][connectors] fix shadowed NPE in elasticsearch sink connector

flinkbot edited a comment on issue #8849: [hotfix][connectors] fix shadowed NPE in elasticsearch sink connector URL: https://github.com/apache/flink/pull/8849#issuecomment-504907532 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community t

[GitHub] [flink] tzulitai commented on issue #8849: [hotfix][connectors] fix shadowed NPE in elasticsearch sink connector

tzulitai commented on issue #8849: [hotfix][connectors] fix shadowed NPE in elasticsearch sink connector URL: https://github.com/apache/flink/pull/8849#issuecomment-505698528 @flinkbot approve all This is an automated message

[GitHub] [flink] tzulitai commented on issue #8849: [hotfix][connectors] fix shadowed NPE in elasticsearch sink connector

tzulitai commented on issue #8849: [hotfix][connectors] fix shadowed NPE in elasticsearch sink connector URL: https://github.com/apache/flink/pull/8849#issuecomment-505698475 Thanks for this fix, merging .. This is an automat

[GitHub] [flink] flinkbot edited a comment on issue #8618: [FLINK-12732][state-processor-api] Add savepoint reader for consuming partitioned operator state

flinkbot edited a comment on issue #8618: [FLINK-12732][state-processor-api] Add savepoint reader for consuming partitioned operator state URL: https://github.com/apache/flink/pull/8618#issuecomment-498777998 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbo

[GitHub] [flink] tzulitai commented on issue #8618: [FLINK-12732][state-processor-api] Add savepoint reader for consuming partitioned operator state

tzulitai commented on issue #8618: [FLINK-12732][state-processor-api] Add savepoint reader for consuming partitioned operator state URL: https://github.com/apache/flink/pull/8618#issuecomment-505697948 Merging ... This is an

[GitHub] [flink] tzulitai commented on issue #8618: [FLINK-12732][state-processor-api] Add savepoint reader for consuming partitioned operator state

tzulitai commented on issue #8618: [FLINK-12732][state-processor-api] Add savepoint reader for consuming partitioned operator state URL: https://github.com/apache/flink/pull/8618#issuecomment-505697913 @flinkbot approve architecture @flinkbot approve quality ---

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297466824 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiong

[GitHub] [flink] lirui-apache commented on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner

lirui-apache commented on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner URL: https://github.com/apache/flink/pull/8859#issuecomment-505697061 For Hive to access (non-generic) views created by Flink, we need to 1) remove the catalog part from the o

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297466312 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/

[jira] [Closed] (FLINK-12972) Ensure calling open/close in join condition of generated functions for blink

[ https://issues.apache.org/jira/browse/FLINK-12972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-12972. -- Resolution: Fixed Fix Version/s: 1.9.0 merged in 1.9.0: 57603790e7e5ed3b7530e26f28d8b6dfe20d642

  1   2   3   4   5   6   >