[jira] [Created] (FLINK-13171) Add withParameters(Configuration) method to DataStream operators

Gyula Fora created FLINK-13171: -- Summary: Add withParameters(Configuration) method to DataStream operators Key: FLINK-13171 URL: https://issues.apache.org/jira/browse/FLINK-13171 Project: Flink

[GitHub] [flink] aljoscha closed pull request #9046: [Table]Add a PrintTableSink

aljoscha closed pull request #9046: [Table]Add a PrintTableSink URL: https://github.com/apache/flink/pull/9046 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] aljoscha closed pull request #9040: [fink-table]Add constructor function for CsvTableSink to meet more scene

aljoscha closed pull request #9040: [fink-table]Add constructor function for CsvTableSink to meet more scene URL: https://github.com/apache/flink/pull/9040 This is an automated message from the Apache Git Service. To

[GitHub] [flink] aljoscha commented on issue #9046: [Table]Add a PrintTableSink

aljoscha commented on issue #9046: [Table]Add a PrintTableSink URL: https://github.com/apache/flink/pull/9046#issuecomment-509664659 Hi, thanks for contributing! However, usually PRs are not accepted if they don't correspond to a Jira Issue. Please also see the contribution guide about

[GitHub] [flink] aljoscha commented on issue #9040: [fink-table]Add constructor function for CsvTableSink to meet more scene

aljoscha commented on issue #9040: [fink-table]Add constructor function for CsvTableSink to meet more scene URL: https://github.com/apache/flink/pull/9040#issuecomment-509664714 Hi, thanks for contributing! However, usually PRs are not accepted if they don't correspond to a Jira Issue.

[GitHub] [flink] kezhuw commented on issue #8418: [FLINK-12491][docs][configuration] Fix incorrect javadoc for path sep…

kezhuw commented on issue #8418: [FLINK-12491][docs][configuration] Fix incorrect javadoc for path sep… URL: https://github.com/apache/flink/pull/8418#issuecomment-509665793 @flinkbot attention @dawidwys This is an

[GitHub] [flink] carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301606976 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301605326 ## File path:

[GitHub] [flink] KurtYoung closed pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

KurtYoung closed pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] wuchong commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

wuchong commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301619382 ## File path:

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

xccui 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_r301626139 ## File path: docs/dev/parallel.zh.md ## @@ -22,29 +22,20 @@ specific language

[jira] [Commented] (FLINK-13165) Complete requested slots in request order

