[
https://issues.apache.org/jira/browse/FLINK-5931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791378#comment-16791378
]
vinoyang commented on FLINK-5931:
-
[~wheat9] Are you still working on this issue? What's
[
https://issues.apache.org/jira/browse/FLINK-11895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791377#comment-16791377
]
vinoyang commented on FLINK-11895:
--
[~lukaj] I think it is duplicated by FLINK-5931.
>
JingsongLi commented on a change in pull request #7961:
[FLINK-11882][table-runtime-blink] Introduce BytesHashMap to batch hash agg
URL: https://github.com/apache/flink/pull/7961#discussion_r264992207
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flin
[
https://issues.apache.org/jira/browse/FLINK-11896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11896:
---
Labels: pull-request-available (was: )
> Introduce stream physical nodes
>
flinkbot commented on issue #7969: [FLINK-11896] [table-planner-blink]
Introduce stream physical nodes
URL: https://github.com/apache/flink/pull/7969#issuecomment-472291067
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
godfreyhe opened a new pull request #7969: [FLINK-11896] [table-planner-blink]
Introduce stream physical nodes
URL: https://github.com/apache/flink/pull/7969
## What is the purpose of the change
*Introduce stream physical RelNode*
## Brief change log
- *adds all strea
godfrey he created FLINK-11896:
--
Summary: Introduce stream physical nodes
Key: FLINK-11896
URL: https://issues.apache.org/jira/browse/FLINK-11896
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-11896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-11896:
---
Description: This issues aims to introduce flink stream physical RelNode,
such as ``StreamExecCalc``
KurtYoung commented on a change in pull request #7961:
[FLINK-11882][table-runtime-blink] Introduce BytesHashMap to batch hash agg
URL: https://github.com/apache/flink/pull/7961#discussion_r264982223
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink
[
https://issues.apache.org/jira/browse/FLINK-11896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-11896:
---
Description: This issues aims to introduce flink stream physical RelNode,
such as {{StreamExecCalc}}
[
https://issues.apache.org/jira/browse/FLINK-11896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-11896:
---
Description: This issues aims to introduce flink stream physical RelNode,
such as {{StreamExecCalc}}
[
https://issues.apache.org/jira/browse/FLINK-11888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791288#comment-16791288
]
Yu Li commented on FLINK-11888:
---
[~sunjincheng121] has located the root cause of the port
KurtYoung commented on a change in pull request #7958:
[FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink
table
URL: https://github.com/apache/flink/pull/7958#discussion_r264971905
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/a
KurtYoung commented on a change in pull request #7958:
[FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink
table
URL: https://github.com/apache/flink/pull/7958#discussion_r264971696
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/a
KurtYoung commented on a change in pull request #7958:
[FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink
table
URL: https://github.com/apache/flink/pull/7958#discussion_r264971399
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/a
KurtYoung commented on a change in pull request #7958:
[FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink
table
URL: https://github.com/apache/flink/pull/7958#discussion_r264971007
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/a
KurtYoung commented on a change in pull request #7958:
[FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink
table
URL: https://github.com/apache/flink/pull/7958#discussion_r264970786
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/a
link3280 commented on a change in pull request #7895:
[FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials
URL: https://github.com/apache/flink/pull/7895#discussion_r264971776
##
File path: flink-yarn/src/test/java/org/apache/flink/yarn/UtilsTest.java
###
[
https://issues.apache.org/jira/browse/FLINK-11892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791286#comment-16791286
]
sunjincheng commented on FLINK-11892:
-
Hi Thanks for your nice check [~carp84] !
Of
[
https://issues.apache.org/jira/browse/FLINK-11892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-11892:
---
Assignee: Yu Li
> Port conflict problem when do the end-to-end nightly-tests.
> ---
[
https://issues.apache.org/jira/browse/FLINK-11894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791273#comment-16791273
]
Kurt Young commented on FLINK-11894:
maybe we should move this issue under
[FLINK-1
Luka Jurukovski created FLINK-11895:
---
Summary: Allow FileSystem Configs to be altered at Runtime
Key: FLINK-11895
URL: https://issues.apache.org/jira/browse/FLINK-11895
Project: Flink
Issue
Jingsong Lee created FLINK-11894:
Summary: AbstractRowSerializer.serializeToPages return type should
be void
Key: FLINK-11894
URL: https://issues.apache.org/jira/browse/FLINK-11894
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791268#comment-16791268
]
Yu Li commented on FLINK-11892:
---
+1, nice analysis on the root cause!
I encountered the s
[
https://issues.apache.org/jira/browse/FLINK-11893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin reassigned FLINK-11893:
Assignee: Jiangjie Qin
> Update ecosystem page and add it to the navigation bar
> ---
[
https://issues.apache.org/jira/browse/FLINK-11893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11893:
---
Labels: pull-request-available (was: )
> Update ecosystem page and add it to the navigation
Jiangjie Qin created FLINK-11893:
Summary: Update ecosystem page and add it to the navigation bar
Key: FLINK-11893
URL: https://issues.apache.org/jira/browse/FLINK-11893
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-11892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11892:
Description:
When I do the end-to-end check according to
`[https://github.com/apache/flink/tree/m
[
https://issues.apache.org/jira/browse/FLINK-11892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791183#comment-16791183
]
sunjincheng commented on FLINK-11892:
-
Just now I try to use `flink-end-to-end-tests
[
https://issues.apache.org/jira/browse/FLINK-6131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791175#comment-16791175
]
Ashish Pokharel commented on FLINK-6131:
All, looping back again on this. This fe
klion26 commented on issue #7965: make JDBCOutputFormat ClassCastException more
helpful
URL: https://github.com/apache/flink/pull/7965#issuecomment-472238898
@FaxianZhao could you please edit the title of this PR to match our
guidelines (included in the PR template)
--
sunjincheng created FLINK-11892:
---
Summary: Port conflict problem when do the end-to-end
nightly-tests.
Key: FLINK-11892
URL: https://issues.apache.org/jira/browse/FLINK-11892
Project: Flink
Is
sunjincheng created FLINK-11891:
---
Summary: Fix some script or test case bug in 1.8 RC
Key: FLINK-11891
URL: https://issues.apache.org/jira/browse/FLINK-11891
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-11449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-11449.
Resolution: Fixed
Fix Version/s: 1.9.0
Fixed in 1.9.0:
Introduce a new expression stack an
asfgit closed pull request #7664: [FLINK-11449][table] Uncouple the Expression
class from RexNodes.
URL: https://github.com/apache/flink/pull/7664
This is an automated message from the Apache Git Service.
To respond to the m
asfgit merged pull request #7967: [FLINK-11449][table] Uncouple the Expression
class from RexNodes
URL: https://github.com/apache/flink/pull/7967
This is an automated message from the Apache Git Service.
To respond to the me
twalthr commented on issue #7967: [FLINK-11449][table] Uncouple the Expression
class from RexNodes
URL: https://github.com/apache/flink/pull/7967#issuecomment-472180884
Thank you @dawidwys for the review and @sunjincheng121 for the preparatory
work. Merging this now.
-
Xeli commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added
PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r264828377
##
File path:
flink-connectors/flink-connector-gcp-pubsub/src/mai
Xeli commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added
PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r264827593
##
File path:
flink-connectors/flink-connector-gcp-pubsub/src/mai
Xeli commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added
PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r264810803
##
File path:
flink-connectors/flink-connector-gcp-pubsub/src/mai
[
https://issues.apache.org/jira/browse/FLINK-11692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11692:
---
Labels: pull-request-available (was: )
> Add Proxy for DataDog Metric Reporter
> --
flinkbot commented on issue #7968: [FLINK-11692] [Datadog Reporter] added proxy
to datadog reporter
URL: https://github.com/apache/flink/pull/7968#issuecomment-472096718
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review you
scott-mitchell opened a new pull request #7968: [FLINK-11692] [Datadog
Reporter] added proxy to datadog reporter
URL: https://github.com/apache/flink/pull/7968
## What is the purpose of the change
This pull request adds a configurable proxy to the Datadog metric reporter.
[
https://issues.apache.org/jira/browse/FLINK-11865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16790700#comment-16790700
]
Aljoscha Krettek commented on FLINK-11865:
--
Fixed on release-1.8 in
ce7aea06785
aljoscha commented on issue #7957: [FLINK-11865] Improve code generation speed
in TraversableSerializer
URL: https://github.com/apache/flink/pull/7957#issuecomment-472069699
Merged
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-11865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-11865.
Resolution: Fixed
> Code generation in TraversableSerializer is prohibitively slow
> -
aljoscha closed pull request #7957: [FLINK-11865] Improve code generation speed
in TraversableSerializer
URL: https://github.com/apache/flink/pull/7957
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-11539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16790701#comment-16790701
]
Aljoscha Krettek commented on FLINK-11539:
--
[~jkreileder] The fix for this (FLI
dawidwys commented on a change in pull request #7967: [FLINK-11449][table]
Uncouple the Expression class from RexNodes
URL: https://github.com/apache/flink/pull/7967#discussion_r264723067
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/scala/
dawidwys commented on a change in pull request #7967: [FLINK-11449][table]
Uncouple the Expression class from RexNodes
URL: https://github.com/apache/flink/pull/7967#discussion_r264711540
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/scala/
dawidwys commented on a change in pull request #7967: [FLINK-11449][table]
Uncouple the Expression class from RexNodes
URL: https://github.com/apache/flink/pull/7967#discussion_r264742116
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/validate/F
dawidwys commented on a change in pull request #7967: [FLINK-11449][table]
Uncouple the Expression class from RexNodes
URL: https://github.com/apache/flink/pull/7967#discussion_r264742946
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expression
dawidwys commented on a change in pull request #7967: [FLINK-11449][table]
Uncouple the Expression class from RexNodes
URL: https://github.com/apache/flink/pull/7967#discussion_r264703419
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/scala/
dawidwys commented on a change in pull request #7967: [FLINK-11449][table]
Uncouple the Expression class from RexNodes
URL: https://github.com/apache/flink/pull/7967#discussion_r264751565
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expression
dawidwys commented on a change in pull request #7967: [FLINK-11449][table]
Uncouple the Expression class from RexNodes
URL: https://github.com/apache/flink/pull/7967#discussion_r264703739
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/scala/
dawidwys commented on a change in pull request #7967: [FLINK-11449][table]
Uncouple the Expression class from RexNodes
URL: https://github.com/apache/flink/pull/7967#discussion_r264710350
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/scala/
Timo Walther created FLINK-11890:
Summary: Replace Table API string-based expressions by a Java DSL
Key: FLINK-11890
URL: https://issues.apache.org/jira/browse/FLINK-11890
Project: Flink
Issu
zhijiangW commented on issue #7963: [FLINK-11885][network] Introduce
RecordWriterBuilder for creating RecordWriter instance
URL: https://github.com/apache/flink/pull/7963#issuecomment-472059561
@pnowojski , I have updated the codes for only fixing `StreamTask` class
compared with first ver
[
https://issues.apache.org/jira/browse/FLINK-2316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-2316.
---
Resolution: Won't Fix
The static code analysis was never really used. This issue is not relevant
any
[
https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16790614#comment-16790614
]
Timo Walther commented on FLINK-11068:
--
Hi [~hequn8128], sorry for not answering ea
[
https://issues.apache.org/jira/browse/FLINK-11865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16790604#comment-16790604
]
Aljoscha Krettek commented on FLINK-11865:
--
Fixed on master in
f0cdd9d2ae09061c
zhijiangW commented on issue #7963: [FLINK-11885][network] Introduce
RecordWriterBuilder for creating RecordWriter instance
URL: https://github.com/apache/flink/pull/7963#issuecomment-472020549
Thanks for the review @pnowojski .
I forgot fixing one point resulting in travis failure.
flinkbot commented on issue #7967: [FLINK-11449][table] Uncouple the Expression
class from RexNodes
URL: https://github.com/apache/flink/pull/7967#issuecomment-472017793
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review you
twalthr opened a new pull request #7967: [FLINK-11449][table] Uncouple the
Expression class from RexNodes
URL: https://github.com/apache/flink/pull/7967
## What is the purpose of the change
This PR aims to improves the contribution of #7664. It further minimizes the
amount of change
[
https://issues.apache.org/jira/browse/FLINK-11887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11887:
---
Labels: pull-request-available (was: )
> Operator's Latency Metrics continues to increase
>
zhijiangW commented on issue #7730: [FLINK-11646][test] Remove legacy
MockRecordWriter
URL: https://github.com/apache/flink/pull/7730#issuecomment-472012093
Thanks for review and merging @pnowojski .
I would add that in the commit next time. :)
--
[
https://issues.apache.org/jira/browse/FLINK-11888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16790567#comment-16790567
]
Yu Li commented on FLINK-11888:
---
[~Zentol] Please let me know if you have any comments her
flinkbot commented on issue #7966: [FLINK-11887][metrics] Fixed latency metrics
drift apart
URL: https://github.com/apache/flink/pull/7966#issuecomment-472009888
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull r
SuXingLee opened a new pull request #7966: [FLINK-11887][metrics] Fixed latency
metrics drift apart
URL: https://github.com/apache/flink/pull/7966
## What is the purpose of the change
Use ```System.currentTimeMillis``` to replace ```System.nanoTime``` in
```LatencyMarker```,
in o
[
https://issues.apache.org/jira/browse/FLINK-11889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-11889:
-
Description:
During the [ML
discussion|https://lists.apache.org/thread.html/b8d2f3209e7
Aljoscha Krettek created FLINK-11889:
Summary: Remove "stop" signal along with Stoppable interfaces
Key: FLINK-11889
URL: https://issues.apache.org/jira/browse/FLINK-11889
Project: Flink
Yu Li created FLINK-11888:
-
Summary: Refine document of how to run end-to-end tests
Key: FLINK-11888
URL: https://issues.apache.org/jira/browse/FLINK-11888
Project: Flink
Issue Type: Improvement
Suxing Lee created FLINK-11887:
--
Summary: Operator's Latency Metrics continues to increase
Key: FLINK-11887
URL: https://issues.apache.org/jira/browse/FLINK-11887
Project: Flink
Issue Type: Bug
tweise commented on issue #7896: [FLINK-9007] [kinesis] [e2e] Add Kinesis
end-to-end test
URL: https://github.com/apache/flink/pull/7896#issuecomment-471992102
@StefanRRichter could you approve the PR or let me know if anything else
should be done here?
---
leesf commented on issue #7940: [hotfix][docs] fix error in functions example
URL: https://github.com/apache/flink/pull/7940#issuecomment-471980702
cc @twalthr @zentol
This is an automated message from the Apache Git Service
GJL commented on issue #7922: [FLINK-10756][runtime][tests] Wait for TM
processes to shutdown
URL: https://github.com/apache/flink/pull/7922#issuecomment-471974410
@flinkbot approve all
This is an automated message from the A
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r264635101
##
File path:
flink-connectors/flink-connector-gcp-pubsub/sr
GJL commented on issue #7922: [FLINK-10756][runtime][tests] Wait for TM
processes to shutdown
URL: https://github.com/apache/flink/pull/7922#issuecomment-471968212
@flinkbot approve description
This is an automated message fr
flinkbot commented on issue #7965: make JDBCOutputFormat ClassCastException
more helpful
URL: https://github.com/apache/flink/pull/7965#issuecomment-471968284
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull requ
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r264638629
##
File path:
flink-connectors/flink-connector-gcp-pubsub/sr
FaxianZhao opened a new pull request #7965: make JDBCOutputFormat
ClassCastException more helpful
URL: https://github.com/apache/flink/pull/7965
## What is the purpose of the change
This PR makes JDBCOutputFormat's ClassCastException more readable. Current
exception make me confused whi
pnowojski commented on a change in pull request #7911: [FLINK-11082][network]
Fix the logic of getting backlog in sub partition
URL: https://github.com/apache/flink/pull/7911#discussion_r264636431
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partiti
pnowojski commented on a change in pull request #7911: [FLINK-11082][network]
Fix the logic of getting backlog in sub partition
URL: https://github.com/apache/flink/pull/7911#discussion_r264637060
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partiti
pnowojski commented on a change in pull request #7713: [FLINK-10995][network]
Copy intermediate serialization results only once for broadcast mode
URL: https://github.com/apache/flink/pull/7713#discussion_r264634735
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime
[
https://issues.apache.org/jira/browse/FLINK-11646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-11646.
--
Resolution: Fixed
Fix Version/s: 1.9.0
merged commit 6f66e23 into apache:master
> Remo
pnowojski merged pull request #7730: [FLINK-11646][test] Remove legacy
MockRecordWriter
URL: https://github.com/apache/flink/pull/7730
This is an automated message from the Apache Git Service.
To respond to the message, plea
pnowojski commented on a change in pull request #7963: [FLINK-11885][network]
Introduce RecordWriterBuilder for creating RecordWriter instance
URL: https://github.com/apache/flink/pull/7963#discussion_r264631813
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r264624917
##
File path:
flink-connectors/flink-connector-gcp-pubsub/sr
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r264622246
##
File path:
flink-connectors/flink-connector-gcp-pubsub/sr
becketqin commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source
connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-471952495
> Hello @rmetzger
>
> Let me address them point by point:
>
>
> I rea
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r264614405
##
File path:
flink-connectors/flink-connector-gcp-pubsub/sr
flinkbot commented on issue #7964: [FLINK-11886] [doc] update the output of
start/stop_cluster.sh in job…
URL: https://github.com/apache/flink/pull/7964#issuecomment-471946845
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to revi
[
https://issues.apache.org/jira/browse/FLINK-11886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11886:
---
Labels: pull-request-available (was: )
> update the output of cluster management script in
chummyhe89 opened a new pull request #7964: [FLINK-11886] [doc] update the
output of start/stop_cluster.sh in job…
URL: https://github.com/apache/flink/pull/7964
## What is the purpose of the change
Update the output of the cluster management script in
jobmanager_hig
[
https://issues.apache.org/jira/browse/FLINK-11856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-11856.
--
Resolution: Implemented
Fix Version/s: 1.9.0
fixed in 5968206f843a58e10e3db58cde3407bb3608d085
[
https://issues.apache.org/jira/browse/FLINK-11885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11885:
---
Labels: pull-request-available (was: )
> Introduce RecordWriterBuilder for creating RecordW
KurtYoung merged pull request #7949: [FLINK-11856][table-runtime-blink]
Introduce BinaryHashTable to batch table runtime
URL: https://github.com/apache/flink/pull/7949
This is an automated message from the Apache Git Service
[
https://issues.apache.org/jira/browse/FLINK-11886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chunpinghe updated FLINK-11886:
---
Attachment: ha_doc_updated.png
> update the output of cluster management script in
> jobmanager_hig
[
https://issues.apache.org/jira/browse/FLINK-11886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chunpinghe updated FLINK-11886:
---
Attachment: ha_doc.png
> update the output of cluster management script in
> jobmanager_high_availa
[
https://issues.apache.org/jira/browse/FLINK-11886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chunpinghe updated FLINK-11886:
---
Attachment: (was: jira_cluster.sh.png)
> update the output of cluster management script in
> jo
1 - 100 of 134 matches
Mail list logo
