Uploaded image for project: 'Pentaho Data Integration - Kettle'
  1. Pentaho Data Integration - Kettle
  2. PDI-13062

PDI 5.2.0 - Cassandra Input cannot connect to Cassandra 2.1.0

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Closed
    • Severity: Low
    • Resolution: Fixed
    • Affects Version/s: 5.2.0 GA
    • Fix Version/s: None
    • Labels:
      None
    • Story Points:
      3
    • PDI Sub-component:
    • Notice:
      When an issue is open, the "Fix Version/s" field conveys a target, not necessarily a commitment. When an issue is closed, the "Fix Version/s" field conveys the version that the issue was fixed in.
    • Browser:
      Google Chrome 32.x
    • Operating System/s:
      Windows 8.1 (64 bit)

      Description

      PDI version 5.2.0
      Cassandra version 2.1.0

      When using "Cassandra Input" in PDI I get following error:
      2014/10/14 19:20:09 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@421912b9 - Unable to connect to retrieve column meta data for user at this stage
      2014/10/14 19:20:35 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2904f275 - ERROR (version 5.2.0.0, build 1 from 2014-09-30_19-48-28 by buildguy) : An error occurred while getting the schema information::

      null
      2014/10/14 19:20:35 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2904f275 - ERROR (version 5.2.0.0, build 1 from 2014-09-30_19-48-28 by buildguy) : InvalidRequestException(why:Undefined name populate_io_cache_on_flush in selection clause)
      2014/10/14 19:20:35 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2904f275 - at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:49032)
      2014/10/14 19:20:35 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2904f275 - at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:49009)
      2014/10/14 19:20:35 - org.pentaho.di.trans.steps.cassandrainput.CassandraInputMeta@2904f275 - at org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result.read(Cassandra.java:48924)
      )

      Cassandra 2.1.0 has removed columns :
      1) populate_io_cache_on_flush
      2) replicate_on_write
      from system.schema_columnfamilies.

      pentaho-cassandra-plugin / src / org / pentaho / cassandra / legacy / CassandraColumnMetaData.java is trying to select those fields (line 240)

      String cqlQ = "select " + CFMetaDataElements.COMPARATOR + ", " + CFMetaDataElements.DEFAULT_VALIDATOR + "," //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$
      + CFMetaDataElements.COLUMN_ALIASES + ", " + CFMetaDataElements.KEY_ALIASES + ", " //$NON-NLS-1$ //$NON-NLS-2$
      + CFMetaDataElements.KEY_VALIDATOR + ", " + CFMetaDataElements.BLOOM_FILTER_FP_CHANCE + ", " //$NON-NLS-1$ //$NON-NLS-2$
      + CFMetaDataElements.CACHING + ", " + CFMetaDataElements.COMPACTION_STRATEGY_CLASS + ", " //$NON-NLS-1$ //$NON-NLS-2$
      + CFMetaDataElements.COMPACTION_STRATEGY_OPTIONS + ", " + CFMetaDataElements.COMPRESSION_PARAMETERS + ", " //$NON-NLS-1$ //$NON-NLS-2$
      + CFMetaDataElements.GC_GRACE_SECONDS + ", " + CFMetaDataElements.LOCAL_READ_REPAIR_CHANCE + ", " //$NON-NLS-1$ //$NON-NLS-2$
      + CFMetaDataElements.MAX_COMPACTION_THRESHOLD + ", " + CFMetaDataElements.MIN_COMPACTION_THRESHOLD + ", " //$NON-NLS-1$ //$NON-NLS-2$
      + CFMetaDataElements.POPULATE_IO_CACHE_ON_FLUSH + ", " + CFMetaDataElements.READ_REPAIR_CHANCE + ", " //$NON-NLS-1$ //$NON-NLS-2$
      + CFMetaDataElements.REPLICATE_ON_WRITE + ", " + CFMetaDataElements.TYPE + ", " //$NON-NLS-1$ //$NON-NLS-2$
      + CFMetaDataElements.VALUE_ALIAS + " from system.schema_columnfamilies where keyspace_name='" //$NON-NLS-1$
      + conn.m_keyspaceName + "' and columnfamily_name='" + m_columnFamilyName + "';"; //$NON-NLS-1$ //$NON-NLS-2$

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                ggedas Gediminas Juodeikis
              • Votes:
                2 Vote for this issue
                Watchers:
                8 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: