[GitHub] [flink] zentol commented on issue #8930: [FLINK-12955] HBase LookupableTableSource

zentol commented on issue #8930: [FLINK-12955] HBase LookupableTableSource URL: https://github.com/apache/flink/pull/8930#issuecomment-508901705 CI report for commit ae1363bb0188a922190234d5f07b02fac1a175e7: FAILURE [Build](https://travis-ci.org/flink-ci/flink-ci/builds/554872254?utm_source

[jira] [Commented] (FLINK-12852) Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879607#comment-16879607 ] Yun Gao commented on FLINK-12852: - Very thanks [~StephanEwen] for the detailed compariso

[GitHub] [flink] ye-lun commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese

ye-lun commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese URL: https://github.com/apache/flink/pull/8995#discussion_r300821436 ## File path: docs/dev/parallel.zh.md ## @@ -177,25 +159,18 @@ try { -### Syste

[GitHub] [flink] zentol commented on issue #8933: [FLINK-12968][table-common] Add an utility for finding a common type from a set of types

zentol commented on issue #8933: [FLINK-12968][table-common] Add an utility for finding a common type from a set of types URL: https://github.com/apache/flink/pull/8933#issuecomment-508899094 CI report for commit b9c2383e2b8a7608f5269e03888f149996ba9f4e: SUCCESS [Travis](https://travis-ci.

[GitHub] [flink] ye-lun commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese

ye-lun commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese URL: https://github.com/apache/flink/pull/8995#discussion_r300821012 ## File path: docs/dev/parallel.zh.md ## @@ -177,25 +159,18 @@ try { -### Syste

[GitHub] [flink] ye-lun commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese

ye-lun commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese URL: https://github.com/apache/flink/pull/8995#discussion_r300820989 ## File path: docs/dev/parallel.zh.md ## @@ -22,29 +22,20 @@ specific language govern

[jira] [Commented] (FLINK-13117) Serialize Issue when restoring from savepoint

