[GitHub] [flink] dawidwys merged pull request #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly

2020-02-24 Thread GitBox
dawidwys merged pull request #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly URL: https://github.com/apache/flink/pull/11070 This is an automated message from the Apache Git Service. To

[GitHub] [flink] hequn8128 commented on a change in pull request #11198: [FLINK-16248][python][ml] Add interfaces for MLEnvironment and MLEnvironmentFactory

2020-02-24 Thread GitBox
hequn8128 commented on a change in pull request #11198: [FLINK-16248][python][ml] Add interfaces for MLEnvironment and MLEnvironmentFactory URL: https://github.com/apache/flink/pull/11198#discussion_r383706073 ## File path: flink-python/pyflink/ml/tests/__init__.py ## @@

[GitHub] [flink] wangyang0918 commented on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly

2020-02-24 Thread GitBox
wangyang0918 commented on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly URL: https://github.com/apache/flink/pull/11070#issuecomment-590731927 @dawidwys Finally, both the travis and azure have passed. Could you help with merging?

[GitHub] [flink] hequn8128 commented on a change in pull request #11198: [FLINK-16248][python][ml] Add interfaces for MLEnvironment and MLEnvironmentFactory

2020-02-24 Thread GitBox
hequn8128 commented on a change in pull request #11198: [FLINK-16248][python][ml] Add interfaces for MLEnvironment and MLEnvironmentFactory URL: https://github.com/apache/flink/pull/11198#discussion_r383707337 ## File path: flink-python/pyflink/table/table_environment.py #

[GitHub] [flink] hequn8128 commented on a change in pull request #11198: [FLINK-16248][python][ml] Add interfaces for MLEnvironment and MLEnvironmentFactory

2020-02-24 Thread GitBox
hequn8128 commented on a change in pull request #11198: [FLINK-16248][python][ml] Add interfaces for MLEnvironment and MLEnvironmentFactory URL: https://github.com/apache/flink/pull/11198#discussion_r383706073 ## File path: flink-python/pyflink/ml/tests/__init__.py ## @@

[GitHub] [flink] flinkbot edited a comment on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+ URL: https://github.com/apache/flink/pull/11206#issuecomment-590703317 ## CI report: * b6b8bbaf1be639dae03850e547721a293037d9c8 Travis: [SUCCESS](htt

[GitHub] [flink] dianfu commented on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+

2020-02-24 Thread GitBox
dianfu commented on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+ URL: https://github.com/apache/flink/pull/11206#issuecomment-590726707 @hequn8128 Thanks for creating the following-up ticket. --

[jira] [Assigned] (FLINK-16273) Solve "sun.misc.Unseafe or java.nio.DirectByteBuffer.(long, int) not available" problem for users

2020-02-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16273: --- Assignee: Dian Fu > Solve "sun.misc.Unseafe or java.nio.DirectByteBuffer.(long, int) not > availab

[jira] [Updated] (FLINK-16273) Solve "sun.misc.Unseafe or java.nio.DirectByteBuffer.(long, int) not available" problem for users

2020-02-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-16273: Fix Version/s: 1.11.0 > Solve "sun.misc.Unseafe or java.nio.DirectByteBuffer.(long, int) not > available"

[jira] [Created] (FLINK-16274) Add typed builder methods for setting dynamic configuration on StatefulFunctionsAppContainers

2020-02-24 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-16274: --- Summary: Add typed builder methods for setting dynamic configuration on StatefulFunctionsAppContainers Key: FLINK-16274 URL: https://issues.apache.org/jira/browse/FL

[GitHub] [flink] hequn8128 edited a comment on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+

2020-02-24 Thread GitBox
hequn8128 edited a comment on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+ URL: https://github.com/apache/flink/pull/11206#issuecomment-590715955 @dianfu Solve this automatically is good. FYI, ([ARROW-7223](https://issues.apache.org/j

[jira] [Created] (FLINK-16273) Solve "sun.misc.Unseafe or java.nio.DirectByteBuffer.(long, int) not available" problem for users

2020-02-24 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-16273: --- Summary: Solve "sun.misc.Unseafe or java.nio.DirectByteBuffer.(long, int) not available" problem for users Key: FLINK-16273 URL: https://issues.apache.org/jira/browse/FLINK-16273

