[jira] [Assigned] (FLINK-9416) Make job submission retriable operation in case of a ongoing leader election

2018-05-24 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-9416: Assignee: Till Rohrmann > Make job submission retriable operation in case of a ongoing

[jira] [Assigned] (FLINK-9421) RunningJobsRegistry entries are not cleaned up after job termination

2018-05-24 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-9421: Assignee: Till Rohrmann > RunningJobsRegistry entries are not cleaned up after job

[jira] [Commented] (FLINK-9427) Cannot download from BlobServer, because the server address is unknown.

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488622#comment-16488622 ] ASF GitHub Bot commented on FLINK-9427: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #6069: [FLINK-9416] Make all RestClusterClient calls retr...

2018-05-24 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/6069 [FLINK-9416] Make all RestClusterClient calls retriable ## What is the purpose of the change This commit changes the RestClusterClient calls such that they are all retriable wrt

[jira] [Updated] (FLINK-9430) Support Casting of Object to Primitive types for Flink SQL UDF

2018-05-24 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-9430: -- Description: We want to add a SQL UDF to access specific element in a JSON string using JSON path.

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488529#comment-16488529 ] ASF GitHub Bot commented on FLINK-9423: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Created] (FLINK-9430) Support Casting of Object to Primitive types for Flink SQL UDF

2018-05-24 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-9430: - Summary: Support Casting of Object to Primitive types for Flink SQL UDF Key: FLINK-9430 URL: https://issues.apache.org/jira/browse/FLINK-9430 Project: Flink

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488530#comment-16488530 ] ASF GitHub Bot commented on FLINK-9423: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

