[jira] [Updated] (FLINK-22170) Manual test for hive dialect

2021-04-15 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-22170: --- Description: This is to test the HiveParser introduced by

[jira] [Assigned] (FLINK-22288) Remove unnecesary argument from JdbcSink.exactlyOnceSink

2021-04-15 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-22288: - Assignee: Roman Khachatryan > Remove unnecesary argument from

[jira] [Updated] (FLINK-20103) Improve test coverage with chaos testing & side-by-side tests

2021-04-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20103: --- Labels: pull-request-available (was: ) > Improve test coverage with chaos testing &

[GitHub] [flink] pnowojski opened a new pull request #15631: [FLINK-20103][tests] Add UnalignedCheckpointsStressITCase

2021-04-15 Thread GitBox
pnowojski opened a new pull request #15631: URL: https://github.com/apache/flink/pull/15631 This PR adds extra test coverage for unaligned checkpoints. ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a

[GitHub] [flink] flinkbot commented on pull request #15630: [FLINK-22119][hive][doc] Update document for hive dialect

2021-04-15 Thread GitBox
flinkbot commented on pull request #15630: URL: https://github.com/apache/flink/pull/15630#issuecomment-820432322 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

[GitHub] [flink] lirui-apache commented on pull request #15630: [FLINK-22119][hive][doc] Update document for hive dialect

2021-04-15 Thread GitBox
lirui-apache commented on pull request #15630: URL: https://github.com/apache/flink/pull/15630#issuecomment-820432079 ![Screen Shot 2021-04-15 at 9 38 29 PM](https://user-images.githubusercontent.com/5210788/114879021-67fbad80-9e33-11eb-878b-7667e38e3baa.png) Attached is a screenshot of

[jira] [Updated] (FLINK-22119) Update document for hive dialect

2021-04-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22119: --- Labels: pull-request-available (was: ) > Update document for hive dialect >

[GitHub] [flink] lirui-apache opened a new pull request #15630: [FLINK-22119][hive][doc] Update document for hive dialect

2021-04-15 Thread GitBox
lirui-apache opened a new pull request #15630: URL: https://github.com/apache/flink/pull/15630 ## What is the purpose of the change Update document for hive dialect ## Brief change log - Update the DML and DQL section of the hive dialect doc ##

[GitHub] [flink] flinkbot commented on pull request #15629: [FLINK-22291][hive] Fix split switching in HiveInputFormatPartitionReader

2021-04-15 Thread GitBox
flinkbot commented on pull request #15629: URL: https://github.com/apache/flink/pull/15629#issuecomment-820430964 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

[GitHub] [flink] kezhuw commented on pull request #15601: [FLINK-18071][FLINK-21996][coordination] - Part two: Ensure reliable OperatorEvent to running Task matching

2021-04-15 Thread GitBox
kezhuw commented on pull request #15601: URL: https://github.com/apache/flink/pull/15601#issuecomment-820430611 Some thoughts on signature of `subtaskReady`: 1. `void subtaskReady(int subtask, SubtaskGateway gateway)` 2. `void subtaskReady(int subtask, SubtaskGateway gateway,

[jira] [Updated] (FLINK-22119) Update document for hive dialect

2021-04-15 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-22119: --- Priority: Blocker (was: Major) > Update document for hive dialect > > >

[GitHub] [flink-web] morsapaes commented on pull request #434: [FLINK-21720] Updates documentation style guides for the new (Hugo) build system

2021-04-15 Thread GitBox
morsapaes commented on pull request #434: URL: https://github.com/apache/flink-web/pull/434#issuecomment-820429944 Thanks for taking this on, @scherrca ! Are you done with the changes? I didn't go into too much detail in the ticket, but the idea behind changing the Documentation Style

[jira] [Updated] (FLINK-22291) Fix split switching in HiveInputFormatPartitionReader

2021-04-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22291: --- Labels: pull-request-available (was: ) > Fix split switching in

[GitHub] [flink] miklosgergely opened a new pull request #15629: [FLINK-22291][hive] Fix split switching in HiveInputFormatPartitionReader