[GitHub] [flink] flinkbot edited a comment on issue #11207: [FLINK-16131] [docs] Translate /opt/filesystems/s3.zh.md into Chinese

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11207: [FLINK-16131] [docs] Translate /opt/filesystems/s3.zh.md into Chinese URL: https://github.com/apache/flink/pull/11207#issuecomment-590718863 ## CI report: * 5d4205e058b63f5e320edc6e21384c1be017316a Travis: [PENDING](https://travis-ci.co

[GitHub] [flink] zhijiangW commented on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-24 Thread GitBox
zhijiangW commented on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#issuecomment-590720137 Thanks for the updates @wsry . As for the issue of connection index, I prefer to ke

[GitHub] [flink] flinkbot commented on issue #11207: [FLINK-16131] [docs] Translate /opt/filesystems/s3.zh.md into Chinese

2020-02-24 Thread GitBox
flinkbot commented on issue #11207: [FLINK-16131] [docs] Translate /opt/filesystems/s3.zh.md into Chinese URL: https://github.com/apache/flink/pull/11207#issuecomment-590718863 ## CI report: * 5d4205e058b63f5e320edc6e21384c1be017316a UNKNOWN Bot commands The @flin

[GitHub] [flink] flinkbot edited a comment on issue #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#issuecomment-588760864 ## CI report: * abb918ce3a00f39036b019a1eeb3e49dd91910b8 Travis: [CANCELED](https://travis-ci.co

[GitHub] [flink] flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly URL: https://github.com/apache/flink/pull/11070#issuecomment-585205728 ## CI report: * 6a2109197d2aa39abcf9f91c924462bb6aac3462 Travis: [SUCCESS](https://tra

[jira] [Created] (FLINK-16272) Move Stateful Functions end-to-end test framework classes to common module

2020-02-24 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-16272: --- Summary: Move Stateful Functions end-to-end test framework classes to common module Key: FLINK-16272 URL: https://issues.apache.org/jira/browse/FLINK-16272

[GitHub] [flink] lirui-apache commented on issue #11175: [FLINK-16197][hive] Failed to query partitioned table when partition …

2020-02-24 Thread GitBox
lirui-apache commented on issue #11175: [FLINK-16197][hive] Failed to query partitioned table when partition … URL: https://github.com/apache/flink/pull/11175#issuecomment-590716987 @bowenli86 I agree we should educate users to avoid the discrepancy in the first place. Hive provides the `M

[GitHub] [flink] hequn8128 commented on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+

2020-02-24 Thread GitBox
hequn8128 commented on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+ URL: https://github.com/apache/flink/pull/11206#issuecomment-590715955 @dianfu Solve this automatically is good. FYI, ([ARROW-7223](https://issues.apache.org/jira/bro

[GitHub] [flink] JingsongLi merged pull request #11194: [FLINK-16242][table-runtime-blink] Duplicate field serializers in BaseRowSerializer

2020-02-24 Thread GitBox
JingsongLi merged pull request #11194: [FLINK-16242][table-runtime-blink] Duplicate field serializers in BaseRowSerializer URL: https://github.com/apache/flink/pull/11194 This is an automated message from the Apache Git Serv

[GitHub] [flink] JingsongLi commented on issue #11194: [FLINK-16242][table-runtime-blink] Duplicate field serializers in BaseRowSerializer

2020-02-24 Thread GitBox
JingsongLi commented on issue #11194: [FLINK-16242][table-runtime-blink] Duplicate field serializers in BaseRowSerializer URL: https://github.com/apache/flink/pull/11194#issuecomment-590713837 > > @Jiayi-Liao Can you create a PR for release-1.9? > > Sure. I'll create a PR for 1.9 bra

[jira] [Commented] (FLINK-11546) Add option to manually set job ID in CLI

2020-02-24 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044160#comment-17044160 ] lining commented on FLINK-11546: [~uce] could you assign it to me? > Add option to manu

[GitHub] [flink] dianfu commented on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+

2020-02-24 Thread GitBox
dianfu commented on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+ URL: https://github.com/apache/flink/pull/11206#issuecomment-590713510 @hequn8128 Thanks for the review and suggestion. I'm in favor of making it transparent for users,

