[jira] [Updated] (FLINK-20055) Datadog API Key exposed in Flink JobManager logs

2020-12-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-20055: - Affects Version/s: (was: 1.11.2) (was: 1.9.1)

[GitHub] [flink] zentol merged pull request #13995: [FLINK-20055] [runtime/config] - hide sensitive datadog API key from logs

2020-12-02 Thread GitBox
zentol merged pull request #13995: URL: https://github.com/apache/flink/pull/13995 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

[GitHub] [flink] zentol commented on a change in pull request #13995: [FLINK-20055] [runtime/config] - hide sensitive datadog API key from logs

2020-12-02 Thread GitBox
zentol commented on a change in pull request #13995: URL: https://github.com/apache/flink/pull/13995#discussion_r534533271 ## File path: flink-core/src/main/java/org/apache/flink/configuration/GlobalConfiguration.java ## @@ -44,7 +44,8 @@ public static final String

[GitHub] [flink] flinkbot edited a comment on pull request #13964: [FLINK-19314][coordination] Add DeclarativeSlotPoolBridge

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #13964: URL: https://github.com/apache/flink/pull/13964#issuecomment-723100396 ## CI report: * 002a26e22352ec2a5c79c3cde4ed4b749f87e7e1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13722: [FLINK-19636][coordination] Add DeclarativeSlotPool

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #13722: URL: https://github.com/apache/flink/pull/13722#issuecomment-713509789 ## CI report: * 7cdd555313da89f3b6be3da396e6782460a482d8 UNKNOWN * 2f59bf5d7da389a1f208497fec6d4453bee129de Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13722: [FLINK-19636][coordination] Add DeclarativeSlotPool

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #13722: URL: https://github.com/apache/flink/pull/13722#issuecomment-713509789 ## CI report: * 7cdd555313da89f3b6be3da396e6782460a482d8 UNKNOWN * 2f59bf5d7da389a1f208497fec6d4453bee129de Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14290: [FLINK-19725][runtime] Increased the timeout for the instantiation of the akka logger.

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14290: URL: https://github.com/apache/flink/pull/14290#issuecomment-737361432 ## CI report: * 9e641d037ebefb6e4f84a7d0e1a1ce68702d2b16 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * 851970c1c94f8f44058f914d3dbeb959cb66ee53 Azure:

[GitHub] [flink-web] morsapaes opened a new pull request #397: Add 1.12 Release announcement.

2020-12-02 Thread GitBox
morsapaes opened a new pull request #397: URL: https://github.com/apache/flink-web/pull/397 Adding a blogpost for the upcoming 1.12 release announcement. Feel free to comment and leave any feedback! This is an

[GitHub] [flink] rmetzger commented on a change in pull request #14238: [FLINK-20347] Rework YARN documentation page

2020-12-02 Thread GitBox
rmetzger commented on a change in pull request #14238: URL: https://github.com/apache/flink/pull/14238#discussion_r534389195 ## File path: docs/deployment/resource-providers/yarn.md ## @@ -0,0 +1,238 @@ +--- +title: "Apache Hadoop YARN" +nav-title: YARN +nav-parent_id:

[GitHub] [flink] tillrohrmann commented on a change in pull request #14287: [FLINK-20352][docs] Updated CLI documentation.

2020-12-02 Thread GitBox
tillrohrmann commented on a change in pull request #14287: URL: https://github.com/apache/flink/pull/14287#discussion_r534376202 ## File path: docs/deployment/cli.md ## @@ -23,664 +23,254 @@ specific language governing permissions and limitations under the License. -->

[GitHub] [flink] tillrohrmann commented on a change in pull request #14238: [FLINK-20347] Rework YARN documentation page

2020-12-02 Thread GitBox
tillrohrmann commented on a change in pull request #14238: URL: https://github.com/apache/flink/pull/14238#discussion_r534375151 ## File path: docs/deployment/resource-providers/yarn.md ## @@ -0,0 +1,238 @@ +--- +title: "Apache Hadoop YARN" +nav-title: YARN +nav-parent_id:

