[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829456#comment-15829456
]
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
Thanks for the ping here @tonycox .
---
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
[
https://issues.apache.org/jira/browse/FLINK-5566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing updated FLINK-5566:
-
Description:
We define two structure mode to hold statistics
1. TableStats: contain stats for table
[
https://issues.apache.org/jira/browse/FLINK-5554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829453#comment-15829453
]
ramkrishna.s.vasudevan commented on FLINK-5554:
---
Thanks for starting this thread via JIRA
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829437#comment-15829437
]
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
As Jark Wu said in [jira](https://issues.apache.org/jira/browse/FLINK-5554)
> I think the HBaseTableSource should return a composite type (with column
family and qualifier), and we can get
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829435#comment-15829435
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user tonycox commented on a diff in the pull
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r96802576
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSourceInputFormat.java
---
@@ -0,0 +1,322 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-5571:
--
Description:
Currently, a User Defined Function (UDF) in table API & SQL works on zero, one,
or
[
https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5386:
---
Description:
Similar to the SQL, window clause is defined "as" a symbol which is explicitly
used in
[
https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5386:
---
Description:
Similar to the SQL, window clause is defined "as" a symbol which is explicitly
used in
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829296#comment-15829296
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on a diff in the pull
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r96790253
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSourceInputFormat.java
---
@@ -0,0 +1,322 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829295#comment-15829295
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on a diff in the pull
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r96790136
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSourceInputFormat.java
---
@@ -0,0 +1,322 @@
+/*
+ *
Github user gallenvara closed the pull request at:
https://github.com/apache/flink/pull/3121
---
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
[
https://issues.apache.org/jira/browse/FLINK-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829258#comment-15829258
]
ASF GitHub Bot commented on FLINK-5434:
---
Github user gallenvara closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-4683:
--
Assignee: sunjincheng
> Add SlideRow row-windows for batch tables
>
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-5571:
--
Summary: add open and close methods for UserDefinedFunction in TableAPI &
SQL (was: add open/close
godfrey he created FLINK-5571:
-
Summary: add open/close methods for UserDefinedFunction in
TableAPI & SQL
Key: FLINK-5571
URL: https://issues.apache.org/jira/browse/FLINK-5571
Project: Flink
Kurt Young created FLINK-5570:
-
Summary: Support register external catalog to table environment
Key: FLINK-5570
URL: https://issues.apache.org/jira/browse/FLINK-5570
Project: Flink
Issue Type:
Kurt Young created FLINK-5568:
-
Summary: Introduce interface for catalog, and provide an in-memory
implementation
Key: FLINK-5568
URL: https://issues.apache.org/jira/browse/FLINK-5568
Project: Flink
Kurt Young created FLINK-5569:
-
Summary: Migrate current table registration to in-memory catalog
Key: FLINK-5569
URL: https://issues.apache.org/jira/browse/FLINK-5569
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-5567:
--
Issue Type: Sub-task (was: Bug)
Parent: FLINK-5565
> Introduce and migrate current table
Kurt Young created FLINK-5567:
-
Summary: Introduce and migrate current table statistics to
FlinkStatistics
Key: FLINK-5567
URL: https://issues.apache.org/jira/browse/FLINK-5567
Project: Flink
Kurt Young created FLINK-5566:
-
Summary: Introduce structure to hold table and column level
statistics
Key: FLINK-5566
URL: https://issues.apache.org/jira/browse/FLINK-5566
Project: Flink
Issue
Kurt Young created FLINK-5565:
-
Summary: Improve flink cost model framework
Key: FLINK-5565
URL: https://issues.apache.org/jira/browse/FLINK-5565
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829213#comment-15829213
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on a diff in the pull
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r96783534
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java
---
@@ -0,0 +1,117 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-5554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829146#comment-15829146
]
Jark Wu edited comment on FLINK-5554 at 1/19/17 1:56 AM:
-
Flink has already
[
https://issues.apache.org/jira/browse/FLINK-5554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829146#comment-15829146
]
Jark Wu commented on FLINK-5554:
Flink has already supported composite types , and can access like
Github user liuyuzhong7 commented on the issue:
https://github.com/apache/flink/pull/3138
@zentol Right, Strom LocalCluster can run in a single class without
powermock.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3150
The PR looks good to me, +1 to merge
---
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
[
https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829127#comment-15829127
]
ASF GitHub Bot commented on FLINK-4693:
---
Github user wuchong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829087#comment-15829087
]
ASF GitHub Bot commented on FLINK-5452:
---
Github user KurtYoung commented on the issue:
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/3095
Thanks @fhueske, i will fix this today.
---
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
[
https://issues.apache.org/jira/browse/FLINK-5558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828855#comment-15828855
]
ASF GitHub Bot commented on FLINK-5558:
---
GitHub user greghogan opened a pull request:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/3169
[FLINK-5558] [gelly] Replace TriangleCount with a Count analytic
TriangleCount can be replaced by a generic Count analytic for DataSet. The
analytics currently using TriangleCount can simply use
[
https://issues.apache.org/jira/browse/FLINK-5562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828847#comment-15828847
]
ASF GitHub Bot commented on FLINK-5562:
---
GitHub user greghogan opened a pull request:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/3168
[FLINK-5562] [gelly] Driver fixes
Improve parametrization and output formatting.
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/3167
[FLINK-5563] [gelly] Add density to vertex metrics
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/greghogan/flink
[
https://issues.apache.org/jira/browse/FLINK-5563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828804#comment-15828804
]
ASF GitHub Bot commented on FLINK-5563:
---
GitHub user greghogan opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang reassigned FLINK-5564:
Assignee: Shaoxuan Wang
> User Defined Aggregates
> ---
>
>
Shaoxuan Wang created FLINK-5564:
Summary: User Defined Aggregates
Key: FLINK-5564
URL: https://issues.apache.org/jira/browse/FLINK-5564
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828570#comment-15828570
]
Michael Gummelt commented on FLINK-5533:
Michael Gummelt from Mesosphere here. I work on the
Greg Hogan created FLINK-5563:
-
Summary: Add density to vertex metrics
Key: FLINK-5563
URL: https://issues.apache.org/jira/browse/FLINK-5563
Project: Flink
Issue Type: Improvement
Greg Hogan created FLINK-5562:
-
Summary: Driver fixes
Key: FLINK-5562
URL: https://issues.apache.org/jira/browse/FLINK-5562
Project: Flink
Issue Type: Bug
Components: Gelly
Affects
[
https://issues.apache.org/jira/browse/FLINK-5559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828460#comment-15828460
]
Nico Kruber commented on FLINK-5559:
or even better, migrate the IllegalArgumentException to
[
https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828474#comment-15828474
]
sunjincheng commented on FLINK-5386:
Hi [~fhueske] sorry for the delayed reply
According to our
[
https://issues.apache.org/jira/browse/FLINK-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5505:
-
Summary: Harmonize ZooKeeper configuration parameters (was: Rename
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828457#comment-15828457
]
ASF GitHub Bot commented on FLINK-3849:
---
GitHub user tonycox opened a pull request:
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3166
[FLINK-3849] [WIP] Add FilterableTableSource interface and Rules for
pushing it
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list
Nico Kruber created FLINK-5561:
--
Summary: DataInputDeserializer#available returns one too few
Key: FLINK-5561
URL: https://issues.apache.org/jira/browse/FLINK-5561
Project: Flink
Issue Type:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/3165
[FLINK-5560] [webfrontend] Align table header columns with body
The checkpoint summary stats table was misaligned. The header listed the
state size before the end to end duration whereas the body had
[
https://issues.apache.org/jira/browse/FLINK-5560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828438#comment-15828438
]
ASF GitHub Bot commented on FLINK-5560:
---
GitHub user uce opened a pull request:
Ufuk Celebi created FLINK-5560:
--
Summary: Header in checkpoint stats summary misaligned
Key: FLINK-5560
URL: https://issues.apache.org/jira/browse/FLINK-5560
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828422#comment-15828422
]
ASF GitHub Bot commented on FLINK-5556:
---
GitHub user uce opened a pull request:
Nico Kruber created FLINK-5559:
--
Summary: queryable state:
KvStateRequestSerializer#deserializeKeyAndNamespace() throws an IOException
without own failure message if deserialisation fails
Key: FLINK-5559
URL:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/3164
[FLINK-5556] [checkpointing] Report correct buffered bytes during alignment
During stream alignment via the `BarrierTracker`, we were reporting the
wrong number of spilled bytes, because the
[
https://issues.apache.org/jira/browse/FLINK-5557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828415#comment-15828415
]
ASF GitHub Bot commented on FLINK-5557:
---
GitHub user greghogan opened a pull request:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/3163
[FLINK-5557] [gelly] Fix link in library methods
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/greghogan/flink
Greg Hogan created FLINK-5558:
-
Summary: Replace TriangleCount with a Count analytic
Key: FLINK-5558
URL: https://issues.apache.org/jira/browse/FLINK-5558
Project: Flink
Issue Type: Improvement
Greg Hogan created FLINK-5557:
-
Summary: Fix link in library methods
Key: FLINK-5557
URL: https://issues.apache.org/jira/browse/FLINK-5557
Project: Flink
Issue Type: Improvement
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3162
[FLINK-5503] [log] Print error message in case MesosApplicationMaster
Runner fails
This PR is based on #3159.
This PR adds an error message to the mesos-appmaster.sh script which is
[
https://issues.apache.org/jira/browse/FLINK-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828374#comment-15828374
]
ASF GitHub Bot commented on FLINK-5503:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828370#comment-15828370
]
Fabian Hueske commented on FLINK-5554:
--
The Table API uses Calcite to translate queries into
Ufuk Celebi created FLINK-5556:
--
Summary: BarrierBuffer resets bytes written on spiller roll over
Key: FLINK-5556
URL: https://issues.apache.org/jira/browse/FLINK-5556
Project: Flink
Issue
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3150
Thanks for updating the PR. +1 to merge.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828363#comment-15828363
]
ASF GitHub Bot commented on FLINK-4693:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828361#comment-15828361
]
ASF GitHub Bot commented on FLINK-5464:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3128
I've had an offline chat with @rmetzger and @uce. We agreed that using a
ByteBuffer and resizing it manually was a bit undesirable.
Instead we opted for the following approach:
* use
[
https://issues.apache.org/jira/browse/FLINK-5492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828352#comment-15828352
]
ASF GitHub Bot commented on FLINK-5492:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3161
[FLINK-5492] [log] Log unresolved address when starting an ActorSystem
With the Flakka changes we no longer resolve the given hostname into an IP.
Thus,
we should henceforth log the
[
https://issues.apache.org/jira/browse/FLINK-5493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828350#comment-15828350
]
Chesnay Schepler commented on FLINK-5493:
-
ok cool, I'll adjust the commit message to reflect
[
https://issues.apache.org/jira/browse/FLINK-5493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828334#comment-15828334
]
Till Rohrmann commented on FLINK-5493:
--
Yes it does :-)
> FlinkDistributionOverlay does not properly
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828326#comment-15828326
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user tonycox commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828324#comment-15828324
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user tonycox commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828327#comment-15828327
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user tonycox commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828330#comment-15828330
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user tonycox commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828328#comment-15828328
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user tonycox commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828325#comment-15828325
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user tonycox commented on a diff in the pull
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r9157
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java
---
@@ -0,0 +1,117 @@
+/*
+ *
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
We need discuss that
---
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,
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r96668950
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSourceInputFormat.java
---
@@ -0,0 +1,322 @@
+/*
+ *
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r96665731
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java
---
@@ -0,0 +1,117 @@
+/*
+ *
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r96665689
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java
---
@@ -0,0 +1,117 @@
+/*
+ *
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r96665755
--- Diff:
flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseTableSourceITCase.java
---
@@ -0,0 +1,117 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828321#comment-15828321
]
Greg Hogan commented on FLINK-4338:
---
[~StephanEwen] is there more work to be done under this super-task?
[
https://issues.apache.org/jira/browse/FLINK-5504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828311#comment-15828311
]
ASF GitHub Bot commented on FLINK-5504:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3160
[backport] [FLINK-5504] Create mesos-appmaster log file in log directory
Backport of #3159 onto the `release-1.2` branch.
This PR prepends the FLINK_LOG_DIR env variable pointing to
[
https://issues.apache.org/jira/browse/FLINK-5504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828310#comment-15828310
]
ASF GitHub Bot commented on FLINK-5504:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3159
[FLINK-5504] Create mesos-appmaster log file in log directory
This PR prepends the FLINK_LOG_DIR env variable pointing to Flink's logging
directory to the logging file name.
You can merge
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828306#comment-15828306
]
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
So am not sure if we can add specific API in table.api for hbase? Is that
allowed?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-1750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828303#comment-15828303
]
Kate Eri commented on FLINK-1750:
-
Hello, guys.
I have started to work on the current topic and first of
Robert Metzger created FLINK-:
-
Summary: Add documentation about debugging watermarks
Key: FLINK-
URL: https://issues.apache.org/jira/browse/FLINK-
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828295#comment-15828295
]
ASF GitHub Bot commented on FLINK-5468:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3119
Looks good to me, +1 to merge it
---
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
Anton Solovev created FLINK-5554:
Summary: Add sql operator to table api for getting columns from
HBase
Key: FLINK-5554
URL: https://issues.apache.org/jira/browse/FLINK-5554
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev updated FLINK-5554:
-
Description:
example of select query
{code}
table.select("f1:q1, f1:q2, f1:q3");
{code}
or/and
1 - 100 of 335 matches
Mail list logo