[GitHub] [flink] flinkbot commented on issue #11207: [FLINK-16131] [docs] Translate /opt/filesystems/s3.zh.md into Chinese

2020-02-24 Thread GitBox
flinkbot commented on issue #11207: [FLINK-16131] [docs] Translate /opt/filesystems/s3.zh.md into Chinese URL: https://github.com/apache/flink/pull/11207#issuecomment-590712471 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to rev

[jira] [Updated] (FLINK-16131) Translate "Amazon S3" page of "File Systems" into Chinese

2020-02-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16131: --- Labels: pull-request-available (was: ) > Translate "Amazon S3" page of "File Systems" into

[GitHub] [flink] flinkbot edited a comment on issue #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#issuecomment-588760864 ## CI report: * 89d26f578174d90ce9979f076346376bf3597a5b Travis: [SUCCESS](https://travis-ci.com

[GitHub] [flink] PatrickRen opened a new pull request #11207: [FLINK-16131] [docs] Translate /opt/filesystems/s3.zh.md into Chinese

2020-02-24 Thread GitBox
PatrickRen opened a new pull request #11207: [FLINK-16131] [docs] Translate /opt/filesystems/s3.zh.md into Chinese URL: https://github.com/apache/flink/pull/11207 ## What is the purpose of the change This pull request translates /opt/filesystems/s3.zh.md into Chinese, and fixes a ty

[GitHub] [flink] Jiayi-Liao commented on issue #11194: [FLINK-16242][table-runtime-blink] Duplicate field serializers in BaseRowSerializer

2020-02-24 Thread GitBox
Jiayi-Liao commented on issue #11194: [FLINK-16242][table-runtime-blink] Duplicate field serializers in BaseRowSerializer URL: https://github.com/apache/flink/pull/11194#issuecomment-590711635 > @Jiayi-Liao Can you create a PR for release-1.9? Sure. I'll create a PR for 1.9 branch la

[GitHub] [flink] JingsongLi commented on issue #11194: [FLINK-16242][table-runtime-blink] Duplicate field serializers in BaseRowSerializer

2020-02-24 Thread GitBox
JingsongLi commented on issue #11194: [FLINK-16242][table-runtime-blink] Duplicate field serializers in BaseRowSerializer URL: https://github.com/apache/flink/pull/11194#issuecomment-590708419 @Jiayi-Liao Can you create a PR for release-1.9?

[GitHub] [flink] flinkbot edited a comment on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+ URL: https://github.com/apache/flink/pull/11206#issuecomment-590703317 ## CI report: * b6b8bbaf1be639dae03850e547721a293037d9c8 Travis: [PENDING](htt

[jira] [Commented] (FLINK-16270) Use LogicalType to equals/hashcode in TableSchema

2020-02-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044146#comment-17044146 ] Jingsong Lee commented on FLINK-16270: -- [~twalthr] [~ykt836] Have discussed some co

[jira] [Created] (FLINK-16271) Introduce ArrowScalarFunctionOperator for vectorized Python UDF execution

2020-02-24 Thread Dian Fu (Jira)
Dian Fu created FLINK-16271: --- Summary: Introduce ArrowScalarFunctionOperator for vectorized Python UDF execution Key: FLINK-16271 URL: https://issues.apache.org/jira/browse/FLINK-16271 Project: Flink

[GitHub] [flink] flinkbot commented on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+

2020-02-24 Thread GitBox
flinkbot commented on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+ URL: https://github.com/apache/flink/pull/11206#issuecomment-590703317 ## CI report: * b6b8bbaf1be639dae03850e547721a293037d9c8 UNKNOWN Bot comman

[GitHub] [flink] flinkbot edited a comment on issue #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#issuecomment-588760864 ## CI report: * 89d26f578174d90ce9979f076346376bf3597a5b Travis: [SUCCESS](https://travis-ci.com

[GitHub] [flink] JingsongLi commented on a change in pull request #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug

2020-02-24 Thread GitBox
JingsongLi commented on a change in pull request #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug URL: https://github.com/apache/flink/pull/11204#discussion_r383677579 ## File path: flink-table/flink-table-api-java/src/test/java/org/apache/flink/tabl

