[jira] [Resolved] (FLINK-8985) End-to-end test: CLI

2018-11-06 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8985. - Resolution: Fixed Fix Version/s: 1.7.0 Fixed in 1.8:

[jira] [Updated] (FLINK-10807) KafkaConsumer still consume removed topic after changing topics list

2018-11-06 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-10807: --- Description: subscribedPartitionsToStartOffsets in KafkaConsumerBase is getting values from

[jira] [Created] (FLINK-10807) KafkaConsumer still consume removed topic after changing topics list

2018-11-06 Thread Jiayi Liao (JIRA)
Jiayi Liao created FLINK-10807: -- Summary: KafkaConsumer still consume removed topic after changing topics list Key: FLINK-10807 URL: https://issues.apache.org/jira/browse/FLINK-10807 Project: Flink

[jira] [Commented] (FLINK-10790) Refactor all the StreamPartitioner implementations into runtime module

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1660#comment-1660 ] ASF GitHub Bot commented on FLINK-10790: zhijiangW commented on issue #7037:

[GitHub] zhijiangW commented on issue #7037: [FLINK-10790][network] Refactor StreamPartitioner implementations into runtime module

2018-11-06 Thread GitBox
zhijiangW commented on issue #7037: [FLINK-10790][network] Refactor StreamPartitioner implementations into runtime module URL: https://github.com/apache/flink/pull/7037#issuecomment-436525702 @pnowojski , there are some problems for this issue now. I will update the codes later. Sorry for

[jira] [Issue Comment Deleted] (FLINK-10384) Add Sinh math function supported in Table API and SQL

2018-11-06 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-10384: - Comment: was deleted (was: [~pnovi...@gmail.com] I think this issue could be closed.) > Add Sinh math

[jira] [Closed] (FLINK-10384) Add Sinh math function supported in Table API and SQL

2018-11-06 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang closed FLINK-10384. Resolution: Fixed Fix Version/s: 1.7.0 > Add Sinh math function supported in Table API and SQL >

[GitHub] tzulitai commented on issue #7028: [FLINK-10789] New serializer snapshots after 1.6 should implement TypeSerializerSnapshot

2018-11-06 Thread GitBox
tzulitai commented on issue #7028: [FLINK-10789] New serializer snapshots after 1.6 should implement TypeSerializerSnapshot URL: https://github.com/apache/flink/pull/7028#issuecomment-436501351 Thanks for the review @StefanRRichter! Will proceed to merge this and also the 1.7 backport.

[jira] [Commented] (FLINK-10789) Some new serializer snapshots added after 1.6 are not implementing the new TypeSerializerSnapshot interface

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16677657#comment-16677657 ] ASF GitHub Bot commented on FLINK-10789: tzulitai commented on issue #7028: [FLINK-10789] New

[jira] [Commented] (FLINK-10791) Provide end-to-end test for Kafka 0.11 connector

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16677655#comment-16677655 ] ASF GitHub Bot commented on FLINK-10791: yanghua opened a new pull request #7038: [FLINK-10791]

[jira] [Updated] (FLINK-10791) Provide end-to-end test for Kafka 0.11 connector

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10791: --- Labels: pull-request-available (was: ) > Provide end-to-end test for Kafka 0.11 connector

[GitHub] yanghua opened a new pull request #7038: [FLINK-10791] Provide end-to-end test for Kafka 0.11 connector

2018-11-06 Thread GitBox
yanghua opened a new pull request #7038: [FLINK-10791] Provide end-to-end test for Kafka 0.11 connector URL: https://github.com/apache/flink/pull/7038 ## What is the purpose of the change *Provide end-to-end test for Kafka 0.11 connector* ## Brief change log

[jira] [Commented] (FLINK-10790) Refactor all the StreamPartitioner implementations into runtime module

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16677646#comment-16677646 ] ASF GitHub Bot commented on FLINK-10790: zhijiangW commented on issue #7037:

[GitHub] zhijiangW commented on issue #7037: [FLINK-10790][network] Refactor StreamPartitioner implementations into runtime module