2018-05-24 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190482258 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java --- @@ -0,0 +1,504 @@ +/* + *

[jira] [Commented] (FLINK-9416) Make job submission retriable operation in case of a ongoing leader election

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488629#comment-16488629 ] ASF GitHub Bot commented on FLINK-9416: --- GitHub user tillrohrmann opened a pull request:

[jira] [Resolved] (FLINK-9415) Remove reference to StreamingMultipleProgramsTestBase in docs

2018-05-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-9415. Resolution: Fixed Fix Version/s: 1.5.1 1.6.0 Merged.

[jira] [Commented] (FLINK-9415) Remove reference to StreamingMultipleProgramsTestBase in docs

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488521#comment-16488521 ] ASF GitHub Bot commented on FLINK-9415: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #6058: [FLINK-9415] Remove reference to StreamingMultiple...

2018-05-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6058 ---

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

2018-05-24 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190481987 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerHeapInternalTimer.java --- @@ -0,0 +1,235 @@ +/*

[jira] [Commented] (FLINK-9429) Quickstart E2E not working locally

2018-05-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488586#comment-16488586 ] Tzu-Li (Gordon) Tai commented on FLINK-9429: The test also works for me locally. Could it be

[jira] [Commented] (FLINK-9234) Commons Logging is missing from shaded Flink Table library

2018-05-24 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488617#comment-16488617 ] Timo Walther commented on FLINK-9234: - It seems that this change has impacts on other modules. The

[GitHub] flink pull request #6067: [FLINK-9427] Fix registration and request slot rac...

2018-05-24 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/6067 [FLINK-9427] Fix registration and request slot race condition in TaskExecutor ## What is the purpose of the change This commit fixes a race condition between the TaskExecutor and the

[GitHub] flink pull request #6068: [FLINK-9421] Remove job from RunningJobsRegistry w...

2018-05-24 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/6068 [FLINK-9421] Remove job from RunningJobsRegistry when it reaches a terminal state ## What is the purpose of the change This commit lets the Dispatcher remove the RunningJobsRegistry

[jira] [Commented] (FLINK-9421) RunningJobsRegistry entries are not cleaned up after job termination

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488625#comment-16488625 ] ASF GitHub Bot commented on FLINK-9421: --- GitHub user tillrohrmann opened a pull request:

[jira] [Commented] (FLINK-9234) Commons Logging is missing from shaded Flink Table library

2018-05-24 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488654#comment-16488654 ] Timo Walther commented on FLINK-9234: - I'm thinking about reverting this change. It pulls in different

[jira] [Commented] (FLINK-9418) Migrate SharedBuffer to use MapState

2018-05-24 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488660#comment-16488660 ] aitozi commented on FLINK-9418: --- Hi, can you share some detail about how to reach this "so that only the

[jira] [Reopened] (FLINK-9234) Commons Logging is missing from shaded Flink Table library

2018-05-24 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-9234: - > Commons Logging is missing from shaded Flink Table library >

[GitHub] flink issue #6026: [FLINK-9384]KafkaAvroTableSource failed to work due to ty...

2018-05-24 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6026 Thank you @tragicjun. LGTM. Merging... ---

[jira] [Commented] (FLINK-9424) BlobClientSslTest does not work in all environments

2018-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488695#comment-16488695 ] Chesnay Schepler commented on FLINK-9424: - That said the tests should maybe check whether the

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488707#comment-16488707 ] ASF GitHub Bot commented on FLINK-9303: --- Github user EAlexRojas commented on a diff in the pull

[jira] [Commented] (FLINK-9384) KafkaAvroTableSource failed to work due to type mismatch

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488711#comment-16488711 ] ASF GitHub Bot commented on FLINK-9384: --- Github user twalthr commented on the issue:

[GitHub] flink issue #6026: [FLINK-9384]KafkaAvroTableSource failed to work due to ty...

2018-05-24 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6026 @tragicjun this PR is hard to merge with 6 commits and a merge branch in the middle. Can you squash your commits into one commit that is rebased on the current master and do a force push? ---

[jira] [Commented] (FLINK-3952) Bump Netty to 4.1

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488731#comment-16488731 ] ASF GitHub Bot commented on FLINK-3952: --- pnowojski opened a new pull request #41: [FLINK-3952] Bump

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488735#comment-16488735 ] ASF GitHub Bot commented on FLINK-9303: --- Github user EAlexRojas commented on a diff in the pull

[GitHub] flink pull request #5991: [FLINK-9303] [kafka] Adding support for unassign d...

2018-05-24 Thread EAlexRojas
Github user EAlexRojas commented on a diff in the pull request: https://github.com/apache/flink/pull/5991#discussion_r190530647 --- Diff: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java --- @@

[jira] [Commented] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488658#comment-16488658 ] ASF GitHub Bot commented on FLINK-8946: --- Github user yanghua closed the pull request at:

[GitHub] flink issue #6062: [FLINK-9423][state] Implement efficient deletes for heap-...

2018-05-24 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/6062 @sihuazhou thanks for the review. Addressed your comments, please take a look if you want. ---

[jira] [Commented] (FLINK-9384) KafkaAvroTableSource failed to work due to type mismatch

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488683#comment-16488683 ] ASF GitHub Bot commented on FLINK-9384: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-9424) BlobClientSslTest does not work in all environments

2018-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488689#comment-16488689 ] Chesnay Schepler commented on FLINK-9424: - This is not an issue with the tests but the default

[jira] [Created] (FLINK-9431) Introduce TimeEnd State to flink cep

2018-05-24 Thread aitozi (JIRA)
aitozi created FLINK-9431: - Summary: Introduce TimeEnd State to flink cep Key: FLINK-9431 URL: https://issues.apache.org/jira/browse/FLINK-9431 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-9431) Introduce TimeEnd State to flink cep

2018-05-24 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488734#comment-16488734 ] aitozi commented on FLINK-9431: --- [~dawidwys]two thing: # 1. if i use

[GitHub] flink pull request #5991: [FLINK-9303] [kafka] Adding support for unassign d...

2018-05-24 Thread EAlexRojas
Github user EAlexRojas commented on a diff in the pull request: https://github.com/apache/flink/pull/5991#discussion_r190529981 --- Diff: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java --- @@

[jira] [Comment Edited] (FLINK-9431) Introduce TimeEnd State to flink cep

2018-05-24 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488734#comment-16488734 ] aitozi edited comment on FLINK-9431 at 5/24/18 9:57 AM: [~dawidwys] Three thing:

[jira] [Commented] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488657#comment-16488657 ] ASF GitHub Bot commented on FLINK-8946: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5869: [FLINK-8946] TaskManager stop sending metrics after JobMa...

2018-05-24 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5869 @zentol please see new PR #6060 , closing this PR... ---

[GitHub] flink pull request #5869: [FLINK-8946] TaskManager stop sending metrics afte...

2018-05-24 Thread yanghua
Github user yanghua closed the pull request at: https://github.com/apache/flink/pull/5869 ---

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488670#comment-16488670 ] ASF GitHub Bot commented on FLINK-9423: --- Github user StefanRRichter commented on the issue:

[GitHub] flink pull request #6066: [FLINK-9428] [checkpointing] Allow operators to fl...

2018-05-24 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6066#discussion_r190510791 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperator.java --- @@ -93,6 +93,20 @@ // state

[jira] [Commented] (FLINK-9428) Allow operators to flush data on checkpoint pre-barrier

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488678#comment-16488678 ] ASF GitHub Bot commented on FLINK-9428: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #6066: [FLINK-9428] [checkpointing] Allow operators to fl...

2018-05-24 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6066#discussion_r190512162 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OperatorChainTest.java --- @@ -0,0 +1,142 @@ +/* + *

[jira] [Commented] (FLINK-9428) Allow operators to flush data on checkpoint pre-barrier

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488679#comment-16488679 ] ASF GitHub Bot commented on FLINK-9428: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-9234) Commons Logging is missing from shaded Flink Table library

2018-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488694#comment-16488694 ] Chesnay Schepler commented on FLINK-9234: - My guess is that this wasn't caught on travis since

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488705#comment-16488705 ] ASF GitHub Bot commented on FLINK-9423: --- Github user sihuazhou commented on a diff in the pull

[GitHub] flink pull request #5991: [FLINK-9303] [kafka] Adding support for unassign d...

2018-05-24 Thread EAlexRojas
Github user EAlexRojas commented on a diff in the pull request: https://github.com/apache/flink/pull/5991#discussion_r190518142 --- Diff: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java --- @@

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

2018-05-24 Thread sihuazhou
Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190517094 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java --- @@ -458,24 +458,33 @@ private int

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

2018-05-24 Thread sihuazhou
Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190517336 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimer.java --- @@ -23,8 +23,8 @@ /** * Internal

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488706#comment-16488706 ] ASF GitHub Bot commented on FLINK-9423: --- Github user sihuazhou commented on a diff in the pull

[GitHub] flink pull request #5991: [FLINK-9303] [kafka] Adding support for unassign d...

2018-05-24 Thread EAlexRojas
Github user EAlexRojas commented on a diff in the pull request: https://github.com/apache/flink/pull/5991#discussion_r190519624 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java --- @@

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488710#comment-16488710 ] ASF GitHub Bot commented on FLINK-9303: --- Github user EAlexRojas commented on a diff in the pull

[jira] [Commented] (FLINK-8518) Support DOW, EPOCH, DECADE for EXTRACT

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488712#comment-16488712 ] ASF GitHub Bot commented on FLINK-8518: --- Github user snuyanzin commented on the issue:

[GitHub] flink issue #6007: [FLINK-8518][Table API & SQL] Support DOW for EXTRACT

2018-05-24 Thread snuyanzin
Github user snuyanzin commented on the issue: https://github.com/apache/flink/pull/6007 @twalthr thank you for your comment but could you please clarify this > Can you add some documentation to sqlApi.md such that users know about the semantics? 1. Am I right that

[jira] [Commented] (FLINK-9386) Remove netty-router dependency

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488726#comment-16488726 ] ASF GitHub Bot commented on FLINK-9386: --- Github user pnowojski commented on the issue:

[GitHub] flink issue #6031: [FLINK-9386] Embed netty router

2018-05-24 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/6031 Thanks :) I have squashed commits and rebased the PR on latest master. ---

[jira] [Commented] (FLINK-9431) Introduce TimeEnd State to flink cep

2018-05-24 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488729#comment-16488729 ] Dawid Wysakowicz commented on FLINK-9431: - Have you considered using timed out patterns? You could

[jira] [Comment Edited] (FLINK-9431) Introduce TimeEnd State to flink cep

2018-05-24 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488734#comment-16488734 ] aitozi edited comment on FLINK-9431 at 5/24/18 9:56 AM: [~dawidwys] Three thing:

[jira] [Comment Edited] (FLINK-9431) Introduce TimeEnd State to flink cep

2018-05-24 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488734#comment-16488734 ] aitozi edited comment on FLINK-9431 at 5/24/18 9:56 AM: [~dawidwys] Three thing:

[jira] [Comment Edited] (FLINK-9431) Introduce TimeEnd State to flink cep

2018-05-24 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488734#comment-16488734 ] aitozi edited comment on FLINK-9431 at 5/24/18 10:00 AM: - [~dawidwys] Three thing:

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488737#comment-16488737 ] ASF GitHub Bot commented on FLINK-9303: --- Github user EAlexRojas commented on a diff in the pull

[GitHub] flink issue #6070: [FLINK-9409] [formats] Remove flink-avro and flink-json f...

2018-05-24 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6070 @NicoK can you verify the change? ---

[jira] [Commented] (FLINK-9409) Remove flink-avro and flink-json from /opt

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488753#comment-16488753 ] ASF GitHub Bot commented on FLINK-9409: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

2018-05-24 Thread yanxiaobin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488779#comment-16488779 ] yanxiaobin commented on FLINK-8500: --- I prefer to  to expose Kafka's ConsumerRecord

[jira] [Commented] (FLINK-9428) Allow operators to flush data on checkpoint pre-barrier

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488794#comment-16488794 ] ASF GitHub Bot commented on FLINK-9428: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-8511) Remove legacy code for the TableType annotation

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488801#comment-16488801 ] ASF GitHub Bot commented on FLINK-8511: --- Github user twalthr commented on the issue:

[GitHub] flink issue #6055: [FLINK-8511][table] Remove legacy code for the TableType ...

2018-05-24 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6055 Thank you @kisimple. The PR looks good. We can also remove the `jcl-over-slf4j` dependency and update the `dependencyManagement` section. But I will do this and merge this after testing.

[GitHub] flink pull request #6068: [FLINK-9421] Remove job from RunningJobsRegistry w...

2018-05-24 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/6068#discussion_r190500268 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherResourceCleanupTest.java --- @@ -271,6 +279,80 @@ public void

[GitHub] flink pull request #6068: [FLINK-9421] Remove job from RunningJobsRegistry w...

2018-05-24 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/6068#discussion_r190548385 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherResourceCleanupTest.java --- @@ -271,6 +279,80 @@ public void

[jira] [Commented] (FLINK-9421) RunningJobsRegistry entries are not cleaned up after job termination

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488809#comment-16488809 ] ASF GitHub Bot commented on FLINK-9421: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-9421) RunningJobsRegistry entries are not cleaned up after job termination

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488810#comment-16488810 ] ASF GitHub Bot commented on FLINK-9421: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #6068: [FLINK-9421] Remove job from RunningJobsRegistry w...

2018-05-24 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/6068#discussion_r190548607 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherResourceCleanupTest.java --- @@ -271,6 +279,80 @@ public void

[GitHub] flink pull request #6070: [FLINK-9409] [formats] Remove flink-avro and flink...

2018-05-24 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/6070 [FLINK-9409] [formats] Remove flink-avro and flink-json from /opt ## What is the purpose of the change Both flink-json and flink-avro were added to the /opt directory in order to use them

[jira] [Commented] (FLINK-9409) Remove flink-avro and flink-json from /opt

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488751#comment-16488751 ] ASF GitHub Bot commented on FLINK-9409: --- GitHub user twalthr opened a pull request:

[jira] [Commented] (FLINK-8518) Support DOW, EPOCH, DECADE for EXTRACT

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488768#comment-16488768 ] ASF GitHub Bot commented on FLINK-8518: --- Github user twalthr commented on the issue:

[GitHub] flink issue #6007: [FLINK-8518][Table API & SQL] Support DOW for EXTRACT

2018-05-24 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6007 Hi @snuyanzin, yes, I meant `docs/dev/table/sql.md`. Right now it is not documented which units are supported by `EXTRACT`. Just because `DOW` is in the reserved keywords section doesn't mean

[GitHub] flink pull request #6066: [FLINK-9428] [checkpointing] Allow operators to fl...

2018-05-24 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/6066#discussion_r190543815 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OperatorChainTest.java --- @@ -0,0 +1,142 @@ +/* + *

[jira] [Commented] (FLINK-9421) RunningJobsRegistry entries are not cleaned up after job termination

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488808#comment-16488808 ] ASF GitHub Bot commented on FLINK-9421: --- Github user GJL commented on a diff in the pull request:

[jira] [Created] (FLINK-9432) Support extract epoch, decade, millisecond, microsecond

2018-05-24 Thread Sergey Nuyanzin (JIRA)
Sergey Nuyanzin created FLINK-9432: -- Summary: Support extract epoch, decade, millisecond, microsecond Key: FLINK-9432 URL: https://issues.apache.org/jira/browse/FLINK-9432 Project: Flink

[jira] [Updated] (FLINK-9349) KafkaConnector Exception while fetching from multiple kafka topics

2018-05-24 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-9349: -- Affects Version/s: (was: 1.5.0) Fix Version/s: (was: 1.5.1)

[jira] [Commented] (FLINK-7789) Add handler for Async IO operator timeouts

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488897#comment-16488897 ] ASF GitHub Bot commented on FLINK-7789: --- Github user pnowojski commented on a diff in the pull

[GitHub] flink pull request #6068: [FLINK-9421] Remove job from RunningJobsRegistry w...

2018-05-24 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6068#discussion_r190571226 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherResourceCleanupTest.java --- @@ -271,6 +279,80 @@ public void

[GitHub] flink pull request #6068: [FLINK-9421] Remove job from RunningJobsRegistry w...

2018-05-24 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6068#discussion_r190571258 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherResourceCleanupTest.java --- @@ -271,6 +279,80 @@ public void

[GitHub] flink pull request #6068: [FLINK-9421] Remove job from RunningJobsRegistry w...

2018-05-24 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6068#discussion_r190571191 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherResourceCleanupTest.java --- @@ -271,6 +279,80 @@ public void

[GitHub] flink issue #6043: [FLINK-7386] evolve RequestIndexer API to make it working...

2018-05-24 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/6043 As a high-level comment, I think we may want start making the ElasticSearch connectors projects independent of each other. We previously tried to share code between versions, which has

[jira] [Commented] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488913#comment-16488913 ] ASF GitHub Bot commented on FLINK-7386: --- Github user StephanEwen commented on the issue:

[jira] [Created] (FLINK-9433) SystemProcessingTimeService does not work properly

2018-05-24 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-9433: - Summary: SystemProcessingTimeService does not work properly Key: FLINK-9433 URL: https://issues.apache.org/jira/browse/FLINK-9433 Project: Flink Issue Type:

[GitHub] flink issue #6043: [FLINK-7386] evolve RequestIndexer API to make it working...

2018-05-24 Thread cjolif
Github user cjolif commented on the issue: https://github.com/apache/flink/pull/6043 Overall I think the most important thing to do is do something :) We can't let Flink elasticsearch in the broken state they are today. There must either be a purely REST-based solution or make sure

[jira] [Commented] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488928#comment-16488928 ] ASF GitHub Bot commented on FLINK-7386: --- Github user cjolif commented on the issue:

[jira] [Commented] (FLINK-8511) Remove legacy code for the TableType annotation

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489005#comment-16489005 ] ASF GitHub Bot commented on FLINK-8511: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-9433) SystemProcessingTimeService does not work properly

2018-05-24 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489006#comment-16489006 ] Stephan Ewen commented on FLINK-9433: - Can you share the design how you want to fix this? Ideally, we

[jira] [Comment Edited] (FLINK-9424) BlobClientSslTest does not work in all environments

2018-05-24 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489002#comment-16489002 ] yuqi edited comment on FLINK-9424 at 5/24/18 1:43 PM: -- [~twalthr] I have met this

[jira] [Closed] (FLINK-9425) Make release scripts compliant with ASF release policy

2018-05-24 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9425. Resolution: Fixed Fix Version/s: 1.5.0 Fixed via master:

[jira] [Commented] (FLINK-9420) Add tests for SQL IN sub-query operator in streaming

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489104#comment-16489104 ] ASF GitHub Bot commented on FLINK-9420: --- Github user twalthr commented on the issue:

[GitHub] flink issue #6065: [FLINK-9420][TableAPI & SQL] Add tests for SQL IN sub-que...

2018-05-24 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6065 Thank you @Xpray. The changes look good to me. I will merge this. ---

[jira] [Commented] (FLINK-8933) Avoid calling Class#newInstance

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489143#comment-16489143 ] ASF GitHub Bot commented on FLINK-8933: --- Github user yanghua commented on the issue:

[GitHub] flink pull request #6015: [FLINK-8933] Avoid calling Class#newInstance(part ...

2018-05-24 Thread yanghua
Github user yanghua closed the pull request at: https://github.com/apache/flink/pull/6015 ---

[jira] [Commented] (FLINK-9427) Cannot download from BlobServer, because the server address is unknown.

2018-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489139#comment-16489139 ] ASF GitHub Bot commented on FLINK-9427: --- Github user asfgit closed the pull request at:

  1   2   3   >