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

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

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

Github user delding commented on the issue: https://github.com/apache/flink/pull/2332 I agree it might be an overkill. But in case of having an sink that only supports Put/Delete, it would be better to have ordered execution than not, after all HBase has this API so there could be

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

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525128#comment-15525128 ] 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 With in a single row you need guarantee of order of execution? I agree Append/Increment or non-idempotent in certain failure cases but there is a Nonce generator for that. I should say I have not

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

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

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

Github user delding commented on the issue: https://github.com/apache/flink/pull/2332 Hi @ramkrish86 , I'm thinking replace batch() with mutateRow() because it provides atomic ordered mutations for a single row, but it only supports Put and Delete which should be fine since only Put

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

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525031#comment-15525031 ] 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 @delding Do you have uses cases with Append/Increment? I think with the batch() API we are not sure of the order of execution of the batch() in the hbase server but still it would help

[jira] [Commented] (FLINK-4690) Replace SlotAllocationFuture with flink's own future

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

[GitHub] flink pull request #2552: [FLINK-4690] Replace SlotAllocationFuture with fli...

GitHub user KurtYoung opened a pull request: https://github.com/apache/flink/pull/2552 [FLINK-4690] Replace SlotAllocationFuture with flink's own future You can merge this pull request into a Git repository by running: $ git pull https://github.com/KurtYoung/flink flink-4690

[jira] [Created] (FLINK-4690) Replace SlotAllocationFuture with flink's own future

Kurt Young created FLINK-4690: - Summary: Replace SlotAllocationFuture with flink's own future Key: FLINK-4690 URL: https://issues.apache.org/jira/browse/FLINK-4690 Project: Flink Issue Type:

[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=15524939#comment-15524939 ] ASF GitHub Bot commented on FLINK-4035: --- Github user tzulitai commented on the issue:

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

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2369 @rmetzger Thanks for addressing the comments! Did a final pass, and the changes look good to me. I agree with merging the connector as is. Adding the timestamp to the regular sink interface

[jira] [Commented] (FLINK-4606) Integrate the new ResourceManager with the existing FlinkResourceManager

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

[GitHub] flink pull request #2540: [FLINK-4606] [cluster management] Integrate the ne...

Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2540#discussion_r80612002 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -66,15 +67,16 @@ * {@link

[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

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

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

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

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

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

[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=15523849#comment-15523849 ] ASF GitHub Bot commented on FLINK-2055: --- Github user nielsbasjes 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] [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 >

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

[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] [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=15523703#comment-15523703 ] ASF GitHub Bot commented on FLINK-4439: --- Github user rmetzger commented on the issue:

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

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

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

[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

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

[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

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

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

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

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

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

[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] [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() {

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

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

[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

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

[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

[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=15523203#comment-15523203 ] ASF GitHub Bot commented on FLINK-4280: --- Github user gyfora commented on the issue:

[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 Hi, I like the proposed changes, do you think it would make sense to add the possibility to set specific offsets on a per partition basis? ``` kafka.setStartOffsets(Map

[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=15523161#comment-15523161 ] ASF GitHub Bot commented on FLINK-4564: --- Github user zentol commented on a diff in the pull request:

[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=15523162#comment-15523162 ] ASF GitHub Bot commented on FLINK-4564: --- Github user zentol commented on a diff in the pull request:

[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=15523156#comment-15523156 ] ASF GitHub Bot commented on FLINK-4564: --- Github user zentol commented on a diff in the pull request:

[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=15523159#comment-15523159 ] ASF GitHub Bot commented on FLINK-4564: --- Github user zentol commented on a diff in the pull request:

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

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

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

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

[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=15523158#comment-15523158 ] ASF GitHub Bot commented on FLINK-4564: --- Github user zentol commented on a diff in the pull request:

[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=15523155#comment-15523155 ] ASF GitHub Bot commented on FLINK-4564: --- Github user zentol commented on a diff in the pull request:

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

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2517#discussion_r80473933 --- Diff: docs/monitoring/metrics.md --- @@ -280,6 +280,7 @@ Metrics can be exposed to an external system by configuring one or several repor -

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

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2517#discussion_r80480187 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/FrontMetricGroup.java --- @@ -0,0 +1,129 @@ +/* + * Licensed to the

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

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2517#discussion_r80477622 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/metrics/MetricRegistryTest.java --- @@ -280,4 +282,65 @@ public void

[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=15523157#comment-15523157 ] ASF GitHub Bot commented on FLINK-4564: --- Github user zentol commented on a diff in the pull request:

[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=15523163#comment-15523163 ] ASF GitHub Bot commented on FLINK-4564: --- Github user zentol commented on a diff in the pull request:

  1   2   3   >