[jira] [Commented] (FLINK-16270) Use LogicalType to equals/hashcode in TableSchema

2020-02-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044143#comment-17044143 ] Jark Wu commented on FLINK-16270: - Hi [~twalthr], [~ykt836], what do you think about thi

[GitHub] [flink] wuchong commented on a change in pull request #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug

2020-02-24 Thread GitBox
wuchong commented on a change in pull request #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug URL: https://github.com/apache/flink/pull/11204#discussion_r383675893 ## File path: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/d

[GitHub] [flink] flinkbot commented on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+

2020-02-24 Thread GitBox
flinkbot commented on issue #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+ URL: https://github.com/apache/flink/pull/11206#issuecomment-590701000 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the co

[jira] [Updated] (FLINK-16263) BaseRowArrowReaderWriterTest/RowArrowReaderWriterTest sun.misc.Unsafe or java.nio.DirectByteBuffer.(long, int) not available

2020-02-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16263: --- Labels: pull-request-available test-stability (was: test-stability) > BaseRowArrowReaderWri

[GitHub] [flink] dianfu opened a new pull request #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+

2020-02-24 Thread GitBox
dianfu opened a new pull request #11206: [FLINK-16263][python][tests] Set io.netty.tryReflectionSetAccessible to true for JDK9+ URL: https://github.com/apache/flink/pull/11206 ## What is the purpose of the change *This pull request sets io.netty.tryReflectionSetAccessible to true

[GitHub] [flink] flinkbot edited a comment on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema URL: https://github.com/apache/flink/pull/11205#issuecomment-590680897 ## CI report: * 453d2f6811975cdd4d0826b64adc08dfd5192af4 Travis: [FAILURE](https://travis-ci.com/flink-

[GitHub] [flink] flinkbot edited a comment on issue #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#issuecomment-588760864 ## CI report: * 89d26f578174d90ce9979f076346376bf3597a5b Travis: [SUCCESS](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly URL: https://github.com/apache/flink/pull/11070#issuecomment-585205728 ## CI report: * b36749feb6378d63620cfe897c0cf9a4a4c84512 Travis: [CANCELED](https://tr

[jira] [Commented] (FLINK-16270) Use LogicalType to equals/hashcode in TableSchema

2020-02-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044136#comment-17044136 ] Jingsong Lee commented on FLINK-16270: -- PR: [https://github.com/apache/flink/pull/1

[GitHub] [flink] JingsongLi commented on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema

2020-02-24 Thread GitBox
JingsongLi commented on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema URL: https://github.com/apache/flink/pull/11205#issuecomment-590698568 > If the `TableSchema` only accept/store new types, I think it's fine to refactor the equals. However, as you said, leg

[GitHub] [flink] JingsongLi commented on a change in pull request #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug

2020-02-24 Thread GitBox
JingsongLi commented on a change in pull request #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug URL: https://github.com/apache/flink/pull/11204#discussion_r383672069 ## File path: flink-table/flink-table-api-java/src/test/java/org/apache/flink/tabl

[GitHub] [flink-statefun] tzulitai closed pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment

2020-02-24 Thread GitBox
tzulitai closed pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment URL: https://github.com/apache/flink-statefun/pull/32 This is an automated message from the A

[GitHub] [flink] wuchong commented on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema

2020-02-24 Thread GitBox
wuchong commented on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema URL: https://github.com/apache/flink/pull/11205#issuecomment-590696428 If the `TableSchema` only accept/store new types, I think it's fine to refactor the equals. However, as you said, legacy p

[GitHub] [flink] flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly URL: https://github.com/apache/flink/pull/11070#issuecomment-585205728 ## CI report: * b36749feb6378d63620cfe897c0cf9a4a4c84512 Travis: [CANCELED](https://tr

[GitHub] [flink] JingsongLi commented on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema

2020-02-24 Thread GitBox
JingsongLi commented on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema URL: https://github.com/apache/flink/pull/11205#issuecomment-590694517 > I'm still not sure about this approach. Because the DataType stored in the TableSchema may still hold the different c

[GitHub] [flink] Sxnan commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-24 Thread GitBox
Sxnan commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#discussion_r383669171 ## File path: docs/dev/connectors/pubsub.zh.md ## @@ -143,22 +135,22 @@ env.addSou