2018-11-06 Thread GitBox
zhijiangW commented on issue #7037: [FLINK-10790][network] Refactor StreamPartitioner implementations into runtime module URL: https://github.com/apache/flink/pull/7037#issuecomment-436496303 @pnowojski , this is the preparation for unifying implementations in both stream and batch modes.

[jira] [Updated] (FLINK-10790) Refactor all the StreamPartitioner implementations into runtime module

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10790: --- Labels: pull-request-available (was: ) > Refactor all the StreamPartitioner

[jira] [Commented] (FLINK-10790) Refactor all the StreamPartitioner implementations into runtime module

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16677643#comment-16677643 ] ASF GitHub Bot commented on FLINK-10790: zhijiangW opened a new pull request #7037:

[GitHub] zhijiangW opened a new pull request #7037: [FLINK-10790][network] Refactor StreamPartitioner implementations into runtime module

2018-11-06 Thread GitBox
zhijiangW opened a new pull request #7037: [FLINK-10790][network] Refactor StreamPartitioner implementations into runtime module URL: https://github.com/apache/flink/pull/7037 ## What is the purpose of the change *Before refactoring `ChannelSelector` interface mentioned in

[jira] [Updated] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

2018-11-06 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-10806: --- Summary: Support multiple consuming offsets when discovering a new topic (was: Add optional

[jira] [Updated] (FLINK-10806) Add optional consuming parameters when discovering a new topic

2018-11-06 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-10806: --- Summary: Add optional consuming parameters when discovering a new topic (was: Support consume from

[jira] [Created] (FLINK-10806) Support consume from earliest offset with a new topic

2018-11-06 Thread Jiayi Liao (JIRA)
Jiayi Liao created FLINK-10806: -- Summary: Support consume from earliest offset with a new topic Key: FLINK-10806 URL: https://issues.apache.org/jira/browse/FLINK-10806 Project: Flink Issue

[jira] [Commented] (FLINK-10706) Update the Flink Dashboard and its components

2018-11-06 Thread Yadong Xie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16677570#comment-16677570 ] Yadong Xie commented on FLINK-10706: Hi [~fwollert], would you please assign this issue to me? In

[jira] [Commented] (FLINK-9699) Add api to replace registered table

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16677502#comment-16677502 ] ASF GitHub Bot commented on FLINK-9699: --- zjffdu commented on issue #6236: [FLINK-9699] [table] Add

[GitHub] zjffdu commented on issue #6236: [FLINK-9699] [table] Add api to replace registered table

2018-11-06 Thread GitBox
zjffdu commented on issue #6236: [FLINK-9699] [table] Add api to replace registered table URL: https://github.com/apache/flink/pull/6236#issuecomment-436471468 Thanks @hequn8128 @yanghua `registerOrReplaceXXX` make sense for me. I will update the PR.

[jira] [Commented] (FLINK-10802) Add metrics on vertex in job graph picture show

2018-11-06 Thread lining (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16677495#comment-16677495 ] lining commented on FLINK-10802: Hi [~till.rohrmann], now user see something need click many page. If we

[jira] [Updated] (FLINK-10644) Batch Job: Speculative execution

2018-11-06 Thread JIN SUN (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JIN SUN updated FLINK-10644: Description: Strugglers/outlier are tasks that run slower than most of the all tasks in a Batch Job,

[jira] [Updated] (FLINK-10644) Batch Job: Speculative execution

2018-11-06 Thread JIN SUN (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JIN SUN updated FLINK-10644: Description: Strugglers/outlier are tasks that run slower than most of the all tasks in a Batch Job,

[jira] [Closed] (FLINK-10671) rest monitoring api Savepoint status call fails if akka.ask.timeout < checkpoint duration

2018-11-06 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-10671. Resolution: Not A Problem Please reopen if necessary. > rest monitoring api Savepoint status call fails

[jira] [Commented] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16677127#comment-16677127 ] ASF GitHub Bot commented on FLINK-10356: NicoK commented on issue #6705: [FLINK-10356][network]

[GitHub] NicoK commented on issue #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-11-06 Thread GitBox
NicoK commented on issue #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#issuecomment-436356439 Thanks @zhijiangW and @pnowojski for the reviews. I have addressed the comments and committed some

[jira] [Commented] (FLINK-10768) Move external catalog related code from TableEnvironment to CatalogManager

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16677099#comment-16677099 ] ASF GitHub Bot commented on FLINK-10768: bowenli86 commented on issue #7011: [FLINK-10768][Table

[GitHub] bowenli86 commented on issue #7011: [FLINK-10768][Table & SQL] Move external catalog related code from TableEnvironment to CatalogManager

2018-11-06 Thread GitBox
bowenli86 commented on issue #7011: [FLINK-10768][Table & SQL] Move external catalog related code from TableEnvironment to CatalogManager URL: https://github.com/apache/flink/pull/7011#issuecomment-436350350 holding on this PR as there are some related discussion going on at[ the design

[jira] [Updated] (FLINK-10699) Create FlinkHmsCatalog for persistent Flink meta objects using Hive metastore as a registry

2018-11-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10699: - Summary: Create FlinkHmsCatalog for persistent Flink meta objects using Hive metastore as a registry

[jira] [Updated] (FLINK-10531) State TTL RocksDb backend end-to-end test failed on Travis

2018-11-06 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-10531: --- Fix Version/s: 1.7.0 > State TTL RocksDb backend end-to-end test failed on Travis >

[jira] [Commented] (FLINK-10531) State TTL RocksDb backend end-to-end test failed on Travis

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16677023#comment-16677023 ] ASF GitHub Bot commented on FLINK-10531: kl0u commented on issue #7036: [FLINK-10531][e2e] Fix

[GitHub] kl0u commented on issue #7036: [FLINK-10531][e2e] Fix unstable TTL end-to-end test.

2018-11-06 Thread GitBox
kl0u commented on issue #7036: [FLINK-10531][e2e] Fix unstable TTL end-to-end test. URL: https://github.com/apache/flink/pull/7036#issuecomment-436331588 R @azagrebin This is an automated message from the Apache Git

[jira] [Commented] (FLINK-10531) State TTL RocksDb backend end-to-end test failed on Travis

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16677018#comment-16677018 ] ASF GitHub Bot commented on FLINK-10531: kl0u opened a new pull request #7036:

[jira] [Updated] (FLINK-10531) State TTL RocksDb backend end-to-end test failed on Travis

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10531: --- Labels: pull-request-available test-stability (was: test-stability) > State TTL RocksDb

[GitHub] kl0u opened a new pull request #7036: [FLINK-10531][e2e] Fix unstable TTL end-to-end test.

2018-11-06 Thread GitBox
kl0u opened a new pull request #7036: [FLINK-10531][e2e] Fix unstable TTL end-to-end test. URL: https://github.com/apache/flink/pull/7036 As describe on the JIRA, the problem is that the clock on the machine on Travis seems to have jumped backwards. This resulted in a mismatch

[jira] [Commented] (FLINK-10797) "IntelliJ Setup" link is broken in Readme.md

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16677010#comment-16677010 ] ASF GitHub Bot commented on FLINK-10797: xndai closed pull request #7025: [FLINK-10797]

[GitHub] xndai closed pull request #7025: [FLINK-10797] "IntelliJ Setup" link is broken in README.md

2018-11-06 Thread GitBox
xndai closed pull request #7025: [FLINK-10797] "IntelliJ Setup" link is broken in README.md URL: https://github.com/apache/flink/pull/7025 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this

[jira] [Commented] (FLINK-10796) Add a default external catalog (as FlinkInMemoryCatalog) to CatalogManager

2018-11-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676991#comment-16676991 ] Bowen Li commented on FLINK-10796: -- [~xiaow...@gmail.com] That's right. I've added the requirement in

[jira] [Updated] (FLINK-10796) Add a default external catalog (as FlinkInMemoryCatalog) to CatalogManager

2018-11-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10796: - Description: CatalogManager has a default catalog (as FlinkInMemoryCatalog), which will be selected

[jira] [Commented] (FLINK-10789) Some new serializer snapshots added after 1.6 are not implementing the new TypeSerializerSnapshot interface

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676988#comment-16676988 ] ASF GitHub Bot commented on FLINK-10789: StefanRRichter commented on a change in pull request

[GitHub] StefanRRichter commented on a change in pull request #7028: [FLINK-10789] New serializer snapshots after 1.6 should implement TypeSerializerSnapshot

2018-11-06 Thread GitBox
StefanRRichter commented on a change in pull request #7028: [FLINK-10789] New serializer snapshots after 1.6 should implement TypeSerializerSnapshot URL: https://github.com/apache/flink/pull/7028#discussion_r231202779 ## File path:

[jira] [Updated] (FLINK-10796) Add a default external catalog (as FlinkInMemoryCatalog) to CatalogManager

2018-11-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10796: - Description: CatalogManager has a default catalog, which will be selected when a catalog name isn’t

[GitHub] asfgit closed pull request #5863: [FLINK-8985][e2etest] initial support for End-to-end CLI test, excluding YARN test

2018-11-06 Thread GitBox
asfgit closed pull request #5863: [FLINK-8985][e2etest] initial support for End-to-end CLI test, excluding YARN test URL: https://github.com/apache/flink/pull/5863 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake

[jira] [Commented] (FLINK-8985) End-to-end test: CLI

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676976#comment-16676976 ] ASF GitHub Bot commented on FLINK-8985: --- asfgit closed pull request #5863: [FLINK-8985][e2etest]

[jira] [Commented] (FLINK-10463) Null literal cannot be properly parsed in Java Table API function call

2018-11-06 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676968#comment-16676968 ] Xingcan Cui commented on FLINK-10463: - [~twalthr], sure. I'll cherry-pick the commit to versions

[jira] [Updated] (FLINK-10463) Null literal cannot be properly parsed in Java Table API function call

2018-11-06 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-10463: Fix Version/s: 1.7.1 1.6.3 > Null literal cannot be properly parsed in Java

[jira] [Closed] (FLINK-10720) Add stress deployment end-to-end test

2018-11-06 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10720. -- Resolution: Implemented Merged in: master: 660bb687c1 release-1.7: 380df0559b > Add stress

[jira] [Commented] (FLINK-10531) State TTL RocksDb backend end-to-end test failed on Travis

2018-11-06 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676957#comment-16676957 ] Kostas Kloudas commented on FLINK-10531: It is a test instability. The way the test works is

[jira] [Commented] (FLINK-10463) Null literal cannot be properly parsed in Java Table API function call

2018-11-06 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676955#comment-16676955 ] Timo Walther commented on FLINK-10463: -- [~xccui] can you also cherry-pick bug fixes to the last two

[jira] [Assigned] (FLINK-10531) State TTL RocksDb backend end-to-end test failed on Travis

2018-11-06 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-10531: -- Assignee: Kostas Kloudas (was: Renjie Liu) > State TTL RocksDb backend end-to-end

[jira] [Commented] (FLINK-10720) Add stress deployment end-to-end test

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676948#comment-16676948 ] ASF GitHub Bot commented on FLINK-10720: asfgit closed pull request #6994: [FLINK-10720][tests]

[GitHub] asfgit closed pull request #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many …

2018-11-06 Thread GitBox
asfgit closed pull request #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many … URL: https://github.com/apache/flink/pull/6994 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Commented] (FLINK-10720) Add stress deployment end-to-end test

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676943#comment-16676943 ] ASF GitHub Bot commented on FLINK-10720: StefanRRichter commented on issue #6994:

[GitHub] StefanRRichter commented on issue #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many …

2018-11-06 Thread GitBox
StefanRRichter commented on issue #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many … URL: https://github.com/apache/flink/pull/6994#issuecomment-436309544 Thanks @tillrohrmann! Merging. This is an

[jira] [Updated] (FLINK-10805) test_confluent_schema_registry.sh and test_sql_client.sh end-to-end test broken

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10805: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] tillrohrmann opened a new pull request #7035: [BP-1.7][FLINK-10805] Fix failing end-to-end tests

2018-11-06 Thread GitBox
tillrohrmann opened a new pull request #7035: [BP-1.7][FLINK-10805] Fix failing end-to-end tests URL: https://github.com/apache/flink/pull/7035 Backport of #7034 for `release-1.7`. This is an automated message from the

[GitHub] tillrohrmann opened a new pull request #7034: [FLINK-10805] Fix failing end-to-end tests

2018-11-06 Thread GitBox
tillrohrmann opened a new pull request #7034: [FLINK-10805] Fix failing end-to-end tests URL: https://github.com/apache/flink/pull/7034 ## What is the purpose of the change Fix test_confluent_schema_registry.sh and test_sql_client.sh end-to-end tests which failed because of

[jira] [Commented] (FLINK-10805) test_confluent_schema_registry.sh and test_sql_client.sh end-to-end test broken

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676937#comment-16676937 ] ASF GitHub Bot commented on FLINK-10805: tillrohrmann opened a new pull request #7034:

[jira] [Commented] (FLINK-10771) Replace hard code of job graph file path with config option for FileJobGraphRetriever

2018-11-06 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676916#comment-16676916 ] vinoyang commented on FLINK-10771: -- Yes, In AbstractYarnClusterDescriptor, we can explicitly set the

[jira] [Commented] (FLINK-8985) End-to-end test: CLI

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676906#comment-16676906 ] ASF GitHub Bot commented on FLINK-8985: --- twalthr commented on issue #5863: [FLINK-8985][e2etest]

[jira] [Updated] (FLINK-8985) End-to-end test: CLI

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8985: -- Labels: pull-request-available (was: ) > End-to-end test: CLI > > >

[GitHub] twalthr commented on issue #5863: [FLINK-8985][e2etest] initial support for End-to-end CLI test, excluding YARN test

2018-11-06 Thread GitBox
twalthr commented on issue #5863: [FLINK-8985][e2etest] initial support for End-to-end CLI test, excluding YARN test URL: https://github.com/apache/flink/pull/5863#issuecomment-436296096 Thanks for the PR @walterddr. I think the test looks good to merge. I will add some additional safety

[jira] [Resolved] (FLINK-10463) Null literal cannot be properly parsed in Java Table API function call

2018-11-06 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui resolved FLINK-10463. - Resolution: Fixed Fixed in 1.8.0 5a4e5e9dcaa83368862d27bd80429235c02ed66e > Null literal

[jira] [Updated] (FLINK-10463) Null literal cannot be properly parsed in Java Table API function call

2018-11-06 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-10463: Fix Version/s: 1.8.0 > Null literal cannot be properly parsed in Java Table API function call >

[jira] [Commented] (FLINK-10463) Null literal cannot be properly parsed in Java Table API function call

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676893#comment-16676893 ] ASF GitHub Bot commented on FLINK-10463: asfgit closed pull request #6888: [FLINK-10463][table]

[GitHub] asfgit closed pull request #6888: [FLINK-10463][table] Null literal cannot be properly parsed in Java Table API function call

2018-11-06 Thread GitBox
asfgit closed pull request #6888: [FLINK-10463][table] Null literal cannot be properly parsed in Java Table API function call URL: https://github.com/apache/flink/pull/6888 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[jira] [Updated] (FLINK-10805) test_confluent_schema_registry.sh and test_sql_client.sh end-to-end test broken

2018-11-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10805: -- Description: The end-to-end test {{test_confluent_schema_registry.sh}} and

[jira] [Commented] (FLINK-10771) Replace hard code of job graph file path with config option for FileJobGraphRetriever

2018-11-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676883#comment-16676883 ] Till Rohrmann commented on FLINK-10771: --- Or better to set a value in the {{Configuration}} in the

[jira] [Commented] (FLINK-9699) Add api to replace registered table

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676878#comment-16676878 ] ASF GitHub Bot commented on FLINK-9699: --- yanghua commented on issue #6236: [FLINK-9699] [table] Add

[GitHub] yanghua commented on issue #6236: [FLINK-9699] [table] Add api to replace registered table

2018-11-06 Thread GitBox
yanghua commented on issue #6236: [FLINK-9699] [table] Add api to replace registered table URL: https://github.com/apache/flink/pull/6236#issuecomment-436288232 @hequn8128 I agree with you. Actually, I have given a similar suggestion about `CREATE VIEW` in SQL client. See

[jira] [Commented] (FLINK-10384) Add Sinh math function supported in Table API and SQL

2018-11-06 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676875#comment-16676875 ] vinoyang commented on FLINK-10384: -- [~pnovi...@gmail.com] I think this issue could be closed. > Add

[jira] [Commented] (FLINK-10771) Replace hard code of job graph file path with config option for FileJobGraphRetriever

2018-11-06 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676866#comment-16676866 ] vinoyang commented on FLINK-10771: -- OK, since it may be used, why don't we refactor it as: if it's not

[jira] [Created] (FLINK-10805) test_confluent_schema_registry.sh and test_sql_client.sh end-to-end test broken

2018-11-06 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10805: - Summary: test_confluent_schema_registry.sh and test_sql_client.sh end-to-end test broken Key: FLINK-10805 URL: https://issues.apache.org/jira/browse/FLINK-10805

[jira] [Commented] (FLINK-10802) Add metrics on vertex in job graph picture show

2018-11-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676850#comment-16676850 ] Till Rohrmann commented on FLINK-10802: --- Hi [~lining], I think this could be useful feature but we

[jira] [Commented] (FLINK-10463) Null literal cannot be properly parsed in Java Table API function call

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676846#comment-16676846 ] ASF GitHub Bot commented on FLINK-10463: hequn8128 commented on issue #6888:

[GitHub] hequn8128 commented on issue #6888: [FLINK-10463][table] Null literal cannot be properly parsed in Java Table API function call

2018-11-06 Thread GitBox
hequn8128 commented on issue #6888: [FLINK-10463][table] Null literal cannot be properly parsed in Java Table API function call URL: https://github.com/apache/flink/pull/6888#issuecomment-436276465 Thank you all for the review and suggestions!

[jira] [Commented] (FLINK-10771) Replace hard code of job graph file path with config option for FileJobGraphRetriever

2018-11-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676841#comment-16676841 ] Till Rohrmann commented on FLINK-10771: --- But from the implementation of {{FileJobGraphRetriever}}

[jira] [Commented] (FLINK-9699) Add api to replace registered table

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676842#comment-16676842 ] ASF GitHub Bot commented on FLINK-9699: --- hequn8128 commented on issue #6236: [FLINK-9699] [table]

[GitHub] hequn8128 commented on issue #6236: [FLINK-9699] [table] Add api to replace registered table

2018-11-06 Thread GitBox
hequn8128 commented on issue #6236: [FLINK-9699] [table] Add api to replace registered table URL: https://github.com/apache/flink/pull/6236#issuecomment-436275448 @zjffdu Thanks for the PR. I think this feature is very useful. I haven't taken a deep look at the code. Considering the api,

[GitHub] shaoxuan-wang commented on issue #7025: [FLINK-10797] "IntelliJ Setup" link is broken in README.md

2018-11-06 Thread GitBox
shaoxuan-wang commented on issue #7025: [FLINK-10797] "IntelliJ Setup" link is broken in README.md URL: https://github.com/apache/flink/pull/7025#issuecomment-436263199 > @shaoxuan-wang regardless the duplication of this pr(#7025 ) and #7024 I'd like to point out two concerns on this

[jira] [Commented] (FLINK-10797) "IntelliJ Setup" link is broken in Readme.md

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676792#comment-16676792 ] ASF GitHub Bot commented on FLINK-10797: shaoxuan-wang commented on issue #7025: [FLINK-10797]

[jira] [Commented] (FLINK-10795) STDDEV_POP error

2018-11-06 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676791#comment-16676791 ] Hequn Cheng commented on FLINK-10795: - Hi, I had looked into this issue. I think it is a precision

[jira] [Updated] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10419: --- Labels: pull-request-available (was: ) > ClassNotFoundException while deserializing user

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676768#comment-16676768 ] ASF GitHub Bot commented on FLINK-10419: NicoK opened a new pull request #7033:

[GitHub] NicoK opened a new pull request #7033: [FLINK-10419][checkpoint] fix ClassNotFoundException while deserializing user exceptions

2018-11-06 Thread GitBox
NicoK opened a new pull request #7033: [FLINK-10419][checkpoint] fix ClassNotFoundException while deserializing user exceptions URL: https://github.com/apache/flink/pull/7033 ## What is the purpose of the change `DeclineCheckpoint` tries to make sure that it does wrap any exception

[jira] [Created] (FLINK-10804) Transfer suppressed exceptions with SerializedThrowable

2018-11-06 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10804: --- Summary: Transfer suppressed exceptions with SerializedThrowable Key: FLINK-10804 URL: https://issues.apache.org/jira/browse/FLINK-10804 Project: Flink Issue

[jira] [Commented] (FLINK-10797) "IntelliJ Setup" link is broken in Readme.md

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676750#comment-16676750 ] ASF GitHub Bot commented on FLINK-10797: TisonKun edited a comment on issue #7025: [FLINK-10797]

[GitHub] TisonKun edited a comment on issue #7025: [FLINK-10797] "IntelliJ Setup" link is broken in README.md

2018-11-06 Thread GitBox
TisonKun edited a comment on issue #7025: [FLINK-10797] "IntelliJ Setup" link is broken in README.md URL: https://github.com/apache/flink/pull/7025#issuecomment-436249401 @shaoxuan-wang regardless the duplication of this pr(#7025 ) and #7024 I'd like to point out two concerns on this

[jira] [Commented] (FLINK-10797) "IntelliJ Setup" link is broken in Readme.md

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676747#comment-16676747 ] ASF GitHub Bot commented on FLINK-10797: TisonKun commented on issue #7025: [FLINK-10797]

[GitHub] TisonKun commented on issue #7025: [FLINK-10797] "IntelliJ Setup" link is broken in README.md

2018-11-06 Thread GitBox
TisonKun commented on issue #7025: [FLINK-10797] "IntelliJ Setup" link is broken in README.md URL: https://github.com/apache/flink/pull/7025#issuecomment-436249401 @shaoxuan-wang regardless the duplication of this pr(#7025 ) and #7024 I'd like to point out two concerns on this thread.

[jira] [Commented] (FLINK-10353) Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint written with Semantic.AT_LEAST_ONCE fails with NPE

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676695#comment-16676695 ] ASF GitHub Bot commented on FLINK-10353: StefanRRichter commented on issue #7010:

[GitHub] StefanRRichter commented on issue #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf…

2018-11-06 Thread GitBox
StefanRRichter commented on issue #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf… URL: https://github.com/apache/flink/pull/7010#issuecomment-436235901 Addressed the comments. Please have another look.

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676692#comment-16676692 ] ASF GitHub Bot commented on FLINK-10600: yanghua commented on issue #6924: [FLINK-10600] Provide

[GitHub] yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-11-06 Thread GitBox
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#issuecomment-436235491 @shaoxuan-wang Can you share your error log with us? The test cases related to kafka connector are not very

[GitHub] shaoxuan-wang commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-11-06 Thread GitBox
shaoxuan-wang commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#issuecomment-436234220 @pnowojski @yanghuaI got this test failure when I rebase the flink master to my own repository which is

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676690#comment-16676690 ] ASF GitHub Bot commented on FLINK-10600: shaoxuan-wang commented on issue #6924: [FLINK-10600]

[jira] [Updated] (FLINK-10801) Fix sql client integrate elasticsearch connector test failure

2018-11-06 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-10801: - Description: It usually reports :  {code:java} FAIL SQL Client Elasticsearch Upsert: Output hash

  1   2   3   >