[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

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

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2512 Hi, I have some suggestions for renaming some of the interfaces and their methods in this pull request to come up with some clearer, more consistent naming schemes. I suggest the

[jira] [Created] (FLINK-4654) clean up docs

David Anderson created FLINK-4654: - Summary: clean up docs Key: FLINK-4654 URL: https://issues.apache.org/jira/browse/FLINK-4654 Project: Flink Issue Type: Improvement Components:

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79799726 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java --- @@ -174,6 +174,62 @@ protected void setErrorState(ParseErrorState

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

[GitHub] flink issue #2480: [FLINK-4408][JobManager] Introduce JobMasterRunner and im...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2480 This looks quite good to me. Will try to merge it onto the latest `flip-6` branch... --- 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-4361) Introduce Flink's own future abstraction

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

[GitHub] flink pull request #2472: [FLINK-4361] Introduce Flink's own future abstract...

Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2472 --- 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

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

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15509376#comment-15509376 ] Timo Walther commented on FLINK-4624: - {{VertexGroupItem}} and {{VertexGroupItem}} are

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79799184 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java --- @@ -174,6 +174,62 @@ protected void setErrorState(ParseErrorState

[GitHub] flink issue #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2487 That all sounds very good. I would personally like it if this contribution would enter Flink in some way. There have been thoughts and discussions one in a while about creating a

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79798776 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java --- @@ -174,6 +174,62 @@ protected void setErrorState(ParseErrorState

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

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

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79798925 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java --- @@ -174,6 +174,62 @@ protected void setErrorState(ParseErrorState

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79798804 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java --- @@ -174,6 +174,62 @@ protected void setErrorState(ParseErrorState

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

[GitHub] flink pull request #2519: [docs] Small improvements to the docs.

Github user alpinegizmo closed the pull request at: https://github.com/apache/flink/pull/2519 --- 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

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79798968 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java --- @@ -174,6 +174,62 @@ protected void setErrorState(ParseErrorState

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79798819 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java --- @@ -174,6 +174,62 @@ protected void setErrorState(ParseErrorState

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79804683 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java --- @@ -174,6 +174,62 @@ protected void setErrorState(ParseErrorState

[GitHub] flink pull request #2513: [hotfix] RescalingITCase

Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/2513 --- 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

[jira] [Updated] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery.

[ https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4651: -- Description: Currently the {{WindowOperator}} checkpoints the processing time timers, but upon

[jira] [Updated] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery.

[ https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4651: -- Description: Currently the {{WindowOperator}} checkpoints the processing time timers, but upon

[GitHub] flink issue #2303: [FLINK-4248] [core] [table] CsvTableSource does not suppo...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2303 @fhueske thanks for reviewing my code. I addressed your feedback. --- 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] [Created] (FLINK-4653) Refactor JobClientActor to adapt to the new Rpc framework and new cluster managerment

zhangjing created FLINK-4653: Summary: Refactor JobClientActor to adapt to the new Rpc framework and new cluster managerment Key: FLINK-4653 URL: https://issues.apache.org/jira/browse/FLINK-4653 Project:

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

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

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

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

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

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

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79791682 --- Diff: flink-batch-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/TestTableInputFormatITCase.java --- @@ -0,0 +1,112 @@ +/* +

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79791290 --- Diff: flink-batch-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/TestTableInputFormatITCase.java --- @@ -0,0 +1,112 @@ +/* +

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79791990 --- Diff: flink-batch-connectors/flink-hbase/src/test/resources/hbase-site.xml --- @@ -1,43 +0,0 @@ - - - - --- End diff -- I

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79791171 --- Diff: flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java --- @@ -67,18 +66,23 @@ protected

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79791053 --- Diff: flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java --- @@ -67,18 +66,23 @@ protected

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

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

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

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

[jira] [Assigned] (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 reassigned FLINK-4241: --- Assignee: Timo Walther > Cryptic expression parser exceptions >

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

Github user liuyuzhong commented on the issue: https://github.com/apache/flink/pull/2452 That's OK. I understand. It's not so easy to make a decesion. --- 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 issue #2524: [FLINK-4653] [Client] Refactor JobClientActor to adapt to...

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2524 Thanks for the PR @beyond1920. We just rebased the flip-6 branch. Could you rebase the PR? --- 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-4506) CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true

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

[jira] [Created] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery.

Kostas Kloudas created FLINK-4651: - Summary: Re-register processing time timers at the WindowOperator upon recovery. Key: FLINK-4651 URL: https://issues.apache.org/jira/browse/FLINK-4651 Project:

[GitHub] flink issue #2477: [FLINK-4506] CsvOutputFormat defaults allowNullValues to ...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2477 I agree with @zentol. `this.allowNullValues = false;` is the behavior since the initial code import. I would not change this and rather fix the JavaDocs. --- If your project is set up for it, you

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[GitHub] flink issue #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we...

Github user haoch commented on the issue: https://github.com/apache/flink/pull/2487 @StephanEwen sure, that's all ok. :-) --- 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

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

[ https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15509478#comment-15509478 ] ASF GitHub Bot commented on FLINK-4520: --- Github user haoch 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=15509474#comment-15509474 ] ASF GitHub Bot commented on FLINK-4653: --- Github user beyond1920 commented on the issue:

[jira] [Commented] (FLINK-4654) clean up docs

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

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

[jira] [Commented] (FLINK-4650) Frequent task manager disconnects from JobManager

[ https://issues.apache.org/jira/browse/FLINK-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15509268#comment-15509268 ] Stephan Ewen commented on FLINK-4650: - Can you describe what message you get? Do the Akka heartbeats

[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=15509390#comment-15509390 ] ASF GitHub Bot commented on FLINK-4653: --- GitHub user beyond1920 opened a pull request:

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

GitHub user beyond1920 opened a pull request: https://github.com/apache/flink/pull/2524 [FLINK-4653] [Client] Refactor JobClientActor to adapt to new Rpc framework and new cluster managerment There are following main changes: 1. Create a RpcEndpoint(temporary named

[jira] [Created] (FLINK-4652) Don't pass credentials explicitly to AmazonClient - use credentials provider instead

Kristian Frøhlich Hansen created FLINK-4652: --- Summary: Don't pass credentials explicitly to AmazonClient - use credentials provider instead Key: FLINK-4652 URL:

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79799395 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java --- @@ -174,6 +174,62 @@ protected void setErrorState(ParseErrorState

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79799234 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java --- @@ -174,6 +174,62 @@ protected void setErrorState(ParseErrorState

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[GitHub] flink issue #2473: [FLINK-4580] [rpc] Verify that the rpc endpoint supports ...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2473 The idea is nice, but it comes at the cost of yet another message roundtrip at startup. Since we should anyways forward the target endpoint invocation failures to the source gateway, I

[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 , I rebase the PR already. Thanks. --- 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

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79804375 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java --- @@ -174,6 +174,62 @@ protected void setErrorState(ParseErrorState

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[jira] [Commented] (FLINK-4478) Implement heartbeat logic

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

[jira] [Commented] (FLINK-1605) Create a shaded Hadoop fat jar to resolve library version conflicts

[ https://issues.apache.org/jira/browse/FLINK-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15509539#comment-15509539 ] Renkai Ge commented on FLINK-1605: -- Hi [~rmetzger], Could you help take a view at this issue

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15509534#comment-15509534 ] Martin Junghanns commented on FLINK-4624: - Thanks for the explanation, it now works as expected.

[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=15509469#comment-15509469 ] Stephan Ewen commented on FLINK-4632: - Do you know which of the following two situations is the case?

[GitHub] flink pull request #2525: [FLINK-4654] Small improvements to the docs.

GitHub user alpinegizmo opened a pull request: https://github.com/apache/flink/pull/2525 [FLINK-4654] Small improvements to the docs. Reading through the docs, I found some small problems -- typos, broken links, awkward phrases. (This was originally submitted as PR 2519, but I'd

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79804868 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java --- @@ -174,6 +174,62 @@ protected void setErrorState(ParseErrorState

[GitHub] flink issue #2435: [FLINK-4478] [flip-6] Add HeartbeatManager

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2435 I've rebased the PR onto the latest flip-6 branch. --- 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-2055) Implement Streaming HBaseSink

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

[jira] [Commented] (FLINK-3988) Add data set connector to DistributedLog

[ https://issues.apache.org/jira/browse/FLINK-3988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15509802#comment-15509802 ] Fabian Hueske commented on FLINK-3988: -- Hi [~johnlon], I don't think so. The issue is not assigned

[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=15509900#comment-15509900 ] ASF GitHub Bot commented on FLINK-4580: --- GitHub user tillrohrmann opened a pull request:

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

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2512 I think most of the proposed renames are good. One thing that would be good to change is to remove `SnapshotProvider` and just have that method directly on `OperatorStateBackend`. I really

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user nielsbasjes commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79816145 --- Diff: flink-batch-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/TestTableInputFormatITCase.java --- @@ -0,0 +1,112 @@ +/*

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

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

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user nielsbasjes commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79816123 --- Diff: flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java --- @@ -67,18 +66,23 @@ protected

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

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

[jira] [Resolved] (FLINK-3042) Define a way to let types create their own TypeInformation

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

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

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

[GitHub] flink pull request #2468: [FLINK-3580] [table] Add OVERLAPS function

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2468#discussion_r79824678 --- Diff: docs/dev/table_api.md --- @@ -1578,6 +1578,17 @@ localTimestamp() + + +{% highlight java

[GitHub] flink pull request #2468: [FLINK-3580] [table] Add OVERLAPS function

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2468#discussion_r79827070 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/time.scala --- @@ -248,3 +249,97 @@ case class LocalTime()

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

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

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

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

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

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

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

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

[GitHub] flink pull request #2468: [FLINK-3580] [table] Add OVERLAPS function

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2468#discussion_r79826575 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/time.scala --- @@ -248,3 +249,97 @@ case class LocalTime()

[GitHub] flink pull request #2468: [FLINK-3580] [table] Add OVERLAPS function

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2468#discussion_r79824726 --- Diff: docs/dev/table_api.md --- @@ -1940,6 +1951,17 @@ localTimestamp() + + +{% highlight scala

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

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

[GitHub] flink pull request #2468: [FLINK-3580] [table] Add OVERLAPS function

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2468#discussion_r79826729 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/time.scala --- @@ -248,3 +249,97 @@ case class LocalTime()

[GitHub] flink pull request #2468: [FLINK-3580] [table] Add OVERLAPS function

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2468#discussion_r79824752 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/scala/table/expressionDsl.scala --- @@ -472,5 +472,30 @@ object localTimestamp {

[GitHub] flink pull request #2468: [FLINK-3580] [table] Add OVERLAPS function

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2468#discussion_r79824738 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/scala/table/expressionDsl.scala --- @@ -472,5 +472,30 @@ object localTimestamp {

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

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

[jira] [Resolved] (FLINK-3060) Add possibility to integrate custom types into the TypeExtractor

[ https://issues.apache.org/jira/browse/FLINK-3060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-3060. - Resolution: Fixed Assignee: Timo Walther Fix Version/s: 1.2.0 This has been fixed

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

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2332 Hi @delding, I'm sorry that I did not mention this earlier, but I just noticed that the `HBaseSink` does not implement any logic for checkpointing and fault-tolerance. The checkpointing

  1   2   3   >