[GitHub] [flink] Sxnan commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-24 Thread GitBox
Sxnan commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#discussion_r383667086 ## File path: docs/dev/connectors/pubsub.md ## @@ -143,13 +143,13 @@ env.addSource

[jira] [Created] (FLINK-16270) Use LogicalType to equals/hashcode in TableSchema

2020-02-24 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-16270: Summary: Use LogicalType to equals/hashcode in TableSchema Key: FLINK-16270 URL: https://issues.apache.org/jira/browse/FLINK-16270 Project: Flink Issue Type:

[GitHub] [flink] Sxnan commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-24 Thread GitBox
Sxnan commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#discussion_r383667140 ## File path: docs/dev/connectors/pubsub.zh.md ## @@ -143,22 +135,22 @@ env.addSou

[GitHub] [flink] wuchong commented on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema

2020-02-24 Thread GitBox
wuchong commented on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema URL: https://github.com/apache/flink/pull/11205#issuecomment-590690935 I'm still not sure about this approach. Because the DataType stored in the TableSchema may still hold the different conver

[GitHub] [flink] Sxnan commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-24 Thread GitBox
Sxnan commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#discussion_r383665364 ## File path: docs/dev/connectors/pubsub.zh.md ## @@ -39,24 +37,17 @@ following de

[GitHub] [flink] Sxnan commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-24 Thread GitBox
Sxnan commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#discussion_r383665012 ## File path: docs/dev/connectors/pubsub.zh.md ## @@ -39,24 +37,17 @@ following de

[GitHub] [flink] wuchong commented on a change in pull request #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug

2020-02-24 Thread GitBox
wuchong commented on a change in pull request #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug URL: https://github.com/apache/flink/pull/11204#discussion_r383664396 ## File path: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/d

[GitHub] [flink] Sxnan commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-24 Thread GitBox
Sxnan commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#discussion_r383664368 ## File path: docs/dev/connectors/pubsub.zh.md ## @@ -23,9 +23,7 @@ specific langu

[GitHub] [flink] flinkbot edited a comment on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema URL: https://github.com/apache/flink/pull/11205#issuecomment-590680897 ## CI report: * 453d2f6811975cdd4d0826b64adc08dfd5192af4 Travis: [PENDING](https://travis-ci.com/flink-

[GitHub] [flink] flinkbot commented on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema

2020-02-24 Thread GitBox
flinkbot commented on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema URL: https://github.com/apache/flink/pull/11205#issuecomment-590680897 ## CI report: * 453d2f6811975cdd4d0826b64adc08dfd5192af4 UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot commented on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema

2020-02-24 Thread GitBox
flinkbot commented on issue #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema URL: https://github.com/apache/flink/pull/11205#issuecomment-590678898 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] JingsongLi commented on issue #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug

2020-02-24 Thread GitBox
JingsongLi commented on issue #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug URL: https://github.com/apache/flink/pull/11204#issuecomment-590678576 > Thanks @JingsongLi . I think FLINK-16265 is also introduced by FLINK-15912. We should fix that too.

[jira] [Updated] (FLINK-16265) TPC-H end-to-end test (Blink Planner): Encodings that differ from the schema are not supported yet for CsvTableSources.

2020-02-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16265: --- Labels: pull-request-available test-stability (was: test-stability) > TPC-H end-to-end test

[GitHub] [flink] JingsongLi opened a new pull request #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema

2020-02-24 Thread GitBox
JingsongLi opened a new pull request #11205: [FLINK-16265][table] Use LogicalType to equals in TableSchema URL: https://github.com/apache/flink/pull/11205 ## What is the purpose of the change ``` - name: TableNumber2 type: source $VAR_UPDATE_MODE schema:

[GitHub] [flink] flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly URL: https://github.com/apache/flink/pull/11070#issuecomment-585205728 ## CI report: * b36749feb6378d63620cfe897c0cf9a4a4c84512 Travis: [CANCELED](https://tr

[jira] [Reopened] (FLINK-15154) Change Flink binding addresses in local mode

2020-02-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-15154: -- Looking more into this issue, I found that this cannot be fully covered by  FLINK-15911. Therefore

