[jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker

[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523340#comment-15523340 ] ASF GitHub Bot commented on FLINK-4280: --- Github user tzulitai commented on the issue:

[jira] [Commented] (FLINK-4564) [metrics] Delimiter should be configured per reporter

[ https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523352#comment-15523352 ] ASF GitHub Bot commented on FLINK-4564: --- Github user ex00 commented on a diff in the pull request:

[GitHub] flink pull request #2517: [FLINK-4564] [metrics] Delimiter should be configu...

Github user ex00 commented on a diff in the pull request: https://github.com/apache/flink/pull/2517#discussion_r80499420 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistry.java --- @@ -219,9 +249,16 @@ public ScopeFormats getScopeFormats() {

[jira] [Updated] (FLINK-4686) Add possibility to get column names

[ https://issues.apache.org/jira/browse/FLINK-4686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4686: Labels: starter (was: ) > Add possibility to get column names >

[jira] [Created] (FLINK-4686) Add possibility to get column names

Timo Walther created FLINK-4686: --- Summary: Add possibility to get column names Key: FLINK-4686 URL: https://issues.apache.org/jira/browse/FLINK-4686 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-4687) Add getAddress method to RpcService

Till Rohrmann created FLINK-4687: Summary: Add getAddress method to RpcService Key: FLINK-4687 URL: https://issues.apache.org/jira/browse/FLINK-4687 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-4687) Add getAddress method to RpcService

[ https://issues.apache.org/jira/browse/FLINK-4687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523629#comment-15523629 ] ASF GitHub Bot commented on FLINK-4687: --- GitHub user tillrohrmann opened a pull request:

[jira] [Updated] (FLINK-4688) Optimizer hangs for hours when optimizing complex plans

[ https://issues.apache.org/jira/browse/FLINK-4688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4688: - Attachment: stacktrace_76minsAfterSubmission.java Stacktrace 76 mins after submission >

[GitHub] flink issue #2397: [FLINK-4439] Validate 'bootstrap.servers' config in flink...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2397 Thank you. The pull request is now good to be merged! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Created] (FLINK-4688) Optimizer hangs for hours when optimizing complex plans

Fabian Hueske created FLINK-4688: Summary: Optimizer hangs for hours when optimizing complex plans Key: FLINK-4688 URL: https://issues.apache.org/jira/browse/FLINK-4688 Project: Flink Issue

[jira] [Updated] (FLINK-4688) Optimizer hangs for hours when optimizing complex plans

[ https://issues.apache.org/jira/browse/FLINK-4688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4688: - Attachment: stacktrace_shortlyAfterSubmission.java Stacktrace shortly after submission >

[jira] [Updated] (FLINK-4688) Optimizer hangs for hours when optimizing complex plans

[ https://issues.apache.org/jira/browse/FLINK-4688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4688: - Attachment: stacktrace_32minsAfterSubmission.java Stacktrace 32 mins after submission >

[GitHub] flink issue #2397: [FLINK-4439] Validate 'bootstrap.servers' config in flink...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2397 I've rebased to current master and triggered a build. https://travis-ci.org/rmetzger/flink/builds/162871029 --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2332 @nielsbasjes I want to avoid to exclude a version that is still in use by existing Flink users. I do not have in insight in which HBase versions currently in use. If (basically) everybody is on

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523868#comment-15523868 ] ASF GitHub Bot commented on FLINK-2055: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523695#comment-15523695 ] ASF GitHub Bot commented on FLINK-4035: --- Github user rmetzger commented on the issue:

[jira] [Commented] (FLINK-4439) Error message KafkaConsumer08 when all 'bootstrap.servers' are invalid

[ https://issues.apache.org/jira/browse/FLINK-4439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523703#comment-15523703 ] ASF GitHub Bot commented on FLINK-4439: --- Github user rmetzger commented on the issue:

[jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker

[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523705#comment-15523705 ] ASF GitHub Bot commented on FLINK-4280: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #2509: [FLINK-4280][kafka-connector] Explicit start position con...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2509 Thank you for working on this. I gave #2369 some love today to speed up things ;) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-4439) Error message KafkaConsumer08 when all 'bootstrap.servers' are invalid

[ https://issues.apache.org/jira/browse/FLINK-4439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523891#comment-15523891 ] ASF GitHub Bot commented on FLINK-4439: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

Github user nielsbasjes commented on the issue: https://github.com/apache/flink/pull/2332 @fhueske: What is "older" ? I would like a clear statement about the (minimal) supported versions of HBase. I would see 1.1.x as old enough, or do you see 0.98 still required? --- If

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523849#comment-15523849 ] ASF GitHub Bot commented on FLINK-2055: --- Github user nielsbasjes commented on the issue:

[GitHub] flink issue #2369: [FLINK-4035] Add a streaming connector for Apache Kafka 0...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2369 @tzulitai I addressed all your comments except the one relating `FlinkKafkaProducer010Configuration`: I had a quick offline discussion with @StephanEwen about the issue and he suggested to add the

[GitHub] flink pull request #2550: [Flink-4657] Implement HighAvailabilityServices ba...

GitHub user KurtYoung opened a pull request: https://github.com/apache/flink/pull/2550 [Flink-4657] Implement HighAvailabilityServices based on zookeeper This actually contains 3 commits. More details can be found here: https://github.com/StephanEwen/incubator-flink/pull/15 You

[jira] [Updated] (FLINK-4410) Report more information about operator checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4410: Summary: Report more information about operator checkpoints (was: Split checkpoint times into

[GitHub] flink pull request #2535: [FLINK-4662] Bump Calcite version up to 1.9

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2535 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Resolved] (FLINK-4590) Some Table API tests are failing when debug lvl is set to DEBUG

[ https://issues.apache.org/jira/browse/FLINK-4590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4590. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 7eb45c133c49933b14719f06bf68ccf162a3e0b2.

[jira] [Resolved] (FLINK-4241) Cryptic expression parser exceptions

[ https://issues.apache.org/jira/browse/FLINK-4241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4241. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in ef15984988e883ced5311b332e5e5d8521c9573f.

[GitHub] flink pull request #2529: [FLINK-4241] [table] Cryptic expression parser exc...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2529 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker

[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523328#comment-15523328 ] ASF GitHub Bot commented on FLINK-4280: --- Github user tzulitai commented on the issue:

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523327#comment-15523327 ] ASF GitHub Bot commented on FLINK-4035: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink issue #2509: [FLINK-4280][kafka-connector] Explicit start position con...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2509 Hi @gyfora, Yes, it is absolutely possible to add that. There's actually a JIRA for that feature too ([FLINK-3123](https://issues.apache.org/jira/browse/FLINK-3123)), so I'd say we can add

[GitHub] flink pull request #2319: [FLINK-4294] [table] Allow access of composite typ...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2319#discussion_r80500304 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/scala/table/expressionDsl.scala --- @@ -223,10 +223,28 @@ trait

[jira] [Updated] (FLINK-3801) Upgrade Joda-Time library to 2.9.3

[ https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3801: -- Description: Currently yoda-time 2.5 is used which was very old. We should upgrade to 2.9.3 was: Currently

[jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode()

[ https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3222: -- Description: Here is related code: {code} result = 31 * result + (int) (subTaskStats.length ^

[jira] [Commented] (FLINK-4241) Cryptic expression parser exceptions

[ https://issues.apache.org/jira/browse/FLINK-4241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523636#comment-15523636 ] ASF GitHub Bot commented on FLINK-4241: --- Github user asfgit closed the pull request at:

[jira] [Updated] (FLINK-4410) Report more information about operator checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4410: Affects Version/s: 1.1.2 > Report more information about operator checkpoints >

[jira] [Updated] (FLINK-4410) Report more information about operator checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4410: Priority: Major (was: Minor) > Report more information about operator checkpoints >

[jira] [Updated] (FLINK-4410) Report more information about operator checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4410: Component/s: State Backends, Checkpointing > Report more information about operator checkpoints >

[jira] [Created] (FLINK-4684) Remove obsolete classloader from CheckpointCoordinator

Stephan Ewen created FLINK-4684: --- Summary: Remove obsolete classloader from CheckpointCoordinator Key: FLINK-4684 URL: https://issues.apache.org/jira/browse/FLINK-4684 Project: Flink Issue

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523334#comment-15523334 ] ASF GitHub Bot commented on FLINK-4035: --- Github user rmetzger commented on the issue:

[jira] [Commented] (FLINK-4252) Table program cannot be compiled

[ https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523617#comment-15523617 ] ASF GitHub Bot commented on FLINK-4252: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #2507: [FLINK-4252] [table] Validate input and output cla...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2507 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #2551: [FLINK-4687] [rpc] Add getAddress to RpcService

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2551 [FLINK-4687] [rpc] Add getAddress to RpcService Adds the `getAddress` method to the `RpcService` which allows to retrieve the address under which the `RpcService` is reachable. You can merge

[GitHub] flink pull request #2369: [FLINK-4035] Add a streaming connector for Apache ...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2369#discussion_r80491475 --- Diff: flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java --- @@

[GitHub] flink issue #2509: [FLINK-4280][kafka-connector] Explicit start position con...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2509 I'll rebase this PR soon, probably will also wait for Kafka 0.10 connector to be merged. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-4294) Allow access of composite type fields

[ https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523361#comment-15523361 ] ASF GitHub Bot commented on FLINK-4294: --- Github user twalthr commented on a diff in the pull

[jira] [Updated] (FLINK-4410) Report more information about operator checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4410: Description: Checkpoint statistics contain the duration of a checkpoint, measured as from the

[jira] [Updated] (FLINK-4410) Report more information about operator checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4410: Fix Version/s: 1.2.0 > Report more information about operator checkpoints >

[jira] [Created] (FLINK-4685) Gather operator checkpoint durations data sizes from the runtime

Stephan Ewen created FLINK-4685: --- Summary: Gather operator checkpoint durations data sizes from the runtime Key: FLINK-4685 URL: https://issues.apache.org/jira/browse/FLINK-4685 Project: Flink

[jira] [Commented] (FLINK-4662) Bump Calcite version up to 1.9

[ https://issues.apache.org/jira/browse/FLINK-4662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523472#comment-15523472 ] ASF GitHub Bot commented on FLINK-4662: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (FLINK-4252) Table program cannot be compiled

[ https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4252. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in f150f987772c8d96f41a5acd1d20cba6622cb5c9.

[jira] [Updated] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3734: -- Description: {code} DataInputView in = inputState.getState(getUserCodeClassloader()); final long

[jira] [Updated] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2765: -- Description: Currently 0.98.11 is used: {code} 0.98.11-hadoop2 {code} Stable release for

[GitHub] flink pull request #2504: [FLINK-4590] [table] Some Table API tests are fail...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2504 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4590) Some Table API tests are failing when debug lvl is set to DEBUG

[ https://issues.apache.org/jira/browse/FLINK-4590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523591#comment-15523591 ] ASF GitHub Bot commented on FLINK-4590: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker

[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15524101#comment-15524101 ] ASF GitHub Bot commented on FLINK-4280: --- Github user gyfora commented on the issue:

[jira] [Closed] (FLINK-598) Add support for globalOrdering in DataSet API

[ https://issues.apache.org/jira/browse/FLINK-598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian closed FLINK-598. - Resolution: Fixed Closing since the sub-tasks are Closed and Resolved. > Add

[GitHub] flink issue #2509: [FLINK-4280][kafka-connector] Explicit start position con...

Github user gyfora commented on the issue: https://github.com/apache/flink/pull/2509 @tzulitai makes sense ! As for for the Map you are right, the multiple topic case slipped my mind :) --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Updated] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4632: Priority: Blocker (was: Major) > when yarn nodemanager lost, flink hung >

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522404#comment-15522404 ] Stephan Ewen commented on FLINK-4632: - I have tried to reproduce this, but it works well on my

[jira] [Updated] (FLINK-3674) Add an interface for Time aware User Function

[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3674: Summary: Add an interface for Time aware User Function (was: Add an interface for

[jira] [Updated] (FLINK-3674) Add an interface for Time aware User Functions

[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3674: Summary: Add an interface for Time aware User Functions (was: Add an interface for Time

[jira] [Assigned] (FLINK-4489) Implement TaskManager's SlotAllocationTable

[ https://issues.apache.org/jira/browse/FLINK-4489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangjing reassigned FLINK-4489: Assignee: zhangjing > Implement TaskManager's SlotAllocationTable >

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522303#comment-15522303 ] 刘喆 commented on FLINK-4632: --- I tried the lastest github version, the problem is still there. When the job is

[jira] [Assigned] (FLINK-3674) Add an interface for EventTime aware User Function

[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3674: --- Assignee: Aljoscha Krettek (was: ramkrishna.s.vasudevan) > Add an interface for

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522387#comment-15522387 ] ASF GitHub Bot commented on FLINK-2055: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15523269#comment-15523269 ] ASF GitHub Bot commented on FLINK-4035: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink issue #2369: [FLINK-4035] Add a streaming connector for Apache Kafka 0...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2369 I'm currently working on rebasing the PR and addressing the comments. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[GitHub] flink pull request #2369: [FLINK-4035] Add a streaming connector for Apache ...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2369#discussion_r80496915 --- Diff: flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010Fetcher.java ---

[jira] [Updated] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4534: -- Description: Iteration over state.bucketStates is protected by synchronization in other methods, except for

[jira] [Updated] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler

[ https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4573: -- Description: {code} try {

[jira] [Commented] (FLINK-4408) Submit Job and setup ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15524664#comment-15524664 ] ASF GitHub Bot commented on FLINK-4408: --- Github user KurtYoung closed the pull request at:

[jira] [Commented] (FLINK-4653) Refactor JobClientActor to adapt to the new Rpc framework and new cluster managerment

[ https://issues.apache.org/jira/browse/FLINK-4653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15524806#comment-15524806 ] ASF GitHub Bot commented on FLINK-4653: --- Github user beyond1920 commented on the issue:

[GitHub] flink issue #2524: [FLINK-4653] [Client] Refactor JobClientActor to adapt to...

Github user beyond1920 commented on the issue: https://github.com/apache/flink/pull/2524 @mxm , thanks for your review. I modified the content based on your advice: 1. The changes could compile successfully now, sorry for the level mistake. 2. AwaitJobResult method in

[GitHub] flink pull request #2480: [FLINK-4408][JobManager] Introduce JobMasterRunner...

Github user KurtYoung closed the pull request at: https://github.com/apache/flink/pull/2480 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Resolved] (FLINK-4408) Submit Job and setup ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young resolved FLINK-4408. --- Resolution: Fixed > Submit Job and setup ExecutionGraph > --- > >

[jira] [Created] (FLINK-4689) Implement a simple slot provider for the new job manager

Kurt Young created FLINK-4689: - Summary: Implement a simple slot provider for the new job manager Key: FLINK-4689 URL: https://issues.apache.org/jira/browse/FLINK-4689 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522193#comment-15522193 ] ASF GitHub Bot commented on FLINK-2055: --- Github user ramkrish86 commented on the issue:

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2332 > This scheme does not provide exactly-once delivery guarantees, however at any given point in time the table would be in a state as if the updates were only sent once. This is the same guarantee

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2332 @ramkrish86 that is correct. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[GitHub] flink issue #2545: [FLINK-4673] [core] TypeInfoFactory for Either type

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2545 I will review this PR soon. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[jira] [Commented] (FLINK-4673) TypeInfoFactory for Either type

[ https://issues.apache.org/jira/browse/FLINK-4673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522384#comment-15522384 ] ASF GitHub Bot commented on FLINK-4673: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests

[ https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522565#comment-15522565 ] ASF GitHub Bot commented on FLINK-4552: --- Github user zentol commented on the issue:

[GitHub] flink issue #2465: [FLINK-4447] [docs] Include NettyConfig options on Config...

Github user uce commented on the issue: https://github.com/apache/flink/pull/2465 Very good! +1 to add this with a note that the defaults should work fine out of the box. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-4447) Include NettyConfig options on Configurations page

[ https://issues.apache.org/jira/browse/FLINK-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522597#comment-15522597 ] ASF GitHub Bot commented on FLINK-4447: --- Github user uce commented on the issue:

[jira] [Updated] (FLINK-4596) RESTART_STRATEGY is not really pluggable

[ https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4596: - Affects Version/s: 1.2.0 > RESTART_STRATEGY is not really pluggable >

[jira] [Updated] (FLINK-4596) RESTART_STRATEGY is not really pluggable

[ https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4596: - Issue Type: Wish (was: Bug) > RESTART_STRATEGY is not really pluggable >

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522744#comment-15522744 ] ASF GitHub Bot commented on FLINK-2055: --- Github user nielsbasjes commented on the issue:

[jira] [Commented] (FLINK-4653) Refactor JobClientActor to adapt to the new Rpc framework and new cluster managerment

[ https://issues.apache.org/jira/browse/FLINK-4653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522610#comment-15522610 ] ASF GitHub Bot commented on FLINK-4653: --- Github user mxm commented on a diff in the pull request:

[jira] [Commented] (FLINK-4596) RESTART_STRATEGY is not really pluggable

[ https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522615#comment-15522615 ] Till Rohrmann commented on FLINK-4596: -- Hi [~nguraja], you're right that the class loading will fail

[GitHub] flink issue #2512: [FLINK-4379] Rescalable non-partitioned state

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2512 I would like to go for a follow-up PR. This is currently blocking some other work, so getting it in soon would help. --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-4379) Add Rescalable Non-Partitioned State

[ https://issues.apache.org/jira/browse/FLINK-4379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522638#comment-15522638 ] ASF GitHub Bot commented on FLINK-4379: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-4580) Check that the RpcEndpoint supports the specified RpcGateway

[ https://issues.apache.org/jira/browse/FLINK-4580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522651#comment-15522651 ] ASF GitHub Bot commented on FLINK-4580: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2547: [FLINK-4552] Refactor WindowOperator/Trigger Tests

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2547 There is a failing test:`TimestampsAndPeriodicWatermarksOperatorTest.testTimestampsAndPeriodicWatermarksOperator(TimestampsAndPeriodicWatermarksOperatorTest.java:74)` --- If your project is set up

[jira] [Commented] (FLINK-4673) TypeInfoFactory for Either type

[ https://issues.apache.org/jira/browse/FLINK-4673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522591#comment-15522591 ] ASF GitHub Bot commented on FLINK-4673: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #2545: [FLINK-4673] [core] TypeInfoFactory for Either typ...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2545#discussion_r80424649 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/EitherTypeInfoFactory.java --- @@ -0,0 +1,34 @@ +/* + * Licensed to the

[GitHub] flink pull request #2524: [FLINK-4653] [Client] Refactor JobClientActor to a...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2524#discussion_r80441549 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobClient/JobClientUtils.java --- @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache

[GitHub] flink issue #2526: [FLINK-4580] [rpc] Report rpc invocation exceptions to th...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2526 Thanks for the review @StephanEwen. Will merge this PR then. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15522823#comment-15522823 ] ASF GitHub Bot commented on FLINK-2055: --- Github user fhueske commented on the issue:

  1   2   3   >