liuxianjiao commented on issue #6612: [FLINK-10215]Add configuration of java
option for historyserver
URL: https://github.com/apache/flink/pull/6612#issuecomment-416847140
@yanghua Thanks for your advice, I have changed the format of this PR. I
have tested it and used it many times to set
[
https://issues.apache.org/jira/browse/FLINK-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596010#comment-16596010
]
ASF GitHub Bot commented on FLINK-10215:
liuxianjiao commented on issue #6612: [
Chesnay Schepler created FLINK-10241:
Summary: Reduce performance/stability impact of latency metrics
Key: FLINK-10241
URL: https://issues.apache.org/jira/browse/FLINK-10241
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-10236:
-
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-10241
> Reduce histogram
Chesnay Schepler created FLINK-10242:
Summary: Disable latency metrics by default
Key: FLINK-10242
URL: https://issues.apache.org/jira/browse/FLINK-10242
Project: Flink
Issue Type: Sub-ta
yanghua commented on issue #6266: [FLINK-9682] Add setDescription to execution
environment and provide description field for the rest api
URL: https://github.com/apache/flink/pull/6266#issuecomment-416850243
@zentol Can you review this PR?
--
[
https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596021#comment-16596021
]
ASF GitHub Bot commented on FLINK-9682:
---
yanghua commented on issue #6266: [FLINK-9
Chesnay Schepler created FLINK-10243:
Summary: Add option to reduce latency metrics granularity
Key: FLINK-10243
URL: https://issues.apache.org/jira/browse/FLINK-10243
Project: Flink
Issu
Chesnay Schepler created FLINK-10244:
Summary: Add option to measure latency as absolute value
Key: FLINK-10244
URL: https://issues.apache.org/jira/browse/FLINK-10244
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-10238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596028#comment-16596028
]
ASF GitHub Bot commented on FLINK-10238:
asfgit closed pull request #121: [FLIN
[
https://issues.apache.org/jira/browse/FLINK-10238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596030#comment-16596030
]
ASF GitHub Bot commented on FLINK-10238:
StephanEwen commented on issue #121: [
zentol commented on issue #6266: [FLINK-9682] Add setDescription to execution
environment and provide description field for the rest api
URL: https://github.com/apache/flink/pull/6266#issuecomment-416853509
Not at the moment.
[
https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596031#comment-16596031
]
ASF GitHub Bot commented on FLINK-9682:
---
zentol commented on issue #6266: [FLINK-96
[
https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10241:
--
Fix Version/s: 1.7.0
> Reduce performance/stability impact of latency metrics
> --
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shimin Yang closed FLINK-9567.
--
> Flink does not release resource in Yarn Cluster mode
> --
[
https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10241:
--
Fix Version/s: 1.5.4
1.6.1
> Reduce performance/stability impact of latency
Shimin Yang created FLINK-10245:
---
Summary: Add DataStream HBase Sink
Key: FLINK-10245
URL: https://issues.apache.org/jira/browse/FLINK-10245
Project: Flink
Issue Type: Sub-task
Compon
Till Rohrmann created FLINK-10246:
-
Summary: Harden and separate MetricQueryService
Key: FLINK-10246
URL: https://issues.apache.org/jira/browse/FLINK-10246
Project: Flink
Issue Type: Improvem
twalthr commented on issue #6621: [FLINK-8686] [sql-client] Limit result size
for prototyping modes
URL: https://github.com/apache/flink/pull/6621#issuecomment-416858616
Thank you @fhueske. I would be happy if you could take another look.
--
Till Rohrmann created FLINK-10247:
-
Summary: Run MetricQueryService in separate thread pool
Key: FLINK-10247
URL: https://issues.apache.org/jira/browse/FLINK-10247
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596051#comment-16596051
]
ASF GitHub Bot commented on FLINK-8686:
---
twalthr commented on issue #6621: [FLINK-
Clark opened a new pull request #6627: [FLINK-10245] [Streaming Connector]
Add Pojo, Tuple, Row and Scala Pr…
URL: https://github.com/apache/flink/pull/6627
## What is the purpose of the change
This PR introduce the HBase sink for Datastream which can support Pojo, Row,
Tuple an
[
https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596058#comment-16596058
]
ASF GitHub Bot commented on FLINK-10245:
Clark opened a new pull request #66
[
https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10245:
---
Labels: pull-request-available (was: )
> Add DataStream HBase Sink
> --
[
https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596059#comment-16596059
]
Timo Walther commented on FLINK-9172:
-
[~walterddr] the support for external catalogs
fhueske commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input
format
URL: https://github.com/apache/flink/pull/6483#issuecomment-416864894
Hi @HuangZhenQiu, agreed.
Let's add filter push down later. I don't think we can limit the changes to
`ParquetTableSource` (the f
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596066#comment-16596066
]
ASF GitHub Bot commented on FLINK-7243:
---
fhueske commented on issue #6483: [FLINK-7
[
https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596068#comment-16596068
]
Rong Rong commented on FLINK-9172:
--
Yes. I think so too. the only thing missing was {{Ta
Shimin Yang created FLINK-10248:
---
Summary: Add HBase Table Sink
Key: FLINK-10248
URL: https://issues.apache.org/jira/browse/FLINK-10248
Project: Flink
Issue Type: Sub-task
Components:
fhueske commented on issue #6621: [FLINK-8686] [sql-client] Limit result size
for prototyping modes
URL: https://github.com/apache/flink/pull/6621#issuecomment-416867688
Thanks for the update @twalthr.
+1 to merge
Thi
[
https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596072#comment-16596072
]
ASF GitHub Bot commented on FLINK-8686:
---
fhueske commented on issue #6621: [FLINK-
Andrey Zagrebin created FLINK-10249:
---
Summary: Document hadoop/presto s3 file system configuration
forwarding
Key: FLINK-10249
URL: https://issues.apache.org/jira/browse/FLINK-10249
Project: Flink
PengYang created FLINK-10250:
Summary: Flink doesn't support functions that extend
RichAggregateFunction in a group window
Key: FLINK-10250
URL: https://issues.apache.org/jira/browse/FLINK-10250
Project:
[
https://issues.apache.org/jira/browse/FLINK-10250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596089#comment-16596089
]
Fabian Hueske commented on FLINK-10250:
---
Hi [~LaiAng], Thanks for your questions a
[
https://issues.apache.org/jira/browse/FLINK-10250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-10250.
-
Resolution: Won't Fix
> Flink doesn't support functions that extend RichAggregateFunction in a g
Till Rohrmann created FLINK-10251:
-
Summary: Handle oversized response messages in AkkaRpcActor
Key: FLINK-10251
URL: https://issues.apache.org/jira/browse/FLINK-10251
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-10250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596098#comment-16596098
]
PengYang commented on FLINK-10250:
--
@[~fhueske] OK Thanks !
> Flink doesn't support f
Till Rohrmann created FLINK-10252:
-
Summary: Handle oversized metric messges
Key: FLINK-10252
URL: https://issues.apache.org/jira/browse/FLINK-10252
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-10253:
-
Summary: Run MetricQueryService with lower priority
Key: FLINK-10253
URL: https://issues.apache.org/jira/browse/FLINK-10253
Project: Flink
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/FLINK-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-10137:
-
Fix Version/s: 1.5.4
1.7.0
1.6.1
> YARN: Log completed Containers
GJL commented on issue #6550: [FLINK-10137][YARN] Log completed containers.
URL: https://github.com/apache/flink/pull/6550#issuecomment-416882644
@zentol @yanghua
Thanks for reviewing.
@zentol I think this should be merged to 1.5, 1.6, and 1.7.
---
[
https://issues.apache.org/jira/browse/FLINK-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596108#comment-16596108
]
ASF GitHub Bot commented on FLINK-10137:
GJL commented on issue #6550: [FLINK-10
[
https://issues.apache.org/jira/browse/FLINK-9991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-9991:
Summary: Add regexp_replace supported in TableAPI and SQL (was: Add
regex_replace supported in TableAPI an
[
https://issues.apache.org/jira/browse/FLINK-10225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596124#comment-16596124
]
Till Rohrmann commented on FLINK-10225:
---
Thanks for reporting this issue [~PierreZ
tillrohrmann commented on issue #5931: [FLINK-9190][flip6,yarn] Request new
container if container completed unexpectedly
URL: https://github.com/apache/flink/pull/5931#issuecomment-416895148
@TisonKun, yes #6132 implements the notification about failed allocations.
However, the `SlotPool
[
https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596147#comment-16596147
]
ASF GitHub Bot commented on FLINK-9190:
---
tillrohrmann commented on issue #5931: [FL
tillrohrmann commented on issue #6601: [FLINK-10193] Add @RpcTimeout to
JobMasterGateway.triggerSavepoint
URL: https://github.com/apache/flink/pull/6601#issuecomment-416898324
You're right @GJL. Then I would vote for the first test case. Something
along the lines:
```
Future future1
[
https://issues.apache.org/jira/browse/FLINK-10193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596159#comment-16596159
]
ASF GitHub Bot commented on FLINK-10193:
tillrohrmann commented on issue #6601:
[
https://issues.apache.org/jira/browse/FLINK-10238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-10238.
--
Resolution: Done
Done in 8541e8338868b5d7abba8cb38faa02d6d078ca02
> Make nightly builds easie
[
https://issues.apache.org/jira/browse/FLINK-10238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-10238.
> Make nightly builds easier discoverable
> ---
>
>
asfgit closed pull request #6621: [FLINK-8686] [sql-client] Limit result size
for prototyping modes
URL: https://github.com/apache/flink/pull/6621
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
[
https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596185#comment-16596185
]
ASF GitHub Bot commented on FLINK-8686:
---
asfgit closed pull request #6621: [FLINK-
[
https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-10206:
-
Priority: Major (was: Critical)
> Add hbase stream connector
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-10206:
-
Fix Version/s: (was: 1.6.1)
> Add hbase stream connector
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596194#comment-16596194
]
Timo Walther commented on FLINK-10206:
--
[~dangdangdang] for streaming sinks I think
[
https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-10206:
-
Issue Type: New Feature (was: Improvement)
> Add hbase stream connector
> -
Guibo-Pan commented on issue #6544: [FLINK-8532] [Streaming] modify
RebalancePartitioner to use a random partition as its first partition
URL: https://github.com/apache/flink/pull/6544#issuecomment-416913773
@StephanEwen Thanks for your suggestion. I've made an update to it.
For furt
[
https://issues.apache.org/jira/browse/FLINK-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596197#comment-16596197
]
ASF GitHub Bot commented on FLINK-8532:
---
Guibo-Pan commented on issue #6544: [FLINK
[
https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596206#comment-16596206
]
Timo Walther commented on FLINK-8686:
-
The result size has been limited.
Fixed in 1.
[
https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8686:
Description:
This issue describes follow-up issues that should be fixes in order to make the
SQL c
yanghua commented on issue #6450: [FLINK-9991] [table] Add regexp_replace
supported in TableAPI and SQL
URL: https://github.com/apache/flink/pull/6450#issuecomment-416918269
@xccui I have updated and rebased this PR, can you review it? thanks.
--
[
https://issues.apache.org/jira/browse/FLINK-9991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596210#comment-16596210
]
ASF GitHub Bot commented on FLINK-9991:
---
yanghua commented on issue #6450: [FLINK-9
yanghua commented on issue #6622: [FLINK-10222] Table scalar function
expression parses error when function name equals the exists keyword suffix
URL: https://github.com/apache/flink/pull/6622#issuecomment-416919005
@walterddr
--
[
https://issues.apache.org/jira/browse/FLINK-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596212#comment-16596212
]
ASF GitHub Bot commented on FLINK-10222:
yanghua commented on issue #6622: [FLIN
[
https://issues.apache.org/jira/browse/FLINK-10225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596215#comment-16596215
]
Pierre Zemb commented on FLINK-10225:
-
Thanks [~till.rohrmann] for the reply! I'm no
aitozi created FLINK-10254:
--
Summary: Fix check in stateBackend
Key: FLINK-10254
URL: https://issues.apache.org/jira/browse/FLINK-10254
Project: Flink
Issue Type: Improvement
Components: S
[
https://issues.apache.org/jira/browse/FLINK-10225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596237#comment-16596237
]
Till Rohrmann commented on FLINK-10225:
---
In general this change is not too complic
zentol closed pull request #6550: [FLINK-10137][YARN] Log completed containers.
URL: https://github.com/apache/flink/pull/6550
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign p
[
https://issues.apache.org/jira/browse/FLINK-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596259#comment-16596259
]
ASF GitHub Bot commented on FLINK-10137:
zentol closed pull request #6550: [FLIN
[
https://issues.apache.org/jira/browse/FLINK-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-10137.
Resolution: Fixed
master: c3a74a12a063129367945e0ca1fa60535f5ca8c9
1.6: 57f73c852714175a09
Clark closed pull request #6627: [FLINK-10245] [Streaming Connector] Add
Pojo, Tuple, Row and Scala Pr…
URL: https://github.com/apache/flink/pull/6627
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of proven
[
https://issues.apache.org/jira/browse/FLINK-10225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596270#comment-16596270
]
Pierre Zemb commented on FLINK-10225:
-
I still want to give it a try ;) Do you have
[
https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596269#comment-16596269
]
ASF GitHub Bot commented on FLINK-10245:
Clark closed pull request #6627: [F
[
https://issues.apache.org/jira/browse/FLINK-10230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10230:
Assignee: vinoyang
> Support printing the query of a view
>
[
https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596278#comment-16596278
]
ASF GitHub Bot commented on FLINK-10245:
Clark opened a new pull request #66
[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-9962.
-
Resolution: Fixed
And on release-1.6 with 3f6e0b7031ef94dfa36161a462958f856987356b
> allow users
Clark opened a new pull request #6628: [FLINK-10245] [Streaming Connector]
Add Pojo, Tuple, Row and Scala Product DataStream Sink for HBase
URL: https://github.com/apache/flink/pull/6628
## What is the purpose of the change
This PR introduce the HBase sink for Datastream which ca
[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reopened FLINK-9962:
---
> allow users to specify TimeZone in DateTimeBucketer
> -
[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-9962:
--
Fix Version/s: (was: 1.7.0)
1.6.1
> allow users to specify TimeZone in D
[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-9962.
-
Resolution: Fixed
> allow users to specify TimeZone in DateTimeBucketer
> ---
[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596276#comment-16596276
]
ASF GitHub Bot commented on FLINK-9962:
---
asfgit closed pull request #6492: [FLINK-9
[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-9962.
-
Resolution: Fixed
Closed on master with 7eb41f33fbce8da52cbba160f0ecff6fe96f124b
> allow users t
asfgit closed pull request #6492: [FLINK-9962] [FS connector] allow users to
specify TimeZone in DateTimeBucketer
URL: https://github.com/apache/flink/pull/6492
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of
[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reopened FLINK-9962:
---
> allow users to specify TimeZone in DateTimeBucketer
> -
[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reopened FLINK-9962:
---
> allow users to specify TimeZone in DateTimeBucketer
> -
[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-9962.
-
Resolution: Fixed
Merged on master with 7eb41f33fbce8da52cbba160f0ecff6fe96f124b
and on release-1
azagrebin commented on a change in pull request #6599: [FLINK-10150][metrics]
Fix OperatorMetricGroup creation for Batch
URL: https://github.com/apache/flink/pull/6599#discussion_r213666345
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskMetric
[
https://issues.apache.org/jira/browse/FLINK-10150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596294#comment-16596294
]
ASF GitHub Bot commented on FLINK-10150:
azagrebin commented on a change in pull
WheresAlice opened a new pull request #6629: [hotfix] [docs] Fix typo in batch
connectors
URL: https://github.com/apache/flink/pull/6629
Small fix for a typo in the docs.
This is an automated message from the Apache Git Servi
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596312#comment-16596312
]
ASF GitHub Bot commented on FLINK-9043:
---
GodfreyJohnson opened a new pull request #
GodfreyJohnson opened a new pull request #6630: [FLINK-9043] restore from the
latest job's completed checkpoint with …
URL: https://github.com/apache/flink/pull/6630
- For
[FLINK-9043](https://issues.apache.org/jira/browse/FLINK-9043?filter=-6&jql=project%20%3D%20FLINK%20AND%20created%20
azagrebin commented on issue #5996: [FLINK-9343] [Example] Add Async Example
with External Rest API call
URL: https://github.com/apache/flink/pull/5996#issuecomment-416948982
Hi @medcv, do you have some ETA for the PR changes?
---
[
https://issues.apache.org/jira/browse/FLINK-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596314#comment-16596314
]
ASF GitHub Bot commented on FLINK-9343:
---
azagrebin commented on issue #5996: [FLINK
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596318#comment-16596318
]
godfrey johnson commented on FLINK-9043:
[https://github.com/GodfreyJohnson/flink
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596318#comment-16596318
]
godfrey johnson edited comment on FLINK-9043 at 8/29/18 1:28 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596318#comment-16596318
]
godfrey johnson edited comment on FLINK-9043 at 8/29/18 1:29 PM:
--
dawidwys commented on a change in pull request #6611: [FLINK-3875] [connectors]
Add an upsert table sink factory for Elasticsearch
URL: https://github.com/apache/flink/pull/6611#discussion_r213665920
##
File path: docs/dev/table/connect.md
##
@@ -583,6 +584,104 @@ Make sur
dawidwys commented on a change in pull request #6611: [FLINK-3875] [connectors]
Add an upsert table sink factory for Elasticsearch
URL: https://github.com/apache/flink/pull/6611#discussion_r213597931
##
File path:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/or
dawidwys commented on a change in pull request #6611: [FLINK-3875] [connectors]
Add an upsert table sink factory for Elasticsearch
URL: https://github.com/apache/flink/pull/6611#discussion_r213664413
##
File path:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/or
[
https://issues.apache.org/jira/browse/FLINK-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596330#comment-16596330
]
ASF GitHub Bot commented on FLINK-3875:
---
dawidwys commented on a change in pull req
1 - 100 of 208 matches
Mail list logo