[GitHub] [flink] flinkbot edited a comment on issue #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug URL: https://github.com/apache/flink/pull/11204#issuecomment-590664310 ## CI report: * 25f8bebe1722525aab960e1dbc8ef38d4409b899 Travis: [FAILURE](https://travis-ci

[jira] [Updated] (FLINK-16269) Generic type can not be matched when convert table to stream.

2020-02-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16269: Component/s: (was: API / Type Serialization System) Table SQL / API > Generic type ca

[jira] [Comment Edited] (FLINK-16009) Native support for the Variable-length and Zig-zag Variable-length integers

2020-02-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044106#comment-17044106 ] Yun Gao edited comment on FLINK-16009 at 2/25/20 4:06 AM: -- Hi [

[jira] [Commented] (FLINK-16009) Native support for the Variable-length and Zig-zag Variable-length integers

2020-02-24 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044106#comment-17044106 ] Yun Gao commented on FLINK-16009: - Hi [~NicoK] Very thanks for the information ! I think

[jira] [Commented] (FLINK-16265) TPC-H end-to-end test (Blink Planner): Encodings that differ from the schema are not supported yet for CsvTableSources.

2020-02-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044105#comment-17044105 ] Jingsong Lee commented on FLINK-16265: -- I think the fix we can do could be comparin

[jira] [Commented] (FLINK-16265) TPC-H end-to-end test (Blink Planner): Encodings that differ from the schema are not supported yet for CsvTableSources.

2020-02-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044104#comment-17044104 ] Jingsong Lee commented on FLINK-16265: -- This is something related to FLINK-15038.

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment

2020-02-24 Thread GitBox
tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment URL: https://github.com/apache/flink-statefun/pull/32#discussion_r383647373 ## File path: statefun-end-to-end-tests/statefun-sanity-it

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment

2020-02-24 Thread GitBox
tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment URL: https://github.com/apache/flink-statefun/pull/32#discussion_r383644382 ## File path: statefun-end-to-end-tests/statefun-sanity-i

[jira] [Assigned] (FLINK-16042) Add state benchmark for append operation in AppendingState

2020-02-24 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-16042: - Assignee: Jiayi Liao > Add state benchmark for append operation in AppendingState > ---

[jira] [Updated] (FLINK-16042) Add state benchmark for append operation in AppendingState

2020-02-24 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-16042: -- Fix Version/s: 1.11.0 > Add state benchmark for append operation in AppendingState > -

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment

2020-02-24 Thread GitBox
tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment URL: https://github.com/apache/flink-statefun/pull/32#discussion_r383644382 ## File path: statefun-end-to-end-tests/statefun-sanity-i

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment

2020-02-24 Thread GitBox
tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment URL: https://github.com/apache/flink-statefun/pull/32#discussion_r383644382 ## File path: statefun-end-to-end-tests/statefun-sanity-i

[jira] [Created] (FLINK-16269) Generic type can not be matched when convert table to stream.

2020-02-24 Thread xiemeilong (Jira)
xiemeilong created FLINK-16269: -- Summary: Generic type can not be matched when convert table to stream. Key: FLINK-16269 URL: https://issues.apache.org/jira/browse/FLINK-16269 Project: Flink Is

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment

2020-02-24 Thread GitBox
tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment URL: https://github.com/apache/flink-statefun/pull/32#discussion_r383644382 ## File path: statefun-end-to-end-tests/statefun-sanity-i

[GitHub] [flink] flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly URL: https://github.com/apache/flink/pull/11070#issuecomment-585205728 ## CI report: * b36749feb6378d63620cfe897c0cf9a4a4c84512 Travis: [CANCELED](https://tr

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment

2020-02-24 Thread GitBox
tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment URL: https://github.com/apache/flink-statefun/pull/32#discussion_r383644382 ## File path: statefun-end-to-end-tests/statefun-sanity-i

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment

2020-02-24 Thread GitBox
tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment URL: https://github.com/apache/flink-statefun/pull/32#discussion_r383642397 ## File path: statefun-end-to-end-tests/statefun-sanity-it