[ https://issues.apache.org/jira/browse/FLINK-13117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879588#comment-16879588 ] Yun Tang commented on FLINK-13117: -- [~sch.oh] You could refer to [state schema_evoluti

[GitHub] [flink] Clarkkkkk commented on issue #7550: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink for HBase

Clark commented on issue #7550: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink for HBase URL: https://github.com/apache/flink/pull/7550#issuecomment-508895467 Not ready for review after refactoring.

[GitHub] [flink] zentol commented on issue #8935: [Flink-12973]Support reading Hive complex types like array and map

zentol commented on issue #8935: [Flink-12973]Support reading Hive complex types like array and map URL: https://github.com/apache/flink/pull/8935#issuecomment-508895231 CI report for commit 56bcca0279bde35a856dea882d8afeb43deb6938: SUCCESS [Travis](https://travis-ci.org/flink-ci/flink-ci/

[GitHub] [flink] zentol commented on issue #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

zentol commented on issue #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#issuecomment-508894995 CI report for commit b2821a6ae97fd943f3a66b672e85fbd2374126c4: FAILURE [Travis](https://travis-ci.org/flink-ci/flink-ci

[GitHub] [flink] zentol commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis

zentol commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis URL: https://github.com/apache/flink/pull/8911#issuecomment-508894996 CI report for commit 887e6044d73ad3c74a58e175544263aa268f9abf: FAILURE [Travis](https://travis-ci.org/flink-ci/flink-ci/builds/554872310

[jira] [Assigned] (FLINK-13129) Port CsvTableFactory to table-api-java-bridge

[ https://issues.apache.org/jira/browse/FLINK-13129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Louis Xu reassigned FLINK-13129: Assignee: Louis Xu > Port CsvTableFactory to table-api-java-bridge >

[GitHub] [flink] klion26 commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese

klion26 commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese URL: https://github.com/apache/flink/pull/8995#discussion_r300818504 ## File path: docs/dev/parallel.zh.md ## @@ -80,17 +71,11 @@ env.execute("Word Count

[GitHub] [flink] klion26 commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese

klion26 commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese URL: https://github.com/apache/flink/pull/8995#discussion_r300818962 ## File path: docs/dev/parallel.zh.md ## @@ -177,25 +159,18 @@ try { -### Syst

[GitHub] [flink] klion26 commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese

klion26 commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese URL: https://github.com/apache/flink/pull/8995#discussion_r300818439 ## File path: docs/dev/parallel.zh.md ## @@ -22,29 +22,20 @@ specific language gover

[jira] [Commented] (FLINK-13129) Port CsvTableFactory to table-api-java-bridge

[ https://issues.apache.org/jira/browse/FLINK-13129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879586#comment-16879586 ] Louis Xu commented on FLINK-13129: -- Hello，Jark! Can I do this job if possible? Thank

[GitHub] [flink] klion26 commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese

klion26 commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese URL: https://github.com/apache/flink/pull/8995#discussion_r300818614 ## File path: docs/dev/parallel.zh.md ## @@ -177,25 +159,18 @@ try { -### Syst

[GitHub] [flink] klion26 commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese

klion26 commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese URL: https://github.com/apache/flink/pull/8995#discussion_r300818330 ## File path: docs/dev/parallel.zh.md ## @@ -22,29 +22,20 @@ specific language gover

[GitHub] [flink] klion26 commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese

klion26 commented on a change in pull request #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese URL: https://github.com/apache/flink/pull/8995#discussion_r300818711 ## File path: docs/dev/parallel.zh.md ## @@ -177,25 +159,18 @@ try { -### Syst

[GitHub] [flink] Clarkkkkk commented on a change in pull request #7550: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink for HBase

Clark commented on a change in pull request #7550: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink for HBase URL: https://github.com/apache/flink/pull/7550#discussion_r300818477 ## File path: flink-connectors/flin

[GitHub] [flink] Clarkkkkk commented on a change in pull request #7550: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink for HBase

Clark commented on a change in pull request #7550: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink for HBase URL: https://github.com/apache/flink/pull/7550#discussion_r300818450 ## File path: flink-connectors/fli

[jira] [Created] (FLINK-13129) Port CsvTableFactory to talbe-api-java-bridge

Jark Wu created FLINK-13129: --- Summary: Port CsvTableFactory to talbe-api-java-bridge Key: FLINK-13129 URL: https://issues.apache.org/jira/browse/FLINK-13129 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-13129) Port CsvTableFactory to talbe-api-java-bridge

[ https://issues.apache.org/jira/browse/FLINK-13129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13129: Component/s: Table SQL / API > Port CsvTableFactory to talbe-api-java-bridge > ---

[jira] [Updated] (FLINK-13129) Port CsvTableFactory to table-api-java-bridge

[ https://issues.apache.org/jira/browse/FLINK-13129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13129: Summary: Port CsvTableFactory to table-api-java-bridge (was: Port CsvTableFactory to talbe-api-java-bridg

[GitHub] [flink] zentol commented on issue #8944: [FLINK-13058][Table SQL / Runtime] Avoid memory copy for the trimming operations of BinaryString

zentol commented on issue #8944: [FLINK-13058][Table SQL / Runtime] Avoid memory copy for the trimming operations of BinaryString URL: https://github.com/apache/flink/pull/8944#issuecomment-508892607 CI report for commit 7cbfc8c4a202fb6102a8e14f353a29207b4cd2da: SUCCESS [Travis](https://tr

[GitHub] [flink] zentol commented on issue #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager

zentol commented on issue #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager URL: https://github.com/apache/flink/pull/8952#issuecomment-508889790 CI report for commit 8bb7c0d0f75527b8b9edf4db41a300702c805cae: FAILURE [Travis](https://travis-ci.org/flink-ci/flink-ci/bu

[GitHub] [flink] zentol commented on issue #8967: [FLINK-13059][Cassandra Connector] Release Semaphore correctly on Exception in send()

zentol commented on issue #8967: [FLINK-13059][Cassandra Connector] Release Semaphore correctly on Exception in send() URL: https://github.com/apache/flink/pull/8967#issuecomment-508887383 CI report for commit 18b9bf24d58870dd64c6f5e511785967ef2b9452: FAILURE [Travis](https://travis-ci.org

[GitHub] [flink] zentol commented on issue #8982: [FLINK-13098][datastream] Add a new type UNDEFINED of shuffle mode

zentol commented on issue #8982: [FLINK-13098][datastream] Add a new type UNDEFINED of shuffle mode URL: https://github.com/apache/flink/pull/8982#issuecomment-508884830 CI report for commit 71f31349c115a02902144c852dd8bf4208ca91aa: SUCCESS [Travis](https://travis-ci.org/flink-ci/flink-ci/

[GitHub] [flink] stevenzwu opened a new pull request #8665: [FLINK-12781] [Runtime/REST] include the whole stack trace in response payload

stevenzwu opened a new pull request #8665: [FLINK-12781] [Runtime/REST] include the whole stack trace in response payload URL: https://github.com/apache/flink/pull/8665 This is an automated message from the Apache Gi

[GitHub] [flink] stevenzwu closed pull request #8665: [FLINK-12781] [Runtime/REST] include the whole stack trace in response payload

stevenzwu closed pull request #8665: [FLINK-12781] [Runtime/REST] include the whole stack trace in response payload URL: https://github.com/apache/flink/pull/8665 This is an automated message from the Apache Git Service. To

[GitHub] [flink] bowenli86 commented on a change in pull request #8987: [FLINK-13090][hive] Test Hive connector with hive runner

bowenli86 commented on a change in pull request #8987: [FLINK-13090][hive] Test Hive connector with hive runner URL: https://github.com/apache/flink/pull/8987#discussion_r300811534 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/batch/connectors/h

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

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

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

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

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

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

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

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

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

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

[GitHub] [flink] bowenli86 commented on issue #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager

bowenli86 commented on issue #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#issuecomment-508877866 Hi @twalthr , thanks for your feedback! I believe cutting the scope to only support Hive UDFs makes sense given

[GitHub] [flink] zentol commented on issue #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner

zentol commented on issue #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner URL: https://github.com/apache/flink/pull/8962#issuecomment-508877585 CI report for commit bc4c0ef1db430b1118cf6979ee245f003c116cdd: FAILURE [Travis](https://travis-ci.or

[GitHub] [flink] zentol commented on issue #8956: [FLINK-12991][python] Correct the implementation of Catalog.get_table_factory

zentol commented on issue #8956: [FLINK-12991][python] Correct the implementation of Catalog.get_table_factory URL: https://github.com/apache/flink/pull/8956#issuecomment-508877002 CI report for commit 59c446d3df87c0405515a4ab7360df3f21e46dd4: FAILURE [Travis](https://travis-ci.org/flink-c

[GitHub] [flink] mans2singh commented on issue #8990: [FLINK-13104][metrics] Updated request callback to log warning on failure

mans2singh commented on issue #8990: [FLINK-13104][metrics] Updated request callback to log warning on failure URL: https://github.com/apache/flink/pull/8990#issuecomment-508876438 @zentol - From what I can see from the [logs](https://travis-ci.org/apache/flink/jobs/554410650) the error is

[GitHub] [flink] zentol commented on issue #8965: [FLINK-13068][hive] HiveTableSink should implement PartitionableTable…

zentol commented on issue #8965: [FLINK-13068][hive] HiveTableSink should implement PartitionableTable… URL: https://github.com/apache/flink/pull/8965#issuecomment-508875776 CI report for commit 24f08d498acacab13056065657719c0592f0f75d: FAILURE [Travis](https://travis-ci.org/flink-ci/flink

[GitHub] [flink] bowenli86 commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager

bowenli86 commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#discussion_r300807011 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog

[GitHub] [flink] bowenli86 commented on issue #9004: [FLINK-13128][hive] make HiveGenericUDAF expose accumulator type in order to create its corresponding AggregateFunctionDefinition

bowenli86 commented on issue #9004: [FLINK-13128][hive] make HiveGenericUDAF expose accumulator type in order to create its corresponding AggregateFunctionDefinition URL: https://github.com/apache/flink/pull/9004#issuecomment-508874495 cc @xuefuz @JingsongLi @lirui-apache @zjuwangg -

[GitHub] [flink] flinkbot commented on issue #9004: [FLINK-13128][hive] make HiveGenericUDAF expose accumulator type in order to create its corresponding AggregateFunctionDefinition

flinkbot commented on issue #9004: [FLINK-13128][hive] make HiveGenericUDAF expose accumulator type in order to create its corresponding AggregateFunctionDefinition URL: https://github.com/apache/flink/pull/9004#issuecomment-508874425 Thanks a lot for your contribution to the Apache Flink

[jira] [Updated] (FLINK-13128) make HiveGenericUDAF expose accumulator type in order to create its corresponding AggregateFunctionDefinition

[ https://issues.apache.org/jira/browse/FLINK-13128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13128: --- Labels: pull-request-available (was: ) > make HiveGenericUDAF expose accumulator type in or

[GitHub] [flink] bowenli86 opened a new pull request #9004: [FLINK-13128][hive] make HiveGenericUDAF expose accumulator type in order to create its corresponding AggregateFunctionDefinition

bowenli86 opened a new pull request #9004: [FLINK-13128][hive] make HiveGenericUDAF expose accumulator type in order to create its corresponding AggregateFunctionDefinition URL: https://github.com/apache/flink/pull/9004 ## What is the purpose of the change This PR exposes `HiveGener

[jira] [Updated] (FLINK-13128) make HiveGenericUDAF expose accumulator type in order to create its corresponding AggregateFunctionDefinition

[ https://issues.apache.org/jira/browse/FLINK-13128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13128: - Summary: make HiveGenericUDAF expose accumulator type in order to create its corresponding AggregateFunc

[jira] [Created] (FLINK-13128) make HiveGenericUDAF expose accumulator type

Bowen Li created FLINK-13128: Summary: make HiveGenericUDAF expose accumulator type Key: FLINK-13128 URL: https://issues.apache.org/jira/browse/FLINK-13128 Project: Flink Issue Type: Sub-task

[GitHub] [flink] zentol commented on issue #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment

zentol commented on issue #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment URL: https://github.com/apache/flink/pull/8984#issuecomment-508872444 CI report for commit 0aa1e39f2100670115c4ebf91346e573a55a1762: SUCCESS [Travis](https://travis-

[GitHub] [flink] zentol commented on issue #8985: [FLINK-13101][datastream] Introduce blockingAfterChainingOff property of StreamGraph

zentol commented on issue #8985: [FLINK-13101][datastream] Introduce blockingAfterChainingOff property of StreamGraph URL: https://github.com/apache/flink/pull/8985#issuecomment-508866383 CI report for commit 34336fc5898ab8bd74eb30153dcc13dd9611983f: SUCCESS [Travis](https://travis-ci.org/

[GitHub] [flink] zentol commented on issue #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner

zentol commented on issue #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner URL: https://github.com/apache/flink/pull/8962#issuecomment-508856136 CI report for commit eb067a185e36fccf7467d3943e7892e673efca67: FAILURE [Travis](https://travis-ci.or

[GitHub] [flink] zentol commented on issue #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner

zentol commented on issue #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner URL: https://github.com/apache/flink/pull/8962#issuecomment-508855818 CI report for commit eb067a185e36fccf7467d3943e7892e673efca67: FAILURE [Travis](https://travis-ci.or

[GitHub] [flink] zentol commented on issue #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner

zentol commented on issue #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner URL: https://github.com/apache/flink/pull/8962#issuecomment-508854441 CI report for commit eb067a185e36fccf7467d3943e7892e673efca67: FAILURE [Travis](https://travis-ci.or

[GitHub] [flink] zentol commented on issue #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

zentol commented on issue #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#issuecomment-508849011 CI report for commit ad580cc3e675efdd6adaeb89ac0bf6dcf42c2c21: FAILURE [Travis](https://travis-ci.org/dataArtisans/flink/bu

[GitHub] [flink] zentol commented on issue #8980: [FLINK-13040] improve blink table config

zentol commented on issue #8980: [FLINK-13040] improve blink table config URL: https://github.com/apache/flink/pull/8980#issuecomment-508848986 CI report for commit 7466689272e5240b8caed477be963dd6fdc2cf4e: FAILURE [Travis](https://travis-ci.org/dataArtisans/flink/builds/554657993?utm_sourc

[GitHub] [flink] bowenli86 commented on issue #8935: [Flink-12973]Support reading Hive complex types like array and map

bowenli86 commented on issue #8935: [Flink-12973]Support reading Hive complex types like array and map URL: https://github.com/apache/flink/pull/8935#issuecomment-508842193 @zjuwangg there are some compile errors. Can you fix them? --

[jira] [Comment Edited] (FLINK-12934) add hadoop dependencies as 'flink-shaded-hadoop-2-uber' for flink-connector-hive to connect to remote hive metastore service

[ https://issues.apache.org/jira/browse/FLINK-12934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16878914#comment-16878914 ] Bowen Li edited comment on FLINK-12934 at 7/5/19 7:09 PM: -- merg

[jira] [Closed] (FLINK-12237) Support Hive table stats related operations in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-12237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-12237. Resolution: Fixed merged in 1.9.0: 6d7a15e328e8af6f001d6191c3f167bd8038bf14 > Support Hive table stats re

[GitHub] [flink] asfgit closed pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog

asfgit closed pull request #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8636 This is an automated message from the Apache Git Service. To resp

[GitHub] [flink] zentol commented on issue #8987: [FLINK-13090][hive] Test Hive connector with hive runner

zentol commented on issue #8987: [FLINK-13090][hive] Test Hive connector with hive runner URL: https://github.com/apache/flink/pull/8987#issuecomment-508841343 CI report for commit c9a63b5246e7ff7f2049955ec417646dbb05b021: SUCCESS [Travis](https://travis-ci.org/dataArtisans/flink/builds/55

[GitHub] [flink] bowenli86 commented on issue #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog

bowenli86 commented on issue #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8636#issuecomment-508841232 LGTM, thanks for the contribution！ @flinkbot approve all Merging ---

[GitHub] [flink] xuefuz commented on issue #8987: [FLINK-13090][hive] Test Hive connector with hive runner

xuefuz commented on issue #8987: [FLINK-13090][hive] Test Hive connector with hive runner URL: https://github.com/apache/flink/pull/8987#issuecomment-508839490 Sounds good then. +1 for the PR to be merged. This is an automate

[GitHub] [flink] bowenli86 commented on issue #8956: [FLINK-12991][python] Correct the implementation of Catalog.get_table_factory

bowenli86 commented on issue #8956: [FLINK-12991][python] Correct the implementation of Catalog.get_table_factory URL: https://github.com/apache/flink/pull/8956#issuecomment-508837545 sounds good. For the PR specifically, I'm fine either way because `open, close, getTableFactory` a

[GitHub] [flink] bowenli86 closed pull request #8831: [FLINK-12935][hive] package flink-connector-hive into flink distribution for HiveCatalog

bowenli86 closed pull request #8831: [FLINK-12935][hive] package flink-connector-hive into flink distribution for HiveCatalog URL: https://github.com/apache/flink/pull/8831 This is an automated message from the Apache Git Se

[GitHub] [flink] bowenli86 commented on issue #8831: [FLINK-12935][hive] package flink-connector-hive into flink distribution for HiveCatalog

bowenli86 commented on issue #8831: [FLINK-12935][hive] package flink-connector-hive into flink distribution for HiveCatalog URL: https://github.com/apache/flink/pull/8831#issuecomment-508836857 @zentol ok, let's postpone this to 1.10. Closing this PR for now --

[GitHub] [flink] bowenli86 edited a comment on issue #8889: [FLINK-12934][hive] add hadoop dependencies as 'flink-shaded-hadoop-2-uber' for flink-connector-hive to connect to remote hive metastore ser

bowenli86 edited a comment on issue #8889: [FLINK-12934][hive] add hadoop dependencies as 'flink-shaded-hadoop-2-uber' for flink-connector-hive to connect to remote hive metastore service URL: https://github.com/apache/flink/pull/8889#issuecomment-508830423 > Do we know what's inside the s

[GitHub] [flink] asfgit closed pull request #8889: [FLINK-12934][hive] add hadoop dependencies as 'flink-shaded-hadoop-2-uber' for flink-connector-hive to connect to remote hive metastore service

asfgit closed pull request #8889: [FLINK-12934][hive] add hadoop dependencies as 'flink-shaded-hadoop-2-uber' for flink-connector-hive to connect to remote hive metastore service URL: https://github.com/apache/flink/pull/8889 --

[GitHub] [flink] bowenli86 edited a comment on issue #8889: [FLINK-12934][hive] add hadoop dependencies as 'flink-shaded-hadoop-2-uber' for flink-connector-hive to connect to remote hive metastore ser

bowenli86 edited a comment on issue #8889: [FLINK-12934][hive] add hadoop dependencies as 'flink-shaded-hadoop-2-uber' for flink-connector-hive to connect to remote hive metastore service URL: https://github.com/apache/flink/pull/8889#issuecomment-508830423 > Do we know what's inside the s

[GitHub] [flink] bowenli86 edited a comment on issue #9001: [FLINK-13110][hive] Fix Hive-1.2.1 build

bowenli86 edited a comment on issue #9001: [FLINK-13110][hive] Fix Hive-1.2.1 build URL: https://github.com/apache/flink/pull/9001#issuecomment-508835425 LGTM, @lirui-apache thanks for fixing the problem! I agree that we should be careful and should test hive-1.2.1 profile for every change

[GitHub] [flink] bowenli86 edited a comment on issue #9001: [FLINK-13110][hive] Fix Hive-1.2.1 build

bowenli86 edited a comment on issue #9001: [FLINK-13110][hive] Fix Hive-1.2.1 build URL: https://github.com/apache/flink/pull/9001#issuecomment-508835425 LGTM @lirui-apache thanks for fixing the problem! I agree that we should be careful and should test hive-1.2.1 profile for every

[GitHub] [flink] bowenli86 commented on issue #9001: [FLINK-13110][hive] Fix Hive-1.2.1 build

bowenli86 commented on issue #9001: [FLINK-13110][hive] Fix Hive-1.2.1 build URL: https://github.com/apache/flink/pull/9001#issuecomment-508835425 @lirui-apache thanks for fixing the problem! I agree that we should be careful and should test hive-1.2.1 profile for every change since now loc

[jira] [Created] (FLINK-13127) "--yarnship" doesn't support resource classloading

David Moravek created FLINK-13127: - Summary: "--yarnship" doesn't support resource classloading Key: FLINK-13127 URL: https://issues.apache.org/jira/browse/FLINK-13127 Project: Flink Issue Ty

[GitHub] [flink] bowenli86 commented on issue #8889: [FLINK-12934][hive] add hadoop dependencies as 'flink-shaded-hadoop-2-uber' for flink-connector-hive to connect to remote hive metastore service

bowenli86 commented on issue #8889: [FLINK-12934][hive] add hadoop dependencies as 'flink-shaded-hadoop-2-uber' for flink-connector-hive to connect to remote hive metastore service URL: https://github.com/apache/flink/pull/8889#issuecomment-508830423 > Do we know what's inside the shaded j

[GitHub] [flink] bowenli86 commented on issue #8965: [FLINK-13068][hive] HiveTableSink should implement PartitionableTable…

bowenli86 commented on issue #8965: [FLINK-13068][hive] HiveTableSink should implement PartitionableTable… URL: https://github.com/apache/flink/pull/8965#issuecomment-508830048 LGTM, thanks for your contribution! @flinkbot approve all I've restarted the CI since it's failing a

[GitHub] [flink] zentol commented on issue #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese

zentol commented on issue #8995: FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese URL: https://github.com/apache/flink/pull/8995#issuecomment-508828738 CI report for commit ac5a550b8dfe8ebde32b295ec2b6990fd2c580ed: FAILURE [Travis](https://travis-ci.org/dataArtisans/flink

[GitHub] [flink] zentol commented on issue #8999: [hotfix] Remove incorrect doc comments from RocksDBMapState

zentol commented on issue #8999: [hotfix] Remove incorrect doc comments from RocksDBMapState URL: https://github.com/apache/flink/pull/8999#issuecomment-508817918 CI report for commit ec08704855355ecf0e2d8e26df634206dd6ee587: SUCCESS [Travis](https://travis-ci.org/dataArtisans/flink/builds

[GitHub] [flink] StephanEwen commented on issue #8704: [FLINK-12812][runtime] Set resource profiles for task slots

StephanEwen commented on issue #8704: [FLINK-12812][runtime] Set resource profiles for task slots URL: https://github.com/apache/flink/pull/8704#issuecomment-508815027 Thanks @xintongsong this looks really good now. Will take this over and merge the PR. There are some minor ad

[jira] [Updated] (FLINK-13081) Supports explain DAG plan

[ https://issues.apache.org/jira/browse/FLINK-13081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13081: --- Labels: pull-request-available (was: ) > Supports explain DAG plan > --

[jira] [Closed] (FLINK-13081) Supports explain DAG plan

[ https://issues.apache.org/jira/browse/FLINK-13081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-13081. Resolution: Fixed Implemented in 14cda6ce2b0baf88bf228294fff3c9ee878bb559 > Supports expl

[GitHub] [flink] dawidwys closed pull request #8973: [FLINK-13081][table-planner][table-api-java] Supports explain DAG plan

dawidwys closed pull request #8973: [FLINK-13081][table-planner][table-api-java] Supports explain DAG plan URL: https://github.com/apache/flink/pull/8973 This is an automated message from the Apache Git Service. To respond t

[GitHub] [flink] dawidwys commented on issue #8973: [FLINK-13081][table-planner][table-api-java] Supports explain DAG plan

dawidwys commented on issue #8973: [FLINK-13081][table-planner][table-api-java] Supports explain DAG plan URL: https://github.com/apache/flink/pull/8973#issuecomment-508808236 Thank you for the updated. I fixed small mistake and merged it. --

[GitHub] [flink] sjwiesman commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

sjwiesman commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r300739522 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,243 @@ +-

[GitHub] [flink] sjwiesman commented on issue #8827: [FLINK-12928][docs] Remove old Flink ML docs

sjwiesman commented on issue #8827: [FLINK-12928][docs] Remove old Flink ML docs URL: https://github.com/apache/flink/pull/8827#issuecomment-508805132 @shaoxuan-wang +1 I did a quick grep and believe I've removed all remnants of FlinkML from the docs. -

[GitHub] [flink] StephanEwen commented on a change in pull request #8704: [FLINK-12812][runtime] Set resource profiles for task slots

StephanEwen commented on a change in pull request #8704: [FLINK-12812][runtime] Set resource profiles for task slots URL: https://github.com/apache/flink/pull/8704#discussion_r300735357 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/Resour

[jira] [Comment Edited] (FLINK-12852) Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879396#comment-16879396 ] zhijiang edited comment on FLINK-12852 at 7/5/19 3:58 PM: -- Than

[jira] [Commented] (FLINK-12852) Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879396#comment-16879396 ] zhijiang commented on FLINK-12852: -- Thanks for above detail conclusions [~StephanEwen]!

[GitHub] [flink] zentol commented on issue #8988: [FLINK-12736][coordination] Release TaskExecutor in SlotManager if no slot allocations after partition check

zentol commented on issue #8988: [FLINK-12736][coordination] Release TaskExecutor in SlotManager if no slot allocations after partition check URL: https://github.com/apache/flink/pull/8988#issuecomment-508802740 CI report for commit 9652eea4452fac16a48d2225b9fef2d492f2b36f: FAILURE [Travis

[GitHub] [flink] StephanEwen commented on a change in pull request #8704: [FLINK-12812][runtime] Set resource profiles for task slots

StephanEwen commented on a change in pull request #8704: [FLINK-12812][runtime] Set resource profiles for task slots URL: https://github.com/apache/flink/pull/8704#discussion_r300734438 ## File path: flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java

[GitHub] [flink] zentol commented on issue #8989: [hotfix][runtime] ComponentMainThreadExecutorServiceAdapter

zentol commented on issue #8989: [hotfix][runtime] ComponentMainThreadExecutorServiceAdapter URL: https://github.com/apache/flink/pull/8989#issuecomment-508798217 CI report for commit 3cd535c2b7c1c94aa94966f1beef35fa0933fa47: FAILURE [Travis](https://travis-ci.org/dataArtisans/flink/builds

[GitHub] [flink] zentol commented on issue #8990: [FLINK-13104][metrics] Updated request callback to log warning on failure

zentol commented on issue #8990: [FLINK-13104][metrics] Updated request callback to log warning on failure URL: https://github.com/apache/flink/pull/8990#issuecomment-508798237 CI report for commit 29640a3b84241b408f1e9deaf88b76cde3028d97: FAILURE [Travis](https://travis-ci.org/dataArtisan

[GitHub] [flink] zentol commented on issue #8993: [FLINK-13108][Table SQL / Planner] Remove duplicated type cast in generated code

zentol commented on issue #8993: [FLINK-13108][Table SQL / Planner] Remove duplicated type cast in generated code URL: https://github.com/apache/flink/pull/8993#issuecomment-508798258 CI report for commit 5bbae097d12ed6101333210af32994101178be9c: FAILURE [Travis](https://travis-ci.org/data

[GitHub] [flink] zentol commented on issue #8994: [FLINK-13057][state] Correct comments in ListState class

zentol commented on issue #8994: [FLINK-13057][state] Correct comments in ListState class URL: https://github.com/apache/flink/pull/8994#issuecomment-508796299 CI report for commit a0cd89a69dbce15adc26d5dc28ef49640ab8c8c8: FAILURE [Travis](https://travis-ci.org/dataArtisans/flink/builds/55

[GitHub] [flink] zentol commented on issue #9000: [FLINK-13101][datastream] Add slotSharingAfterChainingDisabled proper…

zentol commented on issue #9000: [FLINK-13101][datastream] Add slotSharingAfterChainingDisabled proper… URL: https://github.com/apache/flink/pull/9000#issuecomment-508796323 CI report for commit 2f861e597ff2056e8012caa6d6fc9d460f117fe8: SUCCESS [Travis](https://travis-ci.org/dataArtisans/f

[GitHub] [flink] flinkbot commented on issue #9003: [FLINK-13125][docs] Make PubSub stability warning more prominent

flinkbot commented on issue #9003: [FLINK-13125][docs] Make PubSub stability warning more prominent URL: https://github.com/apache/flink/pull/9003#issuecomment-508788787 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review you

[jira] [Updated] (FLINK-13125) Add note to PubSub connector documentation about beta status

[ https://issues.apache.org/jira/browse/FLINK-13125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13125: --- Labels: pull-request-available (was: ) > Add note to PubSub connector documentation about b

[GitHub] [flink] rmetzger opened a new pull request #9003: [FLINK-13125][docs] Make PubSub stability warning more prominent

rmetzger opened a new pull request #9003: [FLINK-13125][docs] Make PubSub stability warning more prominent URL: https://github.com/apache/flink/pull/9003 ## What is the purpose of the change Make the warning on the GCP PubSub connector stability more prominent ![image](https:

[jira] [Closed] (FLINK-12744) ML common parameters

[ https://issues.apache.org/jira/browse/FLINK-12744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang closed FLINK-12744. - Resolution: Fixed Fix Version/s: 1.9.0 > ML common parameters > > >

[jira] [Updated] (FLINK-12744) ML common parameters

[ https://issues.apache.org/jira/browse/FLINK-12744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12744: --- Labels: pull-request-available (was: ) > ML common parameters > > >

[jira] [Commented] (FLINK-12744) ML common parameters

[ https://issues.apache.org/jira/browse/FLINK-12744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879343#comment-16879343 ] Shaoxuan Wang commented on FLINK-12744: --- Fixed in master: f18481ee54b61a737ae1426f

[jira] [Updated] (FLINK-13124) Stop fails with Universal Kafka Consumer

eamTask.finishTask(SourceStreamTask.java:150) > taskmanager_1 | at > org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:808) > taskmanager_1 | at > org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpoint(StreamTask.java:683) > taskmanag

  1   2   3   4   >