[
https://issues.apache.org/jira/browse/FLINK-5517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849595#comment-15849595
]
ASF GitHub Bot commented on FLINK-5517:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3235
Thank you for looking into this @tedyu.
In the
ML(http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Help-using-HBase-with-Flink-1-1-4-td11094.html),
Giuliano has also
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3237#discussion_r99064341
--- Diff: docs/setup/mesos.md ---
@@ -92,18 +92,25 @@ Universe. In the search prompt, just search for Flink.
**Note**: At the time of this writing,
[
https://issues.apache.org/jira/browse/FLINK-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849585#comment-15849585
]
ASF GitHub Bot commented on FLINK-5474:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849587#comment-15849587
]
ASF GitHub Bot commented on FLINK-5474:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3237#discussion_r99064510
--- Diff: docs/setup/mesos.md ---
@@ -92,18 +92,25 @@ Universe. In the search prompt, just search for Flink.
**Note**: At the time of this writing,
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3237#discussion_r99064919
--- Diff: docs/setup/mesos.md ---
@@ -92,18 +92,25 @@ Universe. In the search prompt, just search for Flink.
**Note**: At the time of this writing,
[
https://issues.apache.org/jira/browse/FLINK-5474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849586#comment-15849586
]
ASF GitHub Bot commented on FLINK-5474:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849574#comment-15849574
]
ASF GitHub Bot commented on FLINK-5494:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849573#comment-15849573
]
ASF GitHub Bot commented on FLINK-5494:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849576#comment-15849576
]
ASF GitHub Bot commented on FLINK-5494:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849577#comment-15849577
]
ASF GitHub Bot commented on FLINK-5494:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3236#discussion_r99061454
--- Diff: docs/setup/mesos.md ---
@@ -145,60 +174,75 @@ If set to 'docker', specify the image name:
In the `/bin` directory of the Flink distribution,
[
https://issues.apache.org/jira/browse/FLINK-5494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849575#comment-15849575
]
ASF GitHub Bot commented on FLINK-5494:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3236#discussion_r99063127
--- Diff: docs/setup/mesos.md ---
@@ -107,29 +107,58 @@ Unvierse. Please use the following workaround in the
meantime:
## Mesos without DC/OS
[
https://issues.apache.org/jira/browse/FLINK-5494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849572#comment-15849572
]
ASF GitHub Bot commented on FLINK-5494:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3236#discussion_r99062197
--- Diff: docs/setup/mesos.md ---
@@ -107,29 +107,58 @@ Unvierse. Please use the following workaround in the
meantime:
## Mesos without DC/OS
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3236#discussion_r99063368
--- Diff: docs/setup/mesos.md ---
@@ -107,29 +107,58 @@ Unvierse. Please use the following workaround in the
meantime:
## Mesos without DC/OS
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3236#discussion_r99063747
--- Diff: docs/setup/mesos.md ---
@@ -145,60 +174,75 @@ If set to 'docker', specify the image name:
In the `/bin` directory of the Flink distribution,
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3236#discussion_r99061517
--- Diff: docs/setup/mesos.md ---
@@ -145,60 +174,75 @@ If set to 'docker', specify the image name:
In the `/bin` directory of the Flink distribution,
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
@fhueske - Please have a look at the javadoc.
---
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
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849460#comment-15849460
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849443#comment-15849443
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the issue:
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
> For now I'd suggest to keep the scope of the PR as it is right now. A bit
more Java documentation on HBaseTableSource to explain how it is used would be
great.
We can implement the
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849138#comment-15849138
]
Bill Liu edited comment on FLINK-5668 at 2/1/17 11:56 PM:
--
thanks [~wheat9] for
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849138#comment-15849138
]
Bill Liu edited comment on FLINK-5668 at 2/1/17 11:52 PM:
--
thanks [~wheat9] for
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849138#comment-15849138
]
Bill Liu commented on FLINK-5668:
-
thanks [~wheat9] for filling the full contexts.
YARN's own fault
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849048#comment-15849048
]
Haohui Mai commented on FLINK-5668:
---
Please allow me to fill in some of the contexts here.
The request
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3250
Thank you for this contribution. Please open a
[ticket](https://issues.apache.org/jira/browse/FLINK) describing your algorithm
and its appropriateness as an example running on a distributed stream
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849010#comment-15849010
]
ASF GitHub Bot commented on FLINK-5624:
---
GitHub user haohui opened a pull request:
GitHub user haohui opened a pull request:
https://github.com/apache/flink/pull/3252
[FLINK-5624] Support tumbling window on streaming tables in the SQL API.
This is a POC to add tumbling window support for streaming tables in SQL.
Essentially it recognizes the
[
https://issues.apache.org/jira/browse/FLINK-2908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848990#comment-15848990
]
ASF GitHub Bot commented on FLINK-2908:
---
GitHub user greghogan opened a pull request:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/3251
[FLINK-2908] [web frontend] Redraw web plan when browser resized
Redraw the job plan visual graph when the browser width is increased.
You can merge this pull request into a Git repository by
[
https://issues.apache.org/jira/browse/FLINK-2908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan reassigned FLINK-2908:
-
Assignee: Greg Hogan
> Web interface redraw web plan when browser resized
>
GitHub user dsnz opened a pull request:
https://github.com/apache/flink/pull/3250
Eratosthenes Sieve, a helpful and interesting example of using
DeltaIteration
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dsnz/flink master
[
https://issues.apache.org/jira/browse/FLINK-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848778#comment-15848778
]
Dawid Wysakowicz commented on FLINK-5510:
-
Just had a look into the code and been wondering how
[
https://issues.apache.org/jira/browse/FLINK-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-5510:
---
Assignee: Dawid Wysakowicz
> Replace Scala Future with FlinkFuture in
[
https://issues.apache.org/jira/browse/FLINK-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848733#comment-15848733
]
Dawid Wysakowicz commented on FLINK-5510:
-
Hi I would be glad to work on that.
> Replace Scala
[
https://issues.apache.org/jira/browse/FLINK-5603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848732#comment-15848732
]
Dawid Wysakowicz commented on FLINK-5603:
-
I think this is a duplicate of [FLINK-5510]
> Use
[
https://issues.apache.org/jira/browse/FLINK-3162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-3162.
-
Resolution: Won't Fix
Closing this issue since this feature is only useful for standalone clusters
and
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/3249
[FLINK-3163] [scripts] Configure Flink for NUMA systems
Start a TaskManager on each NUMA node on each worker when the new
configuration option 'taskmanager.compute.numa' is enabled.
This
Ted Yu created FLINK-5696:
-
Summary: Access to REAPER_THREAD lacks proper synchronization in
SafetyNetCloseableRegistry#doRegister
Key: FLINK-5696
URL: https://issues.apache.org/jira/browse/FLINK-5696
[
https://issues.apache.org/jira/browse/FLINK-3163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848661#comment-15848661
]
ASF GitHub Bot commented on FLINK-3163:
---
GitHub user greghogan opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848638#comment-15848638
]
Fabian Hueske commented on FLINK-5695:
--
Hi [~sunjincheng121], I am not sure how this change would
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848626#comment-15848626
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3149
Hi all,
thanks for the feedback. Let's stick to the nested schema then.
I think the best approach to support projections on nested fields is to
implement a second interface (i.e., a
[
https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5695:
---
Description:
Optimize table type systems based on database semantics.As follows:
{code}
[
https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5695:
---
Description:
Optimize table type systems based on database semantics.As follows:
{code}
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/3248
Optimize table type systems based on database semantics
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
[
https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848540#comment-15848540
]
ASF GitHub Bot commented on FLINK-5695:
---
GitHub user sunjincheng121 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5695:
---
Description:
Optimize table type systems based on database semantics.As follows:
{code}
[
https://issues.apache.org/jira/browse/FLINK-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5695:
---
Description:
Optimize table type systems based on database semantics.As follows:
{code}
sunjincheng created FLINK-5695:
--
Summary: Optimize table type systems based on database semantics
Key: FLINK-5695
URL: https://issues.apache.org/jira/browse/FLINK-5695
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848530#comment-15848530
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3149
Sorry for the late response.
Regarding to the `HBaseTableSchema`, I agree with that to move the
`addColumn(...)` method into `HBaseTableSource`.
Regarding to the nested vs flat
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/3247
[FLINK-5680] [docs] Document env.ssh.opts
Document env.ssh.opts in setup/config.html.
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-5680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848447#comment-15848447
]
ASF GitHub Bot commented on FLINK-5680:
---
GitHub user greghogan opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848421#comment-15848421
]
ASF GitHub Bot commented on FLINK-5441:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3107
What about using slf4j syntax `env.sql("SELECT * FROM {} JOIN {}", table1,
table2)` ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848324#comment-15848324
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the issue:
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
bq.ProjectableTableSource works in scan process.
Ya got it. I was just trying to relate with this HBase thing and could find
that we try to read all cols and then do a flatMap and then return
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
I think going through the PR for
https://issues.apache.org/jira/browse/FLINK-3848 - I think we try to project
only the required columns. Similarly we could do here also. So my and @tonycox
's
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848322#comment-15848322
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848319#comment-15848319
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user tonycox commented on the issue:
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 ProjectableTableSource works in scan process. Without it
TableScan is scanning all collumns and applying flatMap function on the whole
data to project and filter. It's inefficient
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
` Table result = tableEnv
.sql("SELECT test1.f1.q1, test1.f2.q2 FROM test1 where
test1.f1.q1 < 103");`
I just tried this query and it works with or
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848311#comment-15848311
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848287#comment-15848287
]
Philipp von dem Bussche commented on FLINK-2821:
Hello [~mxm], after being quiet for a
[
https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848275#comment-15848275
]
ASF GitHub Bot commented on FLINK-5353:
---
Github user fpompermaier commented on the issue:
Github user fpompermaier commented on the issue:
https://github.com/apache/flink/pull/3246
I think that's great!
---
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
[
https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848250#comment-15848250
]
ASF GitHub Bot commented on FLINK-5353:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3246
@fpompermaier @static-max tagging you so that you're aware of this PR. Will
be great to hear feedback from you!
---
If your project is set up for it, you can reply to this email and have your
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/3246
[FLINK-5353] [elasticsearch] User-provided failure handler for
ElasticsearchSink
Only the last commit is relevant. This PR is based on #3112 so that the
functionality is added for all
[
https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848248#comment-15848248
]
ASF GitHub Bot commented on FLINK-5353:
---
GitHub user tzulitai opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev updated FLINK-2168:
-
Labels: (was: starter)
> Add HBaseTableSource
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848109#comment-15848109
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5353 at 2/1/17 8:18 AM:
[
https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-5353:
--
Assignee: Tzu-Li (Gordon) Tai
> Elasticsearch Sink loses well-formed documents
[
https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5353:
---
Component/s: (was: Batch Connectors and Input/Output Formats)
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848113#comment-15848113
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user tonycox commented on the issue:
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@fhueske I preffer a better API with nesting. We can extend
`ProjectableTableSource` with a method like this
```scala
def projectNestedFields(fields: Array[String]): ProjectableTableSource[T]
[
https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848109#comment-15848109
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5353 at 2/1/17 8:12 AM:
[
https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848109#comment-15848109
]
Tzu-Li (Gordon) Tai commented on FLINK-5353:
Ok, then I think the actual cause for the
[
https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848105#comment-15848105
]
Flavio Pompermaier commented on FLINK-5353:
---
My previous PR was
83 matches
Mail list logo