2021-04-15 Thread GitBox
miklosgergely opened a new pull request #15629: URL: https://github.com/apache/flink/pull/15629 ## What is the purpose of the change Due to a bug if HiveInputFormatPartitionReader has read all data from an input split, and switches to a next one in hasNext(), no data will be read

[GitHub] [flink] flinkbot commented on pull request #15628: [FLINK-21329][tests] Increase timeout and delay in local test_local_recovery_and_scheduling.sh

2021-04-15 Thread GitBox
flinkbot commented on pull request #15628: URL: https://github.com/apache/flink/pull/15628#issuecomment-820424769 ## CI report: * c8bd2eaef652c66655e799bc48fe80c576b96bcf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15627: [FLINK-22141] test case for JdbcXaSinkFunction manual test

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15627: URL: https://github.com/apache/flink/pull/15627#issuecomment-820410834 ## CI report: * 8c81924d47c84fc6373424834bd974852a817db8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15626: [FLINK-22286][python] Fix picklebytescoder doesn't support custom python class

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15626: URL: https://github.com/apache/flink/pull/15626#issuecomment-820410735 ## CI report: * be5997550897ff4f5cd9bcab289bc98e31b7ddde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15622: [hotfix][table-common] table properties validation is returning inaccurate error message

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15622: URL: https://github.com/apache/flink/pull/15622#issuecomment-820290426 ## CI report: * af4135b758aa97ee2690a18bb244c95e82d33df5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15615: [FLINK-22021][table-planner-blink] Fix exception when PushFilterIntoLegacyTableSourceScanRule is faced with INTERVAL types

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15615: URL: https://github.com/apache/flink/pull/15615#issuecomment-819492632 ## CI report: * 1e57d4652966ce8b4f8f25c699a0ef39dfc824aa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[jira] [Comment Edited] (FLINK-22069) Check Log Pollution for 1.13 release

2021-04-15 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322176#comment-17322176 ] Stephan Ewen edited comment on FLINK-22069 at 4/15/21, 1:23 PM: There is

[jira] [Comment Edited] (FLINK-22069) Check Log Pollution for 1.13 release

2021-04-15 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322176#comment-17322176 ] Stephan Ewen edited comment on FLINK-22069 at 4/15/21, 1:23 PM: There is

[jira] [Commented] (FLINK-22069) Check Log Pollution for 1.13 release

2021-04-15 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322176#comment-17322176 ] Stephan Ewen commented on FLINK-22069: -- There is one that doesn't yet seem to be fixed that I found

[GitHub] [flink] flinkbot commented on pull request #15628: [FLINK-21329][tests] Increase timeout and delay in local test_local_recovery_and_scheduling.sh

2021-04-15 Thread GitBox
flinkbot commented on pull request #15628: URL: https://github.com/apache/flink/pull/15628#issuecomment-820416194 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

[jira] [Updated] (FLINK-21329) "Local recovery and sticky scheduling end-to-end test" does not finish within 600 seconds

2021-04-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21329: --- Labels: pull-request-available test-stability (was: test-stability) > "Local recovery and

[GitHub] [flink] rkhachatryan opened a new pull request #15628: [FLINK-21329][tests] Increase timeout and delay in local test_local_recovery_and_scheduling.sh

2021-04-15 Thread GitBox
rkhachatryan opened a new pull request #15628: URL: https://github.com/apache/flink/pull/15628 ## What is the purpose of the change 1. Fix `test_local_recovery_and_scheduling.sh` by increasing test timeout and add emit interval at sources 1. Ease further debug by logging the time

[GitHub] [flink-web] morsapaes commented on a change in pull request #434: [FLINK-21720] Updates documentation style guides for the new (Hugo) build system

2021-04-15 Thread GitBox
morsapaes commented on a change in pull request #434: URL: https://github.com/apache/flink-web/pull/434#discussion_r614057537 ## File path: contributing/improve-website.md ## @@ -33,7 +33,7 @@ git checkout asf-site ## Directory structure and files -Flink's website is

[GitHub] [flink-web] morsapaes commented on a change in pull request #434: [FLINK-21720] Updates documentation style guides for the new (Hugo) build system