[GitHub] [flink] tillrohrmann commented on a change in pull request #14238: [FLINK-20347] Rework YARN documentation page

2020-12-02 Thread GitBox
tillrohrmann commented on a change in pull request #14238: URL: https://github.com/apache/flink/pull/14238#discussion_r534374897 ## File path: docs/deployment/resource-providers/yarn.md ## @@ -0,0 +1,238 @@ +--- +title: "Apache Hadoop YARN" +nav-title: YARN +nav-parent_id:

[jira] [Commented] (FLINK-20221) DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss

2020-12-02 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242543#comment-17242543 ] Gyula Fora commented on FLINK-20221: release-1.12: b82a3dc3939bcf4fa5e6f398eafb7d0e92bf62c7

[GitHub] [flink] HuangZhenQiu commented on pull request #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager

2020-12-02 Thread GitBox
HuangZhenQiu commented on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-737375866 @xintongsong Would you please help to review this PR? This is an automated message from the Apache Git

[GitHub] [flink] gyfora commented on pull request #14288: [backport-1.12] [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
gyfora commented on pull request #14288: URL: https://github.com/apache/flink/pull/14288#issuecomment-737375231 merged This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] gyfora closed pull request #14288: [backport-1.12] [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
gyfora closed pull request #14288: URL: https://github.com/apache/flink/pull/14288 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

[GitHub] [flink] gyfora closed pull request #14289: [backport-1.11] [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
gyfora closed pull request #14289: URL: https://github.com/apache/flink/pull/14289 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

[GitHub] [flink] gyfora commented on pull request #14289: [backport-1.11] [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
gyfora commented on pull request #14289: URL: https://github.com/apache/flink/pull/14289#issuecomment-737373450 Merged This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #14290: [FLINK-19725][runtime] Increased the timeout for the instantiation of the akka logger.

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14290: URL: https://github.com/apache/flink/pull/14290#issuecomment-737361432 ## CI report: * 9e641d037ebefb6e4f84a7d0e1a1ce68702d2b16 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14288: [backport-1.12] [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14288: URL: https://github.com/apache/flink/pull/14288#issuecomment-737209587 ## CI report: * d298c6df7d9c780c5f29f93ceea25c9d719aba0d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * 57ed58c709400cabc75c5a6a4fe8587bca16dbb8 Azure:

[GitHub] [flink] flinkbot commented on pull request #14290: [FLINK-19725][runtime] Increased the timeout for the instantiation of the akka logger.

2020-12-02 Thread GitBox
flinkbot commented on pull request #14290: URL: https://github.com/apache/flink/pull/14290#issuecomment-737361432 ## CI report: * 9e641d037ebefb6e4f84a7d0e1a1ce68702d2b16 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-736629561 ## CI report: * 57ed58c709400cabc75c5a6a4fe8587bca16dbb8 Azure:

[GitHub] [flink] kl0u commented on pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-12-02 Thread GitBox
kl0u commented on pull request #14028: URL: https://github.com/apache/flink/pull/14028#issuecomment-737359487 Although the `ProgramInvocationException` is not annotated as `Public` or `PublicEvolving`, due to the fact that it has been here since forever, it seems that in some places we

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242502#comment-17242502 ] Dawid Wysakowicz commented on FLINK-19970: -- Sorry, my bad. Please try again. > State leak in

[GitHub] [flink] flinkbot edited a comment on pull request #14289: [backport-1.11] [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14289: URL: https://github.com/apache/flink/pull/14289#issuecomment-737210394 ## CI report: * b931e79bf211d430583cb7d6de5be6cef88bef53 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14277: [FLINK-20443][API/DataStream]fix lost data in last interval in per window

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14277: URL: https://github.com/apache/flink/pull/14277#issuecomment-736556006 ## CI report: * ee61db5de07ef728b2df3b157e68a60c28623359 Azure:

