Support for Flink 1.11

[Kishor Joshi]

Hi Team,
Since the beam has released the version 2.24 but it seems still the highest 
version that is supported in beam 2.24 (>=2.21) is 1.10.So i would like to know 
what is the plan to release beam with the support of latest flink i.e. 1.11.x.
Thanks & Regards,Kishor

contributor permission for Beam Jira tickets

[Kishor Joshi]

Hi,
This is kishor joshi. Can someone add me as a contributor for Beam's Jira issue 
tracker? I would like to create/assign tickets for my work.
My JIRA id is kishorjoshi.
Thanks & regards,Kishor 

Re: Query about JdbcIO.readRows()

[Kishor Joshi]

 Hi,
This fix is still not available in the Beam 2.15.0. Is there any Jira that has 
been created for this issue ? I am interested to contribute in that.
Thanks & Regards,Kishor
On Friday, August 2, 2019, 10:19:17 PM GMT+5:30, Jean-Baptiste Onofré 
 wrote:  
 
 Agree. I will fix that. 

Regards
JBLe 2 août 2019, à 17:15, Vishwas Bm  a écrit:
  Hi Kishor,   
   + dev ( dev@beam.apache.org)   
   This looks like a bug.  The attribute statementPreparator is nullable 
   It should have been handled in the same way as in the expand method of 
Read class.
   
   
   Thanks & Regards,  Vishwas 
  
 
  On Fri, Aug 2, 2019 at 2:48 PM Kishor Joshi < joshi...@yahoo.com> wrote: 
  
Hi,   
   I am using the just released 2.14 version for JdbcIO with the newly added 
"readRows" functionality.    
   I want to read table data with a query without parameters (select * from 
table_name).    As per my understanding, this should not require 
"StatementPreperator".    However, if I use the newly added "readRows" 
function, I get an exception that seems to force me to use the 
"StatementPreperator".    Stacktrace below.     
 java.lang.IllegalArgumentException: statementPreparator can not be null    
       at 
org.apache.beam.vendor.guava.v20_0.com.google.common.base.Preconditions.checkArgument(Preconditions.java:122)
           at 
org.apache.beam.sdk.io.jdbc.JdbcIO$Read.withStatementPreparator(JdbcIO.java:600)
           at 
org.apache.beam.sdk.io.jdbc.JdbcIO$ReadRows.expand(JdbcIO.java:499)           
at org.apache.beam.sdk.io.jdbc.JdbcIO$ReadRows.expand(JdbcIO.java:410)          
 at org.apache.beam.sdk.Pipeline.applyInternal(Pipeline.java:537)           at 
org.apache.beam.sdk.Pipeline.applyTransform(Pipeline.java:471)           at 
org.apache.beam.sdk.values.PBegin.apply(PBegin.java:44)           at 
com.nokia.csf.dfle.transforms.DfleRdbmsSource.expand(DfleRdbmsSource.java:34)   
        at 
com.nokia.csf.dfle.transforms.DfleRdbmsSource.expand(DfleRdbmsSource.java:10)   
        at org.apache.beam.sdk.Pipeline.applyInternal(Pipeline.java:537)        
   at org.apache.beam.sdk.Pipeline.applyTransform(Pipeline.java:488)           
at org.apache.beam.sdk.values.PBegin.apply(PBegin.java:56)           at 
org.apache.beam.sdk.Pipeline.apply(Pipeline.java:182)           at 
com.nokia.csf.dfle.dsl.DFLEBeamMain.dagWireUp(DFLEBeamMain.java:49)           
at com.nokia.csf.dfle.dsl.DFLEBeamMain.main(DFLEBeamMain.java:120)   
   
   
   The test added in JdbcIOTest.java for this functionality only tests for 
queries with parameters.    Is this new function supported only in the above 
case and not for normal "withQuery" (without parameters) ?    
   
   Thanks & regards,   Kishor