[jira] [Updated] (FLINK-14327) Getting "Could not forward element to next operator" error

2019-10-04 Thread ASK5 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASK5 updated FLINK-14327: - Description: val TEMPERATURE_THRESHOLD: Double = 50.00 val see: StreamExecutionEnvironment = StreamExecutionEn

[jira] [Updated] (FLINK-14327) Getting "Could not forward element to next operator" error

2019-10-04 Thread ASK5 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASK5 updated FLINK-14327: - Attachment: (was: so1.png) > Getting "Could not forward element to next operator" error > --

[jira] [Updated] (FLINK-14327) Getting "Could not forward element to next operator" error

2019-10-04 Thread ASK5 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASK5 updated FLINK-14327: - Attachment: so2.png > Getting "Could not forward element to next operator" error > -

[jira] [Updated] (FLINK-14327) Getting "Could not forward element to next operator" error

2019-10-04 Thread ASK5 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASK5 updated FLINK-14327: - Attachment: so1.png > Getting "Could not forward element to next operator" error > -

[jira] [Created] (FLINK-14327) Getting "Could not forward element to next operator" error

2019-10-04 Thread ASK5 (Jira)
ASK5 created FLINK-14327: Summary: Getting "Could not forward element to next operator" error Key: FLINK-14327 URL: https://issues.apache.org/jira/browse/FLINK-14327 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#issuecomment-534565595 ## CI report: * 6bc9773c54eed0b1646ec67413cb3855c1057d87 : FAILURE [Build](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#issuecomment-534565595 ## CI report: * 6bc9773c54eed0b1646ec67413cb3855c1057d87 : FAILURE [Build](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#issuecomment-534565595 ## CI report: * 6bc9773c54eed0b1646ec67413cb3855c1057d87 : FAILURE [Build](https://travis-ci.com/flink-ci/fl

[jira] [Commented] (FLINK-13656) Upgrade Calcite dependency to 1.21

2019-10-04 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944978#comment-16944978 ] Kurt Young commented on FLINK-13656: [~twalthr] Sorry, didn't notice this. I will do

[jira] [Commented] (FLINK-14306) flink-python build fails with No module named pkg_resources

2019-10-04 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944976#comment-16944976 ] Hequn Cheng commented on FLINK-14306: - Hi [~pnowojski] [~chesnay] [~trohrmann], sorr

[jira] [Assigned] (FLINK-14324) Convert SqlCreateTable with SqlWatermark to CatalogTable

2019-10-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14324: --- Assignee: Jark Wu > Convert SqlCreateTable with SqlWatermark to CatalogTable >

[jira] [Updated] (FLINK-14326) Support to apply watermark assigner according to the WatermarkSpec in TableSourceTable

2019-10-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14326: Component/s: (was: Table SQL / Planner) Table SQL / Runtime > Support to apply waterm

[jira] [Created] (FLINK-14326) Support to apply watermark assigner according to the WatermarkSpec in TableSourceTable

2019-10-04 Thread Jark Wu (Jira)
Jark Wu created FLINK-14326: --- Summary: Support to apply watermark assigner according to the WatermarkSpec in TableSourceTable Key: FLINK-14326 URL: https://issues.apache.org/jira/browse/FLINK-14326 Project:

[jira] [Assigned] (FLINK-14325) Convert CatalogTable to TableSourceTable with additional watermark information

2019-10-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14325: --- Assignee: Jark Wu > Convert CatalogTable to TableSourceTable with additional watermark information

[jira] [Assigned] (FLINK-14326) Support to apply watermark assigner according to the WatermarkSpec in TableSourceTable

2019-10-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14326: --- Assignee: Jark Wu > Support to apply watermark assigner according to the WatermarkSpec in > TableS

[jira] [Created] (FLINK-14325) Convert CatalogTable to TableSourceTable with additional watermark information

2019-10-04 Thread Jark Wu (Jira)
Jark Wu created FLINK-14325: --- Summary: Convert CatalogTable to TableSourceTable with additional watermark information Key: FLINK-14325 URL: https://issues.apache.org/jira/browse/FLINK-14325 Project: Flink

[GitHub] [flink] Mrart removed a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi…

2019-10-04 Thread GitBox
Mrart removed a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi… URL: https://github.com/apache/flink/pull/9773#issuecomment-536870094 @rmetzger Could you help review this PR? Th

