[GitHub] [flink] li-zhao-hotstar commented on issue #9720: [FLINK-13025] Elasticsearch 7.x support

li-zhao-hotstar commented on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-564893587 Hi @yanghua Thanks for the effort. Came from https://issues.apache.org/jira/browse/FLINK-13025, want to check is this available now

[GitHub] [flink] KarmaGYZ edited a comment on issue #10538: [Flink-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration

KarmaGYZ edited a comment on issue #10538: [Flink-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration URL: https://github.com/apache/flink/pull/10538#issuecomment-564862479 Related e2e tests passed [here](https://travis-ci.org/KarmaGYZ/flink/builds/624018259) ---

[GitHub] [flink] flinkbot edited a comment on issue #10500: [FLINK-15161][table-common] Introduce TypeTransformation interface and basic transformations

flinkbot edited a comment on issue #10500: [FLINK-15161][table-common] Introduce TypeTransformation interface and basic transformations URL: https://github.com/apache/flink/pull/10500#issuecomment-563307831 ## CI report: * eec6a875a18e7f5154183c77ede371e4ec1fc74c Travis: [SUCCES

[GitHub] [flink] zhijiangW commented on issue #10539: [FLINK-14952][network] Solve the issue of exceeding memory limits when using mmap blocking partition

zhijiangW commented on issue #10539: [FLINK-14952][network] Solve the issue of exceeding memory limits when using mmap blocking partition URL: https://github.com/apache/flink/pull/10539#issuecomment-564892793 @flinkbot run travis

[GitHub] [flink] KurtYoung closed pull request #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times

KurtYoung closed pull request #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times URL: https://github.com/apache/flink/pull/10523 This is an automated message from the Apache Git Service. To resp

[jira] [Created] (FLINK-15218) java.lang.NoClassDefFoundError: org/apache/flink/table/sources/TableSource

tyler fan created FLINK-15218: - Summary: java.lang.NoClassDefFoundError: org/apache/flink/table/sources/TableSource Key: FLINK-15218 URL: https://issues.apache.org/jira/browse/FLINK-15218 Project: Flink

[GitHub] [flink] JingsongLi commented on issue #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

JingsongLi commented on issue #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#issuecomment-564891650 Code LGTM, but I think you can have some tests manually. -

[jira] [Commented] (FLINK-15217) 'java.time.LocalDate' should support for the CSV input format.

