Roman Khachatryan created FLINK-17547:
-
Summary: Support unaligned checkpoints for records spilled to files
Key: FLINK-17547
URL: https://issues.apache.org/jira/browse/FLINK-17547
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101132#comment-17101132
]
John Lonergan commented on FLINK-17464:
---
I meant arch because this problem wouldn't take the
Rafael Wicht created FLINK-17548:
Summary: Table API Schema from not working
Key: FLINK-17548
URL: https://issues.apache.org/jira/browse/FLINK-17548
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-17194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101125#comment-17101125
]
Gary Yao commented on FLINK-17194:
--
I am able to reliably reproduce this issue by setting
[
https://issues.apache.org/jira/browse/FLINK-17544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Lonergan updated FLINK-17544:
--
Description:
Encountered a situation where I get an NPE from JDBCUpsertOutputFormat.
This
[
https://issues.apache.org/jira/browse/FLINK-17548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rafael Wicht updated FLINK-17548:
-
Description:
The method 'from' of org.apache.flink.table.descriptors.Schema do not work for
flinkbot edited a comment on pull request #12011:
URL: https://github.com/apache/flink/pull/12011#issuecomment-624791772
## CI report:
* 97efd201ad9b8f206e53c4e12998f68c9cc0159a UNKNOWN
* 12a03aeea4dc42a2d2bb1a4f9d885ddb2ecd0b22 Azure:
leonardBang commented on pull request #12010:
URL: https://github.com/apache/flink/pull/12010#issuecomment-624970742
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
JingsongLi commented on a change in pull request #12010:
URL: https://github.com/apache/flink/pull/12010#discussion_r421200211
##
File path:
flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataFileInputFormat.java
##
@@ -0,0 +1,248 @@
+/*
+ *
Cheng Shi created FLINK-17550:
-
Summary: set a retract switch
Key: FLINK-17550
URL: https://issues.apache.org/jira/browse/FLINK-17550
Project: Flink
Issue Type: New Feature
Reporter:
[
https://issues.apache.org/jira/browse/FLINK-16102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-16102.
---
Fix Version/s: 1.11.0
Resolution: Fixed
Resolved in master (1.11.0):
[
https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-9900:
Attachment: mvn-2.log
> Fix unstable test
>
shuiqiangchen opened a new pull request #12013:
URL: https://github.com/apache/flink/pull/12013
## What is the purpose of the change
Keyword arguments is a very commonly used feature in Python. We should
support it in the PyFlink Descriptor API to make the API more user
[
https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101335#comment-17101335
]
Biao Liu commented on FLINK-9900:
-
Thanks [~rmetzger] for reporting.
This time, the case failed to submit
[
https://issues.apache.org/jira/browse/FLINK-17256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17256:
---
Labels: beginners pull-request-available (was: beginners)
> Suppport keyword arguments in
yanghua commented on pull request #7960:
URL: https://github.com/apache/flink/pull/7960#issuecomment-625007207
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
yanghua commented on pull request #8005:
URL: https://github.com/apache/flink/pull/8005#issuecomment-625007331
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
yanghua commented on pull request #8034:
URL: https://github.com/apache/flink/pull/8034#issuecomment-625007088
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
yanghua commented on pull request #7718:
URL: https://github.com/apache/flink/pull/7718#issuecomment-625007470
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
yanghua commented on pull request #7750:
URL: https://github.com/apache/flink/pull/7750#issuecomment-625007557
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-17250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101350#comment-17101350
]
Tammy zhang commented on FLINK-17250:
-
i solved the problem with other methods, i guess the reason
[
https://issues.apache.org/jira/browse/FLINK-17250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101350#comment-17101350
]
Tammy zhang edited comment on FLINK-17250 at 5/7/20, 3:39 AM:
--
thanks for
liying919 removed a comment on pull request #12012:
URL: https://github.com/apache/flink/pull/12012#issuecomment-624991186
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the
liying919 commented on pull request #12012:
URL: https://github.com/apache/flink/pull/12012#issuecomment-625011211
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
sjwiesman edited a comment on pull request #335:
URL: https://github.com/apache/flink-web/pull/335#issuecomment-624921330
My question is who is the target demographic? If it's for new users I think
setting up a cluster is way too much. If it's for existing users, to show them
how to put
[
https://issues.apache.org/jira/browse/FLINK-17204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101232#comment-17101232
]
Austin Cawley-Edwards commented on FLINK-17204:
---
Thank you!!
> The RMQSource and RMQSink
[
https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100286#comment-17100286
]
Austin Cawley-Edwards edited comment on FLINK-17529 at 5/6/20, 10:23 PM:
[
https://issues.apache.org/jira/browse/FLINK-17478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101239#comment-17101239
]
Kenneth William Krugler commented on FLINK-17478:
-
Hi [~gyfora] - is this related to
ThunderSu commented on pull request #11706:
URL: https://github.com/apache/flink/pull/11706#issuecomment-624982628
@hadronzoo @rehevkor5
This is an automated message from the Apache Git Service.
To respond to the
xintongsong commented on pull request #11300:
URL: https://github.com/apache/flink/pull/11300#issuecomment-624988682
@DestyNova
I assume you are using Flink 1.10.0? This PR has been merged after the
release of 1.10.0. It should be included in release 1.10.1 & release 1.11.0,
both
flinkbot edited a comment on pull request #12012:
URL: https://github.com/apache/flink/pull/12012#issuecomment-624987148
## CI report:
* d3c197de000c8ffbb4cd20a8244e906bd90487a2 Azure:
flinkbot edited a comment on pull request #11960:
URL: https://github.com/apache/flink/pull/11960#issuecomment-621791651
## CI report:
* a283855e4c5042bec925a05e15727ab2db71bd1e Azure:
flinkbot commented on pull request #12013:
URL: https://github.com/apache/flink/pull/12013#issuecomment-625002978
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
klion26 commented on pull request #11982:
URL: https://github.com/apache/flink/pull/11982#issuecomment-625010492
@liying919 thanks for the work, I'll review the new pr late today.
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-17479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101355#comment-17101355
]
Congxian Qiu(klion26) commented on FLINK-17479:
---
[~nobleyd] thanks for reporting this
sjwiesman commented on pull request #335:
URL: https://github.com/apache/flink-web/pull/335#issuecomment-624921330
My thinking is who is the target demographic. If it's for new users I think
setting up a cluster is way too much, and if it's for existing users to show
them how to put
flinkbot commented on pull request #12012:
URL: https://github.com/apache/flink/pull/12012#issuecomment-624982451
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
liying919 edited a comment on pull request #11982:
URL: https://github.com/apache/flink/pull/11982#issuecomment-624979748
@klion26 It seems that the PR is closed while I rebased it again.
A new PR is opened here
Canbin Zheng created FLINK-17549:
Summary: Support running Stateful Functions on native Kubernetes
setup
Key: FLINK-17549
URL: https://issues.apache.org/jira/browse/FLINK-17549
Project: Flink
zhule0601 commented on pull request #11590:
URL: https://github.com/apache/flink/pull/11590#issuecomment-624989560
@wuchong Hi, can you help deal with this PR? It has been taking quite a long
time. Orz
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099746#comment-17099746
]
Xingxing Di edited comment on FLINK-16478 at 5/7/20, 3:33 AM:
--
Hi
bowenli86 commented on a change in pull request #11900:
URL: https://github.com/apache/flink/pull/11900#discussion_r421227400
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/catalog/PostgresCatalog.java
##
@@ -216,6 +216,12 @@ public
sjwiesman edited a comment on pull request #335:
URL: https://github.com/apache/flink-web/pull/335#issuecomment-624921330
My thinking is who is the target demographic. If it's for new users I think
setting up a cluster is way too much, and if it's for existing users to show
them how to
liying919 commented on pull request #11982:
URL: https://github.com/apache/flink/pull/11982#issuecomment-624979748
@klion26 It seems that the PR is closed during my rebasing it again. Should
I open a new one or there's a way to reopen it?
liying919 edited a comment on pull request #11982:
URL: https://github.com/apache/flink/pull/11982#issuecomment-624979748
@klion26 It seems that the PR is closed while I rebased it again. Should I
open a new one or there's a way to reopen it?
leonardBang commented on a change in pull request #12010:
URL: https://github.com/apache/flink/pull/12010#discussion_r421202157
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSource.java
##
@@ -121,6 +127,14
flinkbot edited a comment on pull request #12012:
URL: https://github.com/apache/flink/pull/12012#issuecomment-624987148
## CI report:
* d3c197de000c8ffbb4cd20a8244e906bd90487a2 Azure:
flinkbot edited a comment on pull request #12002:
URL: https://github.com/apache/flink/pull/12002#issuecomment-624393131
## CI report:
* 4a3d66188bfe8484de52157d59d5850d3559073c Azure:
flinkbot edited a comment on pull request #11960:
URL: https://github.com/apache/flink/pull/11960#issuecomment-621791651
## CI report:
* a283855e4c5042bec925a05e15727ab2db71bd1e Azure:
[
https://issues.apache.org/jira/browse/FLINK-16529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16529:
---
Labels: pull-request-available (was: )
> Add ignore_parse_errors() method to Json format
SteNicholas opened a new pull request #12014:
URL: https://github.com/apache/flink/pull/12014
## What is the purpose of the change
*JSON format currently support 'format.ignore-parse-errors' to skip dirty
records in Java, which should consistent with Java in Python API.*
zhuzhurk commented on a change in pull request #11929:
URL: https://github.com/apache/flink/pull/11929#discussion_r421212075
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/RestartPipelinedRegionFailoverStrategy.java
##
@@
flinkbot edited a comment on pull request #12002:
URL: https://github.com/apache/flink/pull/12002#issuecomment-624393131
## CI report:
* 6b28c708484cd7c27dd1b1c2e81a0cb8f04c4564 Azure:
yanghua commented on pull request #7764:
URL: https://github.com/apache/flink/pull/7764#issuecomment-625007660
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
yanghua commented on pull request #6432:
URL: https://github.com/apache/flink/pull/6432#issuecomment-625008061
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
yanghua commented on pull request #6631:
URL: https://github.com/apache/flink/pull/6631#issuecomment-625008165
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
yanghua commented on pull request #6675:
URL: https://github.com/apache/flink/pull/6675#issuecomment-625007829
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
flinkbot commented on pull request #12014:
URL: https://github.com/apache/flink/pull/12014#issuecomment-625012050
## CI report:
* a3e1317e6cd01b958a933a0220a70e8b652b3136 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #12013:
URL: https://github.com/apache/flink/pull/12013#issuecomment-625012004
## CI report:
* c947260be5694e47c2a47152a2a1495ef4ddd991 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-13938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-13938:
--
Description:
Currently, every time we start a flink cluster, flink lib jars need to be
uploaded to
flinkbot edited a comment on pull request #12014:
URL: https://github.com/apache/flink/pull/12014#issuecomment-625012050
## CI report:
* a3e1317e6cd01b958a933a0220a70e8b652b3136 Azure:
flinkbot edited a comment on pull request #12013:
URL: https://github.com/apache/flink/pull/12013#issuecomment-625012004
## CI report:
* c947260be5694e47c2a47152a2a1495ef4ddd991 Azure:
flinkbot edited a comment on pull request #12003:
URL: https://github.com/apache/flink/pull/12003#issuecomment-624416714
## CI report:
* 2cc10767854d49f63c6677e7f9217f2c89b8b306 Azure:
flinkbot edited a comment on pull request #11960:
URL: https://github.com/apache/flink/pull/11960#issuecomment-621791651
## CI report:
* 6c9c6d4f1ad70f5911f3e58461b8fb3be975df85 Azure:
JingsongLi commented on a change in pull request #12010:
URL: https://github.com/apache/flink/pull/12010#discussion_r421200716
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSource.java
##
@@ -121,6 +127,14
WeiZhong94 commented on a change in pull request #11960:
URL: https://github.com/apache/flink/pull/11960#discussion_r421203351
##
File path:
flink-python/src/main/java/org/apache/flink/client/python/PythonGatewayServer.java
##
@@ -71,15 +75,42 @@ public static void
WeiZhong94 commented on a change in pull request #11960:
URL: https://github.com/apache/flink/pull/11960#discussion_r421203462
##
File path: flink-python/pyflink/pyflink_gateway_server.py
##
@@ -0,0 +1,209 @@
Xintong Song created FLINK-17551:
Summary: Documentation of stable releases are actually built on
top of snapshot code bases.
Key: FLINK-17551
URL: https://issues.apache.org/jira/browse/FLINK-17551
WeiZhong94 commented on a change in pull request #11960:
URL: https://github.com/apache/flink/pull/11960#discussion_r421203791
##
File path: flink-python/src/main/resources/pyflink-udf-runner.sh
##
@@ -40,4 +40,4 @@ if [[ "$_PYTHON_WORKING_DIR" != "" ]]; then
fi
liying919 commented on pull request #12012:
URL: https://github.com/apache/flink/pull/12012#issuecomment-624999378
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
yanghua commented on pull request #8679:
URL: https://github.com/apache/flink/pull/8679#issuecomment-625008712
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099746#comment-17099746
]
Xingxing Di edited comment on FLINK-16478 at 5/7/20, 3:29 AM:
--
Hi
yanghua commented on pull request #6807:
URL: https://github.com/apache/flink/pull/6807#issuecomment-625008399
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
yanghua commented on pull request #6954:
URL: https://github.com/apache/flink/pull/6954#issuecomment-625008501
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
yanghua commented on pull request #6637:
URL: https://github.com/apache/flink/pull/6637#issuecomment-625008276
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
docete commented on pull request #11276:
URL: https://github.com/apache/flink/pull/11276#issuecomment-625013123
rebased to resolve conflicts.
@KurtYoung please have a look.
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-17125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-17125:
Fix Version/s: 1.11.0
1.10.1
> Add a Usage Notes Page to Answer Common Questions
flinkbot edited a comment on pull request #11276:
URL: https://github.com/apache/flink/pull/11276#issuecomment-593234780
## CI report:
* 772b6e923e3398ddf43c1c300934fb8147d9acfb UNKNOWN
* 644ba6d77ee03a378eea07ed3aff611c86154caa Travis:
liying919 opened a new pull request #12012:
URL: https://github.com/apache/flink/pull/12012
## What is the purpose of the change
Translate tutorials/etl.md to chinese.
## Brief change log
- etl.zh.md is changed into Chinese version.
## Verifying this change
flinkbot edited a comment on pull request #12002:
URL: https://github.com/apache/flink/pull/12002#issuecomment-624393131
## CI report:
* 4a3d66188bfe8484de52157d59d5850d3559073c Azure:
flinkbot commented on pull request #12012:
URL: https://github.com/apache/flink/pull/12012#issuecomment-624987148
## CI report:
* d3c197de000c8ffbb4cd20a8244e906bd90487a2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-17544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-17544:
Fix Version/s: 1.10.2
1.11.0
> NPE JDBCUpsertOutputFormat
> --
liying919 commented on pull request #12012:
URL: https://github.com/apache/flink/pull/12012#issuecomment-624991186
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
JingsongLi commented on a change in pull request #12010:
URL: https://github.com/apache/flink/pull/12010#discussion_r421201261
##
File path:
flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataFileInputFormat.java
##
@@ -0,0 +1,248 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-17544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101317#comment-17101317
]
Jark Wu commented on FLINK-17544:
-
I agree. The this code has been refactored in master branch, but
WeiZhong94 commented on a change in pull request #11960:
URL: https://github.com/apache/flink/pull/11960#discussion_r421204626
##
File path: flink-python/pyflink/fn_execution/tests/test_process_mode_boot.py
##
@@ -114,7 +117,7 @@ def run_boot_py(self):
WeiZhong94 commented on pull request #11960:
URL: https://github.com/apache/flink/pull/11960#issuecomment-624994997
@dianfu Thanks for your review! I have addressed your comments.
This is an automated message from the Apache
WeiZhong94 commented on a change in pull request #11960:
URL: https://github.com/apache/flink/pull/11960#discussion_r421204158
##
File path: flink-python/pyflink/table/tests/test_pandas_udf.py
##
@@ -142,7 +142,7 @@ def time_func(time_param):
'time_param of
[
https://issues.apache.org/jira/browse/FLINK-16099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101333#comment-17101333
]
Andrew.D.lin commented on FLINK-16099:
--
Hi [~jark], I am willing to do it!
> Translate
liying919 commented on pull request #12012:
URL: https://github.com/apache/flink/pull/12012#issuecomment-625004154
@rmetzger It seems that error occurs while fetching the code. Do you know
what should I do
This is an
flinkbot commented on pull request #12014:
URL: https://github.com/apache/flink/pull/12014#issuecomment-625004244
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
liying919 removed a comment on pull request #12012:
URL: https://github.com/apache/flink/pull/12012#issuecomment-624999378
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the
yanghua commented on pull request #10191:
URL: https://github.com/apache/flink/pull/10191#issuecomment-625009111
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on
yanghua commented on pull request #8823:
URL: https://github.com/apache/flink/pull/8823#issuecomment-625009037
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
yanghua commented on pull request #8461:
URL: https://github.com/apache/flink/pull/8461#issuecomment-625008565
leaving...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
rmetzger commented on pull request #12012:
URL: https://github.com/apache/flink/pull/12012#issuecomment-625034157
I manually restarted the failed tasks. It might have been a temporary issue
with GitHub.
Since this change is limited to the documentation, the CI build is not very
flinkbot commented on pull request #12015:
URL: https://github.com/apache/flink/pull/12015#issuecomment-625036292
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
wangyang0918 commented on pull request #12003:
URL: https://github.com/apache/flink/pull/12003#issuecomment-625036828
@kl0u I have addressed the comments and please have another look.
This is an automated message from the
flinkbot edited a comment on pull request #11854:
URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491
## CI report:
* bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN
* dc7a9c5c7d1fac82518815b9277809dfb82ddaac UNKNOWN
*
[
https://issues.apache.org/jira/browse/FLINK-17416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-17416:
---
Affects Version/s: 1.11.0
> Flink-kubernetes doesn't work on java 8 8u252
>
1 - 100 of 399 matches
Mail list logo