[GitHub] [flink] flinkbot edited a comment on issue #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug URL: https://github.com/apache/flink/pull/11204#issuecomment-590664310 ## CI report: * 25f8bebe1722525aab960e1dbc8ef38d4409b899 Travis: [FAILURE](https://travis-ci

[jira] [Closed] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

2020-02-24 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-10918. - Fix Version/s: 1.11.0 1.10.1 Assignee: Stephan Ewen Resolution: Fixed Fixed i

[GitHub] [flink] flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly

2020-02-24 Thread GitBox
flinkbot edited a comment on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly URL: https://github.com/apache/flink/pull/11070#issuecomment-585205728 ## CI report: * b36749feb6378d63620cfe897c0cf9a4a4c84512 Travis: [PENDING](https://tra

[GitHub] [flink] Jiayi-Liao commented on issue #11202: [FLINK-16247][checkpoints] Various cleanups in checkpointing code

2020-02-24 Thread GitBox
Jiayi-Liao commented on issue #11202: [FLINK-16247][checkpoints] Various cleanups in checkpointing code URL: https://github.com/apache/flink/pull/11202#issuecomment-590667087 Great work! LGTM. This is an automated message fro

[GitHub] [flink] wsry commented on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-24 Thread GitBox
wsry commented on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#issuecomment-590666593 I find that the number of tcp connections is one of the factors which influence the performanc

[GitHub] [flink] carp84 commented on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows.

2020-02-24 Thread GitBox
carp84 commented on issue #11095: [FLINK-10918][rocks-db-backend] Fix incremental checkpoints on Windows. URL: https://github.com/apache/flink/pull/11095#issuecomment-590666434 Cherry-picked to release-1.10 and made sure the [travis build](https://travis-ci.org/carp84/flink/builds/65469827

[jira] [Commented] (FLINK-16268) Failed to run rank over window with Hive built-in functions

2020-02-24 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044098#comment-17044098 ] Rui Li commented on FLINK-16268: BTW, the Hive functions {{BoundedOverAggregateHelper}}

[GitHub] [flink] wangyang0918 commented on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly

2020-02-24 Thread GitBox
wangyang0918 commented on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly URL: https://github.com/apache/flink/pull/11070#issuecomment-590665537 @flinkbot run travis This is an aut

[GitHub] [flink] wangyang0918 commented on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly

2020-02-24 Thread GitBox
wangyang0918 commented on issue #11070: [FLINK-16013][core] Make complex type config options could be parsed correctly URL: https://github.com/apache/flink/pull/11070#issuecomment-590665578 @flinkbot run azure This is an auto

[jira] [Commented] (FLINK-16268) Failed to run rank over window with Hive built-in functions

2020-02-24 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044097#comment-17044097 ] Rui Li commented on FLINK-16268: cc [~lzljs3620320] > Failed to run rank over window wi

[jira] [Commented] (FLINK-16268) Failed to run rank over window with Hive built-in functions

2020-02-24 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044096#comment-17044096 ] Rui Li commented on FLINK-16268: I managed to fix the NPE in {{PlannerTypeInferenceUtilI

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment

2020-02-24 Thread GitBox
tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment URL: https://github.com/apache/flink-statefun/pull/32#discussion_r383640278 ## File path: statefun-end-to-end-tests/statefun-sanity-i

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment

2020-02-24 Thread GitBox
tzulitai commented on a change in pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment URL: https://github.com/apache/flink-statefun/pull/32#discussion_r383640278 ## File path: statefun-end-to-end-tests/statefun-sanity-i

[GitHub] [flink] flinkbot commented on issue #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug

2020-02-24 Thread GitBox
flinkbot commented on issue #11204: [FLINK-16264][table] Fix ConnectTableDescriptor loose time attribute bug URL: https://github.com/apache/flink/pull/11204#issuecomment-590664310 ## CI report: * 25f8bebe1722525aab960e1dbc8ef38d4409b899 UNKNOWN Bot commands The @f

[jira] [Assigned] (FLINK-16265) TPC-H end-to-end test (Blink Planner): Encodings that differ from the schema are not supported yet for CsvTableSources.

2020-02-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16265: Assignee: Jingsong Lee > TPC-H end-to-end test (Blink Planner): Encodings that differ fro

  1   2   3   4   5   >