[jira] [Created] (FLINK-14324) Convert SqlCreateTable with SqlWatermark to CatalogTable

2019-10-04 Thread Jark Wu (Jira)
Jark Wu created FLINK-14324: --- Summary: Convert SqlCreateTable with SqlWatermark to CatalogTable Key: FLINK-14324 URL: https://issues.apache.org/jira/browse/FLINK-14324 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-14323) Serialize Expression to String and parse String to Expression

2019-10-04 Thread Jark Wu (Jira)
Jark Wu created FLINK-14323: --- Summary: Serialize Expression to String and parse String to Expression Key: FLINK-14323 URL: https://issues.apache.org/jira/browse/FLINK-14323 Project: Flink Issue Ty

[jira] [Created] (FLINK-14322) Add watermark information in TableSchema

2019-10-04 Thread Jark Wu (Jira)
Jark Wu created FLINK-14322: --- Summary: Add watermark information in TableSchema Key: FLINK-14322 URL: https://issues.apache.org/jira/browse/FLINK-14322 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14321) Support to parse watermark statement in SQL DDL

2019-10-04 Thread Jark Wu (Jira)
Jark Wu created FLINK-14321: --- Summary: Support to parse watermark statement in SQL DDL Key: FLINK-14321 URL: https://issues.apache.org/jira/browse/FLINK-14321 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14320) [FLIP-66] Support Time Attribute in SQL DDL

2019-10-04 Thread Jark Wu (Jira)
Jark Wu created FLINK-14320: --- Summary: [FLIP-66] Support Time Attribute in SQL DDL Key: FLINK-14320 URL: https://issues.apache.org/jira/browse/FLINK-14320 Project: Flink Issue Type: New Feature

[GitHub] [flink] flinkbot edited a comment on issue #9841: [FLINK-14319][api] Register user jar files in execution environment.

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #9841: [FLINK-14319][api] Register user jar files in execution environment. URL: https://github.com/apache/flink/pull/9841#issuecomment-538594244 ## CI report: * 3560d8fdf99dc8140520bf195a09171708c1c241 : FAILURE [Build](https://travis-ci.com/f

[GitHub] [flink] flinkbot commented on issue #9841: [FLINK-14319][api] Register user jar files in execution environment.

2019-10-04 Thread GitBox
flinkbot commented on issue #9841: [FLINK-14319][api] Register user jar files in execution environment. URL: https://github.com/apache/flink/pull/9841#issuecomment-538594244 ## CI report: * 3560d8fdf99dc8140520bf195a09171708c1c241 : UNKNOWN --

[jira] [Comment Edited] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

2019-10-04 Thread Leo Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944912#comment-16944912 ] Leo Zhang edited comment on FLINK-14055 at 10/4/19 11:40 PM: -

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

2019-10-04 Thread Leo Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944912#comment-16944912 ] Leo Zhang commented on FLINK-14055: --- PR on github https://github.com/apache/flink/pull

[GitHub] [flink] flinkbot commented on issue #9841: [FLINK-14319][api] Register user jar files in execution environment.

2019-10-04 Thread GitBox
flinkbot commented on issue #9841: [FLINK-14319][api] Register user jar files in execution environment. URL: https://github.com/apache/flink/pull/9841#issuecomment-538592727 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Commented] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

2019-10-04 Thread Leo Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944911#comment-16944911 ] Leo Zhang commented on FLINK-14319: --- PR on github https://github.com/apache/flink/pull

[jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

2019-10-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14319: --- Labels: pull-request-available (was: ) > Register user jar files in {Stream}ExecutionEnviro

[GitHub] [flink] mr-cloud opened a new pull request #9841: [FLINK-14319][api] Register user jar files in execution environment.

2019-10-04 Thread GitBox
mr-cloud opened a new pull request #9841: [FLINK-14319][api] Register user jar files in execution environment. URL: https://github.com/apache/flink/pull/9841 ## What is the purpose of the change Add interfaces in {Stream}ExecutionEnviroment to allow people to register user j

[GitHub] [flink] flinkbot edited a comment on issue #7598: [FLINK-11333][protobuf] First-class serializer support for Protobuf types

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #7598: [FLINK-11333][protobuf] First-class serializer support for Protobuf types URL: https://github.com/apache/flink/pull/7598#issuecomment-538572354 ## CI report: * 35cb722954d3f608e5b4b0ad02f4e3570ad858cd : SUCCESS [Build](https://travis-ci.

[GitHub] [flink] flinkbot edited a comment on issue #7598: [FLINK-11333][protobuf] First-class serializer support for Protobuf types

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #7598: [FLINK-11333][protobuf] First-class serializer support for Protobuf types URL: https://github.com/apache/flink/pull/7598#issuecomment-538572354 ## CI report: * 35cb722954d3f608e5b4b0ad02f4e3570ad858cd : PENDING [Build](https://travis-ci.

[GitHub] [flink] flinkbot commented on issue #7598: [FLINK-11333][protobuf] First-class serializer support for Protobuf types

2019-10-04 Thread GitBox
flinkbot commented on issue #7598: [FLINK-11333][protobuf] First-class serializer support for Protobuf types URL: https://github.com/apache/flink/pull/7598#issuecomment-538572354 ## CI report: * 35cb722954d3f608e5b4b0ad02f4e3570ad858cd : UNKNOWN -

[GitHub] [flink] ElliotVilhelm commented on issue #7598: [FLINK-11333][protobuf] First-class serializer support for Protobuf types

2019-10-04 Thread GitBox
ElliotVilhelm commented on issue #7598: [FLINK-11333][protobuf] First-class serializer support for Protobuf types URL: https://github.com/apache/flink/pull/7598#issuecomment-538566954 Any expected timeline for this feature? Would really like to use this instead of having to register custom

[jira] [Commented] (FLINK-7002) Partitioning broken if enum is used in compound key specified using field expression

2019-10-04 Thread Sebastian Klemke (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944820#comment-16944820 ] Sebastian Klemke commented on FLINK-7002: - Thanks [~NicoK] for explaining this.

[jira] [Comment Edited] (FLINK-9806) Add a canonical link element to documentation HTML

2019-10-04 Thread nps1337 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944795#comment-16944795 ] nps1337 edited comment on FLINK-9806 at 10/4/19 8:02 PM: - Thanks

[jira] [Comment Edited] (FLINK-9806) Add a canonical link element to documentation HTML

2019-10-04 Thread nps1337 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944795#comment-16944795 ] nps1337 edited comment on FLINK-9806 at 10/4/19 8:01 PM: - Thanks

[jira] [Closed] (FLINK-7002) Partitioning broken if enum is used in compound key specified using field expression

2019-10-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-7002. -- Resolution: Won't Fix Actually, this is not a Flink issue, but an issue of enums in Java and their imp

[jira] [Commented] (FLINK-9806) Add a canonical link element to documentation HTML

2019-10-04 Thread nps1337 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944795#comment-16944795 ] nps1337 commented on FLINK-9806: Thanks you'for you're Information sir i hopful it's make

[GitHub] [flink] flinkbot edited a comment on issue #9840: !VERIFY ONLY! Upgrade ZK to 3.5.5

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #9840: !VERIFY ONLY! Upgrade ZK to 3.5.5 URL: https://github.com/apache/flink/pull/9840#issuecomment-538507626 ## CI report: * 69a880102e3f1c81e1492ec3b56b3c858a89ed54 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/130460555)

[GitHub] [flink] flinkbot edited a comment on issue #9840: !VERIFY ONLY! Upgrade ZK to 3.5.5

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #9840: !VERIFY ONLY! Upgrade ZK to 3.5.5 URL: https://github.com/apache/flink/pull/9840#issuecomment-538507626 ## CI report: * 69a880102e3f1c81e1492ec3b56b3c858a89ed54 : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/130460555)

[GitHub] [flink] flinkbot commented on issue #9840: !VERIFY ONLY! Upgrade ZK to 3.5.5

2019-10-04 Thread GitBox
flinkbot commented on issue #9840: !VERIFY ONLY! Upgrade ZK to 3.5.5 URL: https://github.com/apache/flink/pull/9840#issuecomment-538507626 ## CI report: * 69a880102e3f1c81e1492ec3b56b3c858a89ed54 : UNKNOWN This

[GitHub] [flink] flinkbot commented on issue #9840: !VERIFY ONLY! Upgrade ZK to 3.5.5

2019-10-04 Thread GitBox
flinkbot commented on issue #9840: !VERIFY ONLY! Upgrade ZK to 3.5.5 URL: https://github.com/apache/flink/pull/9840#issuecomment-538500112 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 will use this

[GitHub] [flink] TisonKun opened a new pull request #9840: !VERIFY ONLY! Upgrade ZK to 3.5.5

2019-10-04 Thread GitBox
TisonKun opened a new pull request #9840: !VERIFY ONLY! Upgrade ZK to 3.5.5 URL: https://github.com/apache/flink/pull/9840 CC @StephanEwen @zentol @lamber-ken We explicit depends on zk in flink-queryable-state-runtime, flink-tests and flink-yarn-tests for a proper zk dependencies in

[jira] [Resolved] (FLINK-14283) Update Kinesis consumer documentation for watermarks and event time alignment

2019-10-04 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-14283. -- Resolution: Done > Update Kinesis consumer documentation for watermarks and event time alignme

[GitHub] [flink] tweise merged pull request #9814: [FLINK-14283][kinesis][docs] Update Kinesis consumer docs for recent feature additions

2019-10-04 Thread GitBox
tweise merged pull request #9814: [FLINK-14283][kinesis][docs] Update Kinesis consumer docs for recent feature additions URL: https://github.com/apache/flink/pull/9814 This is an automated message from the Apache Git Service

[GitHub] [flink] jgrier commented on issue #9814: [FLINK-14283][kinesis][docs] Update Kinesis consumer docs for recent feature additions

2019-10-04 Thread GitBox
jgrier commented on issue #9814: [FLINK-14283][kinesis][docs] Update Kinesis consumer docs for recent feature additions URL: https://github.com/apache/flink/pull/9814#issuecomment-538486834 @flinkbot approve all This is an au

[jira] [Commented] (FLINK-14316) stuck in "Job leader ... lost leadership" error

2019-10-04 Thread Steven Zhen Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944638#comment-16944638 ] Steven Zhen Wu commented on FLINK-14316: [~trohrmann] don't know. we are just be

[GitHub] [flink] flinkbot edited a comment on issue #8217: [hotfix][flink-table] Add a space when generate query

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #8217: [hotfix][flink-table] Add a space when generate query URL: https://github.com/apache/flink/pull/8217#issuecomment-538423384 ## CI report: * 67ed4511ea84696304aa6f93234fcece9b5b7a3c : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/b

[GitHub] [flink] walterddr commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

2019-10-04 Thread GitBox
walterddr commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r331571437 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/TableEnvImpl.scala ###

[GitHub] [flink] walterddr commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

2019-10-04 Thread GitBox
walterddr commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r331564214 ## File path: flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java ##

[GitHub] [flink] walterddr commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

2019-10-04 Thread GitBox
walterddr commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r331563611 ## File path: flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java ##

[GitHub] [flink] walterddr commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

2019-10-04 Thread GitBox
walterddr commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r331567932 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperati

[jira] [Comment Edited] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

2019-10-04 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944601#comment-16944601 ] Zhenqiu Huang edited comment on FLINK-14055 at 10/4/19 3:43 PM: --

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

2019-10-04 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944601#comment-16944601 ] Zhenqiu Huang commented on FLINK-14055: --- [~50man] If you already finished the jar

[jira] [Commented] (FLINK-7151) Add a basic function SQL DDL

2019-10-04 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944599#comment-16944599 ] Zhenqiu Huang commented on FLINK-7151: -- [~twalthr] Thanks for bringing this up. I jo

[jira] [Updated] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2019-10-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6053: - Priority: Minor (was: Major) > Gauge should only take subclasses of Number, rather than everythi

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

2019-10-04 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944598#comment-16944598 ] Zhenqiu Huang commented on FLINK-14055: --- [~twalthr] Sure. I can't agree more. I th

[jira] [Comment Edited] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

2019-10-04 Thread Leo Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944595#comment-16944595 ] Leo Zhang edited comment on FLINK-14055 at 10/4/19 3:28 PM:

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

2019-10-04 Thread Leo Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944595#comment-16944595 ] Leo Zhang commented on FLINK-14055: --- Yeah. I totally agree with you [~twalthr] that th

[GitHub] [flink] flinkbot edited a comment on issue #9104: [HOTFIX][mvn] upgrade frontend-maven-plugin version to 1.7.5

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #9104: [HOTFIX][mvn] upgrade frontend-maven-plugin version to 1.7.5 URL: https://github.com/apache/flink/pull/9104#issuecomment-510895464 ## CI report: * 1d3eb46ab1b663b59439c32011c7f959b64c18d1 : FAILURE [Build](https://travis-ci.com/flink-ci/

[jira] [Closed] (FLINK-11340) Bump commons-configuration from 1.7 to 1.10

2019-10-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11340. Resolution: Won't Fix I'm not aware of any concrete issue we are having with commons-confi

[GitHub] [flink] zentol commented on issue #7499: [FLINK-11340] Bump commons-configuration from 1.7 to 1.10

2019-10-04 Thread GitBox
zentol commented on issue #7499: [FLINK-11340] Bump commons-configuration from 1.7 to 1.10 URL: https://github.com/apache/flink/pull/7499#issuecomment-538433635 Closing this PR, see the JIRA for details. This is an automated

[GitHub] [flink] zentol closed pull request #7499: [FLINK-11340] Bump commons-configuration from 1.7 to 1.10

2019-10-04 Thread GitBox
zentol closed pull request #7499: [FLINK-11340] Bump commons-configuration from 1.7 to 1.10 URL: https://github.com/apache/flink/pull/7499 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on issue #8217: [hotfix][flink-table] Add a space when generate query

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #8217: [hotfix][flink-table] Add a space when generate query URL: https://github.com/apache/flink/pull/8217#issuecomment-538423384 ## CI report: * 67ed4511ea84696304aa6f93234fcece9b5b7a3c : PENDING [Build](https://travis-ci.com/flink-ci/flink/b

[GitHub] [flink] zentol commented on issue #7497: [FLINK-11338] Bump maven-enforcer-plugin from 3.0.0-M1 to 3.0.0-M2

2019-10-04 Thread GitBox
zentol commented on issue #7497: [FLINK-11338] Bump maven-enforcer-plugin from 3.0.0-M1 to 3.0.0-M2 URL: https://github.com/apache/flink/pull/7497#issuecomment-538431361 Closing for now, see JIRA for details. This is an autom

[GitHub] [flink] zentol closed pull request #7497: [FLINK-11338] Bump maven-enforcer-plugin from 3.0.0-M1 to 3.0.0-M2

2019-10-04 Thread GitBox
zentol closed pull request #7497: [FLINK-11338] Bump maven-enforcer-plugin from 3.0.0-M1 to 3.0.0-M2 URL: https://github.com/apache/flink/pull/7497 This is an automated message from the Apache Git Service. To respond to the

[jira] [Closed] (FLINK-11338) Bump maven-enforcer-plugin from 3.0.0-M1 to 3.0.0-M2

2019-10-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11338. Resolution: Won't Fix Plugin seems to work just fine on Java 11, and I couldn't find anyth

[jira] [Comment Edited] (FLINK-14211) Add jobManager address configuration for SqlClient

2019-10-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944562#comment-16944562 ] Timo Walther edited comment on FLINK-14211 at 10/4/19 2:50 PM: ---

[jira] [Comment Edited] (FLINK-14211) Add jobManager address configuration for SqlClient

2019-10-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944562#comment-16944562 ] Timo Walther edited comment on FLINK-14211 at 10/4/19 2:49 PM: ---

[GitHub] [flink] zentol commented on issue #7498: [FLINK-11339] Bump exec-maven-plugin from 1.5.0 to 1.6.0

2019-10-04 Thread GitBox
zentol commented on issue #7498: [FLINK-11339] Bump exec-maven-plugin from 1.5.0 to 1.6.0 URL: https://github.com/apache/flink/pull/7498#issuecomment-538429269 Closing for now, see JIRA for details. This is an automated messa

[jira] [Closed] (FLINK-11339) Bump exec-maven-plugin from 1.5.0 to 1.6.0

2019-10-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11339. Resolution: Won't Fix The plugin seems to work just fine on Java 11, at least for our use-

[GitHub] [flink] zentol closed pull request #7498: [FLINK-11339] Bump exec-maven-plugin from 1.5.0 to 1.6.0

2019-10-04 Thread GitBox
zentol closed pull request #7498: [FLINK-11339] Bump exec-maven-plugin from 1.5.0 to 1.6.0 URL: https://github.com/apache/flink/pull/7498 This is an automated message from the Apache Git Service. To respond to the message, p

[jira] [Commented] (FLINK-14211) Add jobManager address configuration for SqlClient

2019-10-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944562#comment-16944562 ] Timo Walther commented on FLINK-14211: -- [~arugal] most of the deployment parameters

[GitHub] [flink] flinkbot edited a comment on issue #9284: [FLINK-13502] move CatalogTableStatisticsConverter & TreeNode to correct package

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #9284: [FLINK-13502] move CatalogTableStatisticsConverter & TreeNode to correct package URL: https://github.com/apache/flink/pull/9284#issuecomment-516662768 ## CI report: * fff36fd941c13764ad55fc85e4604ab64689aa21 : FAILURE [Build](https://tra

[GitHub] [flink] flinkbot commented on issue #8217: [hotfix][flink-table] Add a space when generate query

2019-10-04 Thread GitBox
flinkbot commented on issue #8217: [hotfix][flink-table] Add a space when generate query URL: https://github.com/apache/flink/pull/8217#issuecomment-538423384 ## CI report: * 67ed4511ea84696304aa6f93234fcece9b5b7a3c : UNKNOWN -

[jira] [Commented] (FLINK-13656) Upgrade Calcite dependency to 1.21

2019-10-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944548#comment-16944548 ] Timo Walther commented on FLINK-13656: -- [~ykt836] this issue has been closed but st

[jira] [Closed] (FLINK-13065) Document example snippet correction using KeySelector

2019-10-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-13065. Fix Version/s: 1.10.0 Resolution: Fixed master: 28c5264db5297d1df8ba7e4b774eb485d02

[GitHub] [flink] zentol merged pull request #8954: [FLINK-13065][doc] Corrected example snippet using KeySelector

2019-10-04 Thread GitBox
zentol merged pull request #8954: [FLINK-13065][doc] Corrected example snippet using KeySelector URL: https://github.com/apache/flink/pull/8954 This is an automated message from the Apache Git Service. To respond to the mess

[jira] [Updated] (FLINK-13065) Document example snippet correction using KeySelector

2019-10-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-13065: - Component/s: API / DataStream > Document example snippet correction using KeySelector >

[GitHub] [flink] zentol commented on issue #9104: [HOTFIX][mvn] upgrade frontend-maven-plugin version to 1.7.5

2019-10-04 Thread GitBox
zentol commented on issue #9104: [HOTFIX][mvn] upgrade frontend-maven-plugin version to 1.7.5 URL: https://github.com/apache/flink/pull/9104#issuecomment-538417723 Plugin version bumps are not eligible for hotfixes. Please open a dedicated JIRA ticket and thoroughly explain the problem and

[GitHub] [flink] zentol commented on issue #9259: [MINOR][docs] Doc fix for cluster_setup.md

2019-10-04 Thread GitBox
zentol commented on issue #9259: [MINOR][docs] Doc fix for cluster_setup.md URL: https://github.com/apache/flink/pull/9259#issuecomment-538416981 If a config option applies to all jobs, then it is not a job-level option. This

[GitHub] [flink] zentol closed pull request #9259: [MINOR][docs] Doc fix for cluster_setup.md

2019-10-04 Thread GitBox
zentol closed pull request #9259: [MINOR][docs] Doc fix for cluster_setup.md URL: https://github.com/apache/flink/pull/9259 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on issue #9839: [BP-1.8][FLINK-14315] Make heartbeat manager fields non-nullable

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #9839: [BP-1.8][FLINK-14315] Make heartbeat manager fields non-nullable URL: https://github.com/apache/flink/pull/9839#issuecomment-538387060 ## CI report: * 085d38ccb49f7d3ea4acb07d44903fdc8d2c6d16 : SUCCESS [Build](https://travis-ci.com/flink

[GitHub] [flink] flinkbot edited a comment on issue #9838: [BP-1.9][FLINK-14315] Make heartbeat manager fields non-nullable

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #9838: [BP-1.9][FLINK-14315] Make heartbeat manager fields non-nullable URL: https://github.com/apache/flink/pull/9838#issuecomment-538387018 ## CI report: * f6a760af29b7e7c1512463497443699ea6454926 : SUCCESS [Build](https://travis-ci.com/flink

[GitHub] [flink] TisonKun closed pull request #9762: !IGNORE! ZK 3.5.5 shaded migration

2019-10-04 Thread GitBox
TisonKun closed pull request #9762: !IGNORE! ZK 3.5.5 shaded migration URL: https://github.com/apache/flink/pull/9762 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] TisonKun commented on issue #9762: !IGNORE! ZK 3.5.5 shaded migration

2019-10-04 Thread GitBox
TisonKun commented on issue #9762: !IGNORE! ZK 3.5.5 shaded migration URL: https://github.com/apache/flink/pull/9762#issuecomment-538412706 closed as prefer narrow the scope. This is an automated message from the Apache Git Se

[GitHub] [flink] TisonKun commented on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh

2019-10-04 Thread GitBox
TisonKun commented on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh URL: https://github.com/apache/flink/pull/9774#issuecomment-538412292 @zentol yes I just downgraded to maven 3.2.5 recently for properly use our tools... closed as won't do. -

[GitHub] [flink] TisonKun closed pull request #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh

2019-10-04 Thread GitBox
TisonKun closed pull request #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh URL: https://github.com/apache/flink/pull/9774 This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [flink] zentol commented on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server.

2019-10-04 Thread GitBox
zentol commented on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server. URL: https://github.com/apache/flink/pull/9758#issuecomment-538411619 What if we didn't share the stats between servers? ---

[GitHub] [flink] flinkbot edited a comment on issue #9837: [FLINK-14315] Make heartbeat manager fields non-nullable

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #9837: [FLINK-14315] Make heartbeat manager fields non-nullable URL: https://github.com/apache/flink/pull/9837#issuecomment-538378656 ## CI report: * e600698ff32b962308385e8d1c9f69b7c3eeaef1 : SUCCESS [Build](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] flinkbot edited a comment on issue #9807: [FLINK-14280] Introduce DispatcherRunner

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #9807: [FLINK-14280] Introduce DispatcherRunner URL: https://github.com/apache/flink/pull/9807#issuecomment-536314902 ## CI report: * 9ef8fe986e4b06d6ae8512e5051933458363511c : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/129597

[GitHub] [flink] twalthr commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

2019-10-04 Thread GitBox
twalthr commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#discussion_r331506354 ## File path: flink-table/flink-table-common/src/main/j

[jira] [Updated] (FLINK-14276) Scala quickstart project does not compile on Java9+

2019-10-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-14276: - Summary: Scala quickstart project does not compile on Java9+ (was: Quickstarts Scala ni

[jira] [Closed] (FLINK-14276) Quickstarts Scala nightly end-to-end test fails on Travis

2019-10-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-14276. Resolution: Fixed master: 3f495d8215e1276ad91de5e4a5b6f160ba15eb13 > Quickstarts Scala ni

[GitHub] [flink] zentol merged pull request #9833: [FLINK-14276][quickstarts] Scala quickstart compiles on JDK 11

2019-10-04 Thread GitBox
zentol merged pull request #9833: [FLINK-14276][quickstarts] Scala quickstart compiles on JDK 11 URL: https://github.com/apache/flink/pull/9833 This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] flinkbot edited a comment on issue #9838: [BP-1.9][FLINK-14315] Make heartbeat manager fields non-nullable

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #9838: [BP-1.9][FLINK-14315] Make heartbeat manager fields non-nullable URL: https://github.com/apache/flink/pull/9838#issuecomment-538387018 ## CI report: * f6a760af29b7e7c1512463497443699ea6454926 : PENDING [Build](https://travis-ci.com/flink

[GitHub] [flink] flinkbot edited a comment on issue #9839: [BP-1.8][FLINK-14315] Make heartbeat manager fields non-nullable

2019-10-04 Thread GitBox
flinkbot edited a comment on issue #9839: [BP-1.8][FLINK-14315] Make heartbeat manager fields non-nullable URL: https://github.com/apache/flink/pull/9839#issuecomment-538387060 ## CI report: * 085d38ccb49f7d3ea4acb07d44903fdc8d2c6d16 : PENDING [Build](https://travis-ci.com/flink

[jira] [Commented] (FLINK-7151) Add a basic function SQL DDL

2019-10-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944492#comment-16944492 ] Timo Walther commented on FLINK-7151: - Hi everyone, sorry for entering the discussion

[GitHub] [flink] flinkbot commented on issue #9838: [BP-1.9][FLINK-14315] Make heartbeat manager fields non-nullable

2019-10-04 Thread GitBox
flinkbot commented on issue #9838: [BP-1.9][FLINK-14315] Make heartbeat manager fields non-nullable URL: https://github.com/apache/flink/pull/9838#issuecomment-538387018 ## CI report: * f6a760af29b7e7c1512463497443699ea6454926 : UNKNOWN --

  1   2   >