[GitHub] [flink] flinkbot commented on pull request #14290: [FLINK-19725][runtime] Increased the timeout for the instantiation of the akka logger.

2020-12-02 Thread GitBox
flinkbot commented on pull request #14290: URL: https://github.com/apache/flink/pull/14290#issuecomment-737341571 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] [Commented] (FLINK-20454) Allow to read metadata for debezium-avro-confluent format

2020-12-02 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242483#comment-17242483 ] hailong wang commented on FLINK-20454: -- Hi [~jark] ,can I take this issue~ > Allow to read

[jira] [Updated] (FLINK-19725) Logger cannot be initialized due to timeout: LoggerInitializationException is thrown

2020-12-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19725: --- Labels: pull-request-available test-stability (was: test-stability) > Logger cannot be

[GitHub] [flink] XComp commented on pull request #14290: [FLINK-19725][runtime] Increased the timeout for the instantiation of the akka logger.

2020-12-02 Thread GitBox
XComp commented on pull request #14290: URL: https://github.com/apache/flink/pull/14290#issuecomment-737340098 @tillrohrmann I guess something for you to review. This is an automated message from the Apache Git Service. To

[GitHub] [flink] XComp opened a new pull request #14290: [FLINK-19725][runtime] Increased the timeout for the instantiation of the akka logger.

2020-12-02 Thread GitBox
XComp opened a new pull request #14290: URL: https://github.com/apache/flink/pull/14290 … ## What is the purpose of the change Occasionally, we had failing builds due to the Slf4Logger not being instantiated in time. The default setting is 5s which might be

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-02 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242478#comment-17242478 ] Thomas Wozniakowski commented on FLINK-19970: - For some reason I can't compile your branch,

[jira] [Comment Edited] (FLINK-19725) Logger cannot be initialized due to timeout: LoggerInitializationException is thrown

2020-12-02 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241649#comment-17241649 ] Matthias edited comment on FLINK-19725 at 12/2/20, 4:14 PM: Several SO

[GitHub] [flink] flinkbot edited a comment on pull request #14277: [FLINK-20443][API/DataStream]fix lost data in last interval in per window

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14277: URL: https://github.com/apache/flink/pull/14277#issuecomment-736556006 ## CI report: * 81f15556a782db8b8958cf6498a654ac28e525f7 Azure:

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

2020-12-02 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242471#comment-17242471 ] Matthias commented on FLINK-16947: --

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242463#comment-17242463 ] Dawid Wysakowicz commented on FLINK-19970: -- Yeah, you're actually right. It's enough to build

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-02 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242459#comment-17242459 ] Thomas Wozniakowski commented on FLINK-19970: - Do I need to rebuild our Job JAR using the

[jira] [Closed] (FLINK-20447) Querying grouy by PK does not work

2020-12-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20447. --- Resolution: Not A Problem > Querying grouy by PK does not work > -- > >

[jira] [Commented] (FLINK-20447) Querying grouy by PK does not work

2020-12-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242456#comment-17242456 ] Jark Wu commented on FLINK-20447: - Even if {{Code}} is the primary key, you still have to wrap

[jira] [Commented] (FLINK-20455) Add check to LicenseChecker for top level /LICENSE files in shaded jars

2020-12-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242455#comment-17242455 ] Robert Metzger commented on FLINK-20455: Besides FLINK-20442,

[jira] [Created] (FLINK-20455) Add check to LicenseChecker for top level /LICENSE files in shaded jars

2020-12-02 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20455: -- Summary: Add check to LicenseChecker for top level /LICENSE files in shaded jars Key: FLINK-20455 URL: https://issues.apache.org/jira/browse/FLINK-20455 Project:

[jira] [Commented] (FLINK-20373) Flink table jsonArray access all

2020-12-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242450#comment-17242450 ] Jark Wu commented on FLINK-20373: - Sorry, I still can't understand what feature do you want. Could you

