tzulitai closed pull request #76: [FLINK-16785] Add README.md for the Python SDK
URL: https://github.com/apache/flink-statefun/pull/76
This is an automated message from the Apache Git Service.
To respond to the message, pleas
[
https://issues.apache.org/jira/browse/FLINK-16317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067409#comment-17067409
]
Piotr Nowojski commented on FLINK-16317:
Support for keyed state, watermarks, la
pnowojski commented on issue #11467: [FLINK-16317][operators] Provide support
for watermarks, key selector and latency marker in MultipleInputStreamOperator
URL: https://github.com/apache/flink/pull/11467#issuecomment-604262485
Azure test failure is unrelated, travis green. Merging. Thanks
pnowojski merged pull request #11467: [FLINK-16317][operators] Provide support
for watermarks, key selector and latency marker in MultipleInputStreamOperator
URL: https://github.com/apache/flink/pull/11467
This is an automat
jinhai created FLINK-16793:
--
Summary: Add jobName to log4j ConversionPattern
Key: FLINK-16793
URL: https://issues.apache.org/jira/browse/FLINK-16793
Project: Flink
Issue Type: Improvement
wsry commented on a change in pull request #11351: [FLINK-16404][runtime] Solve
the potential deadlock problem when reducing exclusive buffers to zero
URL: https://github.com/apache/flink/pull/11351#discussion_r398346990
##
File path:
flink-streaming-java/src/main/java/org/apache/f
wsry commented on a change in pull request #11351: [FLINK-16404][runtime] Solve
the potential deadlock problem when reducing exclusive buffers to zero
URL: https://github.com/apache/flink/pull/11351#discussion_r398344908
##
File path:
flink-streaming-java/src/main/java/org/apache/f
wsry commented on a change in pull request #11351: [FLINK-16404][runtime] Solve
the potential deadlock problem when reducing exclusive buffers to zero
URL: https://github.com/apache/flink/pull/11351#discussion_r398343075
##
File path:
flink-runtime/src/main/java/org/apache/flink/ru
[
https://issues.apache.org/jira/browse/FLINK-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yanxiaobin updated FLINK-16792:
---
Description:
When flink-s3-fs-hadoop-1.10.0.jar is placed in the lib directory of Flink
distributio
[
https://issues.apache.org/jira/browse/FLINK-16792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067389#comment-17067389
]
yanxiaobin commented on FLINK-16792:
The issue is related to https://issues.apache.o
yanxiaobin created FLINK-16792:
--
Summary: flink-s3-fs-hadoop cannot access s3
Key: FLINK-16792
URL: https://issues.apache.org/jira/browse/FLINK-16792
Project: Flink
Issue Type: Bug
Com
[
https://issues.apache.org/jira/browse/FLINK-15616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067387#comment-17067387
]
Hequn Cheng commented on FLINK-15616:
-
The problem has been reported by several user
[
https://issues.apache.org/jira/browse/FLINK-16791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067380#comment-17067380
]
yanxiaobin commented on FLINK-16791:
I checked that the application does not contain
[
https://issues.apache.org/jira/browse/FLINK-16791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yanxiaobin updated FLINK-16791:
---
Description:
Since aws s3 is needed, so copy the flink-s3-fs-hadoop-1.10.0.jar JAR file to
the {{li
yanxiaobin created FLINK-16791:
--
Summary: Could not deploy Yarn job cluster when using
flink-s3-fs-hadoop-1.10.0.jar
Key: FLINK-16791
URL: https://issues.apache.org/jira/browse/FLINK-16791
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067375#comment-17067375
]
Hequn Cheng commented on FLINK-16790:
-
[~yuwenbing] Thanks a lot for reporting the p
[
https://issues.apache.org/jira/browse/FLINK-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-16790:
---
Assignee: yuwenbing
> enables the interpretation of backslash escapes
> ---
[
https://issues.apache.org/jira/browse/FLINK-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067370#comment-17067370
]
yuwenbing commented on FLINK-16790:
---
I want to take this issue，someone can assign it t
yuwenbing created FLINK-16790:
-
Summary: enables the interpretation of backslash escapes
Key: FLINK-16790
URL: https://issues.apache.org/jira/browse/FLINK-16790
Project: Flink
Issue Type: Improve
tzulitai closed pull request #75: [hotfix][bugfix] The generic ingress requires
an utf-8 key.
URL: https://github.com/apache/flink-statefun/pull/75
This is an automated message from the Apache Git Service.
To respond to the
flinkbot commented on issue #11518: [FLINK-16555] Block Enum as key type
URL: https://github.com/apache/flink/pull/11518#issuecomment-604227071
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
[
https://issues.apache.org/jira/browse/FLINK-16555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16555:
---
Labels: pull-request-available usability (was: usability)
> Preflight check for known unsta
qqibrow opened a new pull request #11518: [FLINK-16555] Block Enum as key type
URL: https://github.com/apache/flink/pull/11518
## What is the purpose of the change
This PR blocks enum type as key type. Because hashCode() of Enum type calls
Object.hashCode(), therefore keyBy on En
[
https://issues.apache.org/jira/browse/FLINK-16728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067346#comment-17067346
]
Zhu Zhu commented on FLINK-16728:
-
Hi [~lilyevsky], it is intentioned to shutdown a Task
[
https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067343#comment-17067343
]
Rong Rong commented on FLINK-16789:
---
I've share a code snippet in
[https://github.com
[
https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-5552:
-
Comment: was deleted
(was: Yes. I think having it in the log is possible. however, based on my
experienc
[
https://issues.apache.org/jira/browse/FLINK-16789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-16789:
--
Description:
Currently there are no easy way to assign jmxrmi port to a running Flink job.
The typica
Rong Rong created FLINK-16789:
-
Summary: Support JMX RMI via JMXConnectorServer
Key: FLINK-16789
URL: https://issues.apache.org/jira/browse/FLINK-16789
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067341#comment-17067341
]
Rong Rong commented on FLINK-5552:
--
Oops.. I just realized that I am not talking about t
flinkbot commented on issue #11517: [FLINK-16786][hotfix] fix pyarrow version
in setup.py
URL: https://github.com/apache/flink/pull/11517#issuecomment-604213883
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull re
[
https://issues.apache.org/jira/browse/FLINK-16483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067335#comment-17067335
]
Rong Rong commented on FLINK-16483:
---
yeah. I took a look and seems like simply align t
[
https://issues.apache.org/jira/browse/FLINK-16786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16786:
---
Labels: pull-request-available (was: )
> Fix pyarrow version incompatible problem
> ---
walterddr opened a new pull request #11517: [FLINK-16786][hotfix] fix pyarrow
version in setup.py
URL: https://github.com/apache/flink/pull/11517
## What is the purpose of the change
Fix incorrectly configured pyarrow version
## Verifying this change
This change is
[
https://issues.apache.org/jira/browse/FLINK-16039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067332#comment-17067332
]
Manas Kale edited comment on FLINK-16039 at 3/26/20, 3:49 AM:
[
https://issues.apache.org/jira/browse/FLINK-16039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067332#comment-17067332
]
Manas Kale edited comment on FLINK-16039 at 3/26/20, 3:49 AM:
[
https://issues.apache.org/jira/browse/FLINK-16039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067332#comment-17067332
]
Manas Kale commented on FLINK-16039:
Hi all, I've started a discussion on the mailin
TisonKun commented on a change in pull request #11460:
[FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web
Submission
URL: https://github.com/apache/flink/pull/11460#discussion_r398299862
##
File path:
flink-clients/src/main/java/org/apache/flink/client/deplo
TisonKun commented on a change in pull request #11460:
[FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web
Submission
URL: https://github.com/apache/flink/pull/11460#discussion_r398298910
##
File path:
flink-clients/src/main/java/org/apache/flink/client/deplo
TisonKun commented on a change in pull request #11460:
[FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web
Submission
URL: https://github.com/apache/flink/pull/11460#discussion_r397639617
##
File path:
flink-clients/src/main/java/org/apache/flink/client/deplo
TisonKun commented on a change in pull request #11460:
[FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web
Submission
URL: https://github.com/apache/flink/pull/11460#discussion_r398298756
##
File path:
flink-clients/src/main/java/org/apache/flink/client/deplo
TisonKun commented on a change in pull request #11460:
[FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web
Submission
URL: https://github.com/apache/flink/pull/11460#discussion_r398293189
##
File path:
flink-clients/src/main/java/org/apache/flink/client/deplo
[
https://issues.apache.org/jira/browse/FLINK-16708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shangwen Tang updated FLINK-16708:
--
Comment: was deleted
(was: My opinion is that when jdbcWriter.executeBatch () throws an except
[
https://issues.apache.org/jira/browse/FLINK-16708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067329#comment-17067329
]
Shangwen Tang commented on FLINK-16708:
---
I think we should check the connection wh
[
https://issues.apache.org/jira/browse/FLINK-16708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shangwen Tang updated FLINK-16708:
--
Comment: was deleted
(was: So when the connection is closed, the second retry of the flush met
[
https://issues.apache.org/jira/browse/FLINK-16708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shangwen Tang updated FLINK-16708:
--
Comment: was deleted
(was: On the first execution, connection.getAutoCommit () throws PSQLExce
[
https://issues.apache.org/jira/browse/FLINK-16708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shangwen Tang updated FLINK-16708:
--
Description:
In our test environment, I used the tcpkill command to simulate a scenario
where
[
https://issues.apache.org/jira/browse/FLINK-16708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shangwen Tang updated FLINK-16708:
--
Summary: When a JDBC connection has been closed, the retry policy of the
JDBCUpsertOutputForma
PatrickRen commented on issue #11425: [FLINK-16125][kafka] Remove unnecessary
zookeeper.connect property validation
URL: https://github.com/apache/flink/pull/11425#issuecomment-604204398
@flinkbot run travis
@flinkbot run azure
---
[
https://issues.apache.org/jira/browse/FLINK-16780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067327#comment-17067327
]
Benchao Li commented on FLINK-16780:
[~phoenixjiangnan] Thanks for the effort.
I al
zhisheng created FLINK-16788:
Summary: ElasticSearch Connector SQL DDL add optional config (eg:
enable-auth/username/password)
Key: FLINK-16788
URL: https://issues.apache.org/jira/browse/FLINK-16788
Proje
JingsongLi commented on a change in pull request #11381:
[FLINK-16294][connectors /jdbc]Support to create non-existed table in database
automatically when writing data to JDBC connector.
URL: https://github.com/apache/flink/pull/11381#discussion_r398288036
##
File path:
flink-conn
JingsongLi commented on a change in pull request #11381:
[FLINK-16294][connectors /jdbc]Support to create non-existed table in database
automatically when writing data to JDBC connector.
URL: https://github.com/apache/flink/pull/11381#discussion_r398289059
##
File path:
flink-conn
JingsongLi commented on a change in pull request #11381:
[FLINK-16294][connectors /jdbc]Support to create non-existed table in database
automatically when writing data to JDBC connector.
URL: https://github.com/apache/flink/pull/11381#discussion_r398289746
##
File path:
flink-conn
JingsongLi commented on a change in pull request #11381:
[FLINK-16294][connectors /jdbc]Support to create non-existed table in database
automatically when writing data to JDBC connector.
URL: https://github.com/apache/flink/pull/11381#discussion_r398288297
##
File path:
flink-conn
JingsongLi commented on a change in pull request #11381:
[FLINK-16294][connectors /jdbc]Support to create non-existed table in database
automatically when writing data to JDBC connector.
URL: https://github.com/apache/flink/pull/11381#discussion_r398288100
##
File path:
flink-conn
JingsongLi commented on a change in pull request #11381:
[FLINK-16294][connectors /jdbc]Support to create non-existed table in database
automatically when writing data to JDBC connector.
URL: https://github.com/apache/flink/pull/11381#discussion_r398288580
##
File path:
flink-conn
tzulitai commented on issue #75: [hotfix][bugfix] The generic ingress requires
an utf-8 key.
URL: https://github.com/apache/flink-statefun/pull/75#issuecomment-604198407
Thanks! LGTM, merging ...
This is an automated message
Jingsong Lee created FLINK-16787:
Summary: Provide an assigner strategy of average splits allocation
Key: FLINK-16787
URL: https://issues.apache.org/jira/browse/FLINK-16787
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-16726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067323#comment-17067323
]
Matrix42 commented on FLINK-16726:
--
Thanks [~jark].
> ScalarFunction throws Given para
leonardBang commented on issue #11508:
[FLINK-16170][connectors/elasticsearch]SearchTemplateRequest
ClassNotFoundException when use flink-sql-connector-elasticsearch7
URL: https://github.com/apache/flink/pull/11508#issuecomment-604191765
Hi, @wuchong Could you help review this PR？
-
[
https://issues.apache.org/jira/browse/FLINK-16726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-16726.
---
Resolution: Not A Bug
> ScalarFunction throws Given parameters of function 'func' do not match any
> signat
[
https://issues.apache.org/jira/browse/FLINK-16726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067312#comment-17067312
]
Jark Wu commented on FLINK-16726:
-
Hi [~Matrix42], {{2.2}} is a decimal type in SQL whic
[
https://issues.apache.org/jira/browse/FLINK-16777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067307#comment-17067307
]
jackylau commented on FLINK-16777:
--
Hi [~kkl0u] , Exposing HbaseUpsertFunction, FlinkKa
[
https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067304#comment-17067304
]
Jark Wu commented on FLINK-14902:
-
Hi [~phoenixjiangnan], sorray I still don't have enou
LakeShen commented on issue #11499: [FLINK-16681][Connectors/JDBC]Jdbc
JDBCOutputFormat and JDBCLookupFunction PreparedStatement loss connection, if
long time not records to write.
URL: https://github.com/apache/flink/pull/11499#issuecomment-604188922
Hi @docete , thank to your comments. I
[
https://issues.apache.org/jira/browse/FLINK-16782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067298#comment-17067298
]
Jark Wu commented on FLINK-16782:
-
+1 to this :)
> Avoid unnecessary check on expired t
[
https://issues.apache.org/jira/browse/FLINK-16781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067297#comment-17067297
]
Jark Wu commented on FLINK-16781:
-
I don't against with this feature. But maybe [~ykt836
[
https://issues.apache.org/jira/browse/FLINK-16781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067297#comment-17067297
]
Jark Wu edited comment on FLINK-16781 at 3/26/20, 2:05 AM:
---
I
[
https://issues.apache.org/jira/browse/FLINK-16765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-16765:
---
Assignee: yuwenbing
> Replace all BatchTableEnvironment to StreamTableEnvironment in the do
[
https://issues.apache.org/jira/browse/FLINK-16765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-16765:
Fix Version/s: (was: 1.10.1)
(was: 1.11.0)
> Replace all BatchTableEnvi
[
https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067294#comment-17067294
]
Jark Wu commented on FLINK-15509:
-
Hi [~Leonard Xu], we should make sure all the persis
flinkbot edited a comment on issue #11456: [FLINK-16602][k8s] Rework the
internal/external Service
URL: https://github.com/apache/flink/pull/11456#issuecomment-601501414
## CI report:
* 8b988ea012330eaf2e1c42865a198192d27e23cd Travis:
[SUCCESS](https://travis-ci.com/github/flink
Hequn Cheng created FLINK-16786:
---
Summary: Fix pyarrow version incompatible problem
Key: FLINK-16786
URL: https://issues.apache.org/jira/browse/FLINK-16786
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-16483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067282#comment-17067282
]
Hequn Cheng commented on FLINK-16483:
-
[~rongr] The version should be consistent bet
flinkbot edited a comment on issue #11456: [FLINK-16602][k8s] Rework the
internal/external Service
URL: https://github.com/apache/flink/pull/11456#issuecomment-601501414
## CI report:
* 8b988ea012330eaf2e1c42865a198192d27e23cd Travis:
[SUCCESS](https://travis-ci.com/github/flink
flinkbot edited a comment on issue #11483: [FLINK-15438][metrics][datadog]
Report counter deltas and not totals
URL: https://github.com/apache/flink/pull/11483#issuecomment-602252703
## CI report:
* 1ac54f0d5858be27c66f55fb56b96664f4252256 Travis:
[SUCCESS](https://travis-ci.com
XuQianJin-Stars commented on a change in pull request #11186:
[FLINK-16200][sql] Support JSON_EXISTS for blink planner
URL: https://github.com/apache/flink/pull/11186#discussion_r398265336
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/pla
flinkbot edited a comment on issue #11516: [WIP] [FLINK-13483] Retry delete
when checking path existence in AbstractHadoopFileSyste…
URL: https://github.com/apache/flink/pull/11516#issuecomment-604153515
## CI report:
* dc0c3e095a3d484fcfaf6c7edc2f4163518565c9 Travis:
[CANCELED
flinkbot edited a comment on issue #11483: [FLINK-15438][metrics][datadog]
Report counter deltas and not totals
URL: https://github.com/apache/flink/pull/11483#issuecomment-602252703
## CI report:
* 1ac54f0d5858be27c66f55fb56b96664f4252256 Travis:
[PENDING](https://travis-ci.com
flinkbot edited a comment on issue #11516: [WIP] [FLINK-13483] Retry delete
when checking path existence in AbstractHadoopFileSyste…
URL: https://github.com/apache/flink/pull/11516#issuecomment-604153515
## CI report:
* dc0c3e095a3d484fcfaf6c7edc2f4163518565c9 Travis:
[PENDING]
[
https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-5552:
Assignee: Rong Rong
> Make the JMX port available through RESTful API
> --
[
https://issues.apache.org/jira/browse/FLINK-13483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067259#comment-17067259
]
Lu Niu commented on FLINK-13483:
[~liyu] thanks for the reply. I find the problem might
qqibrow commented on issue #11516: [WIP] [FLINK-13483] Retry delete when
checking path existence in AbstractHadoopFileSyste…
URL: https://github.com/apache/flink/pull/11516#issuecomment-604160243
@flinkbot run travis
This is
flinkbot edited a comment on issue #11516: [WIP] [FLINK-13483] Retry delete
when checking path existence in AbstractHadoopFileSyste…
URL: https://github.com/apache/flink/pull/11516#issuecomment-604153515
## CI report:
* dc0c3e095a3d484fcfaf6c7edc2f4163518565c9 Travis:
[FAILURE]
flinkbot commented on issue #11516: [WIP] [FLINK-13483] Retry delete when
checking path existence in AbstractHadoopFileSyste…
URL: https://github.com/apache/flink/pull/11516#issuecomment-604153515
## CI report:
* dc0c3e095a3d484fcfaf6c7edc2f4163518565c9 UNKNOWN
Bot co
flinkbot edited a comment on issue #11483: [FLINK-15438][metrics][datadog]
Report counter deltas and not totals
URL: https://github.com/apache/flink/pull/11483#issuecomment-602252703
## CI report:
* 734a0bc7631586f212a22d9a71e60518d49d2274 Travis:
[SUCCESS](https://travis-ci.com
flinkbot edited a comment on issue #11515: [WIP][FLINK-16744][task] implement
channel state persistence for unaligned checkpoints
URL: https://github.com/apache/flink/pull/11515#issuecomment-604128992
## CI report:
* 81ee27579a19414fba5c99d6cbea201e1632cc2b Travis:
[CANCELED](ht
[
https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067236#comment-17067236
]
Rong Rong edited comment on FLINK-5552 at 3/26/20, 12:00 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067236#comment-17067236
]
Rong Rong commented on FLINK-5552:
--
Yes. I think having it in the log is possible. howev
flinkbot commented on issue #11516: [WIP] [FLINK-13483] Retry delete when
checking path existence in AbstractHadoopFileSyste…
URL: https://github.com/apache/flink/pull/11516#issuecomment-604150347
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help th
[
https://issues.apache.org/jira/browse/FLINK-13483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13483:
---
Labels: pull-request-available test-stability (was: test-stability)
> PrestoS3FileSystemITC
qqibrow opened a new pull request #11516: [WIP] [FLINK-13483] Retry delete
when checking path existence in AbstractHadoopFileSyste…
URL: https://github.com/apache/flink/pull/11516
…mITTest
flinkbot edited a comment on issue #11515: [WIP][FLINK-16744][task] implement
channel state persistence for unaligned checkpoints
URL: https://github.com/apache/flink/pull/11515#issuecomment-604128992
## CI report:
* 81ee27579a19414fba5c99d6cbea201e1632cc2b Travis:
[CANCELED](ht
flinkbot edited a comment on issue #11483: [FLINK-15438][metrics][datadog]
Report counter deltas and not totals
URL: https://github.com/apache/flink/pull/11483#issuecomment-602252703
## CI report:
* 734a0bc7631586f212a22d9a71e60518d49d2274 Travis:
[SUCCESS](https://travis-ci.com
flinkbot edited a comment on issue #11515: [WIP][FLINK-16744][task] implement
channel state persistence for unaligned checkpoints
URL: https://github.com/apache/flink/pull/11515#issuecomment-604128992
## CI report:
* 81ee27579a19414fba5c99d6cbea201e1632cc2b Travis:
[PENDING](htt
sjwiesman commented on a change in pull request #74: [FLINK-16783] Add Python
docker-compose based example
URL: https://github.com/apache/flink-statefun/pull/74#discussion_r398229803
##
File path:
statefun-examples/statefun-python-greeter/generator/event-generator.py
##
@
kottmann commented on issue #11483: [FLINK-15438][metrics][datadog] Report
counter deltas and not totals
URL: https://github.com/apache/flink/pull/11483#issuecomment-604141642
Thanks for the review, I agree this makes it much nicer. I changed it as
suggested and forced pushed the update.
sjwiesman commented on a change in pull request #74: [FLINK-16783] Add Python
docker-compose based example
URL: https://github.com/apache/flink-statefun/pull/74#discussion_r398230859
##
File path: statefun-examples/statefun-python-greeter/greeter/messages.proto
##
@@ -0,0
sjwiesman commented on a change in pull request #74: [FLINK-16783] Add Python
docker-compose based example
URL: https://github.com/apache/flink-statefun/pull/74#discussion_r398229803
##
File path:
statefun-examples/statefun-python-greeter/generator/event-generator.py
##
@
sjwiesman commented on a change in pull request #74: [FLINK-16783] Add Python
docker-compose based example
URL: https://github.com/apache/flink-statefun/pull/74#discussion_r398229298
##
File path: statefun-examples/statefun-python-greeter/greeter/requirements.txt
##
@@ -0,
1 - 100 of 501 matches
Mail list logo
