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

[ 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

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

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

[ 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] [Updated] (FLINK-10463) Null literal cannot be properly parsed in Java Table API function call

[ 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] [Commented] (FLINK-10796) Add a default external catalog (as FlinkInMemoryCatalog) to CatalogManager

[ 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

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

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] [Updated] (FLINK-10699) Create FlinkHmsCatalog for persistent Flink meta objects using Hive metastore as a registry

[ 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

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

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] [Commented] (FLINK-10768) Move external catalog related code from TableEnvironment to CatalogManager

[ 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] StefanRRichter commented on a change in pull request #7028: [FLINK-10789] New serializer snapshots after 1.6 should implement TypeSerializerSnapshot

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] [Commented] (FLINK-10789) Some new serializer snapshots added after 1.6 are not implementing the new TypeSerializerSnapshot interface

[ 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

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

[ 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] [Closed] (FLINK-10720) Add stress deployment end-to-end test

[ 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

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

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-10797) "IntelliJ Setup" link is broken in Readme.md

[ 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]

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

[ 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

[ 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 commented on issue #7036: [FLINK-10531][e2e] Fix unstable TTL end-to-end test.

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] [Closed] (FLINK-10671) rest monitoring api Savepoint status call fails if akka.ask.timeout < checkpoint duration

[ 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] [Updated] (FLINK-10796) Add a default external catalog (as FlinkInMemoryCatalog) to CatalogManager

[ 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-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

[ 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

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] [Updated] (FLINK-10531) State TTL RocksDb backend end-to-end test failed on Travis

[ 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-10463) Null literal cannot be properly parsed in Java Table API function call

[ 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] [Updated] (FLINK-10796) Add a default external catalog (as FlinkInMemoryCatalog) to CatalogManager

[ 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

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

[ 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-10531) State TTL RocksDb backend end-to-end test failed on Travis

[ 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

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

[ 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] [Commented] (FLINK-10802) Add metrics on vertex in job graph picture show

[ 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] [Commented] (FLINK-10706) Update the Flink Dashboard and its components

[ 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] [Created] (FLINK-10806) Support consume from earliest offset with a new topic

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] [Updated] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

[ 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

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

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] [Commented] (FLINK-10790) Refactor all the StreamPartitioner implementations into runtime module

[ 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:

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

[ 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,

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

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-9699) Add api to replace registered table

[ 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

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

[ 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] [Updated] (FLINK-10790) Refactor all the StreamPartitioner implementations into runtime module

[ 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

[ 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

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] [Closed] (FLINK-10384) Add Sinh math function supported in Table API and SQL

[ 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 >

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

[ 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] [Updated] (FLINK-10807) KafkaConsumer still consume removed topic after changing topics list

[ 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

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] [Resolved] (FLINK-8985) End-to-end test: CLI

[ 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] [Commented] (FLINK-10791) Provide end-to-end test for Kafka 0.11 connector

[ 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]

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

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

[ 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-10790) Refactor all the StreamPartitioner implementations into runtime module

[ 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

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

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

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] [Updated] (FLINK-10791) Provide end-to-end test for Kafka 0.11 connector

[ 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

[jira] [Commented] (FLINK-10800) Abstract the StreamPartitionerTest for common codes

[ https://issues.apache.org/jira/browse/FLINK-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676427#comment-16676427 ] ASF GitHub Bot commented on FLINK-10800: zhijiangW commented on a change in pull request #7031:

[GitHub] zhijiangW commented on a change in pull request #7031: [FLINK-10800][network][test] Abstract StreamPartitionerTest for common codes

zhijiangW commented on a change in pull request #7031: [FLINK-10800][network][test] Abstract StreamPartitionerTest for common codes URL: https://github.com/apache/flink/pull/7031#discussion_r231052416 ## File path:

[jira] [Commented] (FLINK-10704) Fix sql client end to end test failure

[ https://issues.apache.org/jira/browse/FLINK-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676433#comment-16676433 ] ASF GitHub Bot commented on FLINK-10704: yanghua commented on issue #6963: [FLINK-10704] Fix sql

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

[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-10600. -- Resolution: Fixed Release Note: merged commit c1683fb into master merged commit

[GitHub] yanghua commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

yanghua commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927#issuecomment-436192629 @pnowojski It is not up to date, it blocked by FLINK-10600(have merged) and FLINK-10704. I will update it soon.

[GitHub] yanghua edited a comment on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

yanghua edited a comment on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927#issuecomment-436192629 @pnowojski It is not up to date, it blocked by FLINK-10600(has been merged) and FLINK-10704. I will update

[GitHub] pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf…

pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf… URL: https://github.com/apache/flink/pull/7010#discussion_r231056814 ## File path:

[GitHub] pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf…

pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf… URL: https://github.com/apache/flink/pull/7010#discussion_r231060083 ## File path:

[GitHub] pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf…

pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf… URL: https://github.com/apache/flink/pull/7010#discussion_r231059615 ## File path:

[GitHub] pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf…

pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf… URL: https://github.com/apache/flink/pull/7010#discussion_r231058042 ## File path:

[GitHub] pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf…

pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf… URL: https://github.com/apache/flink/pull/7010#discussion_r231060313 ## File path:

[GitHub] pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf…

pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf… URL: https://github.com/apache/flink/pull/7010#discussion_r231057070 ## File path:

[GitHub] pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf…

pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf… URL: https://github.com/apache/flink/pull/7010#discussion_r231055211 ## File path:

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

[ https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676510#comment-16676510 ] ASF GitHub Bot commented on FLINK-10353: StefanRRichter commented on a change in pull request

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

StefanRRichter commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf… URL: https://github.com/apache/flink/pull/7010#discussion_r231067562 ## File path:

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

[ https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676508#comment-16676508 ] ASF GitHub Bot commented on FLINK-10353: StefanRRichter commented on a change in pull request

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

[ https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676517#comment-16676517 ] ASF GitHub Bot commented on FLINK-10353: StefanRRichter commented on a change in pull request

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

StefanRRichter commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf… URL: https://github.com/apache/flink/pull/7010#discussion_r231068106 ## File path:

[jira] [Commented] (FLINK-10800) Abstract the StreamPartitionerTest for common codes

[ https://issues.apache.org/jira/browse/FLINK-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676522#comment-16676522 ] ASF GitHub Bot commented on FLINK-10800: pnowojski commented on a change in pull request #7031:

[GitHub] pnowojski commented on a change in pull request #7031: [FLINK-10800][network][test] Abstract StreamPartitionerTest for common codes

pnowojski commented on a change in pull request #7031: [FLINK-10800][network][test] Abstract StreamPartitionerTest for common codes URL: https://github.com/apache/flink/pull/7031#discussion_r231068603 ## File path:

[jira] [Commented] (FLINK-10800) Abstract the StreamPartitionerTest for common codes

[ https://issues.apache.org/jira/browse/FLINK-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676534#comment-16676534 ] ASF GitHub Bot commented on FLINK-10800: zhijiangW commented on a change in pull request #7031:

[GitHub] kl0u commented on a change in pull request #7003: [FLINK-10633][prometheus] Add E2E test

kl0u commented on a change in pull request #7003: [FLINK-10633][prometheus] Add E2E test URL: https://github.com/apache/flink/pull/7003#discussion_r231072668 ## File path:

[jira] [Commented] (FLINK-10633) End-to-end test: Prometheus reporter

[ https://issues.apache.org/jira/browse/FLINK-10633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676585#comment-16676585 ] ASF GitHub Bot commented on FLINK-10633: kl0u commented on a change in pull request #7003:

[GitHub] zhijiangW commented on a change in pull request #7031: [FLINK-10800][network][test] Abstract StreamPartitionerTest for common codes

zhijiangW commented on a change in pull request #7031: [FLINK-10800][network][test] Abstract StreamPartitionerTest for common codes URL: https://github.com/apache/flink/pull/7031#discussion_r231051396 ## File path:

[jira] [Commented] (FLINK-10800) Abstract the StreamPartitionerTest for common codes

[ https://issues.apache.org/jira/browse/FLINK-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676424#comment-16676424 ] ASF GitHub Bot commented on FLINK-10800: zhijiangW commented on a change in pull request #7031:

[GitHub] yanghua commented on issue #6963: [FLINK-10704] Fix sql client end to end test failure

yanghua commented on issue #6963: [FLINK-10704] Fix sql client end to end test failure URL: https://github.com/apache/flink/pull/6963#issuecomment-436190068 @pnowojski OK, Shall I also remove the commit about "Clearly sleep for a while to wait for the correctness of the elasticsearch

[GitHub] pnowojski edited a comment on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

pnowojski edited a comment on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927#issuecomment-436190749 @yanghua is this PR up to date? It looks like it doesn't compile.

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676435#comment-16676435 ] ASF GitHub Bot commented on FLINK-10624: pnowojski commented on issue #6927: [FLINK-10624]

[GitHub] StefanRRichter opened a new pull request #7032: [FLINK-10765][test] Include s3p schema in S3 test

StefanRRichter opened a new pull request #7032: [FLINK-10765][test] Include s3p schema in S3 test URL: https://github.com/apache/flink/pull/7032 ## What is the purpose of the change This PR enhances the `PrestoS3FileSystemITCase` to also test the `s3p` schema. ## Brief

[GitHub] pnowojski commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

pnowojski commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927#issuecomment-436190749 @yanghua is this PR upto date? It looks like it doesn't compile.

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

[ https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676480#comment-16676480 ] ASF GitHub Bot commented on FLINK-10353: StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-10704) Fix sql client end to end test failure

[ https://issues.apache.org/jira/browse/FLINK-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676482#comment-16676482 ] ASF GitHub Bot commented on FLINK-10704: pnowojski commented on issue #6963: [FLINK-10704] Fix

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

StefanRRichter commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf… URL: https://github.com/apache/flink/pull/7010#discussion_r231061192 ## File path:

[GitHub] pnowojski commented on issue #6963: [FLINK-10704] Fix sql client end to end test failure

pnowojski commented on issue #6963: [FLINK-10704] Fix sql client end to end test failure URL: https://github.com/apache/flink/pull/6963#issuecomment-436196552 You don't have, it can be in this PR - just rename the commit message.

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

[ https://issues.apache.org/jira/browse/FLINK-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-10802: --- Description: Hi. Now, if someone want see  job metrics, have to click job overview. if we can add some

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

StefanRRichter commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf… URL: https://github.com/apache/flink/pull/7010#discussion_r231067879 ## File path:

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

[ https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676515#comment-16676515 ] ASF GitHub Bot commented on FLINK-10353: StefanRRichter commented on a change in pull request

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

[ https://issues.apache.org/jira/browse/FLINK-10353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676529#comment-16676529 ] ASF GitHub Bot commented on FLINK-10353: pnowojski commented on a change in pull request #7010:

[GitHub] pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf…

pnowojski commented on a change in pull request #7010: [FLINK-10353][kafka] Support change of transactional semantics in Kaf… URL: https://github.com/apache/flink/pull/7010#discussion_r231069235 ## File path:

[GitHub] zhijiangW commented on a change in pull request #7031: [FLINK-10800][network][test] Abstract StreamPartitionerTest for common codes

zhijiangW commented on a change in pull request #7031: [FLINK-10800][network][test] Abstract StreamPartitionerTest for common codes URL: https://github.com/apache/flink/pull/7031#discussion_r231069815 ## File path:

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

[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676610#comment-16676610 ] Nico Kruber commented on FLINK-10419: - With the new debug infos from FLINK-10655, we finally have

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

[ https://issues.apache.org/jira/browse/FLINK-10706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Wollert updated FLINK-10706: --- Description: The Flink Dashboard uses currently Angular 1, which had its successor coming

[jira] [Resolved] (FLINK-10738) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin resolved FLINK-10738. - Resolution: Cannot Reproduce Release Note: tried it 5x20 times locally and on

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

vinoyang created FLINK-10801: Summary: Fix sql client integrate elasticsearch connector test failure Key: FLINK-10801 URL: https://issues.apache.org/jira/browse/FLINK-10801 Project: Flink Issue

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

[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676430#comment-16676430 ] ASF GitHub Bot commented on FLINK-10600: pnowojski closed pull request #6924: [FLINK-10600]

[GitHub] pnowojski closed pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

pnowojski closed pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924 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

[GitHub] zhijiangW commented on a change in pull request #7031: [FLINK-10800][network][test] Abstract StreamPartitionerTest for common codes

zhijiangW commented on a change in pull request #7031: [FLINK-10800][network][test] Abstract StreamPartitionerTest for common codes URL: https://github.com/apache/flink/pull/7031#discussion_r231052709 ## File path:

  1   2   3   >