[GitHub] [flink] SteNicholas commented on a change in pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-12-02 Thread GitBox
SteNicholas commented on a change in pull request #14028: URL: https://github.com/apache/flink/pull/14028#discussion_r534270664 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/client/JobExecutionException.java ## @@ -19,41 +19,67 @@ package

[jira] [Closed] (FLINK-20452) Mysql JDBC Sink UpsertStreamTableSink requires that Table has a full primary keys

2020-12-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20452. --- Resolution: Not A Problem > Mysql JDBC Sink UpsertStreamTableSink requires that Table has a full primary >

[jira] [Commented] (FLINK-20388) Supports users setting operators' metrics name

2020-12-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242445#comment-17242445 ] Jark Wu commented on FLINK-20388: - Operator description sounds good to me [~chesnay]. > Supports users

[jira] [Updated] (FLINK-20437) Port ExecNode to Java

2020-12-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20437: Component/s: Table SQL / Planner > Port ExecNode to Java > - > > Key:

[jira] [Closed] (FLINK-20428) ZooKeeperLeaderElectionConnectionHandlingTest.testConnectionSuspendedHandlingDuringInitialization failed with "No result is expected since there was no leader elected bef

2020-12-02 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-20428. - Fix Version/s: 1.13.0 1.12.1 Resolution: Fixed Fixed via 1.13.0:

[jira] [Created] (FLINK-20454) Allow to read metadata for debezium-avro-confluent format

2020-12-02 Thread Jark Wu (Jira)
Jark Wu created FLINK-20454: --- Summary: Allow to read metadata for debezium-avro-confluent format Key: FLINK-20454 URL: https://issues.apache.org/jira/browse/FLINK-20454 Project: Flink Issue Type:

[GitHub] [flink] tillrohrmann closed pull request #14268: [FLINK-20428][test] Fix the unstable test ZooKeeperLeaderElectionConnectionHandlingTest#testConnectionSuspendedHandlingDuringInitialization

2020-12-02 Thread GitBox
tillrohrmann closed pull request #14268: URL: https://github.com/apache/flink/pull/14268 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

[jira] [Updated] (FLINK-20385) Allow to read metadata for Canal-json format

2020-12-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20385: Parent: FLINK-18822 Issue Type: Sub-task (was: New Feature) > Allow to read metadata for

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242437#comment-17242437 ] Dawid Wysakowicz commented on FLINK-19970: -- I think it should be rather easy to use this script

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-02 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242433#comment-17242433 ] Thomas Wozniakowski commented on FLINK-19970: - Hey [~dwysakowicz] - great to hear you have a

[GitHub] [flink] tillrohrmann commented on pull request #11338: [FLINK-10052][ha] Tolerate temporarily suspended ZooKeeper connections

2020-12-02 Thread GitBox
tillrohrmann commented on pull request #11338: URL: https://github.com/apache/flink/pull/11338#issuecomment-737294327 Sorry @paulangton. This is still on my plate to review. I'll try to get to it once we have the 1.12 release out. I hope that we can include this feature in the next

[GitHub] [flink] tillrohrmann commented on a change in pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-12-02 Thread GitBox
tillrohrmann commented on a change in pull request #14028: URL: https://github.com/apache/flink/pull/14028#discussion_r534245909 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/client/JobExecutionException.java ## @@ -19,41 +19,67 @@ package

[jira] [Commented] (FLINK-20439) Consider simplifying or removing mechanism to scheduleOrUpdateConsumers

2020-12-02 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242422#comment-17242422 ] Till Rohrmann commented on FLINK-20439: --- Sounds like a good idea to me. > Consider simplifying or

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242420#comment-17242420 ] Dawid Wysakowicz commented on FLINK-19970: -- Hey [~Jamalarm], I worked a little bit on the

[jira] [Commented] (FLINK-20341) Rework Deployment / Coordination Documentation

2020-12-02 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242419#comment-17242419 ] Till Rohrmann commented on FLINK-20341: --- Very good point you are bringing up here [~Leonard Xu].

[jira] [Comment Edited] (FLINK-20427) Remove CheckpointConfig.setPreferCheckpointForRecovery because it can lead to data loss

2020-12-02 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242413#comment-17242413 ] Till Rohrmann edited comment on FLINK-20427 at 12/2/20, 2:59 PM: - No, it

[jira] [Commented] (FLINK-20427) Remove CheckpointConfig.setPreferCheckpointForRecovery because it can lead to data loss

2020-12-02 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242413#comment-17242413 ] Till Rohrmann commented on FLINK-20427: --- No, it is only a problem if a regional failover occurs

[GitHub] [flink] tillrohrmann commented on a change in pull request #14195: [FLINK-20300] Add Flink 1.12 release notes

2020-12-02 Thread GitBox
tillrohrmann commented on a change in pull request #14195: URL: https://github.com/apache/flink/pull/14195#discussion_r534222972 ## File path: docs/release-notes/flink-1.12.md ## @@ -0,0 +1,169 @@ +--- +title: "Release Notes - Flink 1.12" +--- + + + +These release notes

[jira] [Comment Edited] (FLINK-20452) Mysql JDBC Sink UpsertStreamTableSink requires that Table has a full primary keys

2020-12-02 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242387#comment-17242387 ] Leonard Xu edited comment on FLINK-20452 at 12/2/20, 2:45 PM: -- Hi,

[jira] [Commented] (FLINK-20434) Getting The desired archetype does not exist

2020-12-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242403#comment-17242403 ] Chesnay Schepler commented on FLINK-20434: -- [~avilevi] That version of the documentation is not

[jira] [Commented] (FLINK-19725) Logger cannot be initialized due to timeout: LoggerInitializationException is thrown

2020-12-02 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242399#comment-17242399 ] Till Rohrmann commented on FLINK-19725: --- Sounds like a good idea [~mapohl]. +1 for increasing the

[GitHub] [flink] leonardBang commented on pull request #14229: [FLINK-20292][doc] Improve the document about table formats overlap in user fat jar

2020-12-02 Thread GitBox
leonardBang commented on pull request #14229: URL: https://github.com/apache/flink/pull/14229#issuecomment-737267668 @gaoyunhaii Could you have a more look? This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #14286: [FLINK-19398][connectors/hive] Fix the failure when creating hive connector from userclassloader

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14286: URL: https://github.com/apache/flink/pull/14286#issuecomment-737159858 ## CI report: * 94d3621221214543eea1126571a2c6de6b657962 Azure:

[GitHub] [flink] aljoscha commented on a change in pull request #14195: [FLINK-20300] Add Flink 1.12 release notes

2020-12-02 Thread GitBox
aljoscha commented on a change in pull request #14195: URL: https://github.com/apache/flink/pull/14195#discussion_r534210755 ## File path: docs/release-notes/flink-1.12.md ## @@ -0,0 +1,169 @@ +--- +title: "Release Notes - Flink 1.12" +--- + + + +These release notes discuss

[GitHub] [flink] XComp commented on pull request #14287: [FLINK-20352][docs] Updated CLI documentation.

2020-12-02 Thread GitBox
XComp commented on pull request #14287: URL: https://github.com/apache/flink/pull/14287#issuecomment-737262955 @kl0u it would be nice to get some feedback from you as well This is an automated message from the Apache Git

[GitHub] [flink] XComp commented on pull request #14287: [FLINK-20352][docs] Updated CLI documentation.

2020-12-02 Thread GitBox
XComp commented on pull request #14287: URL: https://github.com/apache/flink/pull/14287#issuecomment-737259841 @zentol @rmetzger @tillrohrmann first version of the CLI docs is ready. Looking forward to your feedback. This

[jira] [Comment Edited] (FLINK-20452) Mysql JDBC Sink UpsertStreamTableSink requires that Table has a full primary keys

2020-12-02 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242387#comment-17242387 ] Leonard Xu edited comment on FLINK-20452 at 12/2/20, 2:19 PM: -- Hi,