[ https://issues.apache.org/jira/browse/FLINK-13165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881278#comment-16881278 ] Zhu Zhu commented on FLINK-13165: - Agree this mechanism could reduce the chance that "consumer task gets

[GitHub] [flink] flinkbot commented on issue #9036: [FLINK-13112][table-planner-blink] Support LocalZonedTimestampType in blink

flinkbot commented on issue #9036: [FLINK-13112][table-planner-blink] Support LocalZonedTimestampType in blink URL: https://github.com/apache/flink/pull/9036#issuecomment-509676263 CI report for commit de3f75136b30530e07133fd9e76ec869ee5a6849: FAILURE

[GitHub] [flink] wuchong commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

wuchong commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301631642 ## File path:

[GitHub] [flink] wuchong commented on issue #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

wuchong commented on issue #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#issuecomment-509677027 Hi @carp84 , thanks for reviewing. Comments are addressed.

[jira] [Comment Edited] (FLINK-13165) Complete requested slots in request order

[ https://issues.apache.org/jira/browse/FLINK-13165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881278#comment-16881278 ] Zhu Zhu edited comment on FLINK-13165 at 7/9/19 2:58 PM: - Hi Till, just agree

[GitHub] [flink] wuchong commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

wuchong commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301637293 ## File path:

[jira] [Comment Edited] (FLINK-13165) Complete requested slots in request order

[ https://issues.apache.org/jira/browse/FLINK-13165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881278#comment-16881278 ] Zhu Zhu edited comment on FLINK-13165 at 7/9/19 3:08 PM: - Hi Till, agree this

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

xccui 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_r301626139 ## File path: docs/dev/parallel.zh.md ## @@ -22,29 +22,20 @@ specific language

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

flinkbot commented on issue #8999: [hotfix] Remove incorrect doc comments from RocksDBMapState URL: https://github.com/apache/flink/pull/8999#issuecomment-509701796 CI report for commit ec08704855355ecf0e2d8e26df634206dd6ee587: SUCCESS

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

bowenli86 commented on issue #8987: [FLINK-13090][hive] Test Hive connector with hive runner URL: https://github.com/apache/flink/pull/8987#issuecomment-509705541 @lirui-apache LGTM, thanks for your contribution. Merging

[jira] [Created] (FLINK-13172) JVM crash with dynamic netty-tcnative wrapper to openSSL on some OS

Nico Kruber created FLINK-13172: --- Summary: JVM crash with dynamic netty-tcnative wrapper to openSSL on some OS Key: FLINK-13172 URL: https://issues.apache.org/jira/browse/FLINK-13172 Project: Flink

[jira] [Created] (FLINK-13173) Only run openSSL tests if desired

Nico Kruber created FLINK-13173: --- Summary: Only run openSSL tests if desired Key: FLINK-13173 URL: https://issues.apache.org/jira/browse/FLINK-13173 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-13173) Only run openSSL tests if desired

[ https://issues.apache.org/jira/browse/FLINK-13173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-13173: Priority: Critical (was: Major) > Only run openSSL tests if desired >

[GitHub] [flink] flinkbot commented on issue #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource

flinkbot commented on issue #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource URL: https://github.com/apache/flink/pull/9032#issuecomment-509707835 CI report for commit 471e58edc417ed72fd952ff06dba26277477b82f: SUCCESS

[GitHub] [flink] asfgit closed pull request #8987: [FLINK-13090][hive] Test Hive connector with hive runner

asfgit closed pull request #8987: [FLINK-13090][hive] Test Hive connector with hive runner URL: https://github.com/apache/flink/pull/8987 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (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 closed FLINK-13128. Resolution: Fixed merged in 1.9.0: 5d1e64eda1c4dc9b3563641d393bf1953e4ac06b > make HiveGenericUDAF

[jira] [Updated] (FLINK-13173) Only run openSSL tests if desired

[ https://issues.apache.org/jira/browse/FLINK-13173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13173: --- Labels: pull-request-available (was: ) > Only run openSSL tests if desired >

[GitHub] [flink] NicoK opened a new pull request #9048: [FLINK-13173][tests] only run openSSL-based tests with flink.tests.with-openssl

NicoK opened a new pull request #9048: [FLINK-13173][tests] only run openSSL-based tests with flink.tests.with-openssl URL: https://github.com/apache/flink/pull/9048 ## What is the purpose of the change Rename `flink.tests.force-openssl` (introduced for Flink 1.9) to

[GitHub] [flink] bowenli86 commented on issue #9037: [FLINK-13157]reeanble unit test read complext type of HiveInputFormatTest

bowenli86 commented on issue #9037: [FLINK-13157]reeanble unit test read complext type of HiveInputFormatTest URL: https://github.com/apache/flink/pull/9037#issuecomment-509712031 @zjuwangg thanks for your contribution! I wonder if we should add a shim for the changes you made in

[jira] [Updated] (FLINK-13172) JVM crash with dynamic netty-tcnative wrapper to openSSL on some OS

[ https://issues.apache.org/jira/browse/FLINK-13172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-13172: Description: The dynamically-linked wrapper library in {{flink-shaded-netty-tcnative-dynamic}}

[GitHub] [flink] StephanEwen commented on issue #8846: [FLINK-12766][runtime] Dynamically allocate TaskExecutor's managed memory to slots.

StephanEwen commented on issue #8846: [FLINK-12766][runtime] Dynamically allocate TaskExecutor's managed memory to slots. URL: https://github.com/apache/flink/pull/8846#issuecomment-509729439 I am currently going through this PR. About the changes to the `ResourceProfile`: -

[GitHub] [flink] xuefuz commented on a change in pull request #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource

xuefuz commented on a change in pull request #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource URL: https://github.com/apache/flink/pull/9032#discussion_r301718344 ## File path:

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

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

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

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

[GitHub] [flink] flinkbot commented on issue #9042: [FLINK-12736][coordination] Release TaskExecutor in SlotManager if no slot allocations after partition check (1.7)

flinkbot commented on issue #9042: [FLINK-12736][coordination] Release TaskExecutor in SlotManager if no slot allocations after partition check (1.7) URL: https://github.com/apache/flink/pull/9042#issuecomment-509746192 CI report for commit 1e5d9ea542f75663be46ef7aa14968c6d08b872a: FAILURE

[GitHub] [flink] carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301725717 ## File path:

[GitHub] [flink] flinkbot commented on issue #9041: [FLINK-12736][coordination] Release TaskExecutor in SlotManager if no slot allocations after partition check (1.8)

flinkbot commented on issue #9041: [FLINK-12736][coordination] Release TaskExecutor in SlotManager if no slot allocations after partition check (1.8) URL: https://github.com/apache/flink/pull/9041#issuecomment-509791746 CI report for commit 8060503b13b4cd2ac29bd0985a70d652bab36401: SUCCESS

[GitHub] [flink] bowenli86 commented on issue #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource

bowenli86 commented on issue #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource URL: https://github.com/apache/flink/pull/9032#issuecomment-509713390 @zjuwangg thanks for the PR! LGTM. Can you add corresponding tests too?

[GitHub] [flink] flinkbot commented on issue #9038: [FLINK-13169][tests][coordination] IT test for fine-grained recovery (task executor failures)

flinkbot commented on issue #9038: [FLINK-13169][tests][coordination] IT test for fine-grained recovery (task executor failures) URL: https://github.com/apache/flink/pull/9038#issuecomment-509734568 CI report for commit 9fb4881274cb0d01e1f34f3bb40a2f0228192562: FAILURE

[GitHub] [flink] flinkbot commented on issue #8624: [FLINK-10932]Initial flink-kubernetes module with empty implementation

flinkbot commented on issue #8624: [FLINK-10932]Initial flink-kubernetes module with empty implementation URL: https://github.com/apache/flink/pull/8624#issuecomment-509742224 CI report for commit 8f40df18c9756eaa65a5b91ebc9847a9c0e38d7a: SUCCESS

[GitHub] [flink] Myasuka commented on issue #9023: [FLINK-13154][docs] Fix broken links of web docs

Myasuka commented on issue #9023: [FLINK-13154][docs] Fix broken links of web docs URL: https://github.com/apache/flink/pull/9023#issuecomment-509742057 @flinkbot attention @bowenli86 for I have removed one line in `sqlClient.md`.

[GitHub] [flink] carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301726528 ## File path:

[jira] [Commented] (FLINK-13174) Changes of HiveTableSinkTest in FLINK-13068 introduces compilation error

[ https://issues.apache.org/jira/browse/FLINK-13174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881464#comment-16881464 ] Yu Li commented on FLINK-13174: --- [~phoenixjiangnan] FYI. > Changes of HiveTableSinkTest in FLINK-13068

[jira] [Commented] (FLINK-13068) HiveTableSink should implement PartitionableTableSink

[ https://issues.apache.org/jira/browse/FLINK-13068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881465#comment-16881465 ] Yu Li commented on FLINK-13068: --- The change here seems to be breaking the compilation, I've created

[jira] [Created] (FLINK-13175) FLINK-12951 breaks SQL CLI's ExecutionContextTest

Bowen Li created FLINK-13175: Summary: FLINK-12951 breaks SQL CLI's ExecutionContextTest Key: FLINK-13175 URL: https://issues.apache.org/jira/browse/FLINK-13175 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on issue #9007: [FLINK-13131] [Deployment / YARN] add a custom directory for storing configuration files and jar files for user jobs

flinkbot commented on issue #9007: [FLINK-13131] [Deployment / YARN] add a custom directory for storing configuration files and jar files for user jobs URL: https://github.com/apache/flink/pull/9007#issuecomment-509802559 CI report for commit 54c43e9ef4b19d2a3463847c94759659c5ec8f34:

[GitHub] [flink] bowenli86 commented on a change in pull request #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource

bowenli86 commented on a change in pull request #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource URL: https://github.com/apache/flink/pull/9032#discussion_r301679583 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource

bowenli86 commented on a change in pull request #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource URL: https://github.com/apache/flink/pull/9032#discussion_r301679620 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis

bowenli86 commented on a change in pull request #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis URL: https://github.com/apache/flink/pull/8911#discussion_r301684028 ## File path: .travis.yml ## @@ -191,6 +191,10 @@ jobs: script:

[GitHub] [flink] bowenli86 commented on a change in pull request #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis

bowenli86 commented on a change in pull request #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis URL: https://github.com/apache/flink/pull/8911#discussion_r301685317 ## File path: tools/travis/stage.sh ## @@ -213,6 +220,9 @@ function get_test_modules_for_stage()

[GitHub] [flink] bowenli86 commented on a change in pull request #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis

bowenli86 commented on a change in pull request #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis URL: https://github.com/apache/flink/pull/8911#discussion_r301683816 ## File path: tools/travis/stage.sh ## @@ -25,6 +25,7 @@ STAGE_BLINK_PLANNER="blink_planner"

[jira] [Commented] (FLINK-13150) defaultCatalogName and defaultDatabaseName in TableEnvImpl is not updated after they are updated in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-13150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881416#comment-16881416 ] Xuefu Zhang commented on FLINK-13150: - After talking to [~twalthr] in person and it's clarified that

[jira] [Assigned] (FLINK-13150) defaultCatalogName and defaultDatabaseName in TableEnvImpl is not updated after they are updated in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-13150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang reassigned FLINK-13150: --- Assignee: Xuefu Zhang > defaultCatalogName and defaultDatabaseName in TableEnvImpl is not

[jira] [Commented] (FLINK-12916) KeyedComplexChainTest.testMigrationAndRestore failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-12916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881450#comment-16881450 ] Till Rohrmann commented on FLINK-12916: --- Another instance:

[GitHub] [flink] flinkbot commented on issue #9039: [FLINK-13170][table-planner] Planner should get table factory from ca…

flinkbot commented on issue #9039: [FLINK-13170][table-planner] Planner should get table factory from ca… URL: https://github.com/apache/flink/pull/9039#issuecomment-509748198 CI report for commit 1c1efbbfc19bde250ea215357be969bedcc41ec9: FAILURE

[jira] [Closed] (FLINK-13174) Changes of HiveTableSinkTest in FLINK-13068 introduces compilation error

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

[jira] [Updated] (FLINK-13176) remember current catalog and database in SQL CLI SessionContext

[ https://issues.apache.org/jira/browse/FLINK-13176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13176: --- Labels: pull-request-available (was: ) > remember current catalog and database in SQL CLI

[GitHub] [flink] bowenli86 opened a new pull request #9049: [FLINK-13176][SQL CLI] remember current catalog and database in SQL CLI SessionContext

bowenli86 opened a new pull request #9049: [FLINK-13176][SQL CLI] remember current catalog and database in SQL CLI SessionContext URL: https://github.com/apache/flink/pull/9049 ## What is the purpose of the change This PR supports remembering current catalog and database that users

[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-509714497 LGTM. Merging This is an automated message from

[GitHub] [flink] flinkbot commented on issue #8914: [FLINK-12929] Pass TypeInformation in addSource

flinkbot commented on issue #8914: [FLINK-12929] Pass TypeInformation in addSource URL: https://github.com/apache/flink/pull/8914#issuecomment-509723473 CI report for commit e5821043e99f59a16d3c4275a55641446d0fa707: SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/118427727)

[GitHub] [flink] Myasuka commented on issue #8964: [FLINK-13067][docs] Fix broken links to contributing docs

Myasuka commented on issue #8964: [FLINK-13067][docs] Fix broken links to contributing docs URL: https://github.com/apache/flink/pull/8964#issuecomment-509739280 Rebase latest code to avoid conflict. This is an automated

[GitHub] [flink] bowenli86 commented on a change in pull request #9023: [FLINK-13154][docs] Fix broken links of web docs

bowenli86 commented on a change in pull request #9023: [FLINK-13154][docs] Fix broken links of web docs URL: https://github.com/apache/flink/pull/9023#discussion_r301723171 ## File path: docs/dev/table/sqlClient.md ## @@ -456,8 +456,6 @@ catalogs: Currently Flink

[jira] [Assigned] (FLINK-13174) Changes of HiveTableSinkTest in FLINK-13068 introduces compilation error

[ https://issues.apache.org/jira/browse/FLINK-13174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-13174: Assignee: Bowen Li (was: Rui Li) > Changes of HiveTableSinkTest in FLINK-13068 introduces

[jira] [Commented] (FLINK-13174) Changes of HiveTableSinkTest in FLINK-13068 introduces compilation error

[ https://issues.apache.org/jira/browse/FLINK-13174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881488#comment-16881488 ] Yu Li commented on FLINK-13174: --- Thanks for the quick fix [~phoenixjiangnan]! > Changes of

[jira] [Closed] (FLINK-13068) HiveTableSink should implement PartitionableTableSink

[ https://issues.apache.org/jira/browse/FLINK-13068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13068. Resolution: Fixed merged in 1.9.0: d5f8078a358ed3e1dfa79042873c060e59d4732e > HiveTableSink should

[GitHub] [flink] asfgit closed pull request #8965: [FLINK-13068][hive] HiveTableSink should implement PartitionableTable…

asfgit closed pull request #8965: [FLINK-13068][hive] HiveTableSink should implement PartitionableTable… URL: https://github.com/apache/flink/pull/8965 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot commented on issue #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

flinkbot commented on issue #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module. URL: https://github.com/apache/flink/pull/8294#issuecomment-509758357 CI report for commit 72c25a815f750888a3824a20c3d93b7020ea6bc6: SUCCESS

[jira] [Created] (FLINK-13174) Changes of HiveTableSinkTest in FLINK-13068 introduces compilation error

Yu Li created FLINK-13174: - Summary: Changes of HiveTableSinkTest in FLINK-13068 introduces compilation error Key: FLINK-13174 URL: https://issues.apache.org/jira/browse/FLINK-13174 Project: Flink

[jira] [Created] (FLINK-13176) remember current catalog and database in SQL CLI SessionContext

Bowen Li created FLINK-13176: Summary: remember current catalog and database in SQL CLI SessionContext Key: FLINK-13176 URL: https://issues.apache.org/jira/browse/FLINK-13176 Project: Flink

[GitHub] [flink] flinkbot commented on issue #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem

flinkbot commented on issue #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem URL: https://github.com/apache/flink/pull/8215#issuecomment-509782700 CI report for commit 11fc41cd006cfea385f6e52f74063d13db4f1197: SUCCESS

[GitHub] [flink] flinkbot commented on issue #9048: [FLINK-13173][tests] only run openSSL-based tests with flink.tests.with-openssl

flinkbot commented on issue #9048: [FLINK-13173][tests] only run openSSL-based tests with flink.tests.with-openssl URL: https://github.com/apache/flink/pull/9048#issuecomment-509711808 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot commented on issue #9034: [FLINK-13063] Temporary fix for AsyncWaitOperator consistency problems.

flinkbot commented on issue #9034: [FLINK-13063] Temporary fix for AsyncWaitOperator consistency problems. URL: https://github.com/apache/flink/pull/9034#issuecomment-509717603 CI report for commit d9b53c4c8c8937e6817cdc6f8042d846eee98b14: FAILURE

[GitHub] [flink] carp84 commented on issue #9030: [FLINK-13123] Align Stop/Cancel Commands in CLI and REST Interface and Improve Documentation

carp84 commented on issue #9030: [FLINK-13123] Align Stop/Cancel Commands in CLI and REST Interface and Improve Documentation URL: https://github.com/apache/flink/pull/9030#issuecomment-509772563 Thanks for noticing this and trying to align the commands @knaufk . Not sure whether it's a

[GitHub] [flink] flinkbot commented on issue #9040: [fink-table]Add constructor function for CsvTableSink to meet more scene

flinkbot commented on issue #9040: [fink-table]Add constructor function for CsvTableSink to meet more scene URL: https://github.com/apache/flink/pull/9040#issuecomment-509775533 CI report for commit 13a104fb2b2aeecf0b144367f7045a7ef4c0e002: SUCCESS

[GitHub] [flink] flinkbot commented on issue #9017: [FLINK-13013][network] Request partitions during InputGate#setup

flinkbot commented on issue #9017: [FLINK-13013][network] Request partitions during InputGate#setup URL: https://github.com/apache/flink/pull/9017#issuecomment-509786413 CI report for commit 660aa545880ebbfdb6b65f8cff592a03e864eb7a: FAILURE

[jira] [Updated] (FLINK-11986) Add micro benchmark for state operations

[ https://issues.apache.org/jira/browse/FLINK-11986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-11986: -- Component/s: Benchmarks > Add micro benchmark for state operations >

[GitHub] [flink] flinkbot commented on issue #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client

flinkbot commented on issue #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client URL: https://github.com/apache/flink/pull/8756#issuecomment-509797241 CI report for commit c330ecf662808c11171673f59dd6a7299fd4a757: FAILURE

[GitHub] [flink] flinkbot commented on issue #9037: [FLINK-13157]reeanble unit test read complext type of HiveInputFormatTest

flinkbot commented on issue #9037: [FLINK-13157]reeanble unit test read complext type of HiveInputFormatTest URL: https://github.com/apache/flink/pull/9037#issuecomment-509727140 CI report for commit a25ebb2115c44c7ecf151afcc39d6b2134129f5c: FAILURE

[GitHub] [flink] flinkbot commented on issue #9049: [FLINK-13176][SQL CLI] remember current catalog and database in SQL CLI SessionContext

flinkbot commented on issue #9049: [FLINK-13176][SQL CLI] remember current catalog and database in SQL CLI SessionContext URL: https://github.com/apache/flink/pull/9049#issuecomment-509780489 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] zjuwangg commented on issue #9037: [FLINK-13157]reeanble unit test read complext type of HiveInputFormatTest

zjuwangg commented on issue #9037: [FLINK-13157]reeanble unit test read complext type of HiveInputFormatTest URL: https://github.com/apache/flink/pull/9037#issuecomment-509891144 > @zjuwangg thanks for your contribution! > > I wonder if we should add a shim for the changes you made

[GitHub] [flink] zjuwangg commented on issue #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource

zjuwangg commented on issue #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource URL: https://github.com/apache/flink/pull/9032#issuecomment-509891968 > @zjuwangg thanks for the PR! > > LGTM. Can you add corresponding tests too? Since the planner still

[GitHub] [flink] AjaxXu commented on a change in pull request #9027: [FLINK-13161][table-blink-runtime]numBuckets calculate wrong in BinaryHashBucketArea

AjaxXu commented on a change in pull request #9027: [FLINK-13161][table-blink-runtime]numBuckets calculate wrong in BinaryHashBucketArea URL: https://github.com/apache/flink/pull/9027#discussion_r301872722 ## File path:

[GitHub] [flink] zjuwangg edited a comment on issue #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource

zjuwangg edited a comment on issue #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource URL: https://github.com/apache/flink/pull/9032#issuecomment-509891968 > @zjuwangg thanks for the PR! > > LGTM. Can you add corresponding tests too? Since the

[jira] [Created] (FLINK-13184) Support launching task executors with multi-thread on YARN.

Xintong Song created FLINK-13184: Summary: Support launching task executors with multi-thread on YARN. Key: FLINK-13184 URL: https://issues.apache.org/jira/browse/FLINK-13184 Project: Flink

[GitHub] [flink] flinkbot commented on issue #9025: [FLINK-13149][Web Frontend] support configuration and update Angular to 8.0 version

flinkbot commented on issue #9025: [FLINK-13149][Web Frontend] support configuration and update Angular to 8.0 version URL: https://github.com/apache/flink/pull/9025#issuecomment-509894125 CI report for commit 1a45d666d1d26be26bef806c2af16328ad55b6c4: FAILURE

[GitHub] [flink] flinkbot commented on issue #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

flinkbot commented on issue #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#issuecomment-509894152 CI report for commit eb27e3dd87223401ecaec230aa17b9365da656c8: FAILURE

[GitHub] [flink] flinkbot commented on issue #9054: [FLINK-13183][Table]Add a PrintTableSink

flinkbot commented on issue #9054: [FLINK-13183][Table]Add a PrintTableSink URL: https://github.com/apache/flink/pull/9054#issuecomment-509894186 CI report for commit 5ce3dbdf975676152924611e21be32ea5923cd97: FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/118542845)

[GitHub] [flink] flinkbot commented on issue #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

flinkbot commented on issue #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module. URL: https://github.com/apache/flink/pull/8294#issuecomment-509894092 CI report for commit 215af79ad2894707e9dea714da01dec89b2b815d: FAILURE

[jira] [Comment Edited] (FLINK-13163) Support execution of batch jobs with fewer slots than requested

[ https://issues.apache.org/jira/browse/FLINK-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881704#comment-16881704 ] Zhu Zhu edited comment on FLINK-13163 at 7/10/19 3:51 AM: -- Hi [~till.rohrmann],

[GitHub] [flink] flinkbot commented on issue #8976: [FLINK-12277][table/hive/doc] Add documentation for catalogs

flinkbot commented on issue #8976: [FLINK-12277][table/hive/doc] Add documentation for catalogs URL: https://github.com/apache/flink/pull/8976#issuecomment-509898237 CI report for commit 1264d8146acd9a12e23f7377a1cdc549d6d7c87a: SUCCESS

[GitHub] [flink] flinkbot commented on issue #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

flinkbot commented on issue #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#issuecomment-509898266 CI report for commit eb27e3dd87223401ecaec230aa17b9365da656c8: FAILURE

[GitHub] [flink] xuefuz commented on issue #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource

xuefuz commented on issue #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource URL: https://github.com/apache/flink/pull/9032#issuecomment-509902212 > > @zjuwangg thanks for the PR! > > LGTM. Can you add corresponding tests too? > > Since the planner still

[GitHub] [flink] flinkbot commented on issue #9055: [hotfix][python] Fix the documentation issue

flinkbot commented on issue #9055: [hotfix][python] Fix the documentation issue URL: https://github.com/apache/flink/pull/9055#issuecomment-509902200 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

[GitHub] [flink] dianfu opened a new pull request #9055: [hotfix][python] Fix the documentation issue

dianfu opened a new pull request #9055: [hotfix][python] Fix the documentation issue URL: https://github.com/apache/flink/pull/9055 ## What is the purpose of the change *There is a documentation issue of the TableEnvironment.sql method which fails the travis. This PR fix this

[GitHub] [flink] TsReaper commented on a change in pull request #9029: [FLINK-13118][jdbc] Introduce JDBC table factory and bridge JDBC table source with streaming table source

TsReaper commented on a change in pull request #9029: [FLINK-13118][jdbc] Introduce JDBC table factory and bridge JDBC table source with streaming table source URL: https://github.com/apache/flink/pull/9029#discussion_r301882168 ## File path:

[GitHub] [flink] TsReaper commented on a change in pull request #9029: [FLINK-13118][jdbc] Introduce JDBC table factory and bridge JDBC table source with streaming table source

TsReaper commented on a change in pull request #9029: [FLINK-13118][jdbc] Introduce JDBC table factory and bridge JDBC table source with streaming table source URL: https://github.com/apache/flink/pull/9029#discussion_r301882148 ## File path:

[GitHub] [flink] TsReaper commented on a change in pull request #9029: [FLINK-13118][jdbc] Introduce JDBC table factory and bridge JDBC table source with streaming table source

TsReaper commented on a change in pull request #9029: [FLINK-13118][jdbc] Introduce JDBC table factory and bridge JDBC table source with streaming table source URL: https://github.com/apache/flink/pull/9029#discussion_r301882158 ## File path:

[GitHub] [flink] asfgit merged pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

asfgit merged pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045 This is an automated message from the Apache Git Service. To respond to the

[jira] [Resolved] (FLINK-12955) Add HBase LookupableTableSource and TableFactory

[ https://issues.apache.org/jira/browse/FLINK-12955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-12955. - Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: a1636b1e3b05fb366a9e25a23b555648860d9223

<    1   2   3   4   5   6   >