[ https://issues.apache.org/jira/browse/FLINK-15217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994349#comment-16994349 ] Jingsong Lee commented on FLINK-15217: -- Hi [~xiaojin.wy], [https://github.com/apach

[GitHub] [flink] AHeise commented on a change in pull request #10482: [Flink-11956] Unshade s3 filesystems

AHeise commented on a change in pull request #10482: [Flink-11956] Unshade s3 filesystems URL: https://github.com/apache/flink/pull/10482#discussion_r356998258 ## File path: flink-filesystems/flink-s3-fs-base/pom.xml ## @@ -108,83 +107,6 @@ under the License.

[GitHub] [flink] AHeise commented on a change in pull request #10482: [Flink-11956] Unshade s3 filesystems

AHeise commented on a change in pull request #10482: [Flink-11956] Unshade s3 filesystems URL: https://github.com/apache/flink/pull/10482#discussion_r356997547 ## File path: flink-filesystems/flink-s3-fs-base/pom.xml ## @@ -46,14 +46,14 @@ under the License.

[GitHub] [flink] AHeise commented on a change in pull request #10482: [Flink-11956] Unshade s3 filesystems

AHeise commented on a change in pull request #10482: [Flink-11956] Unshade s3 filesystems URL: https://github.com/apache/flink/pull/10482#discussion_r356996925 ## File path: flink-filesystems/flink-s3-fs-base/pom.xml ## @@ -46,14 +46,14 @@ under the License.

[jira] [Commented] (FLINK-15168) Exception is thrown when using kafka source connector with flink planner

[ https://issues.apache.org/jira/browse/FLINK-15168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994345#comment-16994345 ] Leonard Xu commented on FLINK-15168: This issue will lead end2end cron test fail ev

[jira] [Created] (FLINK-15217) 'java.time.LocalDate' should support for the CSV input format.

xiaojin.wy created FLINK-15217: -- Summary: 'java.time.LocalDate' should support for the CSV input format. Key: FLINK-15217 URL: https://issues.apache.org/jira/browse/FLINK-15217 Project: Flink I

[jira] [Commented] (FLINK-15200) legacy planner cannot deal Type with precision like DataTypes.TIMESTAMP(3) in TableSourceUtil

[ https://issues.apache.org/jira/browse/FLINK-15200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994341#comment-16994341 ] Leonard Xu commented on FLINK-15200: [~dwysakowicz] Happy to hear that, hope to see

[jira] [Commented] (FLINK-15070) Supplement cases of blocking partition with compression for benchmark

[ https://issues.apache.org/jira/browse/FLINK-15070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994334#comment-16994334 ] Haibo Sun commented on FLINK-15070: --- The PR: https://github.com/dataArtisans/flink-ben

[jira] [Commented] (FLINK-15200) legacy planner cannot deal Type with precision like DataTypes.TIMESTAMP(3) in TableSourceUtil

[ https://issues.apache.org/jira/browse/FLINK-15200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994331#comment-16994331 ] Dawid Wysakowicz commented on FLINK-15200: -- Thank you [~Leonard Xu] for opening

[GitHub] [flink] flinkbot edited a comment on issue #10539: [FLINK-14952][network] Solve the issue of exceeding memory limits when using mmap blocking partition

flinkbot edited a comment on issue #10539: [FLINK-14952][network] Solve the issue of exceeding memory limits when using mmap blocking partition URL: https://github.com/apache/flink/pull/10539#issuecomment-564864534 ## CI report: * b89fa1e6eda3fb4a2eca846c94c7881e9b34828d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10538: [Flink-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration

flinkbot edited a comment on issue #10538: [Flink-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration URL: https://github.com/apache/flink/pull/10538#issuecomment-564837772 ## CI report: * 41ed3d467603e389c84f8fd6761a4ffc3c6786e7 Travis: [SUCCESS](https://travis-ci

[jira] [Closed] (FLINK-15200) legacy planner cannot deal Type with precision like DataTypes.TIMESTAMP(3) in TableSourceUtil

[ https://issues.apache.org/jira/browse/FLINK-15200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-15200. Resolution: Duplicate > legacy planner cannot deal Type with precision like DataTypes.TIM

[jira] [Closed] (FLINK-14046) DDL property 'format.fields.#.type' should ignore case

[ https://issues.apache.org/jira/browse/FLINK-14046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-14046. --- Fix Version/s: (was: 1.11.0) Resolution: Won't Fix Close this issue as users don't need to fill {

[GitHub] [flink] flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times

flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times URL: https://github.com/apache/flink/pull/10523#issuecomment-564363476 ## CI report: * afdfe7941439eeec090d3123319c74ecb7fb21ee Travis: [FAILURE](https://travis-ci

[GitHub] [flink] zhijiangW commented on issue #10530: [FLINK-15195] Remove unused KubernetesConfigOptionsInternal.ENTRY_POINT_CLASS_ARGS

zhijiangW commented on issue #10530: [FLINK-15195] Remove unused KubernetesConfigOptionsInternal.ENTRY_POINT_CLASS_ARGS URL: https://github.com/apache/flink/pull/10530#issuecomment-564885441 @flinkbot run travis This is an au

[jira] [Commented] (FLINK-15216) Can't use rocksdb with hdfs filesystem with flink-s3-fs-hadoop

[ https://issues.apache.org/jira/browse/FLINK-15216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994325#comment-16994325 ] Tank commented on FLINK-15216: -- I didn't get this issue with flink 1.8.1 on EMR 5.27 (also

[GitHub] [flink] flinkbot edited a comment on issue #10500: [FLINK-15161][table-common] Introduce TypeTransformation interface and basic transformations

flinkbot edited a comment on issue #10500: [FLINK-15161][table-common] Introduce TypeTransformation interface and basic transformations URL: https://github.com/apache/flink/pull/10500#issuecomment-563307831 ## CI report: * eec6a875a18e7f5154183c77ede371e4ec1fc74c Travis: [SUCCES

[GitHub] [flink] TisonKun commented on a change in pull request #10528: [FLINK-15179] Kubernetes Session CLI use generic ExecutorCLI, not custom one

TisonKun commented on a change in pull request #10528: [FLINK-15179] Kubernetes Session CLI use generic ExecutorCLI, not custom one URL: https://github.com/apache/flink/pull/10528#discussion_r356991038 ## File path: flink-clients/src/main/java/org/apache/flink/client/cli/ExecutorCL

[jira] [Created] (FLINK-15216) Can't use rocksdb with hdfs filesystem with flink-s3-fs-hadoop

Tank created FLINK-15216: Summary: Can't use rocksdb with hdfs filesystem with flink-s3-fs-hadoop Key: FLINK-15216 URL: https://issues.apache.org/jira/browse/FLINK-15216 Project: Flink Issue Type: B

[GitHub] [flink] wuchong commented on issue #10500: [FLINK-15161][table-common] Introduce TypeTransformation interface and basic transformations

wuchong commented on issue #10500: [FLINK-15161][table-common] Introduce TypeTransformation interface and basic transformations URL: https://github.com/apache/flink/pull/10500#issuecomment-564883503 Thanks @twalthr for the reviewing, I updated the `TimeToSqlTypesTransformation` to be more

[jira] [Updated] (FLINK-15215) Not able to provide a custom AWS credentials provider with flink-s3-fs-hadoop

[ https://issues.apache.org/jira/browse/FLINK-15215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tank updated FLINK-15215: - Description: I am using Flink 1.9.0 on EMR (emr 5.28), with StreamingFileSink using an S3 filesystem. I want f

[jira] [Updated] (FLINK-15212) PROCTIME attribute causes problems with timestamp times before 1900 ?

[ https://issues.apache.org/jira/browse/FLINK-15212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15212: --- Component/s: (was: Table SQL / API) Table SQL / Legacy Planner > PROCTIME attr

[GitHub] [flink] TisonKun commented on a change in pull request #10528: [FLINK-15179] Kubernetes Session CLI use generic ExecutorCLI, not custom one

TisonKun commented on a change in pull request #10528: [FLINK-15179] Kubernetes Session CLI use generic ExecutorCLI, not custom one URL: https://github.com/apache/flink/pull/10528#discussion_r356989038 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/exe

[GitHub] [flink] TisonKun commented on a change in pull request #10528: [FLINK-15179] Kubernetes Session CLI use generic ExecutorCLI, not custom one

TisonKun commented on a change in pull request #10528: [FLINK-15179] Kubernetes Session CLI use generic ExecutorCLI, not custom one URL: https://github.com/apache/flink/pull/10528#discussion_r356989038 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/exe

[GitHub] [flink] TisonKun commented on a change in pull request #10528: [FLINK-15179] Kubernetes Session CLI use generic ExecutorCLI, not custom one

TisonKun commented on a change in pull request #10528: [FLINK-15179] Kubernetes Session CLI use generic ExecutorCLI, not custom one URL: https://github.com/apache/flink/pull/10528#discussion_r356988827 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/exe

[jira] [Commented] (FLINK-15212) PROCTIME attribute causes problems with timestamp times before 1900 ?

[ https://issues.apache.org/jira/browse/FLINK-15212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994307#comment-16994307 ] Zhenghua Gao commented on FLINK-15212: -- [~Rockey Cui] Please try Blink planner(mast

[jira] [Created] (FLINK-15215) Not able to provide a custom AWS credentials provider with flink-s3-fs-hadoop

Arjun Prakash created FLINK-15215: - Summary: Not able to provide a custom AWS credentials provider with flink-s3-fs-hadoop Key: FLINK-15215 URL: https://issues.apache.org/jira/browse/FLINK-15215 Proje

[GitHub] [flink] KarmaGYZ commented on issue #10531: [FLINK-15196][Mesos] Using the mesos.resourcemanager.tasks.cpus to determine the cpus of Mesos worker

KarmaGYZ commented on issue #10531: [FLINK-15196][Mesos] Using the mesos.resourcemanager.tasks.cpus to determine the cpus of Mesos worker URL: https://github.com/apache/flink/pull/10531#issuecomment-564879352 Comments addressed. Thanks for the reviews @azagrebin @xintongsong . The Travis g

[GitHub] [flink] flinkbot edited a comment on issue #10540: [FLINK-15185][hive] Shade flink-hadoop-fs to run hive in standalone mode

flinkbot edited a comment on issue #10540: [FLINK-15185][hive] Shade flink-hadoop-fs to run hive in standalone mode URL: https://github.com/apache/flink/pull/10540#issuecomment-564871503 ## CI report: * 29e11fac171f161411931ae37d52580308cc51f7 Travis: [PENDING](https://travis-ci

[GitHub] [flink] KarmaGYZ removed a comment on issue #10531: [FLINK-15196][Mesos] Using the mesos.resourcemanager.tasks.cpus to determine the cpus of Mesos worker

KarmaGYZ removed a comment on issue #10531: [FLINK-15196][Mesos] Using the mesos.resourcemanager.tasks.cpus to determine the cpus of Mesos worker URL: https://github.com/apache/flink/pull/10531#issuecomment-564557324 > Thanks @KarmaGYZ LGTM, modulo @xintongsong's concern, > though we can

[jira] [Assigned] (FLINK-15194) Directories in distributed caches are not extracted in Yarn Per Job Cluster Mode

[ https://issues.apache.org/jira/browse/FLINK-15194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-15194: --- Assignee: Yang Wang (was: sunjincheng) > Directories in distributed caches are not extract

[jira] [Assigned] (FLINK-15194) Directories in distributed caches are not extracted in Yarn Per Job Cluster Mode

[ https://issues.apache.org/jira/browse/FLINK-15194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-15194: --- Assignee: sunjincheng > Directories in distributed caches are not extracted in Yarn Per Job

[GitHub] [flink] flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times

flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times URL: https://github.com/apache/flink/pull/10523#issuecomment-564363476 ## CI report: * afdfe7941439eeec090d3123319c74ecb7fb21ee Travis: [FAILURE](https://travis-ci

[GitHub] [flink] hequn8128 commented on issue #10377: [FLINK-15001] [table-planner-blink] The digest of sub-plan reuse should contain retraction traits for stream physical nodes

hequn8128 commented on issue #10377: [FLINK-15001] [table-planner-blink] The digest of sub-plan reuse should contain retraction traits for stream physical nodes URL: https://github.com/apache/flink/pull/10377#issuecomment-564874854 Merging... --

[jira] [Commented] (FLINK-15013) Flink (on YARN) sometimes needs too many slots

[ https://issues.apache.org/jira/browse/FLINK-15013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994287#comment-16994287 ] Zhu Zhu commented on FLINK-15013: - [~trohrmann] yes that's what I mean. And location pre

[GitHub] [flink] flinkbot edited a comment on issue #10539: [FLINK-14952][network] Solve the issue of exceeding memory limits when using mmap blocking partition

flinkbot edited a comment on issue #10539: [FLINK-14952][network] Solve the issue of exceeding memory limits when using mmap blocking partition URL: https://github.com/apache/flink/pull/10539#issuecomment-564864534 ## CI report: * b89fa1e6eda3fb4a2eca846c94c7881e9b34828d Travis:

[GitHub] [flink] flinkbot commented on issue #10540: [FLINK-15185][hive] Shade flink-hadoop-fs to run hive in standalone mode

flinkbot commented on issue #10540: [FLINK-15185][hive] Shade flink-hadoop-fs to run hive in standalone mode URL: https://github.com/apache/flink/pull/10540#issuecomment-564871503 ## CI report: * 29e11fac171f161411931ae37d52580308cc51f7 UNKNOWN Bot commands The @f

[GitHub] [flink] flinkbot edited a comment on issue #10538: [Flink-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration

flinkbot edited a comment on issue #10538: [Flink-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration URL: https://github.com/apache/flink/pull/10538#issuecomment-564837772 ## CI report: * 41ed3d467603e389c84f8fd6761a4ffc3c6786e7 Travis: [SUCCESS](https://travis-ci

[GitHub] [flink] flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times

flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times URL: https://github.com/apache/flink/pull/10523#issuecomment-564363476 ## CI report: * afdfe7941439eeec090d3123319c74ecb7fb21ee Travis: [FAILURE](https://travis-ci

[jira] [Commented] (FLINK-15212) PROCTIME attribute causes problems with timestamp times before 1900 ?

[ https://issues.apache.org/jira/browse/FLINK-15212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994282#comment-16994282 ] Kurt Young commented on FLINK-15212: [~docete] Do we have a chance to first fix it i

[jira] [Commented] (FLINK-15214) Adding multiple submission e2e test for Flink's Mesos integration

[ https://issues.apache.org/jira/browse/FLINK-15214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994280#comment-16994280 ] Yangze Guo commented on FLINK-15214: I'd like to work on this ticket. Could someone

[jira] [Commented] (FLINK-15212) PROCTIME attribute causes problems with timestamp times before 1900 ?

[ https://issues.apache.org/jira/browse/FLINK-15212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994279#comment-16994279 ] Zhenghua Gao commented on FLINK-15212: -- The root cause is CALCITE-3597.  In Calcit

[jira] [Created] (FLINK-15214) Adding multiple submission e2e test for Flink's Mesos integration

Yangze Guo created FLINK-15214: -- Summary: Adding multiple submission e2e test for Flink's Mesos integration Key: FLINK-15214 URL: https://issues.apache.org/jira/browse/FLINK-15214 Project: Flink

[GitHub] [flink] flinkbot commented on issue #10540: [FLINK-15185][hive] Shade flink-hadoop-fs to run hive in standalone mode

flinkbot commented on issue #10540: [FLINK-15185][hive] Shade flink-hadoop-fs to run hive in standalone mode URL: https://github.com/apache/flink/pull/10540#issuecomment-564868159 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Closed] (FLINK-15213) The conversion between java.sql.Timestamp and long is not asymmetric

[ https://issues.apache.org/jira/browse/FLINK-15213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao closed FLINK-15213. Resolution: Invalid wrong project > The conversion between java.sql.Timestamp and long is not asy

[jira] [Updated] (FLINK-15185) Hive sink can not run in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-15185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15185: --- Labels: pull-request-available (was: ) > Hive sink can not run in standalone mode > ---

[GitHub] [flink] JingsongLi opened a new pull request #10540: [FLINK-15185][hive] Shade flink-hadoop-fs to run hive in standalone mode

JingsongLi opened a new pull request #10540: [FLINK-15185][hive] Shade flink-hadoop-fs to run hive in standalone mode URL: https://github.com/apache/flink/pull/10540 ## What is the purpose of the change Now in hive HadoopFileSystemFactory, we use org.apache.flink.runtime.fs.hdfs

[GitHub] [flink] KurtYoung commented on a change in pull request #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times

KurtYoung commented on a change in pull request #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times URL: https://github.com/apache/flink/pull/10523#discussion_r356974029 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/cli

[jira] [Updated] (FLINK-15185) Hive sink can not run in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-15185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15185: - Description: Now in hive HadoopFileSystemFactory, we use  org.apache.flink.runtime.fs.hdfs.Hadoo

[jira] [Created] (FLINK-15213) The conversion between java.sql.Timestamp and long is not asymmetric

Zhenghua Gao created FLINK-15213: Summary: The conversion between java.sql.Timestamp and long is not asymmetric Key: FLINK-15213 URL: https://issues.apache.org/jira/browse/FLINK-15213 Project: Flink

[jira] [Comment Edited] (FLINK-13437) Add Hive SQL E2E test

[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994265#comment-16994265 ] Jingsong Lee edited comment on FLINK-13437 at 12/12/19 6:13 AM: --

[jira] [Commented] (FLINK-13437) Add Hive SQL E2E test

[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994265#comment-16994265 ] Jingsong Lee commented on FLINK-13437: -- [~twalthr] is right. Unfortunately, without

[GitHub] [flink] flinkbot edited a comment on issue #10538: [Flink-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration

flinkbot edited a comment on issue #10538: [Flink-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration URL: https://github.com/apache/flink/pull/10538#issuecomment-564837772 ## CI report: * 41ed3d467603e389c84f8fd6761a4ffc3c6786e7 Travis: [SUCCESS](https://travis-ci

[GitHub] [flink] flinkbot commented on issue #10539: [FLINK-14952][network] Solve the issue of exceeding memory limits when using mmap blocking partition

flinkbot commented on issue #10539: [FLINK-14952][network] Solve the issue of exceeding memory limits when using mmap blocking partition URL: https://github.com/apache/flink/pull/10539#issuecomment-564864534 ## CI report: * b89fa1e6eda3fb4a2eca846c94c7881e9b34828d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times

flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times URL: https://github.com/apache/flink/pull/10523#issuecomment-564363476 ## CI report: * afdfe7941439eeec090d3123319c74ecb7fb21ee Travis: [FAILURE](https://travis-ci

[jira] [Commented] (FLINK-14796) Add document about limitations of different Hive versions

[ https://issues.apache.org/jira/browse/FLINK-14796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994258#comment-16994258 ] Jingsong Lee commented on FLINK-14796: -- [~jark] Can you assign this to RuiLi? > Ad

[jira] [Commented] (FLINK-14849) Can not submit job when use hive connector

[ https://issues.apache.org/jira/browse/FLINK-14849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994256#comment-16994256 ] Jingsong Lee commented on FLINK-14849: -- [~jark] Can you assign this to me? > Can n

[jira] [Commented] (FLINK-15128) Document support for Hive timestamp type

[ https://issues.apache.org/jira/browse/FLINK-15128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994255#comment-16994255 ] Jingsong Lee commented on FLINK-15128: -- [~jark] Can you assign this to Rui Li? > D

[jira] [Commented] (FLINK-15185) Hive sink can not run in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-15185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994254#comment-16994254 ] Jingsong Lee commented on FLINK-15185: -- [~jark] Can you assign this to Me ? > Hive

[jira] [Commented] (FLINK-15049) Compile error when hash join with timestamp type key

[ https://issues.apache.org/jira/browse/FLINK-15049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994251#comment-16994251 ] Jingsong Lee commented on FLINK-15049: -- [~jark] Can you assign this to [~docete] ?

[jira] [Commented] (FLINK-15050) DataFormatConverters should support any TIMESTAMP WITHOUT TIME ZONE types

[ https://issues.apache.org/jira/browse/FLINK-15050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994253#comment-16994253 ] Jingsong Lee commented on FLINK-15050: -- [~jark] Can you assign this to [~docete] ?

[GitHub] [flink] KarmaGYZ commented on issue #10538: [Flink-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration

KarmaGYZ commented on issue #10538: [Flink-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration URL: https://github.com/apache/flink/pull/10538#issuecomment-564862479 Related e2e tests passed [here](https://travis-ci.org/KarmaGYZ/flink/builds/623992844) --

[jira] [Commented] (FLINK-15204) add documentation for Flink-Hive timestamp conversions in table and udf

[ https://issues.apache.org/jira/browse/FLINK-15204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994247#comment-16994247 ] Jingsong Lee commented on FLINK-15204: -- Hi, Is this duplicate with FLINK-15128 ? >

[jira] [Closed] (FLINK-15211) Web UI request url for watermark is too long in large parallelism

[ https://issues.apache.org/jira/browse/FLINK-15211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fa zheng closed FLINK-15211. Resolution: Duplicate > Web UI request url for watermark is too long in large parallelism > --

[jira] [Reopened] (FLINK-15211) Web UI request url for watermark is too long in large parallelism

[ https://issues.apache.org/jira/browse/FLINK-15211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fa zheng reopened FLINK-15211: -- > Web UI request url for watermark is too long in large parallelism >

[GitHub] [flink] flinkbot commented on issue #10539: [FLINK-14952][network] Solve the issue of exceeding memory limits when using mmap blocking partition

flinkbot commented on issue #10539: [FLINK-14952][network] Solve the issue of exceeding memory limits when using mmap blocking partition URL: https://github.com/apache/flink/pull/10539#issuecomment-564858725 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[jira] [Updated] (FLINK-14952) Yarn containers can exceed physical memory limits when using BoundedBlockingSubpartition.

[ https://issues.apache.org/jira/browse/FLINK-14952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14952: --- Labels: pull-request-available (was: ) > Yarn containers can exceed physical memory limits

[GitHub] [flink] zhijiangW opened a new pull request #10539: [FLINK-14952][network] Solve the issue of exceeding memory limits when using mmap blocking partition

zhijiangW opened a new pull request #10539: [FLINK-14952][network] Solve the issue of exceeding memory limits when using mmap blocking partition URL: https://github.com/apache/flink/pull/10539 ## What is the purpose of the change *As reported by users in mail list, the container woul

[jira] [Updated] (FLINK-15206) support dynamic catalog table for truly unified SQL job

[ https://issues.apache.org/jira/browse/FLINK-15206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15206: - Description: currently if users have both an online and an offline job with same business logic in Flin

[GitHub] [flink] flinkbot edited a comment on issue #10538: [Flink-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration

flinkbot edited a comment on issue #10538: [Flink-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration URL: https://github.com/apache/flink/pull/10538#issuecomment-564837772 ## CI report: * 41ed3d467603e389c84f8fd6761a4ffc3c6786e7 Travis: [SUCCESS](https://travis-ci

[GitHub] [flink] wuchong commented on a change in pull request #10500: [FLINK-15161][table-common] Introduce TypeTransformation interface and basic transformations

wuchong commented on a change in pull request #10500: [FLINK-15161][table-common] Introduce TypeTransformation interface and basic transformations URL: https://github.com/apache/flink/pull/10500#discussion_r356960766 ## File path: flink-table/flink-table-common/src/main/java/org/a

[GitHub] [flink] flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times

flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times URL: https://github.com/apache/flink/pull/10523#issuecomment-564363476 ## CI report: * afdfe7941439eeec090d3123319c74ecb7fb21ee Travis: [FAILURE](https://travis-ci

[jira] [Commented] (FLINK-14007) Add doc for how to using Java user-defined source/sink in Python API

[ https://issues.apache.org/jira/browse/FLINK-14007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994211#comment-16994211 ] Hequn Cheng commented on FLINK-14007: - Resolved in 1.11.0 via 98dd5dc4cf3b31ff7b93b

[jira] [Closed] (FLINK-14007) Add doc for how to using Java user-defined source/sink in Python API

[ https://issues.apache.org/jira/browse/FLINK-14007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14007. --- Resolution: Resolved > Add doc for how to using Java user-defined source/sink in Python API > --

[jira] [Updated] (FLINK-14007) Add doc for how to using Java user-defined source/sink in Python API

[ https://issues.apache.org/jira/browse/FLINK-14007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14007: Fix Version/s: 1.11.0 > Add doc for how to using Java user-defined source/sink in Python API > ---

[jira] [Assigned] (FLINK-14007) Add doc for how to using Java user-defined source/sink in Python API

[ https://issues.apache.org/jira/browse/FLINK-14007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14007: --- Assignee: Hequn Cheng > Add doc for how to using Java user-defined source/sink in Python AP

[GitHub] [flink] hequn8128 closed pull request #10515: [FLINK-14007][python][docs] Add documentation for how to use Java user-defined source/sink in Python API

hequn8128 closed pull request #10515: [FLINK-14007][python][docs] Add documentation for how to use Java user-defined source/sink in Python API URL: https://github.com/apache/flink/pull/10515 This is an automated message from

[GitHub] [flink] wuchong commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

wuchong commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#discussion_r356959150 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/fl

[GitHub] [flink] hequn8128 edited a comment on issue #10515: [FLINK-14007][python][docs] Add documentation for how to use Java user-defined source/sink in Python API

hequn8128 edited a comment on issue #10515: [FLINK-14007][python][docs] Add documentation for how to use Java user-defined source/sink in Python API URL: https://github.com/apache/flink/pull/10515#issuecomment-564847669 @sjwiesman Thanks a lot for the review and nice suggestions. 👍 I wi

[GitHub] [flink] hequn8128 commented on issue #10515: [FLINK-14007][python][docs] Add documentation for how to use Java user-defined source/sink in Python API

hequn8128 commented on issue #10515: [FLINK-14007][python][docs] Add documentation for how to use Java user-defined source/sink in Python API URL: https://github.com/apache/flink/pull/10515#issuecomment-564847669 @sjwiesman Thanks a lot for the review and nice suggestions. 👍 Merging...

[GitHub] [flink] flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times

flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times URL: https://github.com/apache/flink/pull/10523#issuecomment-564363476 ## CI report: * afdfe7941439eeec090d3123319c74ecb7fb21ee Travis: [FAILURE](https://travis-ci

[GitHub] [flink] flinkbot edited a comment on issue #10538: [Flink-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration

flinkbot edited a comment on issue #10538: [Flink-15135][e2e][Mesos] Adding e2e tests for Flink's Mesos integration URL: https://github.com/apache/flink/pull/10538#issuecomment-564837772 ## CI report: * 41ed3d467603e389c84f8fd6761a4ffc3c6786e7 Travis: [PENDING](https://travis-ci

[GitHub] [flink] danny0405 commented on a change in pull request #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times

danny0405 commented on a change in pull request #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times URL: https://github.com/apache/flink/pull/10523#discussion_r356951860 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/cli

[GitHub] [flink] flinkbot edited a comment on issue #10531: [FLINK-15196][Mesos] Using the mesos.resourcemanager.tasks.cpus to determine the cpus of Mesos worker

flinkbot edited a comment on issue #10531: [FLINK-15196][Mesos] Using the mesos.resourcemanager.tasks.cpus to determine the cpus of Mesos worker URL: https://github.com/apache/flink/pull/10531#issuecomment-564535606 ## CI report: * 5a226d77e6d61571ce905f87540fbbf76eb7b3cf Travis:

[GitHub] [flink] danny0405 commented on a change in pull request #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times

danny0405 commented on a change in pull request #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times URL: https://github.com/apache/flink/pull/10523#discussion_r356951663 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/cli

[GitHub] [flink] danny0405 commented on a change in pull request #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times

danny0405 commented on a change in pull request #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times URL: https://github.com/apache/flink/pull/10523#discussion_r356951547 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/cli

[GitHub] [flink] danny0405 commented on a change in pull request #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times

danny0405 commented on a change in pull request #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times URL: https://github.com/apache/flink/pull/10523#discussion_r356951547 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/cli

[jira] [Updated] (FLINK-15206) support dynamic catalog table for truly unified SQL job

[ https://issues.apache.org/jira/browse/FLINK-15206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15206: - Description: currently if users have both an online and an offline job with same business logic in Flin

[GitHub] [flink] JingsongLi commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

JingsongLi commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#discussion_r356949753 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache

[jira] [Updated] (FLINK-15061) create/alter table/databases properties should be case sensitive stored in catalog

[ https://issues.apache.org/jira/browse/FLINK-15061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15061: - Fix Version/s: 1.11.0 > create/alter table/databases properties should be case sensitive stored in > ca

[jira] [Closed] (FLINK-15061) create/alter table/databases properties should be case sensitive stored in catalog

[ https://issues.apache.org/jira/browse/FLINK-15061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-15061. Resolution: Fixed master: ab4c31c5266dac4d1040491aa324a1d0a566c4aa 1.10: c35ae053942860d7bb4677124cb21821d

[GitHub] [flink] bowenli86 closed pull request #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog

bowenli86 closed pull request #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog URL: https://github.com/apache/flink/pull/10493 This is an automated message fr

[jira] [Assigned] (FLINK-15061) create/alter table/databases properties should be case sensitive stored in catalog

[ https://issues.apache.org/jira/browse/FLINK-15061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-15061: Assignee: Terry Wang > create/alter table/databases properties should be case sensitive stored in

  1   2   3   4   5   6   >