[jira] [Commented] (FLINK-20452) Mysql JDBC Sink UpsertStreamTableSink requires that Table has a full primary keys

2020-12-02 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242387#comment-17242387 ] Leonard Xu commented on FLINK-20452: [~HideOnBush] Thanks for the report, but i think it's not a

[GitHub] [flink] flinkbot edited a comment on pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #13641: URL: https://github.com/apache/flink/pull/13641#issuecomment-708569491 ## CI report: * 09d8deb89416f53dfe8b5c16fb9d723cbd98612c UNKNOWN * fe1562c5cda8ecb15f6af1afdf7b6217e6c20c42 UNKNOWN *

[GitHub] [flink] aljoscha commented on a change in pull request #14277: [FLINK-20443][API/DataStream]fix lost data in last interval in per window

2020-12-02 Thread GitBox
aljoscha commented on a change in pull request #14277: URL: https://github.com/apache/flink/pull/14277#discussion_r534195324 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousProcessingTimeTrigger.java ## @@ -80,6

[jira] [Commented] (FLINK-20443) ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2020-12-02 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242385#comment-17242385 ] Aljoscha Krettek commented on FLINK-20443: -- This is the same as FLINK-5149 so I think it's good

[jira] [Updated] (FLINK-20443) ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2020-12-02 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20443: - Summary: ContinuousProcessingTimeTrigger doesn't fire at the end of the window (was:

[jira] [Updated] (FLINK-20453) Move checkpointing classes to the appropriate package