2021-04-15 Thread GitBox
morsapaes commented on a change in pull request #434: URL: https://github.com/apache/flink-web/pull/434#discussion_r614057537 ## File path: contributing/improve-website.md ## @@ -33,7 +33,7 @@ git checkout asf-site ## Directory structure and files -Flink's website is

[GitHub] [flink-web] morsapaes commented on a change in pull request #434: [FLINK-21720] Updates documentation style guides for the new (Hugo) build system

2021-04-15 Thread GitBox
morsapaes commented on a change in pull request #434: URL: https://github.com/apache/flink-web/pull/434#discussion_r614057537 ## File path: contributing/improve-website.md ## @@ -33,7 +33,7 @@ git checkout asf-site ## Directory structure and files -Flink's website is

[GitHub] [flink] flinkbot commented on pull request #15627: [FLINK-22141] test case for JdbcXaSinkFunction manual test

2021-04-15 Thread GitBox
flinkbot commented on pull request #15627: URL: https://github.com/apache/flink/pull/15627#issuecomment-820410834 ## CI report: * 8c81924d47c84fc6373424834bd974852a817db8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15626: [FLINK-22286][python] Fix picklebytescoder doesn't support custom python class

2021-04-15 Thread GitBox
flinkbot commented on pull request #15626: URL: https://github.com/apache/flink/pull/15626#issuecomment-820410735 ## CI report: * be5997550897ff4f5cd9bcab289bc98e31b7ddde UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15624: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15624: URL: https://github.com/apache/flink/pull/15624#issuecomment-820375204 ## CI report: * 116353fd046e9ff90c2aee13fa9de250541c9b48 Azure:

