[jira] [Commented] (FLINK-13405) Translate "Basic API Concepts" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902102#comment-16902102 ] WangHengWei commented on FLINK-13405: - Hi [~jark] [~xccui] [~klion26], I have a ques

[GitHub] [flink] twalthr opened a new pull request #9382: [FLINK-13600][table] Rework TableEnvironment.connect() class hierarchy

twalthr opened a new pull request #9382: [FLINK-13600][table] Rework TableEnvironment.connect() class hierarchy URL: https://github.com/apache/flink/pull/9382 ## What is the purpose of the change This fixes the currently broken `TableEnvironment.connect()` API by reworking the descr

[jira] [Updated] (FLINK-13600) TableEnvironment.connect() is not usable

[ https://issues.apache.org/jira/browse/FLINK-13600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13600: --- Labels: pull-request-available (was: ) > TableEnvironment.connect() is not usable > ---

[GitHub] [flink] flinkbot edited a comment on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support varchar/char/decimal precision to connector

flinkbot edited a comment on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support varchar/char/decimal precision to connector URL: https://github.com/apache/flink/pull/9274#issuecomment-516352701 ## CI report: * 6e259d68552bf14b3c0f593706d2c879d32b294e : FAILU

[GitHub] [flink] flinkbot edited a comment on issue #9022: [FLINK-13127] Fix --yarnship classpath

flinkbot edited a comment on issue #9022: [FLINK-13127] Fix --yarnship classpath URL: https://github.com/apache/flink/pull/9022#issuecomment-509288611 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We w

[GitHub] [flink] tillrohrmann commented on issue #9022: [FLINK-13127] Fix --yarnship classpath

tillrohrmann commented on issue #9022: [FLINK-13127] Fix --yarnship classpath URL: https://github.com/apache/flink/pull/9022#issuecomment-519114007 I'm looking at it right now. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on issue #9359: [FLINK-13441][e2e] Add e2e test for sql batch job

flinkbot edited a comment on issue #9359: [FLINK-13441][e2e] Add e2e test for sql batch job URL: https://github.com/apache/flink/pull/9359#issuecomment-518212897 ## CI report: * fa3a355bd70a013aff95403532a4b1861a6bc173 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/12

[GitHub] [flink] flinkbot edited a comment on issue #9322: [FLINK-13471][table] Add FlatAggregate support to stream Table API(blink planner)

flinkbot edited a comment on issue #9322: [FLINK-13471][table] Add FlatAggregate support to stream Table API(blink planner) URL: https://github.com/apache/flink/pull/9322#issuecomment-517269188 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the co

[GitHub] [flink] aljoscha commented on issue #9322: [FLINK-13471][table] Add FlatAggregate support to stream Table API(blink planner)

aljoscha commented on issue #9322: [FLINK-13471][table] Add FlatAggregate support to stream Table API(blink planner) URL: https://github.com/apache/flink/pull/9322#issuecomment-519110645 Yes, I agree. For now we keep the two separate tests. -

[GitHub] [flink] flinkbot edited a comment on issue #9359: [FLINK-13441][e2e] Add e2e test for sql batch job

flinkbot edited a comment on issue #9359: [FLINK-13441][e2e] Add e2e test for sql batch job URL: https://github.com/apache/flink/pull/9359#issuecomment-518209812 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull r

[GitHub] [flink] 1u0 commented on a change in pull request #9359: [FLINK-13441][e2e] Add e2e test for sql batch job

1u0 commented on a change in pull request #9359: [FLINK-13441][e2e] Add e2e test for sql batch job URL: https://github.com/apache/flink/pull/9359#discussion_r311566368 ## File path: flink-end-to-end-tests/flink-batch-sql-test/src/main/java/org/apache/flink/sql/tests/BatchSQLTestPro

[GitHub] [flink] flinkbot edited a comment on issue #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

flinkbot edited a comment on issue #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#issuecomment-510488226 ## CI report: * fb34a0f4245ddac5872ea77aad07887a6ff12d11 : FAILURE [Build](https://

[GitHub] [flink] flinkbot edited a comment on issue #9359: [FLINK-13441][e2e] Add e2e test for sql batch job

flinkbot edited a comment on issue #9359: [FLINK-13441][e2e] Add e2e test for sql batch job URL: https://github.com/apache/flink/pull/9359#issuecomment-518212897 ## CI report: * fa3a355bd70a013aff95403532a4b1861a6bc173 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/12

[jira] [Commented] (FLINK-13610) Refactor HiveTableSource Test use sql query and remove HiveInputFormatTest

[ https://issues.apache.org/jira/browse/FLINK-13610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902078#comment-16902078 ] Kurt Young commented on FLINK-13610: Thanks for working on this [~Terry1897], I will

[jira] [Assigned] (FLINK-13610) Refactor HiveTableSource Test use sql query and remove HiveInputFormatTest

[ https://issues.apache.org/jira/browse/FLINK-13610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-13610: -- Assignee: Terry Wang > Refactor HiveTableSource Test use sql query and remove HiveInputFormat

[jira] [Updated] (FLINK-13610) Refactor HiveTableSource Test use sql query and remove HiveInputFormatTest

[ https://issues.apache.org/jira/browse/FLINK-13610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13610: --- Affects Version/s: (was: 1.10.0) 1.9.0 > Refactor HiveTableSource Test us

[GitHub] [flink] flinkbot edited a comment on issue #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner

flinkbot edited a comment on issue #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner URL: https://github.com/apache/flink/pull/9370#issuecomment-518545434 Thanks a lot for your contribution to the Apache Flink project. I'm the @fli

[GitHub] [flink] hequn8128 commented on issue #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner

hequn8128 commented on issue #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner URL: https://github.com/apache/flink/pull/9370#issuecomment-519103365 @flinkbot approve all @flinkbot attention @sunjincheng121 ---

[GitHub] [flink] flinkbot edited a comment on issue #9359: [FLINK-13441][e2e] Add e2e test for sql batch job

flinkbot edited a comment on issue #9359: [FLINK-13441][e2e] Add e2e test for sql batch job URL: https://github.com/apache/flink/pull/9359#issuecomment-518209812 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull r

[GitHub] [flink] flinkbot edited a comment on issue #9342: [FLINK-13438][hive] Fix DataTypes.DATE/TIME/TIMESTAMP support for hive connectors

flinkbot edited a comment on issue #9342: [FLINK-13438][hive] Fix DataTypes.DATE/TIME/TIMESTAMP support for hive connectors URL: https://github.com/apache/flink/pull/9342#issuecomment-517768053 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the co

[GitHub] [flink] zjuwangg commented on a change in pull request #9342: [FLINK-13438][hive] Fix DataTypes.DATE/TIME/TIMESTAMP support for hive connectors

zjuwangg commented on a change in pull request #9342: [FLINK-13438][hive] Fix DataTypes.DATE/TIME/TIMESTAMP support for hive connectors URL: https://github.com/apache/flink/pull/9342#discussion_r311559175 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/

[GitHub] [flink] 1u0 commented on a change in pull request #9359: [FLINK-13441][e2e] Add e2e test for sql batch job

1u0 commented on a change in pull request #9359: [FLINK-13441][e2e] Add e2e test for sql batch job URL: https://github.com/apache/flink/pull/9359#discussion_r311559174 ## File path: flink-end-to-end-tests/flink-batch-sql-test/src/main/java/org/apache/flink/sql/tests/BatchSQLTestPro

[jira] [Commented] (FLINK-13573) Merge SubmittedJobGraph into JobGraph

[ https://issues.apache.org/jira/browse/FLINK-13573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902068#comment-16902068 ] Till Rohrmann commented on FLINK-13573: --- I think you are right [~Tison]. The migra

[GitHub] [flink] flinkbot edited a comment on issue #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org

flinkbot edited a comment on issue #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org URL: https://github.com/apache/flink/pull/9230#issuecomment-515090400 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] wuchong commented on issue #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org

wuchong commented on issue #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org URL: https://github.com/apache/flink/pull/9230#issuecomment-519098013 Thanks for the advice @zentol , I have created an INFRA issue INFRA-18843. --

[jira] [Comment Edited] (FLINK-13610) Refactor HiveTableSource Test use sql query and remove HiveInputFormatTest

[ https://issues.apache.org/jira/browse/FLINK-13610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901930#comment-16901930 ] Terry Wang edited comment on FLINK-13610 at 8/7/19 1:31 PM:

[jira] [Commented] (FLINK-13539) DDL do not support CSV tableFactory because CSV require format.fields

[ https://issues.apache.org/jira/browse/FLINK-13539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902059#comment-16902059 ] Jingsong Lee commented on FLINK-13539: -- Be careful with time types: When there are

[jira] [Commented] (FLINK-13635) Unexpectedly interrupted in AsyncFunction#timeout

[ https://issues.apache.org/jira/browse/FLINK-13635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902058#comment-16902058 ] Till Rohrmann commented on FLINK-13635: --- Can't we simply ignore all exceptions com

[GitHub] [flink] flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#issuecomment-516256693 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I h

[jira] [Comment Edited] (FLINK-13011) Release the PyFlink into PyPI

[ https://issues.apache.org/jira/browse/FLINK-13011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902054#comment-16902054 ] sunjincheng edited comment on FLINK-13011 at 8/7/19 1:18 PM: -

[jira] [Closed] (FLINK-13452) Pipelined region failover strategy does not recover Job if checkpoint cannot be read

[ https://issues.apache.org/jira/browse/FLINK-13452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-13452. > Pipelined region failover strategy does not recover Job if checkpoint cannot > be read > --

[jira] [Comment Edited] (FLINK-13011) Release the PyFlink into PyPI

[ https://issues.apache.org/jira/browse/FLINK-13011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902054#comment-16902054 ] sunjincheng edited comment on FLINK-13011 at 8/7/19 1:18 PM: -

[jira] [Commented] (FLINK-13011) Release the PyFlink into PyPI

[ https://issues.apache.org/jira/browse/FLINK-13011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902054#comment-16902054 ] sunjincheng commented on FLINK-13011: - TODO: # Create account in PyPI(pyflink) # A

[GitHub] [flink] GJL commented on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

GJL commented on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#issuecomment-519092634 Merged manually. This is an autom

[GitHub] [flink] GJL closed pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

GJL closed pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268 This is an automated message from the Apache Git Servi

[GitHub] [flink] flinkbot edited a comment on issue #9374: [FLINK-13581][coordination][tests] Harden BatchFineGrainedRecoveryITCase

flinkbot edited a comment on issue #9374: [FLINK-13581][coordination][tests] Harden BatchFineGrainedRecoveryITCase URL: https://github.com/apache/flink/pull/9374#issuecomment-518710116 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 #9348: [FLINK-13505][docs-zh] Translate "Java Lambda Expressions" page into Chinese

flinkbot edited a comment on issue #9348: [FLINK-13505][docs-zh] Translate "Java Lambda Expressions" page into Chinese URL: https://github.com/apache/flink/pull/9348#issuecomment-517906070 ## CI report: * 1e2137271f7d7e3c7036a9e2e045ae3a4a4ff3c1 : FAILURE [Build](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #9381: [FLINK-13608] [docs] Update upgrade compatibility table for 1.9.x

flinkbot edited a comment on issue #9381: [FLINK-13608] [docs] Update upgrade compatibility table for 1.9.x URL: https://github.com/apache/flink/pull/9381#issuecomment-519060626 ## CI report: * 474399ed4fb15ee81511197e141052ae22ed4948 : SUCCESS [Build](https://travis-ci.com/flink-ci

[GitHub] [flink] tillrohrmann commented on a change in pull request #9374: [FLINK-13581][coordination][tests] Harden BatchFineGrainedRecoveryITCase

tillrohrmann commented on a change in pull request #9374: [FLINK-13581][coordination][tests] Harden BatchFineGrainedRecoveryITCase URL: https://github.com/apache/flink/pull/9374#discussion_r311535751 ## File path: flink-tests/src/test/java/org/apache/flink/test/recovery/BatchFineGr

[GitHub] [flink] tillrohrmann commented on a change in pull request #9374: [FLINK-13581][coordination][tests] Harden BatchFineGrainedRecoveryITCase

tillrohrmann commented on a change in pull request #9374: [FLINK-13581][coordination][tests] Harden BatchFineGrainedRecoveryITCase URL: https://github.com/apache/flink/pull/9374#discussion_r311541769 ## File path: flink-tests/src/test/java/org/apache/flink/test/recovery/BatchFineGr

[GitHub] [flink] tillrohrmann commented on a change in pull request #9374: [FLINK-13581][coordination][tests] Harden BatchFineGrainedRecoveryITCase

tillrohrmann commented on a change in pull request #9374: [FLINK-13581][coordination][tests] Harden BatchFineGrainedRecoveryITCase URL: https://github.com/apache/flink/pull/9374#discussion_r311531120 ## File path: flink-tests/src/test/java/org/apache/flink/test/recovery/BatchFineGr

[GitHub] [flink] tillrohrmann commented on a change in pull request #9374: [FLINK-13581][coordination][tests] Harden BatchFineGrainedRecoveryITCase

tillrohrmann commented on a change in pull request #9374: [FLINK-13581][coordination][tests] Harden BatchFineGrainedRecoveryITCase URL: https://github.com/apache/flink/pull/9374#discussion_r311473565 ## File path: flink-core/src/main/java/org/apache/flink/util/ExceptionUtils.java #

[GitHub] [flink] tillrohrmann commented on a change in pull request #9374: [FLINK-13581][coordination][tests] Harden BatchFineGrainedRecoveryITCase

tillrohrmann commented on a change in pull request #9374: [FLINK-13581][coordination][tests] Harden BatchFineGrainedRecoveryITCase URL: https://github.com/apache/flink/pull/9374#discussion_r311531631 ## File path: flink-tests/src/test/java/org/apache/flink/test/recovery/BatchFineGr

[GitHub] [flink] tillrohrmann commented on a change in pull request #9374: [FLINK-13581][coordination][tests] Harden BatchFineGrainedRecoveryITCase

tillrohrmann commented on a change in pull request #9374: [FLINK-13581][coordination][tests] Harden BatchFineGrainedRecoveryITCase URL: https://github.com/apache/flink/pull/9374#discussion_r311474017 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/rest/Res

[jira] [Updated] (FLINK-13635) Unexpectedly interrupted in AsyncFunction#timeout

[ https://issues.apache.org/jira/browse/FLINK-13635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-13635: - Description: Currently the way of handling {{AsyncFunction#timeout}} is a bit weird in {{AsyncWaitOpera

[jira] [Commented] (FLINK-13636) Translate "Flink DataStream API Programming Guide" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902041#comment-16902041 ] WangHengWei commented on FLINK-13636: - Hi [~jark], would you please assign this tick

[jira] [Created] (FLINK-13636) Translate "Flink DataStream API Programming Guide" page into Chinese

WangHengWei created FLINK-13636: --- Summary: Translate "Flink DataStream API Programming Guide" page into Chinese Key: FLINK-13636 URL: https://issues.apache.org/jira/browse/FLINK-13636 Project: Flink

[GitHub] [flink] flinkbot commented on issue #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

flinkbot commented on issue #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#issuecomment-519082259 ## CI report: * 1533b128e0a99b555cd87c64c328d43c5843717b : PENDING [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] flinkbot edited a comment on issue #9380: [FLINK-13630][table-api-bridge] Use values retention configuration from TableConfig if not specified explicitly

flinkbot edited a comment on issue #9380: [FLINK-13630][table-api-bridge] Use values retention configuration from TableConfig if not specified explicitly URL: https://github.com/apache/flink/pull/9380#issuecomment-519039358 ## CI report: * f444918f6b96c7970f869cbf20e919a70990ed02 : S

[jira] [Created] (FLINK-13635) Unexpectedly interrupted in AsyncFunction#timeout

Biao Liu created FLINK-13635: Summary: Unexpectedly interrupted in AsyncFunction#timeout Key: FLINK-13635 URL: https://issues.apache.org/jira/browse/FLINK-13635 Project: Flink Issue Type: Improve

[GitHub] [flink] flinkbot edited a comment on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support varchar/char/decimal precision to connector

flinkbot edited a comment on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support varchar/char/decimal precision to connector URL: https://github.com/apache/flink/pull/9274#issuecomment-516350820 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Commented] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902035#comment-16902035 ] Julian Bauss commented on FLINK-11774: -- I encountered the same issue while using a

[GitHub] [flink] flinkbot edited a comment on issue #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

flinkbot edited a comment on issue #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#issuecomment-504415596 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] pnowojski commented on issue #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

pnowojski commented on issue #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#issuecomment-519079824 I have applied the requested changes and rebased the PR on the latest master branch. --

[GitHub] [flink] flinkbot edited a comment on issue #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

flinkbot edited a comment on issue #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#issuecomment-513663619 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the communit

[GitHub] [flink] fhueske commented on issue #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

fhueske commented on issue #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#issuecomment-519078232 OK, I'll do a few minor changes and will merge the PR. Thanks for working on this @knaufk!

[GitHub] [flink] flinkbot edited a comment on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support varchar/char/decimal precision to connector

flinkbot edited a comment on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support varchar/char/decimal precision to connector URL: https://github.com/apache/flink/pull/9274#issuecomment-516352701 ## CI report: * 6e259d68552bf14b3c0f593706d2c879d32b294e : FAILU

[jira] [Commented] (FLINK-13613) Update migration tests for Flink 1.9

[ https://issues.apache.org/jira/browse/FLINK-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902029#comment-16902029 ] vinoyang commented on FLINK-13613: -- [~till.rohrmann] I did this work after releasing Fl

[GitHub] [flink] flinkbot edited a comment on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support varchar/char/decimal precision to connector

flinkbot edited a comment on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support varchar/char/decimal precision to connector URL: https://github.com/apache/flink/pull/9274#issuecomment-516350820 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] JingsongLi commented on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support varchar/char/decimal precision to connector

JingsongLi commented on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support varchar/char/decimal precision to connector URL: https://github.com/apache/flink/pull/9274#issuecomment-519075883 @wuchong Thanks your advice, comment addressed now, What do you think?

[jira] [Comment Edited] (FLINK-9166) Performance issue with many topologies in a single job

[ https://issues.apache.org/jira/browse/FLINK-9166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901792#comment-16901792 ] pj edited comment on FLINK-9166 at 8/7/19 12:31 PM: [~ssu...@gmail.co

[GitHub] [flink] flinkbot edited a comment on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support varchar/char/decimal precision to connector

flinkbot edited a comment on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support varchar/char/decimal precision to connector URL: https://github.com/apache/flink/pull/9274#issuecomment-516350820 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-13634) StreamingFileSink - allow bulkwriter to compress data

[ https://issues.apache.org/jira/browse/FLINK-13634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joao Boto updated FLINK-13634: -- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > StreamingFileSink - allow bulkwriter t

[jira] [Created] (FLINK-13634) StreamingFileSink - allow bulkwriter to compress data

Joao Boto created FLINK-13634: - Summary: StreamingFileSink - allow bulkwriter to compress data Key: FLINK-13634 URL: https://issues.apache.org/jira/browse/FLINK-13634 Project: Flink Issue Type: I

[GitHub] [flink] JingsongLi commented on a change in pull request #9274: [FLINK-13495][table-planner-blink] blink-planner should support varchar/char/decimal precision to connector

JingsongLi commented on a change in pull request #9274: [FLINK-13495][table-planner-blink] blink-planner should support varchar/char/decimal precision to connector URL: https://github.com/apache/flink/pull/9274#discussion_r311525247 ## File path: flink-table/flink-table-planner-bl

[GitHub] [flink] flinkbot edited a comment on issue #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

flinkbot edited a comment on issue #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#issuecomment-510488226 ## CI report: * fb34a0f4245ddac5872ea77aad07887a6ff12d11 : FAILURE [Build](https://

[GitHub] [flink] flinkbot edited a comment on issue #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

flinkbot edited a comment on issue #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#issuecomment-510482668 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] flinkbot edited a comment on issue #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

flinkbot edited a comment on issue #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#issuecomment-510482668 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] JingsongLi commented on issue #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

JingsongLi commented on issue #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#issuecomment-519067921 > HiveCatalogUseBlinkITCase fails on travis I should sort the results to compare. --

[GitHub] [flink] flinkbot edited a comment on issue #9379: [FLINK-13610][hive]Refactor HiveTableSource Test use sql query and remove HiveInputFormatTest

flinkbot edited a comment on issue #9379: [FLINK-13610][hive]Refactor HiveTableSource Test use sql query and remove HiveInputFormatTest URL: https://github.com/apache/flink/pull/9379#issuecomment-519024849 ## CI report: * 5ca9937fb24f836b70eaf2fc033595dd99c41804 : SUCCESS [Build](ht

[GitHub] [flink] flinkbot commented on issue #9381: [FLINK-13608] [docs] Update upgrade compatibility table for 1.9.x

flinkbot commented on issue #9381: [FLINK-13608] [docs] Update upgrade compatibility table for 1.9.x URL: https://github.com/apache/flink/pull/9381#issuecomment-519060626 ## CI report: * 474399ed4fb15ee81511197e141052ae22ed4948 : PENDING [Build](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] flinkbot commented on issue #9381: [FLINK-13608] [docs] Update upgrade compatibility table for 1.9.x

flinkbot commented on issue #9381: [FLINK-13608] [docs] Update upgrade compatibility table for 1.9.x URL: https://github.com/apache/flink/pull/9381#issuecomment-519058597 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review yo

[jira] [Updated] (FLINK-13608) Update upgrade compatibility table (docs/ops/upgrading.md) for 1.9.0

[ https://issues.apache.org/jira/browse/FLINK-13608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13608: --- Labels: pull-request-available (was: ) > Update upgrade compatibility table (docs/ops/upgra

[GitHub] [flink] tzulitai opened a new pull request #9381: [FLINK-13608] [docs] Update upgrade compatibility table for 1.9.x

tzulitai opened a new pull request #9381: [FLINK-13608] [docs] Update upgrade compatibility table for 1.9.x URL: https://github.com/apache/flink/pull/9381 ## What is the purpose of the change This PR updates the upgrade compatibility table in https://ci.apache.org/projects/flink/fli

[GitHub] [flink] flinkbot edited a comment on issue #9354: [FLINK-13568][sql-parser] DDL create table doesn't allow STRING data …

flinkbot edited a comment on issue #9354: [FLINK-13568][sql-parser] DDL create table doesn't allow STRING data … URL: https://github.com/apache/flink/pull/9354#issuecomment-518083679 ## CI report: * 754c52de984cb476ae0442c6704219b64c68441e : SUCCESS [Build](https://travis-ci.com/fli

[GitHub] [flink] mans2singh edited a comment on issue #9325: [FLINK-13542][metrics] Update datadog reporter to send metrics if the…

mans2singh edited a comment on issue #9325: [FLINK-13542][metrics] Update datadog reporter to send metrics if the… URL: https://github.com/apache/flink/pull/9325#issuecomment-519025031 @zentol - You are right. I am filtering all default metrics and only registering application metrics whi

[jira] [Commented] (FLINK-13633) Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storage

[ https://issues.apache.org/jira/browse/FLINK-13633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901985#comment-16901985 ] TisonKun commented on FLINK-13633: -- Thanks for filing this issue [~fly_in_gis]. It help

[jira] [Updated] (FLINK-13633) Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storage

[ https://issues.apache.org/jira/browse/FLINK-13633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-13633: - Description: Currently, if we enable the high-availability, the ha storage directory structure is store

[jira] [Issue Comment Deleted] (FLINK-13633) Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storage

[ https://issues.apache.org/jira/browse/FLINK-13633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-13633: - Comment: was deleted (was: Thanks for filing this issue [~fly_in_gis]. I think it is reasonable to put

[GitHub] [flink] flinkbot edited a comment on issue #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner

flinkbot edited a comment on issue #9370: [FLINK-13594][python] Improve the 'from_element' method of flink python api to apply to blink planner URL: https://github.com/apache/flink/pull/9370#issuecomment-518549297 ## CI report: * 8dc43f17e0bbd3c33e5fe021e1e5004d1a7bef7f : FAILURE [B

[GitHub] [flink] docete commented on a change in pull request #9331: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner

docete commented on a change in pull request #9331: [FLINK-13523][table-planner-blink] Verify and correct arithmetic function's semantic for Blink planner URL: https://github.com/apache/flink/pull/9331#discussion_r311448173 ## File path: flink-table/flink-table-planner-blink/src/m

[jira] [Commented] (FLINK-13633) Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storage

[ https://issues.apache.org/jira/browse/FLINK-13633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901981#comment-16901981 ] TisonKun commented on FLINK-13633: -- Thanks for filing this issue [~fly_in_gis]. I thin

[GitHub] [flink] mans2singh edited a comment on issue #9325: [FLINK-13542][metrics] Update datadog reporter to send metrics if the…

mans2singh edited a comment on issue #9325: [FLINK-13542][metrics] Update datadog reporter to send metrics if the… URL: https://github.com/apache/flink/pull/9325#issuecomment-519025031 @zentol - You are right. I am filtering all default metrics and only registering application metrics whi

[jira] [Commented] (FLINK-13590) flink-on-yarn sometimes could create many little files that are xxx-taskmanager-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-13590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901979#comment-16901979 ] Yang Wang commented on FLINK-13590: --- [~shu_wen...@qq.com], it seems that the container

[GitHub] [flink] mans2singh edited a comment on issue #9325: [FLINK-13542][metrics] Update datadog reporter to send metrics if the…

mans2singh edited a comment on issue #9325: [FLINK-13542][metrics] Update datadog reporter to send metrics if the… URL: https://github.com/apache/flink/pull/9325#issuecomment-519025031 @zentol - You are right. I am filtering all default metrics and only registering application metrics whi

[jira] [Commented] (FLINK-13489) Heavy deployment end-to-end test fails on Travis with TM heartbeat timeout

[ https://issues.apache.org/jira/browse/FLINK-13489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901970#comment-16901970 ] Yingjie Cao commented on FLINK-13489: - [~till.rohrmann] I agree with you, this shoul

[GitHub] [flink] flinkbot edited a comment on issue #9378: [FLINK-13605][tests] Fix unstable case AsyncDataStreamITCase#testUnor…

flinkbot edited a comment on issue #9378: [FLINK-13605][tests] Fix unstable case AsyncDataStreamITCase#testUnor… URL: https://github.com/apache/flink/pull/9378#issuecomment-518996627 ## CI report: * 70223be8c6932e3c0780d408141fc9ac66fa842a : SUCCESS [Build](https://travis-ci.com/fli

[jira] [Created] (FLINK-13633) Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storage

Yang Wang created FLINK-13633: - Summary: Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storage Key: FLINK-13633 URL: https://issues.apache.org/jira/browse/FLINK-13633

[GitHub] [flink] flinkbot commented on issue #9380: [FLINK-13630][table-api-bridge] Use values retention configuration from TableConfig if not specified explicitly

flinkbot commented on issue #9380: [FLINK-13630][table-api-bridge] Use values retention configuration from TableConfig if not specified explicitly URL: https://github.com/apache/flink/pull/9380#issuecomment-519039358 ## CI report: * f444918f6b96c7970f869cbf20e919a70990ed02 : PENDING

[GitHub] [flink] flinkbot commented on issue #9380: [FLINK-13630][table-api-bridge] Use values retention configuration from TableConfig if not specified explicitly

flinkbot commented on issue #9380: [FLINK-13630][table-api-bridge] Use values retention configuration from TableConfig if not specified explicitly URL: https://github.com/apache/flink/pull/9380#issuecomment-519037769 Thanks a lot for your contribution to the Apache Flink project. I'm the @

[jira] [Updated] (FLINK-13630) StreamTableEnvironment#toAppendStream without QueryConfig overrides values set on TableConfig

[ https://issues.apache.org/jira/browse/FLINK-13630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13630: --- Labels: pull-request-available (was: ) > StreamTableEnvironment#toAppendStream without Quer

[GitHub] [flink] dawidwys opened a new pull request #9380: [FLINK-13630][table-api-bridge] Use values retention configuration from TableConfig if not specified explicitly

dawidwys opened a new pull request #9380: [FLINK-13630][table-api-bridge] Use values retention configuration from TableConfig if not specified explicitly URL: https://github.com/apache/flink/pull/9380 ## What is the purpose of the change In a sequence like this: ``` tEnv.ge

[GitHub] [flink] flinkbot edited a comment on issue #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org

flinkbot edited a comment on issue #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org URL: https://github.com/apache/flink/pull/9230#issuecomment-515090400 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] zentol commented on issue #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org

zentol commented on issue #9230: [FLINK-13430][build] Configure sending travis build notifications to bui...@flink.apache.org URL: https://github.com/apache/flink/pull/9230#issuecomment-519036062 @wuchong Could you reach out to INFRA on what the problem might be? As far as I can tell we sh

[jira] [Updated] (FLINK-13620) Update FlinkKafkaProducerMigrationTest to restore from 1.9 savepoint

[ https://issues.apache.org/jira/browse/FLINK-13620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13620: -- Component/s: Connectors / Kafka > Update FlinkKafkaProducerMigrationTest to restore from 1.9 s

[jira] [Updated] (FLINK-13622) Update WindowOperatorMigrationTest to restore from 1.9 savepoint

[ https://issues.apache.org/jira/browse/FLINK-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13622: -- Component/s: API / DataStream > Update WindowOperatorMigrationTest to restore from 1.9 savepoi

[jira] [Comment Edited] (FLINK-11767) Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.8

[ https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901942#comment-16901942 ] Till Rohrmann edited comment on FLINK-11767 at 8/7/19 10:04 AM: --

[jira] [Updated] (FLINK-13618) Update FlinkKafkaConsumerBaseMigrationTest to restore from 1.9 savepoint

[ https://issues.apache.org/jira/browse/FLINK-13618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13618: -- Component/s: Connectors / Kafka > Update FlinkKafkaConsumerBaseMigrationTest to restore from 1

[jira] [Updated] (FLINK-13617) Update FlinkKafkaProducer011MigrationTest to restore from 1.9 savepoint

[ https://issues.apache.org/jira/browse/FLINK-13617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13617: -- Component/s: Connectors / Kafka > Update FlinkKafkaProducer011MigrationTest to restore from 1.

[jira] [Updated] (FLINK-13615) Update CEPMigrationTest to restore from 1.9 savepoint

[ https://issues.apache.org/jira/browse/FLINK-13615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13615: -- Component/s: Library / CEP > Update CEPMigrationTest to restore from 1.9 savepoint > -

<    1   2   3   4   5   6   7   >