[jira] [Created] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

Rong Rong created FLINK-7373: Summary: Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException Key: FLINK-7373 URL: https://issues.apache.org/jira/browse/FLINK-7373

[jira] [Commented] (FLINK-7245) Enhance the operators to support holding back watermarks

[ https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16115441#comment-16115441 ] Xingcan Cui commented on FLINK-7245: Hi [~fhueske], thanks for your responses. They are really

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16115353#comment-16115353 ] ASF GitHub Bot commented on FLINK-4565: --- Github user tedyu commented on a diff in the pull request:

[GitHub] flink pull request #4404: [FLINK-4565] [table] Support for SQL IN operator

Github user tedyu commented on a diff in the pull request: https://github.com/apache/flink/pull/4404#discussion_r131519235 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/subquery.scala --- @@ -0,0 +1,95 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-4674) File Descriptors not being released after Completion of Flink Job Run via Flink Web Portal

[ https://issues.apache.org/jira/browse/FLINK-4674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16115341#comment-16115341 ] Abey Sam Alex commented on FLINK-4674: -- Could not reproduce the issue after increasing OS level File

[jira] [Commented] (FLINK-7284) Verify compile time and runtime version of Hadoop

[ https://issues.apache.org/jira/browse/FLINK-7284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16115337#comment-16115337 ] mingleizhang commented on FLINK-7284: - Hi, [~till.rohrmann] I would like work on this, but before

[jira] [Commented] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16115329#comment-16115329 ] ASF GitHub Bot commented on FLINK-4534: --- GitHub user zhangminglei opened a pull request:

[GitHub] flink pull request #4482: [FLINK-4534] Fix synchronization issue in Bucketin...

GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/4482 [FLINK-4534] Fix synchronization issue in BucketingSink ## What is the purpose of the change Fix lacking of synchronization in BucketingSink#close method. ## Verifying this

[jira] [Commented] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16115323#comment-16115323 ] Ted Yu commented on FLINK-4534: --- Code w.r.t. state.bucketStates.values() has been refactored since the JIRA