[jira] [Comment Edited] (FLINK-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference

2021-04-15 Thread Andrea Peruffo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322161#comment-17322161 ] Andrea Peruffo edited comment on FLINK-22262 at 4/15/21, 1:10 PM: --

[GitHub] [flink] flinkbot edited a comment on pull request #15621: [FLINK-21879][tests] Harden ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15621: URL: https://github.com/apache/flink/pull/15621#issuecomment-820267169 ## CI report: * 77e1b15a83e1e073054aa2254e528f6d3093ec3d Azure:

[jira] [Comment Edited] (FLINK-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference

2021-04-15 Thread Andrea Peruffo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322161#comment-17322161 ] Andrea Peruffo edited comment on FLINK-22262 at 4/15/21, 1:09 PM: --

[GitHub] [flink-web] StephanEwen commented on pull request #433: [release] [statefun] Announcement blog post and Downloads page update for StateFun 3.0.0

2021-04-15 Thread GitBox
StephanEwen commented on pull request #433: URL: https://github.com/apache/flink-web/pull/433#issuecomment-820408950 If you want, feel free to drop the "on Kubernetes and Cloud platforms" part. I wasn't sure about that. It might sound limiting, but it might also help narrow the scope in a

[jira] [Resolved] (FLINK-21941) testSavepointRescalingOutPartitionedOperatorStateList fail

2021-04-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-21941. -- Resolution: Fixed Fixed in: * master ** 28deff965d63313095114118367075d08d8c075d

[GitHub] [flink] dawidwys closed pull request #15614: [FLINK-21941] Make sure jobs do not finish before taking savepoint in RescalingITCase

2021-04-15 Thread GitBox
dawidwys closed pull request #15614: URL: https://github.com/apache/flink/pull/15614 -- 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,

[GitHub] [flink] dawidwys merged pull request #15613: [FLINK-21941] Make sure jobs do not finish before taking savepoint in RescalingITCase

2021-04-15 Thread GitBox
dawidwys merged pull request #15613: URL: https://github.com/apache/flink/pull/15613 -- 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,

[jira] [Closed] (FLINK-22293) Throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices

2021-04-15 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-22293. -- Resolution: Duplicate > Throw IllegalArgumentException when getNumFiles with partitions on different

[jira] [Commented] (FLINK-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference

2021-04-15 Thread Andrea Peruffo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322161#comment-17322161 ] Andrea Peruffo commented on FLINK-22262: Thanks for your input [~fly_in_gis] , I have

[jira] [Updated] (FLINK-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference

2021-04-15 Thread Andrea Peruffo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrea Peruffo updated FLINK-22262: --- Attachment: jm.log > Flink on Kubernetes ConfigMaps are created without OwnerReference >

[jira] [Closed] (FLINK-22292) Add documentation about state access in Python DataStream API

2021-04-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-22292. --- Resolution: Fixed Merged to master via 2a4265d3dad0d94743d69c38f3284bd5f76ee32d > Add documentation about

[jira] [Updated] (FLINK-13437) Add Hive SQL E2E test

2021-04-15 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13437: --- Fix Version/s: (was: 1.13.0) > Add Hive SQL E2E test > - > >

[GitHub] [flink] AHeise commented on a change in pull request #15613: [FLINK-21941] Make sure jobs do not finish before taking savepoint in RescalingITCase

2021-04-15 Thread GitBox
AHeise commented on a change in pull request #15613: URL: https://github.com/apache/flink/pull/15613#discussion_r614042775 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java ## @@ -876,6 +887,8 @@ public void run(SourceContext

[GitHub] [flink] dianfu closed pull request #15623: [FLINK-22292][python][docs] Add documentation for state acess in Python DataStream API

2021-04-15 Thread GitBox
dianfu closed pull request #15623: URL: https://github.com/apache/flink/pull/15623 -- 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

[jira] [Closed] (FLINK-22125) Revisit the return value of MapState.get when a key doesn't exist

2021-04-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-22125. --- Resolution: Fixed Merged to master via f79333d8b6d04a14fcf8e62a2c35df8ea64548e5 > Revisit the return value

[GitHub] [flink] dianfu closed pull request #15618: [FLINK-22125][python] Returns None when a key doesn't exist when calling MapState.get()

2021-04-15 Thread GitBox
dianfu closed pull request #15618: URL: https://github.com/apache/flink/pull/15618 -- 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

[GitHub] [flink] flinkbot commented on pull request #15627: [FLINK-22141] test case for JdbcXaSinkFunction manual test

2021-04-15 Thread GitBox
flinkbot commented on pull request #15627: URL: https://github.com/apache/flink/pull/15627#issuecomment-820398203 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

[GitHub] [flink] flinkbot edited a comment on pull request #15624: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15624: URL: https://github.com/apache/flink/pull/15624#issuecomment-820375204 ## CI report: * 116353fd046e9ff90c2aee13fa9de250541c9b48 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15625: [FLINK-20761][hive] Escape the location path when creating input spli…

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15625: URL: https://github.com/apache/flink/pull/15625#issuecomment-820375281 ## CI report: * 54d0cef24bee5896b148b79dd8501a1595db91d1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15589: [Flink-22248][Flink-22249] Harden JobMasterStopWithSavepointITCase

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15589: URL: https://github.com/apache/flink/pull/15589#issuecomment-818562022 ## CI report: * 0344f2d9a7d7f5e995dbd9c193d2c3dbd3fdddb8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15546: [FLINK-21346][build system] Adding timeout to all tasks

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15546: URL: https://github.com/apache/flink/pull/15546#issuecomment-816538766 ## CI report: * a9291f19a08586fad64515800cadd838caa66b25 Azure:

[jira] [Closed] (FLINK-20479) Support Row-based Operations in Python Table API

2021-04-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20479. --- Resolution: Implemented > Support Row-based Operations in Python Table API >

[jira] [Closed] (FLINK-20779) Add documentation for row-based operation in Python Table API

2021-04-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20779. --- Resolution: Fixed Merged to master via 75aeb9b4d3c1f7ccfbd2401dfdb2aaa1dbdeef7e > Add documentation for

[GitHub] [flink] dianfu closed pull request #15607: [FLINK-20779][python][docs] Add documentation for row-based operation in Python Table API

2021-04-15 Thread GitBox
dianfu closed pull request #15607: URL: https://github.com/apache/flink/pull/15607 -- 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

[GitHub] [flink-web] tzulitai commented on a change in pull request #433: [release] [statefun] Announcement blog post and Downloads page update for StateFun 3.0.0

2021-04-15 Thread GitBox
tzulitai commented on a change in pull request #433: URL: https://github.com/apache/flink-web/pull/433#discussion_r614030855 ## File path: _posts/2021-04-14-release-statefun-3.0.0.md ## @@ -0,0 +1,166 @@ +--- +layout: post +title: "Stateful Functions 3.0.0 Release

[GitHub] [flink-web] tzulitai commented on a change in pull request #433: [release] [statefun] Announcement blog post and Downloads page update for StateFun 3.0.0

2021-04-15 Thread GitBox
tzulitai commented on a change in pull request #433: URL: https://github.com/apache/flink-web/pull/433#discussion_r614030528 ## File path: _posts/2021-04-14-release-statefun-3.0.0.md ## @@ -0,0 +1,166 @@ +--- +layout: post +title: "Stateful Functions 3.0.0 Release

[jira] [Updated] (FLINK-22141) Manually test exactly-once JDBC sink

2021-04-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22141: --- Labels: pull-request-available release-testing (was: release-testing) > Manually test

[jira] [Resolved] (FLINK-22236) Document opt-in behavior of flamegraph

2021-04-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-22236. -- Resolution: Implemented Implemented in fc0abf71fe00ca23dd69421f1315b4c4fe95903c >

[GitHub] [flink] flinkbot commented on pull request #15626: [FLINK-22286][python] Fix picklebytescoder doesn't support custom python class

2021-04-15 Thread GitBox
flinkbot commented on pull request #15626: URL: https://github.com/apache/flink/pull/15626#issuecomment-820385557 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

[GitHub] [flink] curcur opened a new pull request #15627: [FLINK-22141] test case for JdbcXaSinkFunction manual test

2021-04-15 Thread GitBox
curcur opened a new pull request #15627: URL: https://github.com/apache/flink/pull/15627 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[GitHub] [flink] dawidwys merged pull request #15610: [FLINK-22236][docs] Document opt-in behavior of FlameGraph

2021-04-15 Thread GitBox
dawidwys merged pull request #15610: URL: https://github.com/apache/flink/pull/15610 -- 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,

[GitHub] [flink] dawidwys commented on pull request #15610: [FLINK-22236][docs] Document opt-in behavior of FlameGraph

2021-04-15 Thread GitBox
dawidwys commented on pull request #15610: URL: https://github.com/apache/flink/pull/15610#issuecomment-820384849 Thanks for the update! I will merge it as I saw you addressed all comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Updated] (FLINK-22286) Fix picklebytescoder doesn't support custom python class

2021-04-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22286: --- Labels: pull-request-available (was: ) > Fix picklebytescoder doesn't support custom

[GitHub] [flink] HuangXingBo opened a new pull request #15626: [FLINK-22286][python] Fix picklebytescoder doesn't support custom python class

2021-04-15 Thread GitBox
HuangXingBo opened a new pull request #15626: URL: https://github.com/apache/flink/pull/15626 ## What is the purpose of the change *This pull request will fix picklebytescoder doesn't support custom python class* ## Brief change log - *replace `pickle` with

[GitHub] [flink] zuston commented on pull request #15624: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

2021-04-15 Thread GitBox
zuston commented on pull request #15624: URL: https://github.com/apache/flink/pull/15624#issuecomment-820383988 > @zuston Thanks for working on this issue. LGTM except for one minor comment. Thanks for you reply. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] zuston commented on a change in pull request #15624: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

2021-04-15 Thread GitBox
zuston commented on a change in pull request #15624: URL: https://github.com/apache/flink/pull/15624#discussion_r614017081 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputFormat.java ## @@ -345,13 +345,10

[jira] [Commented] (FLINK-22153) Manually test the sort-merge blocking shuffle

2021-04-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322133#comment-17322133 ] Till Rohrmann commented on FLINK-22153: --- My first observation is that the sort-merge blocking

[GitHub] [flink] lirui-apache commented on pull request #15624: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

2021-04-15 Thread GitBox
lirui-apache commented on pull request #15624: URL: https://github.com/apache/flink/pull/15624#issuecomment-820379737 @zuston Thanks for working on this issue. LGTM except for one minor comment. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-22295) Document sort-merge blocking shuffle

2021-04-15 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-22295: - Summary: Document sort-merge blocking shuffle Key: FLINK-22295 URL: https://issues.apache.org/jira/browse/FLINK-22295 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-22266) Harden JobMasterStopWithSavepointITCase

2021-04-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322132#comment-17322132 ] Dawid Wysakowicz commented on FLINK-22266: -- Thanks for the pointer! > Harden

[GitHub] [flink] zuston commented on a change in pull request #15624: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

2021-04-15 Thread GitBox
zuston commented on a change in pull request #15624: URL: https://github.com/apache/flink/pull/15624#discussion_r614017081 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputFormat.java ## @@ -345,13 +345,10

[GitHub] [flink] lirui-apache commented on a change in pull request #15624: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

2021-04-15 Thread GitBox
lirui-apache commented on a change in pull request #15624: URL: https://github.com/apache/flink/pull/15624#discussion_r614015884 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputFormat.java ## @@ -345,13

[GitHub] [flink] flinkbot commented on pull request #15625: [FLINK-20761][hive] Escape the location path when creating input spli…

2021-04-15 Thread GitBox
flinkbot commented on pull request #15625: URL: https://github.com/apache/flink/pull/15625#issuecomment-820375281 ## CI report: * 54d0cef24bee5896b148b79dd8501a1595db91d1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15624: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

2021-04-15 Thread GitBox
flinkbot commented on pull request #15624: URL: https://github.com/apache/flink/pull/15624#issuecomment-820375204 ## CI report: * 116353fd046e9ff90c2aee13fa9de250541c9b48 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15623: [FLINK-22292][python][docs] Add documentation for state acess in Python DataStream API

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15623: URL: https://github.com/apache/flink/pull/15623#issuecomment-820363670 ## CI report: * ac7717003d88fc10fb4562e2c413c344351c7a72 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15589: [Flink-22248][Flink-22249] Harden JobMasterStopWithSavepointITCase

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15589: URL: https://github.com/apache/flink/pull/15589#issuecomment-818562022 ## CI report: * 0344f2d9a7d7f5e995dbd9c193d2c3dbd3fdddb8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15546: [FLINK-21346][build system] Adding timeout to all tasks

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15546: URL: https://github.com/apache/flink/pull/15546#issuecomment-816538766 ## CI report: * a9291f19a08586fad64515800cadd838caa66b25 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15559: [FLINK-21627][table-planner-blink] The digest of TableScan & Sink should consider table hints

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15559: URL: https://github.com/apache/flink/pull/15559#issuecomment-817479787 ## CI report: * 32b7789699122e7e4e495de4d3f7df282ba8d2b5 UNKNOWN * 627e5ba06f413851352c6c37c13505816e54cfd8 Azure:

[jira] [Commented] (FLINK-22266) Harden JobMasterStopWithSavepointITCase

2021-04-15 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322128#comment-17322128 ] Till Rohrmann commented on FLINK-22266: --- When running the tests in a loop, it can happen that you

[GitHub] [flink] zuston commented on pull request #15624: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

2021-04-15 Thread GitBox
zuston commented on pull request #15624: URL: https://github.com/apache/flink/pull/15624#issuecomment-820369895 Could you review it @lirui-apache -- 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

[GitHub] [flink] zuston edited a comment on pull request #15624: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

2021-04-15 Thread GitBox
zuston edited a comment on pull request #15624: URL: https://github.com/apache/flink/pull/15624#issuecomment-820369895 Could you review it @lirui-apache . Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Comment Edited] (FLINK-22294) Hive reading fail when getting file numbers on different filesystem nameservices

2021-04-15 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322117#comment-17322117 ] Junfan Zhang edited comment on FLINK-22294 at 4/15/21, 11:57 AM: - Could

[GitHub] [flink] HuangXingBo commented on a change in pull request #15623: [FLINK-22292][python][docs] Add documentation for state acess in Python DataStream API

2021-04-15 Thread GitBox
HuangXingBo commented on a change in pull request #15623: URL: https://github.com/apache/flink/pull/15623#discussion_r613999180 ## File path: docs/content.zh/docs/dev/datastream/fault-tolerance/state.md ## @@ -240,6 +248,54 @@ object ExampleCountWindowAverage extends App { }

[jira] [Updated] (FLINK-22294) Hive reading fail when getting file numbers on different filesystem nameservices

2021-04-15 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22294: - Summary: Hive reading fail when getting file numbers on different filesystem nameservices

[GitHub] [flink-web] StephanEwen edited a comment on pull request #433: [release] [statefun] Announcement blog post and Downloads page update for StateFun 3.0.0

2021-04-15 Thread GitBox
StephanEwen edited a comment on pull request #433: URL: https://github.com/apache/flink-web/pull/433#issuecomment-820356948 What do you think about this as the introductory paragraph? The Apache Flink community is happy to announce the release of Stateful Functions

[GitHub] [flink] flinkbot commented on pull request #15625: [FLINK-20761][hive] Escape the location path when creating input spli…

2021-04-15 Thread GitBox
flinkbot commented on pull request #15625: URL: https://github.com/apache/flink/pull/15625#issuecomment-820363974 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

[GitHub] [flink] flinkbot commented on pull request #15623: [FLINK-22292][python][docs] Add documentation for state acess in Python DataStream API

2021-04-15 Thread GitBox
flinkbot commented on pull request #15623: URL: https://github.com/apache/flink/pull/15623#issuecomment-820363670 ## CI report: * ac7717003d88fc10fb4562e2c413c344351c7a72 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15546: [FLINK-21346][build system] Adding timeout to all tasks

2021-04-15 Thread GitBox
flinkbot edited a comment on pull request #15546: URL: https://github.com/apache/flink/pull/15546#issuecomment-816538766 ## CI report: * a9291f19a08586fad64515800cadd838caa66b25 Azure:

[jira] [Updated] (FLINK-22294) Throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices

2021-04-15 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22294: - Description: The same problem like  https://issues.apache.org/jira/browse/FLINK-20710 > Throw

[jira] [Commented] (FLINK-22019) UnalignedCheckpointRescaleITCase hangs on azure

2021-04-15 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322118#comment-17322118 ] Arvid Heise commented on FLINK-22019: - Let's wait for FLINK-21346 for more investigation. >

[GitHub] [flink] flinkbot commented on pull request #15624: [FLINK-22294] Fix throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices

2021-04-15 Thread GitBox
flinkbot commented on pull request #15624: URL: https://github.com/apache/flink/pull/15624#issuecomment-820362901 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

[GitHub] [flink] lirui-apache opened a new pull request #15625: [FLINK-20761][hive] Escape the location path when creating input spli…

2021-04-15 Thread GitBox
lirui-apache opened a new pull request #15625: URL: https://github.com/apache/flink/pull/15625 ## What is the purpose of the change Fix the issue that we can't read hive table/partition whose location contains comma character ## Brief change log - Escape

[jira] [Commented] (FLINK-22294) Throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices

2021-04-15 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322117#comment-17322117 ] Junfan Zhang commented on FLINK-22294: -- Could you help assign this to me? [~lirui] > Throw

[jira] [Updated] (FLINK-22294) Throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices

2021-04-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22294: --- Labels: pull-request-available (was: ) > Throw IllegalArgumentException when getNumFiles

[GitHub] [flink] zuston opened a new pull request #15624: [FLINK-22294] Fix throw IllegalArgumentException when getNumFiles with partitions on different hdfs nameservices

2021-04-15 Thread GitBox
zuston opened a new pull request #15624: URL: https://github.com/apache/flink/pull/15624 … ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

[jira] [Updated] (FLINK-22266) Harden JobMasterStopWithSavepointITCase

2021-04-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22266: - Summary: Harden JobMasterStopWithSavepointITCase (was:

[jira] [Commented] (FLINK-22266) JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithNoRestartsShouldFailTheTerminate fail

2021-04-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322116#comment-17322116 ] Dawid Wysakowicz commented on FLINK-22266: -- Hey Till Rohrmann I've seen your comment Yes you

[jira] [Closed] (FLINK-22268) JobMasterStopWithSavepointITCase.testRestartCheckpointCoordinatorIfStopWithSavepointFails fail because of "Not all required tasks are currently running."

2021-04-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-22268. Resolution: Duplicate >

<    1   2   3   4   5   >