zuston opened a new pull request #15185:
URL: https://github.com/apache/flink/pull/15185
Change-Id: Ia28bb5b7d389b3faedb11af15576a458a74d4e76
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather
zuston closed pull request #15185:
URL: https://github.com/apache/flink/pull/15185
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please
[
https://issues.apache.org/jira/browse/FLINK-21902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305898#comment-17305898
]
Yang Wang commented on FLINK-21902:
---
Thanks for creating this ticket. This is a valid concern and we
zuston commented on a change in pull request #15131:
URL: https://github.com/apache/flink/pull/15131#discussion_r598441079
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java
##
@@ -344,6 +344,13 @@
Jark Wu created FLINK-21909:
---
Summary: Unify API and implementation for Hive and Filesystem
source connector
Key: FLINK-21909
URL: https://issues.apache.org/jira/browse/FLINK-21909
Project: Flink
Jark Wu created FLINK-21908:
---
Summary: Support HiveSource to emit watermarks which is extract
from partition values
Key: FLINK-21908
URL: https://issues.apache.org/jira/browse/FLINK-21908
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-21833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-21833:
Description:
In our company cases, short-life-cycle & huge RowData will use this operator to
[
https://issues.apache.org/jira/browse/FLINK-21833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-21833:
Description:
In our company cases, short-life-cycle & huge RowData will use this operator to
[
https://issues.apache.org/jira/browse/FLINK-21833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-21833:
Description:
In our company cases, short-life-cycle & huge RowData will use this operator to
[
https://issues.apache.org/jira/browse/FLINK-21833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lynn1.zhang updated FLINK-21833:
Description:
In our company cases, short-life-cycle & huge RowData will use this operator to
flinkbot edited a comment on pull request #15308:
URL: https://github.com/apache/flink/pull/15308#issuecomment-803613092
## CI report:
* dd2fb661528502545e6ce121fad7dbb176c795df Azure:
[
https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305891#comment-17305891
]
Guowei Ma commented on FLINK-20816:
---
flinkbot edited a comment on pull request #15308:
URL: https://github.com/apache/flink/pull/15308#issuecomment-803613092
## CI report:
* dd2fb661528502545e6ce121fad7dbb176c795df Azure:
flinkbot edited a comment on pull request #15247:
URL: https://github.com/apache/flink/pull/15247#issuecomment-800773807
## CI report:
* 26b7237eea7690de13b6b8d6a655b27964987a2b Azure:
[
https://issues.apache.org/jira/browse/FLINK-21879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305890#comment-17305890
]
Guowei Ma commented on FLINK-21879:
---
[
https://issues.apache.org/jira/browse/FLINK-21539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305888#comment-17305888
]
Guowei Ma commented on FLINK-21539:
---
Jark Wu created FLINK-21907:
---
Summary: Support watermark syntax for Hive DDL dialect
Key: FLINK-21907
URL: https://issues.apache.org/jira/browse/FLINK-21907
Project: Flink
Issue Type: Sub-task
Jark Wu created FLINK-21906:
---
Summary: Support computed column syntax for Hive DDL dialect
Key: FLINK-21906
URL: https://issues.apache.org/jira/browse/FLINK-21906
Project: Flink
Issue Type:
Jark Wu created FLINK-21905:
---
Summary: Hive streaming source should use FIFO FileSplitAssigner
instead of LIFO
Key: FLINK-21905
URL: https://issues.apache.org/jira/browse/FLINK-21905
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-15528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-15528:
Parent: FLINK-21871
Issue Type: Sub-task (was: New Feature)
> Support higher precision of
wuchong commented on pull request #15308:
URL: https://github.com/apache/flink/pull/15308#issuecomment-803754304
Good point @lirui-apache , hope I have addressed your concern.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
flinkbot edited a comment on pull request #15247:
URL: https://github.com/apache/flink/pull/15247#issuecomment-800773807
## CI report:
* 26b7237eea7690de13b6b8d6a655b27964987a2b Azure:
[
https://issues.apache.org/jira/browse/FLINK-21814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-21814.
---
Fix Version/s: (was: 1.12.3)
1.13.0
Assignee: Peihui He
Resolution:
[
https://issues.apache.org/jira/browse/FLINK-21814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-21814:
Summary: Add host and port information in exception when CollectSink can't
connect to the client (was:
wuchong merged pull request #15297:
URL: https://github.com/apache/flink/pull/15297
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service,
[
https://issues.apache.org/jira/browse/FLINK-21903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-21903:
---
Assignee: zhaoxing
> Translate "Importing Flink into an IDE" page into Chinese
>
wuchong commented on pull request #15306:
URL: https://github.com/apache/flink/pull/15306#issuecomment-803751007
> > Is there any reason why we not use the `BuiltInScalarFunction` to
implement this new function? From my point of view, it would be much simpler if
we use
[
https://issues.apache.org/jira/browse/FLINK-20547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305878#comment-17305878
]
Yingjie Cao commented on FLINK-20547:
-
[~pnowojski] After reading the code, I think I have find the
zicat commented on a change in pull request #15247:
URL: https://github.com/apache/flink/pull/15247#discussion_r598414694
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/temporal/TemporalRowTimeJoinOperator.java
leonardBang commented on a change in pull request #15247:
URL: https://github.com/apache/flink/pull/15247#discussion_r598411887
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/temporal/TemporalRowTimeJoinOperator.java
[
https://issues.apache.org/jira/browse/FLINK-21904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21904:
---
Labels: pull-request-available (was: )
> parseJmJvmArgsAndExportLogs: command not found
tzulitai opened a new pull request #217:
URL: https://github.com/apache/flink-statefun/pull/217
I discovered a mismatch in our modified `standalone-job.sh` script with the
Flink 1.12.x latest changes, by noticing this line in the StateFun image
startup logs:
```
11:37:12,572 ERROR
Tzu-Li (Gordon) Tai created FLINK-21904:
---
Summary: parseJmJvmArgsAndExportLogs: command not found warning
when starting StateFun
Key: FLINK-21904
URL: https://issues.apache.org/jira/browse/FLINK-21904
flinkbot edited a comment on pull request #15298:
URL: https://github.com/apache/flink/pull/15298#issuecomment-803288503
## CI report:
* 681e314e56a4778b586ae6ceae95d5c6620b3a07 Azure:
flinkbot edited a comment on pull request #15309:
URL: https://github.com/apache/flink/pull/15309#issuecomment-803716585
## CI report:
* ce54e396f5dbdbcee6f8d899b533d5c730f79e46 Azure:
[
https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305874#comment-17305874
]
Xintong Song commented on FLINK-15911:
--
bq. 1、all 0 has some security risks.
Could you explain in
[
https://issues.apache.org/jira/browse/FLINK-21903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305871#comment-17305871
]
zhaoxing commented on FLINK-21903:
--
cc [~jark]
I am willing to do it. Can you assign it to me? thank
zhaoxing created FLINK-21903:
Summary: Translate "Importing Flink into an IDE" page into Chinese
Key: FLINK-21903
URL: https://issues.apache.org/jira/browse/FLINK-21903
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-21901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21901:
---
Labels: pull-request-available (was: )
> Update StateFun version to 3.0-SNAPSHOT
>
tzulitai opened a new pull request #216:
URL: https://github.com/apache/flink-statefun/pull/216
Prepares the main branch version for the 3.0.0 release.
It is currently still on `2.3-SNAPSHOT` since we decided to bump directly to
3.0.0 during development.
--
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-21902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305870#comment-17305870
]
Yi Tang edited comment on FLINK-21902 at 3/22/21, 3:32 AM:
---
cc [~fly_in_gis]
[
https://issues.apache.org/jira/browse/FLINK-21902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305870#comment-17305870
]
Yi Tang commented on FLINK-21902:
-
cc [~wangyang]
> A deadlock while using K8s HA service
>
Yi Tang created FLINK-21902:
---
Summary: A deadlock while using K8s HA service
Key: FLINK-21902
URL: https://issues.apache.org/jira/browse/FLINK-21902
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305869#comment-17305869
]
Bo Cui commented on FLINK-15911:
1、all 0 has some security risks.
2、i think add new config, like
[
https://issues.apache.org/jira/browse/FLINK-21539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-21539:
--
Affects Version/s: 1.13.0
> 'SQL Client end-to-end test (Blink planner) Elasticsearch (v6.3.1)' fails
[
https://issues.apache.org/jira/browse/FLINK-21539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305868#comment-17305868
]
Guowei Ma commented on FLINK-21539:
---
flinkbot edited a comment on pull request #15298:
URL: https://github.com/apache/flink/pull/15298#issuecomment-803288503
## CI report:
* 681e314e56a4778b586ae6ceae95d5c6620b3a07 Azure:
Tzu-Li (Gordon) Tai created FLINK-21901:
---
Summary: Update StateFun version to 3.0-SNAPSHOT
Key: FLINK-21901
URL: https://issues.apache.org/jira/browse/FLINK-21901
Project: Flink
Issue
leonardBang edited a comment on pull request #15306:
URL: https://github.com/apache/flink/pull/15306#issuecomment-803735758
> Is there any reason why we not use the `BuiltInScalarFunction` to
implement this new function? From my point of view, it would be much simpler if
we use
leonardBang commented on pull request #15306:
URL: https://github.com/apache/flink/pull/15306#issuecomment-803735758
> Is there any reason why we not use the `BuiltInScalarFunction` to
implement this new function? From my point of view, it would be much simpler if
we use
lirui-apache commented on a change in pull request #15308:
URL: https://github.com/apache/flink/pull/15308#discussion_r598402216
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/JobConfWrapper.java
##
@@ -45,6 +46,12 @@ public
[
https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305867#comment-17305867
]
Guowei Ma commented on FLINK-18634:
---
[
https://issues.apache.org/jira/browse/FLINK-21898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305866#comment-17305866
]
Guowei Ma commented on FLINK-21898:
---
[
https://issues.apache.org/jira/browse/FLINK-21745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305865#comment-17305865
]
Guowei Ma commented on FLINK-21745:
---
[
https://issues.apache.org/jira/browse/FLINK-21745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305830#comment-17305830
]
Guowei Ma edited comment on FLINK-21745 at 3/22/21, 3:22 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-21895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305864#comment-17305864
]
Guowei Ma commented on FLINK-21895:
---
[
https://issues.apache.org/jira/browse/FLINK-21896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305863#comment-17305863
]
Guowei Ma commented on FLINK-21896:
---
[
https://issues.apache.org/jira/browse/FLINK-21416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305860#comment-17305860
]
Guowei Ma commented on FLINK-21416:
---
[
https://issues.apache.org/jira/browse/FLINK-21701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305861#comment-17305861
]
xiangtao commented on FLINK-21701:
--
[~fsk119] ， Thanks for your advice. i will add more test case and
Guowei Ma created FLINK-21900:
-
Summary: flink-statebackend-rocksdb test core dump
Key: FLINK-21900
URL: https://issues.apache.org/jira/browse/FLINK-21900
Project: Flink
Issue Type: Bug
wuchong commented on pull request #15306:
URL: https://github.com/apache/flink/pull/15306#issuecomment-803731420
Is there any reason why we not use the `BuiltInScalarFunction` to implement
this new function? From my point of view, it would be much simpler if we use
`BuiltInScalarFunction`
[
https://issues.apache.org/jira/browse/FLINK-21882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-21882.
---
Fix Version/s: statefun-3.0.0
Resolution: Fixed
[
https://issues.apache.org/jira/browse/FLINK-21865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-21865.
---
Resolution: Fixed
flink-statefun-playground/dev:
[
https://issues.apache.org/jira/browse/FLINK-21899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-21899:
---
Assignee: Jark Wu
> Introduce SOURCE_WATERMARK built-infunction to preserve watermark from source
Jark Wu created FLINK-21899:
---
Summary: Introduce SOURCE_WATERMARK built-infunction to preserve
watermark from source
Key: FLINK-21899
URL: https://issues.apache.org/jira/browse/FLINK-21899
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-21701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305848#comment-17305848
]
Shengkai Fang commented on FLINK-21701:
---
[~xiangtao] I have replied in the link. But it's better
asfgit closed pull request #5:
URL: https://github.com/apache/flink-statefun-playground/pull/5
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this
tzulitai commented on pull request #5:
URL:
https://github.com/apache/flink-statefun-playground/pull/5#issuecomment-803727643
Thanks @igalshilman for adding a greeter example for Python!
LGTM, I've built this locally, ran it once and it worked like a charm.
--
This is an
[
https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305843#comment-17305843
]
Guowei Ma commented on FLINK-20254:
---
[
https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305842#comment-17305842
]
Guowei Ma commented on FLINK-20495:
---
[
https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305841#comment-17305841
]
Xintong Song commented on FLINK-15911:
--
Hi [~Bo Cui],
Could you explain why listening on 0.0.0.0
asfgit closed pull request #4:
URL: https://github.com/apache/flink-statefun-playground/pull/4
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this
[
https://issues.apache.org/jira/browse/FLINK-21032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305840#comment-17305840
]
Guowei Ma commented on FLINK-21032:
---
Guowei Ma created FLINK-21898:
-
Summary: JobRetrievalITCase crash
Key: FLINK-21898
URL: https://issues.apache.org/jira/browse/FLINK-21898
Project: Flink
Issue Type: Bug
Components:
leonardBang commented on a change in pull request #15235:
URL: https://github.com/apache/flink/pull/15235#discussion_r598385738
##
File path: docs/content.zh/docs/connectors/table/elasticsearch.md
##
@@ -59,212 +59,208 @@ CREATE TABLE myUserTable (
);
```
-Connector
[
https://issues.apache.org/jira/browse/FLINK-20723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305834#comment-17305834
]
Guowei Ma commented on FLINK-20723:
---
CassandraConnectorITCase.createTable also fail because of
Guowei Ma created FLINK-21897:
-
Summary: CalcITCase.testPrimitiveMapType[StateBackend=HEAP] fail
because of "Not enough resources available for scheduling"
Key: FLINK-21897
URL:
zicat commented on a change in pull request #15247:
URL: https://github.com/apache/flink/pull/15247#discussion_r598391299
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/temporal/TemporalRowTimeJoinOperator.java
flinkbot edited a comment on pull request #15309:
URL: https://github.com/apache/flink/pull/15309#issuecomment-803716585
## CI report:
* ce54e396f5dbdbcee6f8d899b533d5c730f79e46 Azure:
[
https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305826#comment-17305826
]
Bo Cui edited comment on FLINK-15911 at 3/22/21, 2:33 AM:
--
[~xintongsong] in
[
https://issues.apache.org/jira/browse/FLINK-21871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305831#comment-17305831
]
Jark Wu commented on FLINK-21871:
-
Thanks all for the positive feedbacks. I will create sub-tasks and
[
https://issues.apache.org/jira/browse/FLINK-21745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305830#comment-17305830
]
Guowei Ma commented on FLINK-21745:
---
[
https://issues.apache.org/jira/browse/FLINK-21871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305828#comment-17305828
]
Jingsong Lee commented on FLINK-21871:
--
Looks good to me. +1.
> Support watermark for Hive and
SteNicholas commented on pull request #15282:
URL: https://github.com/apache/flink/pull/15282#issuecomment-803719407
@fsk119 , thanks for your detailed review. The question you mentioned above
has already been discussed by @wuchong . I would like to unify the parser
behavior of
xintongsong commented on pull request #14538:
URL: https://github.com/apache/flink/pull/14538#issuecomment-803719317
Thanks for updating the PR, @yuruguo. I'll try to take a look.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
fsk119 commented on pull request #15282:
URL: https://github.com/apache/flink/pull/15282#issuecomment-803718841
Thanks for your contribution @SteNicholas.
I have some thoughts about this PR. Because our goal is to submit statement
set in the sql client. However, the `Executor` is
Guowei Ma created FLINK-21896:
-
Summary: GroupAggregateJsonPlanTest.testDistinctAggCalls fail
Key: FLINK-21896
URL: https://issues.apache.org/jira/browse/FLINK-21896
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305826#comment-17305826
]
Bo Cui commented on FLINK-15911:
[~xintongsong] in yarn cluster, what are bind-address of JM？ It is not
[
https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305826#comment-17305826
]
Bo Cui edited comment on FLINK-15911 at 3/22/21, 2:17 AM:
--
[~xintongsong] in
Guowei Ma created FLINK-21895:
-
Summary: IncrementalAggregateJsonPlanTest.testIncrementalAggregate
fail
Key: FLINK-21895
URL: https://issues.apache.org/jira/browse/FLINK-21895
Project: Flink
flinkbot commented on pull request #15309:
URL: https://github.com/apache/flink/pull/15309#issuecomment-803716585
## CI report:
* ce54e396f5dbdbcee6f8d899b533d5c730f79e46 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #15309:
URL: https://github.com/apache/flink/pull/15309#issuecomment-803714939
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-21890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-21890.
--
Resolution: Fixed
Fixe in 1.13.0: b644af8476bd7992eaef6392f1ed55d2172ef95f
> Rename DAGProcessor to
[
https://issues.apache.org/jira/browse/FLINK-21890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-21890:
--
Assignee: godfrey he
> Rename DAGProcessor to ExecNodeGraphProcessor
>
godfreyhe merged pull request #15305:
URL: https://github.com/apache/flink/pull/15305
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service,
leonardBang commented on a change in pull request #15247:
URL: https://github.com/apache/flink/pull/15247#discussion_r598382812
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/temporal/TemporalRowTimeJoinOperator.java
xintongsong commented on a change in pull request #15279:
URL: https://github.com/apache/flink/pull/15279#discussion_r598382161
##
File path:
flink-core/src/test/java/org/apache/flink/testutils/ThrowOnDoubleMemoryFreeing.java
##
@@ -19,32 +19,28 @@
package
[
https://issues.apache.org/jira/browse/FLINK-21696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21696:
---
Labels: pull-request-available (was: )
> scala code in "Writing WatermarkGenerators"
Giackgamba opened a new pull request #15309:
URL: https://github.com/apache/flink/pull/15309
## What is the purpose of the change
This pull request completes the changes in docs started by
https://github.com/apache/flink/pull/15142 by adding the `output` parameter to
the `onEvent`
[
https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305805#comment-17305805
]
Guowei Ma commented on FLINK-20816:
---
1 - 100 of 205 matches
Mail list logo