2020-12-02 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20453: -- Summary: Move checkpointing classes to the appropriate package (was: Move

[GitHub] [flink] aljoscha commented on a change in pull request #14120: [FLINK-19984][core] Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgr

2020-12-02 Thread GitBox
aljoscha commented on a change in pull request #14120: URL: https://github.com/apache/flink/pull/14120#discussion_r534191802 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/KeyAndValueSerializer.java ## @@ -41,7 +41,7 @@ *

[jira] [Created] (FLINK-20453) Move checkpointing classes to a the appropriate package

2020-12-02 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-20453: - Summary: Move checkpointing classes to a the appropriate package Key: FLINK-20453 URL: https://issues.apache.org/jira/browse/FLINK-20453 Project: Flink

[jira] [Updated] (FLINK-20453) Move checkpointing classes to a the appropriate package

2020-12-02 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20453: -- Priority: Minor (was: Major) > Move checkpointing classes to a the appropriate

[jira] [Updated] (FLINK-20451) Taskmanager can't apply resources when submit job with configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20451: --- Component/s: Deployment / YARN > Taskmanager can't apply resources when submit job with configs >

[jira] [Created] (FLINK-20452) Mysql JDBC Sink UpsertStreamTableSink requires that Table has a full primary keys

2020-12-02 Thread HideOnBush (Jira)
HideOnBush created FLINK-20452: -- Summary: Mysql JDBC Sink UpsertStreamTableSink requires that Table has a full primary keys Key: FLINK-20452 URL: https://issues.apache.org/jira/browse/FLINK-20452

[jira] [Updated] (FLINK-20103) Improve test coverage for network stack

2020-12-02 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20103: -- Description: This is a follow-up ticket after FLINK-20097. The current setup

[jira] [Commented] (FLINK-20419) Insert fails due to failure to generate execution plan

2020-12-02 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242372#comment-17242372 ] Rui Li commented on FLINK-20419: Hi [~jark], I think you implemented {{BatchExecSinkRule}}, any thoughts

[jira] [Updated] (FLINK-20451) Taskmanager can't apply resources when submit job with configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20451: --- Description: Hi, I meet an unexpected problem that the taskmanager can't apply resources when

[jira] [Commented] (FLINK-20419) Insert fails due to failure to generate execution plan

2020-12-02 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242367#comment-17242367 ] Rui Li commented on FLINK-20419: I suspect the issue is related to dynamic partition grouping.

[jira] [Commented] (FLINK-20434) Getting The desired archetype does not exist

2020-12-02 Thread Avi Levi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242366#comment-17242366 ] Avi Levi commented on FLINK-20434: -- [~chesnay] the problem is that the documentation is incorrect  >

[GitHub] [flink] flinkbot edited a comment on pull request #14287: [FLINK-20352][docs] Updated CLI documentation.

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14287: URL: https://github.com/apache/flink/pull/14287#issuecomment-737189475 ## CI report: * 7f5b5358aa8ee98d70ae3dfe2a14442fe8ec2ad3 Azure:

[jira] [Updated] (FLINK-20451) Taskmanager can't apply resources when submit job with configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20451: --- Summary: Taskmanager can't apply resources when submit job with configs `env.java.opts.taskmanager:

[GitHub] [flink] flinkbot edited a comment on pull request #14288: [backport-1.12] [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14288: URL: https://github.com/apache/flink/pull/14288#issuecomment-737209587 ## CI report: * d298c6df7d9c780c5f29f93ceea25c9d719aba0d Azure:

[jira] [Commented] (FLINK-20373) Flink table jsonArray access all

2020-12-02 Thread HideOnBush (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242359#comment-17242359 ] HideOnBush commented on FLINK-20373:   {code:java} class ExplodeArray() extends

[GitHub] [flink] flinkbot edited a comment on pull request #14289: [backport-1.11] [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14289: URL: https://github.com/apache/flink/pull/14289#issuecomment-737210394 ## CI report: * b931e79bf211d430583cb7d6de5be6cef88bef53 Azure:

[GitHub] [flink] T0UGH commented on pull request #14244: [FLINK-20299][docs-zh] Update Chinese table overview

2020-12-02 Thread GitBox
T0UGH commented on pull request #14244: URL: https://github.com/apache/flink/pull/14244#issuecomment-737215786 > Hi, you need to rebase `master` code first Thank you, I will fix it tomorrow. This is an automated

[GitHub] [flink] flinkbot commented on pull request #14289: [backport-1.11] [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
flinkbot commented on pull request #14289: URL: https://github.com/apache/flink/pull/14289#issuecomment-737210394 ## CI report: * b931e79bf211d430583cb7d6de5be6cef88bef53 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14288: [backport-1.12] [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
flinkbot commented on pull request #14288: URL: https://github.com/apache/flink/pull/14288#issuecomment-737209587 ## CI report: * d298c6df7d9c780c5f29f93ceea25c9d719aba0d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-20451) Taskmanager can't apply resources if use configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20451: --- Summary: Taskmanager can't apply resources if use configs `env.java.opts.taskmanager: -javaagent:`

[GitHub] [flink] StephanEwen commented on pull request #14279: [FLINK-20418][core] Fixing checkpointing of IteratorSourceReader.

2020-12-02 Thread GitBox
StephanEwen commented on pull request #14279: URL: https://github.com/apache/flink/pull/14279#issuecomment-737203187 Thanks for fixing this. For simplicity, can we merge this with

[GitHub] [flink] flinkbot edited a comment on pull request #14287: [FLINK-20352][docs] Updated CLI documentation.

2020-12-02 Thread GitBox
flinkbot edited a comment on pull request #14287: URL: https://github.com/apache/flink/pull/14287#issuecomment-737189475 ## CI report: * 7f5b5358aa8ee98d70ae3dfe2a14442fe8ec2ad3 Azure:

[GitHub] [flink] flinkbot commented on pull request #14289: [backport-1.11] [FLINK-20221] DelimitedInputFormat does not restore compressed splits

2020-12-02 Thread GitBox
flinkbot commented on pull request #14289: URL: https://github.com/apache/flink/pull/14289#issuecomment-737199618 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-20451) Taskmanager Could't apply resources if use configs `env.java.opts.taskmanager: -javaagent:`

2020-12-02 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong updated FLINK-20451: --- Attachment: (was: image-2020-12-02-20-16-50-002.png) > Taskmanager Could't apply resources if

<    1   2   3   >